/[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.6 by joko, Fri Nov 29 04:53:39 2002 UTC
# Line 2  Line 2 
2  ##    $Id$  ##    $Id$
3  ##    --------------------------------------------------------------------------------  ##    --------------------------------------------------------------------------------
4  ##    $Log$  ##    $Log$
5    ##    Revision 1.6  2002/11/29 04:53:39  joko
6    ##    + hash2Sql now knows about SQL_SELECT
7    ##
8    ##    Revision 1.5  2002/11/17 07:18:38  joko
9    ##    + small modification in hash2sql
10    ##
11    ##    Revision 1.4  2002/10/16 22:36:42  joko
12    ##    + sub testDbServer
13    ##
14    ##    Revision 1.3  2002/07/27 00:28:20  cvsjoko
15    ##    bugfixes
16    ##
17    ##    Revision 1.2  2002/07/20 11:09:58  cvsjoko
18    ##    + bugfixes
19    ##    + dont' print sql-errors
20    ##
21  ##    Revision 1.1  2002/07/19 18:14:03  cvsjoko  ##    Revision 1.1  2002/07/19 18:14:03  cvsjoko
22  ##    no message  ##    no message
23  ##  ##
# Line 13  package libdb; Line 29  package libdb;
29  use strict;  use strict;
30  use warnings;  use warnings;
31    
 use libp;  
 use DBI;  
   
32  require Exporter;  require Exporter;
33  our @ISA = qw( Exporter );  our @ISA = qw( Exporter );
34  our @EXPORT = qw(  our @EXPORT_OK = qw(
35                                testDsn hash2Sql                                testDsn hash2Sql
36                                SQL_INSERT SQL_UPDATE                                SQL_INSERT SQL_UPDATE
37                                connectTarget disconnectTarget sendSql                                connectTarget disconnectTarget sendSql
38                                dbNow                                dbNow
39                                getDbNameByDsn sqlDbAction createSqlDb dropSqlDb                                getDbNameByDsn sqlDbAction createSqlDb dropSqlDb
40                                quotesql                                quotesql
41                                testDsnForTables                                testDsnForTables testDbServer
42                                );                                );
43    
44    
45    use libp qw( croak );
46    use DBI;
47    
48  use constant SQL_INSERT => 10;  use constant SQL_INSERT => 10;
49  use constant SQL_UPDATE => 11;  use constant SQL_UPDATE => 11;
50    use constant SQL_SELECT => 12;
51    
52  my $dbmeta_ref_cache;  my $dbmeta_ref_cache;
53    
# Line 44  sub testDsn { Line 62  sub testDsn {
62    }    }
63  }  }
64    
65    sub testDbServer {
66      my $dsn = shift;
67      $dsn =~ s/database=(\w+)//;
68      
69      #print "testDbServer: $dsn", "\n";
70      
71      my $result;
72      if ( my $dbh = DBI->connect($dsn, '', '', {
73                                                          PrintError => 0,
74                                                          } ) ) {
75        $dbh->disconnect();
76        return 1;
77      }
78    }
79    
80    
81    # TODO: handle usage of "$crit" in an abstract way somehow
82  sub hash2Sql {  sub hash2Sql {
83        
84    my $table = shift;    my $table = shift;
# Line 52  sub hash2Sql { Line 87  sub hash2Sql {
87    my $crit = shift;    my $crit = shift;
88        
89    my $sql;    my $sql;
90    if ($mode == SQL_INSERT) {    $mode = SQL_SELECT if ($mode eq 'SQL_SELECT' || $mode eq 'SELECT');
91      $sql = "INSERT INTO $table (#fields#) VALUES (#values#);";    $mode = SQL_INSERT if ($mode eq 'SQL_INSERT' || $mode eq 'INSERT');
92    }    $mode = SQL_UPDATE if ($mode eq 'SQL_UPDATE' || $mode eq 'UPDATE');
93    if ($mode == SQL_UPDATE) {  
94      $sql = "UPDATE $table SET #fields-values# WHERE $crit;";    if ($mode == SQL_SELECT) {
95        $sql = "SELECT #fields# FROM $table WHERE $crit";
96      } elsif ($mode == SQL_INSERT) {
97        $sql = "INSERT INTO $table (#fields#) VALUES (#values#)";
98      } elsif ($mode == SQL_UPDATE) {
99        $sql = "UPDATE $table SET #fields-values# WHERE $crit";
100    }    }
101        
102    my (@fields, @values);    my (@fields, @values);
# Line 105  sub connectTarget { Line 145  sub connectTarget {
145    croak "please supply a dsn or a \"dbmeta\"-hash" if (!$dbmeta);    croak "please supply a dsn or a \"dbmeta\"-hash" if (!$dbmeta);
146    $dbmeta = patch_dbmeta($dbmeta);    $dbmeta = patch_dbmeta($dbmeta);
147    if (!$dbmeta->{connected}) {    if (!$dbmeta->{connected}) {
148      if ($dbmeta->{dbh} = DBI->connect($dbmeta->{dsn})) {      if ($dbmeta->{dbh} = DBI->connect($dbmeta->{dsn}, '', '', { PrintError => 0 } )) {
149        $dbmeta->{dbh}->trace($dbmeta->{trace_level}, $dbmeta->{trace_file});        $dbmeta->{dbh}->trace($dbmeta->{trace_level}, $dbmeta->{trace_file});
150        $dbmeta->{dbh}->{PrintError} = 0;        $dbmeta->{dbh}->{PrintError} = 0;
151        $dbmeta->{connected} = 1;        $dbmeta->{connected} = 1;
152        $dbmeta_ref_cache = $dbmeta;        $dbmeta_ref_cache = $dbmeta;
153          return 1;
154      }      }
155    }    }
156  }  }
# Line 136  sub sendSql { Line 177  sub sendSql {
177      return 0;      return 0;
178    }    }
179    if (my $result = $dbmeta_ref->{dbh}->prepare($sql)) {    if (my $result = $dbmeta_ref->{dbh}->prepare($sql)) {
180      if ($result->execute()) {      #if ($result->execute()) {
181          $result->execute();
182        return $result;        return $result;
183      }      #}
184    }    }
185  }  }
186    
# Line 165  sub sqlDbAction { Line 207  sub sqlDbAction {
207      trace_level => 1,      trace_level => 1,
208      trace_file => 'dbitrace',      trace_file => 'dbitrace',
209    };    };
210    connectTarget($dbmeta);    my $bool_ok;
211    sendSql($sql);    if (connectTarget($dbmeta)) {
212    disconnectTarget($dbmeta);      sendSql($sql);
213        #print "state: ", $dbmeta->{dbh}->state, "\n";
214        #print "err    ", $dbmeta->{dbh}->err, "\n";
215        #$bool_ok = ($dbmeta->{dbh} && $dbmeta->{dbh}->state && !$dbmeta->{dbh}->err);
216        $bool_ok = ($dbmeta->{dbh} && !$dbmeta->{dbh}->err);
217        disconnectTarget($dbmeta);
218      }
219      return $bool_ok;
220  }  }
221    
222  sub createSqlDb {  sub createSqlDb {
223    my $dsn = shift;    my $dsn = shift;
224    my $dbname = getDbNameByDsn($dsn);    my $dbname = getDbNameByDsn($dsn);
225    print "  - creating database $dbname", "\n";    print "  - creating rdbms-database $dbname ($dsn) ...";
226    my $sql;    my $sql;
227    $sql = "CREATE DATABASE $dbname;";    $sql = "CREATE DATABASE $dbname;";
228    sqlDbAction($dsn, $sql);    if ( sqlDbAction($dsn, $sql) ) {
229        print "ok", "\n";
230        return 1;
231      } else {
232        print "failed", "\n";
233        return 0;
234      }
235  }  }
236    
237  sub dropSqlDb {  sub dropSqlDb {
238    my $dsn = shift;    my $dsn = shift;
239    my $dbname = getDbNameByDsn($dsn);    my $dbname = getDbNameByDsn($dsn);
# Line 189  sub dropSqlDb { Line 245  sub dropSqlDb {
245    
246  sub quotesql {  sub quotesql {
247    my $string = shift;    my $string = shift;
248    $string =~ s/'/\\'/g;    if ($string) {
249        $string =~ s/'/\\'/g;
250      }
251    return $string;    return $string;
252  }  }
253    
# Line 203  sub testDsnForTables { Line 261  sub testDsnForTables {
261    return 1 if ($bool_tablesHere);    return 1 if ($bool_tablesHere);
262  }  }
263    
 1;  
264    1;
Legend:
Removed from v.1.1  
changed lines
  Added in v.1.6
MailToCvsAdmin">MailToCvsAdmin
 ViewVC Help
Powered by ViewVC 1.1.26 RSS 2.0 feed