lib/APKPM/Store.pm

   1 package APKPM::Store;
   2
   3 use base qw(Gearman::Driver::Worker);
   4 use Moose;
   5 use Time::HiRes;
   6 use Data::Dump qw(dump);
   7 use DBD::Pg;
   8
   9 with 'APKPM::Gearman';
  10
  11 sub prefix { 'Store_' }
  12
  13 sub process_name {
  14         my ( $self, $orig, $job_name ) = @_;
  15         warn "# process_name $orig $job_name\n";
  16         return "$orig ($job_name)";
  17 }
  18
  19 sub ADSL : Job : MinProcesses(1) : MaxProcesses(5) : Decode(d_json) {
  20         my ( $self, $job, $workload ) = @_;
  21
  22         my $dbh = DBI->connect_cached('DBI:Pg:dbname=apkpm','','', {
  23                 RaiseError => 1,
  24                 AutoCommit => 1,
  25         });
  26
  27         my $h = $workload->{ADSL} || die "no ADSL in ",dump $workload;
  28         foreach my $c ( qw(ip username) ) {
  29                 $h->{$c} = $workload->{$c} || die "no $c in ",dump $workload;
  30         }
  31
  32         warn "# ADSL ", dump $h;
  33
  34         my @c = keys %$h;
  35
  36         my $sql = 'INSERT INTO adsl (' . join(',',@c) . ') values (' . join(',', map { '?' } 0 .. $#c) . ')';
  37         warn $sql;
  38         my $sth = $dbh->prepare($sql);
  39         $sth->execute( map { $h->{$_} } @c );
  40 }
  41
  42 1;