数据查询的脚本,分享一下。

墨迹哥

运行代码需要模块，具体如下：

1. package TDmodule;
   
2. use DBI;
   
3. 
   
4. sub new{
   
5.   $self={};
   
6.   $self->{select_db}=undef;
   
7.   $self->{delete_db}=undef;
   
8.   $self->{insert_db}=undef;
   
9.   $self->{update_db}=undef;
   
10.   bless $self;
    
11.   return $self;
    
12. }
    
13. sub connect_db{
    
14.   my $self=shift;
    
15.   if(@_){
    
16.     $self->{'connect_db'}=DBI->connect("DBI:mysql:database=@_[0];host=@_[1]","@_[2]","@_[3]") or die "No:$!\n";
    
17.   }
    
18.   return $self->{'connect_db'};
    
19. }
    
20. sub select_db{
    
21.   my $self=shift;
    
22.   if(@_){
    
23.       my $select=@_[0]->prepare(@_[1]);
    
24.       $select->execute();
    
25.       $self{select_db}=$select;
    
26.   }
    
27.   return $self{select_db};
    
28.   @_[0]->disconnect;
    
29. }
    
30. 
    
31. sub update_db{
    
32.   my $self=shift;
    
33.   if(@_){
    
34.       eval{
    
35.         $self->{update_db}=@_[0]->do(@_[1]);
    
36.       } or die "No\n";
    
37.   }
    
38. }
    
39. 
    
40. sub insert_db{
    
41.   my $self=shift;
    
42.   if(@_){
    
43.       eval{
    
44.         $self->{insert_db}=@_[0]->do(@_[1]);
    
45.       } or die "No\n";
    
46.   }
    
47. }
    
48. 
    
49. sub delete_db{
    
50.   my $self=shift;
    
51.   if(@_){
    
52.       eval{
    
53.         $self->{delete_db}=@_[0]->do(@_[1]);
    
54.       } or die "No\n";
    
55.   }
    
56. }
    
57. 
    
58. 1;

复制代码

先看代码，具体如下：

1. #!/usr/bin/perl
   
2. use TDmodule;
   
3. 
   
4. # create object
   
5. $test=TDmodule->new();
   
6. 
   
7. # connect db return config
   
8. $config=$test->connect_db("3d_database","localhost","root","mojige123");
   
9. 
   
10. # select for db return database
    
11. $old=$test->select_db($config,"select * from old_papar");
    
12. $user=$test->select_db($config,"select * from user_papar");
    
13. 
    
14. sub result{
    
15.   local($sql)=shift;
    
16.   local($task)=shift;
    
17.   # print execute result
    
18.   while($list=$sql->fetchrow_hashref()){
    
19.       push(@target,$list->{$task});
    
20.   }
    
21.   return @target;
    
22. }
    
23. @old_papar=result($old,'id');
    
24. 
    
25. @user_papar=result($user,'number');
    
26. foreach my $a (@old_papar){
    
27.    print "$a\n";
    
28. }
    
29. print "--------------\n";
    
30. foreach my $b (@user_papar){
    
31.    print "$b\n";
    
32. }

复制代码

在这种情况下读出的数据会有重复读取的问题，例如目标数据要求是每个表读取一次，但是这个方法看起来是读取一次，实际上是读取了两次。具体结果如下所示：

1. root@crunchbang:~# perl TDmodule.pl
   
2. 2
   
3. 4
   
4. 6
   
5. 8
   
6. 10
   
7. --------------
   
8. 2
   
9. 4
   
10. 6
    
11. 8
    
12. 10
    
13. 145
    
14. 693
    
15. 168
    
16. 746
    
17. 206
    
18. 319

复制代码

第一次的结果将会包含到第二次中，为了解决这个问题，我仔细的修改了下代码，发现，只需要每次将容器清空，即可。在这分享一下。。。

1. #!/usr/bin/perl
   
2. use TDmodule;
   
3. 
   
4. # create object
   
5. $test=TDmodule->new();
   
6. 
   
7. # connect db return config
   
8. $config=$test->connect_db("3d_database","localhost","root","mojige123");
   
9. 
   
10. # select for db return database
    
11. $old=$test->select_db($config,"select * from old_papar");
    
12. $user=$test->select_db($config,"select * from user_papar");
    
13. 
    
14. sub result{
    
15.   local($sql)=shift;
    
16.   local($task)=shift;
    
17.   
    
18.   # clean list array
    
19.   @target=();
    
20.   # print execute result
    
21.   while($list=$sql->fetchrow_hashref()){
    
22.       push(@target,$list->{$task});
    
23.   }
    
24.   return @target;
    
25. }
    
26. @old_papar=result($old,'id');
    
27. 
    
28. @user_papar=result($user,'number');
    
29. foreach my $a (@old_papar){
    
30.    print "$a\n";
    
31. }
    
32. print "--------------\n";
    
33. foreach my $b (@user_papar){
    
34.    print "$b\n";
    
35. }

复制代码

墨迹哥

回复 2# sinian126


      好想上海。。。= =