#!/usr/bin/perl use DBI; use IO::File; #use strict; my $arg; #my @proc = `ps aux | grep pl | grep -v grep`; #foreach $arg(@proc){ # if($_){exit;} # } my $db1 = "hisdb"; my $host1 = "192.168.9.109"; my $db2 = "CAMDPAMS"; my $host2 = "192.168.9.10"; my $sth; my $sth1; #$dbh1 = DBI ->connect("dbi:Pg:dbname=$db1;host=$host1","okrotenko","lg414tnk",{AutoCommit=>0,RaiseError=>1,ChopBlanks=>1}); $dbh1 = DBI ->connect("dbi:Pg:dbname=$db1;host=$host1","flsuser","",{AutoCommit=>0,RaiseError=>1,ChopBlanks=>1}); $dbh2 = DBI ->connect("dbi:Pg:dbname=$db2;host=$host2","olegk","4Q2073gl",{AutoCommit=>0,RaiseError=>1,ChopBlanks=>1}); #my $sql = "SELECT count(*) FROM \"WhiteListing\".\"FileSource\" where \"SourceId\" = 1 and \"DateAdded\" >= 'today'"; my $sql1 = "select hash from data_volume.select(?, true, ?, true, ?, 500) order by times_catched"; #"select hash from (select hash, frequency from ( # select hash, sum(distinct 1<prepare($sql); #$sth->execute; #my $cnt =$sth->fetchrow_array; my cnt = 0; #print "Count sha1 in db - $cnt today"; #$sth->finish; my $sql2 = "INSERT INTO \"WhiteListing\".\"FileSource\"(\"SHA1\", \"DateAdded\",\"SourceId\") VALUES (?,now(),1)"; $sth1 = $dbh1->prepare($sql1); $sth1->execute('yesterday','today',$cnt); if ($sth1->rows >0) { while(my @a=$sth1->fetchrow_array){ $sth2 = $dbh2->prepare($sql2); $sth2->execute(@a[0]); $sth2->finish; # print "@a[0]\n"; } } $sth1->finish; $dbh1->disconnect; $dbh2->commit; $dbh2->disconnect; # mikew: wtf? #print "1\n";