use Data::Consumer::Dir;
use Getopt::Long;
my ($db,$user,$name,$procs);
Getoptions(
'db=s' => $db,
'user=s' => $user,
'name=s' => $name,
'procs=i' => $procs
) or die "Bad args";
my $pid= $$;
fork while $procs-->0 and $pid==$$;
my $feed= Data::Consumer::Dir->new( root => '/etc/drop/' );
my $DBH=DBI->connect($db,$user,$name) or die "...";
$feed->consume(sub {
my ($f,$spec,$fh)= @_;
while (<$fh>) {
my @f=split/,/,$_;
$dbh->do('insert into foo (date,height,width) values (?,?,?)',un
+def,@f);
}
});
|