#! /usr/bin/perl -w

use strict;
use Data::Dumper;
use DBD::Pg;
use IPC::Open3::Simple;

$| ++;

my $DB_NAME     = 'db_name';
my $DB_USERNAME = 'db_username';
my $DB_PASSWORD = '12345678';

# log in to the database

my $dbh = DBI->connect("dbi:Pg:dbname=$DB_NAME",
                       $DB_USERNAME,
                       $DB_PASSWORD,
) or die $DBI::errstr;

$dbh->trace(0);

# now run a query to make sure the database connection works

my $sth;
unless ($sth = $dbh->prepare("select now()")) { warn "Unable to prepare SQL."; }
unless ($sth->execute()) { warn "Unable to execute SQL."; }
$sth->finish;

print "ping " , __LINE__ , " " , $dbh->ping, "\n";

# now run a command that fails

my (@cmd_output, @err_output);
my $ipc = IPC::Open3::Simple->new(
      in  => sub { my $fh = shift; print $fh "mydata"; close $fh; } ,
      out => sub { push @cmd_output, $_[0]; } ,
      err => sub { push @err_output, $_[0]; } ,
);

print "ping " , __LINE__ , " " , $dbh->ping, "\n";

#$ipc->run('date');            # this line is fine
$ipc->run('no-such-command');  # this line causes the problem

print "ping " , __LINE__ , " " , $dbh->ping, "\n";

print Dumper("output:", \@cmd_output, "error:", \@err_output), "\n";

print "ping " , __LINE__ , " " , $dbh->ping, "\n";

# now run another database query
unless ($sth = $dbh->prepare("select now()")) { warn "Unable to prepare SQL."; }
print "ping " , __LINE__ , " " , $dbh->ping, "\n";
unless ($sth->execute()) { warn "Unable to execute SQL."; }
print "ping " , __LINE__ , " " , $dbh->ping, "\n";
$sth->finish;

$dbh->disconnect() or die $DBI::errstr;

exit 0;