/[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.1 by cvsjoko, Fri Jul 19 18:14:03 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
24    ##    bugfixes
25    ##
26    ##    Revision 1.2  2002/07/20 11:09:58  cvsjoko
27    ##    + bugfixes
28    ##    + dont' print sql-errors
29    ##
30  ##    Revision 1.1  2002/07/19 18:14:03  cvsjoko  ##    Revision 1.1  2002/07/19 18:14:03  cvsjoko
31  ##    no message  ##    no message
32  ##  ##
# Line 13  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 44  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 52  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 105  sub connectTarget { Line 155  sub connectTarget {
155    croak "please supply a dsn or a \"dbmeta\"-hash" if (!$dbmeta);    croak "please supply a dsn or a \"dbmeta\"-hash" if (!$dbmeta);
156    $dbmeta = patch_dbmeta($dbmeta);    $dbmeta = patch_dbmeta($dbmeta);
157    if (!$dbmeta->{connected}) {    if (!$dbmeta->{connected}) {
158      if ($dbmeta->{dbh} = DBI->connect($dbmeta->{dsn})) {      if ($dbmeta->{dbh} = DBI->connect($dbmeta->{dsn}, '', '', { PrintError => 0 } )) {
159        $dbmeta->{dbh}->trace($dbmeta->{trace_level}, $dbmeta->{trace_file});        $dbmeta->{dbh}->trace($dbmeta->{trace_level}, $dbmeta->{trace_file});
160        $dbmeta->{dbh}->{PrintError} = 0;        $dbmeta->{dbh}->{PrintError} = 0;
161        $dbmeta->{connected} = 1;        $dbmeta->{connected} = 1;
162        $dbmeta_ref_cache = $dbmeta;        $dbmeta_ref_cache = $dbmeta;
163          return 1;
164      }      }
165    }    }
166  }  }
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 136  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 165  sub sqlDbAction { Line 222  sub sqlDbAction {
222      trace_level => 1,      trace_level => 1,
223      trace_file => 'dbitrace',      trace_file => 'dbitrace',
224    };    };
225    connectTarget($dbmeta);    my $bool_ok;
226    sendSql($sql);    if (connectTarget($dbmeta)) {
227    disconnectTarget($dbmeta);      sendSql($sql);
228        #print "state: ", $dbmeta->{dbh}->state, "\n";
229        #print "err    ", $dbmeta->{dbh}->err, "\n";
230        #$bool_ok = ($dbmeta->{dbh} && $dbmeta->{dbh}->state && !$dbmeta->{dbh}->err);
231        $bool_ok = ($dbmeta->{dbh} && !$dbmeta->{dbh}->err);
232        disconnectTarget($dbmeta);
233      }
234      return $bool_ok;
235  }  }
236    
237  sub createSqlDb {  sub createSqlDb {
238    my $dsn = shift;    my $dsn = shift;
239    my $dbname = getDbNameByDsn($dsn);    my $dbname = getDbNameByDsn($dsn);
240    print "  - creating database $dbname", "\n";    print "  - creating rdbms-database $dbname ($dsn) ...";
241    my $sql;    my $sql;
242    $sql = "CREATE DATABASE $dbname;";    $sql = "CREATE DATABASE $dbname;";
243    sqlDbAction($dsn, $sql);    if ( sqlDbAction($dsn, $sql) ) {
244        print "ok", "\n";
245        return 1;
246      } else {
247        print "failed", "\n";
248        return 0;
249      }
250  }  }
251    
252  sub dropSqlDb {  sub dropSqlDb {
253    my $dsn = shift;    my $dsn = shift;
254    my $dbname = getDbNameByDsn($dsn);    my $dbname = getDbNameByDsn($dsn);
# Line 189  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    
# Line 203  sub testDsnForTables { Line 276  sub testDsnForTables {
276    return 1 if ($bool_tablesHere);    return 1 if ($bool_tablesHere);
277  }  }
278    
 1;  
279    1;
Legend:
Removed from v.1.1  
changed lines
  Added in v.1.9
MailToCvsAdmin">MailToCvsAdmin
 ViewVC Help
Powered by ViewVC 1.1.26 RSS 2.0 feed