/[cvs]/nfo/perl/libs/libdb.pm
ViewVC logotype

Diff of /nfo/perl/libs/libdb.pm

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

revision 1.3 by cvsjoko, Sat Jul 27 00:28:20 2002 UTC revision 1.9 by joko, Sun Feb 9 04:47:58 2003 UTC
# Line 2  Line 2 
2  ##    $Id$  ##    $Id$
3  ##    --------------------------------------------------------------------------------  ##    --------------------------------------------------------------------------------
4  ##    $Log$  ##    $Log$
5    ##    Revision 1.9  2003/02/09 04:47:58  joko
6    ##    + minor fix
7    ##
8    ##    Revision 1.8  2002/12/12 02:48:58  joko
9    ##    + played with fixing disconnectTarget
10    ##
11    ##    Revision 1.7  2002/12/01 22:13:17  joko
12    ##    + minor bugfix?
13    ##
14    ##    Revision 1.6  2002/11/29 04:53:39  joko
15    ##    + hash2Sql now knows about SQL_SELECT
16    ##
17    ##    Revision 1.5  2002/11/17 07:18:38  joko
18    ##    + small modification in hash2sql
19    ##
20    ##    Revision 1.4  2002/10/16 22:36:42  joko
21    ##    + sub testDbServer
22    ##
23  ##    Revision 1.3  2002/07/27 00:28:20  cvsjoko  ##    Revision 1.3  2002/07/27 00:28:20  cvsjoko
24  ##    bugfixes  ##    bugfixes
25  ##  ##
# Line 20  package libdb; Line 38  package libdb;
38  use strict;  use strict;
39  use warnings;  use warnings;
40    
 use libp;  
 use DBI;  
   
41  require Exporter;  require Exporter;
42  our @ISA = qw( Exporter );  our @ISA = qw( Exporter );
43  our @EXPORT = qw(  our @EXPORT_OK = qw(
44                                testDsn hash2Sql                                testDsn hash2Sql
45                                SQL_INSERT SQL_UPDATE                                SQL_INSERT SQL_UPDATE
46                                connectTarget disconnectTarget sendSql                                connectTarget disconnectTarget sendSql
47                                dbNow                                dbNow
48                                getDbNameByDsn sqlDbAction createSqlDb dropSqlDb                                getDbNameByDsn sqlDbAction createSqlDb dropSqlDb
49                                quotesql                                quotesql
50                                testDsnForTables                                testDsnForTables testDbServer
51                                );                                );
52    
53    
54    use Carp;
55    use DBI;
56    use Data::Dumper;
57    
58  use constant SQL_INSERT => 10;  use constant SQL_INSERT => 10;
59  use constant SQL_UPDATE => 11;  use constant SQL_UPDATE => 11;
60    use constant SQL_SELECT => 12;
61    
62  my $dbmeta_ref_cache;  my $dbmeta_ref_cache;
63    
# Line 51  sub testDsn { Line 72  sub testDsn {
72    }    }
73  }  }
74    
75    sub testDbServer {
76      my $dsn = shift;
77      $dsn =~ s/database=(\w+)//;
78      
79      #print "testDbServer: $dsn", "\n";
80      
81      my $result;
82      if ( my $dbh = DBI->connect($dsn, '', '', {
83                                                          PrintError => 0,
84                                                          } ) ) {
85        $dbh->disconnect();
86        return 1;
87      }
88    }
89    
90    
91    # TODO: handle usage of "$crit" in an abstract way somehow
92  sub hash2Sql {  sub hash2Sql {
93        
94    my $table = shift;    my $table = shift;
# Line 59  sub hash2Sql { Line 97  sub hash2Sql {
97    my $crit = shift;    my $crit = shift;
98        
99    my $sql;    my $sql;
100    if ($mode == SQL_INSERT) {    $mode = SQL_SELECT if ($mode eq 'SQL_SELECT' || $mode eq 'SELECT');
101      $sql = "INSERT INTO $table (#fields#) VALUES (#values#);";    $mode = SQL_INSERT if ($mode eq 'SQL_INSERT' || $mode eq 'INSERT');
102    }    $mode = SQL_UPDATE if ($mode eq 'SQL_UPDATE' || $mode eq 'UPDATE');
103    if ($mode == SQL_UPDATE) {  
104      $sql = "UPDATE $table SET #fields-values# WHERE $crit;";    if ($mode == SQL_SELECT) {
105        $sql = "SELECT #fields# FROM $table WHERE $crit";
106      } elsif ($mode == SQL_INSERT) {
107        $sql = "INSERT INTO $table (#fields#) VALUES (#values#)";
108      } elsif ($mode == SQL_UPDATE) {
109        $sql = "UPDATE $table SET #fields-values# WHERE $crit";
110    }    }
111        
112    my (@fields, @values);    my (@fields, @values);
# Line 124  sub connectTarget { Line 167  sub connectTarget {
167    
168  sub disconnectTarget {  sub disconnectTarget {
169    #my $dbmeta = shift;    #my $dbmeta = shift;
170      #print "disc\n";
171    #croak "please supply a \"dbmeta\"-hash" if (!$dbmeta);    #croak "please supply a \"dbmeta\"-hash" if (!$dbmeta);
172    #$dbmeta = patch_dbmeta($dbmeta);    #$dbmeta = patch_dbmeta($dbmeta);
173    #$dbmeta->{dbh} && $dbmeta->{dbh}->disconnect();    #$dbmeta->{dbh} && $dbmeta->{dbh}->disconnect();
174    my $dbmeta = $dbmeta_ref_cache;    my $dbmeta = $dbmeta_ref_cache;
175    $dbmeta->{dbh} && $dbmeta->{dbh}->disconnect();    #print Dumper($dbmeta);
176      #$dbmeta->{dbh} && $dbmeta->{dbh}->disconnect();
177      $dbmeta->{dbh}->disconnect();
178      undef($dbmeta->{dbh});
179      undef($dbmeta);
180    undef($dbmeta_ref_cache);    undef($dbmeta_ref_cache);
181  }  }
182    
# Line 144  sub sendSql { Line 192  sub sendSql {
192      return 0;      return 0;
193    }    }
194    if (my $result = $dbmeta_ref->{dbh}->prepare($sql)) {    if (my $result = $dbmeta_ref->{dbh}->prepare($sql)) {
195      if ($result->execute()) {      #if ($result->execute()) {
196          $result->execute();
197        return $result;        return $result;
198      }      #}
199    }    }
200  }  }
201    
# Line 211  sub dropSqlDb { Line 260  sub dropSqlDb {
260    
261  sub quotesql {  sub quotesql {
262    my $string = shift;    my $string = shift;
263    $string =~ s/'/\\'/g;    if ($string) {
264        $string =~ s/'/\\'/g;
265      }
266    return $string;    return $string;
267  }  }
268    
Legend:
Removed from v.1.3  
changed lines
  Added in v.1.9
MailToCvsAdmin">MailToCvsAdmin
 ViewVC Help
Powered by ViewVC 1.1.26 RSS 2.0 feed