做了个并行处理数据的perl,高手帮忙看看,有没问题

honghec

1. 
   
2. 
   
3. #!/usr/bin/perl
   
4. 
   
5. use DBI;
   
6. 
   
7. my $quit         = 2;
   
8. 
   
9. $SIG{CHLD}   = sub {$quit++;while(waitpid(-1,WNOHANG)>0){}};
   
10. $SIG{INT}      = sub {$quit++};
    
11. 
    
12. my $dsn          = "DBI:mysql:database=cc_com;host=61.152.X.X:3306;user=web_mysql;password=shocom#7-06";
    
13. my $sql           = "";
    
14. my $sth           = "";
    
15. 
    
16. while(1){
    
17.         my @ret_value;
    
18.         $dbh       = DBI->connect($dsn) || die "Database connection not made: $DBI::errstr";
    
19.         $isselect = 0;
    
20.         $i            = 0;
    
21.         $sql        = "SELECT * FROM upload_temp";
    
22.         $sth        = $dbh->prepare( $sql );
    
23. 
    
24.         $sth->execute();
    
25. 
    
26. 
    
27.         while($quit>0){
    
28.                 if(@row = $sth->fetchrow_array){
    
29.                         $quit--;
    
30.                         $i++;
    
31.                         defined($ret_value[$i] = fork()) or die "error!n";
    
32.                         if($ret_value[$i] == 0){
    
33.                                 format_conversion($row[1]);
    
34.                                 exit 0;
    
35.                         }
    
36.                 }else{
    
37.                         last;
    
38.                 }
    
39. 
    
40.         }
    
41.         foreach my $ret (@ret_value){
    
42.                 if(!defined($ret)){
    
43.                         #print "not defined ret_value[0] next\n";
    
44.                         next;
    
45.                 }
    
46.                 waitpid($ret,0);
    
47.                 print "waitpid($ret 0)\n";
    
48.         }
    
49.         sleep(5);
    
50. }
    
51. 
    
52. $dbh->disconnect;
    
53. exit 0;
    
54. 
    
55. sub format_conversion
    
56. {
    
57.         my $file_path = shift;
    
58.         print "$file_path\n";
    
59.         #这里可以把数据库里的数据清除掉,做相关处理
    
60.         sleep 10;
    
61. }
    
62. 
    

复制代码

为什么每次while里都要$dbh       = DBI->connect一次吗,不能一直连接着吗??

honghec

大家帮我看看吧,为什么

每次while里都要 $dbh       = DBI->connect 一次吗,不能一直连接着吗??

honghec

In Perl you cannot make persistent connections to MySQL, unless you use mod_perl.

wsliuhao

In Perl you cannot make persistent connections to MySQL, unless you use mod_perl.

是mysql本身的限制么？我连oracle没出过什么问题的。

honghec

mysql用PHP连是可以用persistent connections 的啊

现在我是想把
$dbh       = DBI->connect($dsn)放在while外面,,在while里头判断连接是否断掉,如果断了就再连一次

不知道有没有更好的办法啊

ziluobu

应该有参数设置长连接短连接，你查查mysql函数的资料，一般默认都是短连接

ulmer

Hi,

put $dbh = DBI->... outside of while(1).
or
write subroutine that returns $dbh then call this sub first.
in the while loop to check $dbh, if $dbh is dead, call this sub again.

--ulmer