#!/usr/bin/perl

use warnings;
use strict;

use POE;
use POE::Wheel::Run;
use POE::Filter::Line;
use POE::Filter::Stream;

$| = 1;
my $outCT = 0;
my $program = "MyDbQueryProgram";
my @progargs = ("SELECT * FROM MY_TABLE;");
POE::Session->create(
 inline_states => {
  _start => \&startup,
  stdout => \&stdout,
  stdin => \&stdin,
  stderr => \&stderr,
 }
);
POE::Kernel->run();

sub startup {
 my $heap = $_[HEAP];
 
 my $wheel = POE::Wheel::Run->new(
  Program => $program,
  ProgramArgs => \@progargs,

  StdinEvent => 'stdin',
  StderrEvent => 'stderr',
  StdoutEvent => "stdout", 	
  StdoutFilter => POE::Filter::Stream->new(),
 );


 print "Wheel ID is ".$wheel->ID."\n";
 print "Wheel's PID is ".$wheel->PID."\n";
 $heap->{program} = $wheel;
}


sub stdout {
 my ($heap, $input, $wheelID) = @_[HEAP, ARG0, ARG1];
 print "$input\n";
 $outCT++;
 print $outCT;
}

sub stderr {
 my ($op, $errnum, $errstr, $wheel_id) = @_[ARG0, ARG1, ARG2, ARG3];
 print "stderr\n";
 print "OP = $op\nERRNUM = $errnum\nERRSTR = $errstr\nID = $wheel_id\n";
}

sub stdin {
 print "stdin\n";
}