/[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.11 by joko, Wed Apr 9 07:53:33 2003 UTC
# Line 2  Line 2 
2  ##    $Id$  ##    $Id$
3  ##    --------------------------------------------------------------------------------  ##    --------------------------------------------------------------------------------
4  ##    $Log$  ##    $Log$
5    ##    Revision 1.11  2003/04/09 07:53:33  joko
6    ##    minor namespace update
7    ##
8    ##    Revision 1.10  2003/04/08 23:07:57  joko
9    ##    renamed core database helper functions
10    ##    moved 'hash2Sql' and 'quotesql' to shortcuts::db
11    ##
12    ##    Revision 1.9  2003/02/09 04:47:58  joko
13    ##    + minor fix
14    ##
15    ##    Revision 1.8  2002/12/12 02:48:58  joko
16    ##    + played with fixing disconnectTarget
17    ##
18    ##    Revision 1.7  2002/12/01 22:13:17  joko
19    ##    + minor bugfix?
20    ##
21    ##    Revision 1.6  2002/11/29 04:53:39  joko
22    ##    + hash2Sql now knows about SQL_SELECT
23    ##
24    ##    Revision 1.5  2002/11/17 07:18:38  joko
25    ##    + small modification in hash2sql
26    ##
27    ##    Revision 1.4  2002/10/16 22:36:42  joko
28    ##    + sub testDbServer
29    ##
30    ##    Revision 1.3  2002/07/27 00:28:20  cvsjoko
31    ##    bugfixes
32    ##
33    ##    Revision 1.2  2002/07/20 11:09:58  cvsjoko
34    ##    + bugfixes
35    ##    + dont' print sql-errors
36    ##
37  ##    Revision 1.1  2002/07/19 18:14:03  cvsjoko  ##    Revision 1.1  2002/07/19 18:14:03  cvsjoko
38  ##    no message  ##    no message
39  ##  ##
# Line 13  package libdb; Line 45  package libdb;
45  use strict;  use strict;
46  use warnings;  use warnings;
47    
 use libp;  
 use DBI;  
   
48  require Exporter;  require Exporter;
49  our @ISA = qw( Exporter );  our @ISA = qw( Exporter );
50  our @EXPORT = qw(  our @EXPORT_OK = qw(
51                                testDsn hash2Sql                                testDsn
                               SQL_INSERT SQL_UPDATE  
52                                connectTarget disconnectTarget sendSql                                connectTarget disconnectTarget sendSql
53                                dbNow                                dbNow
54                                getDbNameByDsn sqlDbAction createSqlDb dropSqlDb                                dsn2dbname sqlDbAction createSqlDb dropSqlDb
55                                quotesql                                testDsnForTables testDbServer
                               testDsnForTables  
56                                );                                );
57    
58  use constant SQL_INSERT => 10;  
59  use constant SQL_UPDATE => 11;  use Carp;
60    use DBI;
61    use Data::Dumper;
62    
63    use shortcuts::database qw( dsn2dbname );
64    
65  my $dbmeta_ref_cache;  my $dbmeta_ref_cache;
66    
# Line 44  sub testDsn { Line 75  sub testDsn {
75    }    }
76  }  }
77    
78  sub hash2Sql {  sub testDbServer {
79        my $dsn = shift;
80    my $table = shift;    $dsn =~ s/database=(\w+)//;
   my $hash = shift;  
   my $mode = shift;  
   my $crit = shift;  
     
   my $sql;  
   if ($mode == SQL_INSERT) {  
     $sql = "INSERT INTO $table (#fields#) VALUES (#values#);";  
   }  
   if ($mode == SQL_UPDATE) {  
     $sql = "UPDATE $table SET #fields-values# WHERE $crit;";  
   }  
81        
82    my (@fields, @values);    #print "testDbServer: $dsn", "\n";
   foreach my $key (keys %{$hash}) {  
     push @fields, $key;  
     push @values, $hash->{$key};  
   }  
   # quote each element  
   map { if (defined $_) { $_ = "'$_'" } else { $_ = "null" } } @values;  
83        
84    my $fields = join(', ', @fields);    my $result;
85    my $values = join(', ', @values);    if ( my $dbh = DBI->connect($dsn, '', '', {
86    my $fields_values = '';                                                        PrintError => 0,
87    my $fc = 0;                                                        } ) ) {
88    foreach (@fields) {      $dbh->disconnect();
89      $fields_values .= $_ . '=' . $values[$fc] . ', ';      return 1;
     $fc++;  
90    }    }
   $fields_values = substr($fields_values, 0, -2);  
     
   $sql =~ s/#fields#/$fields/;  
   $sql =~ s/#values#/$values/;  
   $sql =~ s/#fields-values#/$fields_values/;  
     
   return $sql;  
91  }  }
92    
93    
94    
95  sub patch_dbmeta {  sub patch_dbmeta {
96        
97    my $dbmeta = shift;    my $dbmeta = shift;
# Line 105  sub connectTarget { Line 113  sub connectTarget {
113    croak "please supply a dsn or a \"dbmeta\"-hash" if (!$dbmeta);    croak "please supply a dsn or a \"dbmeta\"-hash" if (!$dbmeta);
114    $dbmeta = patch_dbmeta($dbmeta);    $dbmeta = patch_dbmeta($dbmeta);
115    if (!$dbmeta->{connected}) {    if (!$dbmeta->{connected}) {
116      if ($dbmeta->{dbh} = DBI->connect($dbmeta->{dsn})) {      if ($dbmeta->{dbh} = DBI->connect($dbmeta->{dsn}, '', '', { PrintError => 0 } )) {
117        $dbmeta->{dbh}->trace($dbmeta->{trace_level}, $dbmeta->{trace_file});        $dbmeta->{dbh}->trace($dbmeta->{trace_level}, $dbmeta->{trace_file});
118        $dbmeta->{dbh}->{PrintError} = 0;        $dbmeta->{dbh}->{PrintError} = 0;
119        $dbmeta->{connected} = 1;        $dbmeta->{connected} = 1;
120        $dbmeta_ref_cache = $dbmeta;        $dbmeta_ref_cache = $dbmeta;
121          return 1;
122      }      }
123    }    }
124  }  }
125    
126  sub disconnectTarget {  sub disconnectTarget {
127    #my $dbmeta = shift;    #my $dbmeta = shift;
128      #print "disc\n";
129    #croak "please supply a \"dbmeta\"-hash" if (!$dbmeta);    #croak "please supply a \"dbmeta\"-hash" if (!$dbmeta);
130    #$dbmeta = patch_dbmeta($dbmeta);    #$dbmeta = patch_dbmeta($dbmeta);
131    #$dbmeta->{dbh} && $dbmeta->{dbh}->disconnect();    #$dbmeta->{dbh} && $dbmeta->{dbh}->disconnect();
132    my $dbmeta = $dbmeta_ref_cache;    my $dbmeta = $dbmeta_ref_cache;
133    $dbmeta->{dbh} && $dbmeta->{dbh}->disconnect();    #print Dumper($dbmeta);
134      #$dbmeta->{dbh} && $dbmeta->{dbh}->disconnect();
135      $dbmeta->{dbh}->disconnect();
136      undef($dbmeta->{dbh});
137      undef($dbmeta);
138    undef($dbmeta_ref_cache);    undef($dbmeta_ref_cache);
139  }  }
140    
# Line 136  sub sendSql { Line 150  sub sendSql {
150      return 0;      return 0;
151    }    }
152    if (my $result = $dbmeta_ref->{dbh}->prepare($sql)) {    if (my $result = $dbmeta_ref->{dbh}->prepare($sql)) {
153      if ($result->execute()) {      #if ($result->execute()) {
154          $result->execute();
155        return $result;        return $result;
156      }      #}
157    }    }
158  }  }
159    
# Line 149  sub dbNow { Line 164  sub dbNow {
164  }  }
165    
166    
 sub getDbNameByDsn {  
   my $dsn = shift;  
   $dsn =~ m/database=(.+?);/;  
   my $database_name = $1;  
   return $database_name;  
 }  
   
167  sub sqlDbAction {  sub sqlDbAction {
168    my $dsn = shift;    my $dsn = shift;
169    $dsn =~ s/database=.+?;//;    $dsn =~ s/database=.+?;//;
# Line 165  sub sqlDbAction { Line 173  sub sqlDbAction {
173      trace_level => 1,      trace_level => 1,
174      trace_file => 'dbitrace',      trace_file => 'dbitrace',
175    };    };
176    connectTarget($dbmeta);    my $bool_ok;
177    sendSql($sql);    if (connectTarget($dbmeta)) {
178    disconnectTarget($dbmeta);      sendSql($sql);
179        #print "state: ", $dbmeta->{dbh}->state, "\n";
180        #print "err    ", $dbmeta->{dbh}->err, "\n";
181        #$bool_ok = ($dbmeta->{dbh} && $dbmeta->{dbh}->state && !$dbmeta->{dbh}->err);
182        $bool_ok = ($dbmeta->{dbh} && !$dbmeta->{dbh}->err);
183        disconnectTarget($dbmeta);
184      }
185      return $bool_ok;
186  }  }
187    
188  sub createSqlDb {  sub createSqlDb {
189    my $dsn = shift;    my $dsn = shift;
190    my $dbname = getDbNameByDsn($dsn);    my $dbname = dsn2dbname($dsn);
191    print "  - creating database $dbname", "\n";    print "  - creating rdbms-database $dbname ($dsn) ...";
192    my $sql;    my $sql;
193    $sql = "CREATE DATABASE $dbname;";    $sql = "CREATE DATABASE $dbname;";
194    sqlDbAction($dsn, $sql);    if ( sqlDbAction($dsn, $sql) ) {
195        print "ok", "\n";
196        return 1;
197      } else {
198        print "failed", "\n";
199        return 0;
200      }
201  }  }
202    
203  sub dropSqlDb {  sub dropSqlDb {
204    my $dsn = shift;    my $dsn = shift;
205    my $dbname = getDbNameByDsn($dsn);    my $dbname = dsn2dbname($dsn);
206    print "  - dropping database $dbname", "\n";    print "  - dropping database $dbname", "\n";
207    my $sql;    my $sql;
208    $sql = "DROP DATABASE $dbname;";    $sql = "DROP DATABASE $dbname;";
209    sqlDbAction($dsn, $sql);    sqlDbAction($dsn, $sql);
210  }  }
211    
 sub quotesql {  
   my $string = shift;  
   $string =~ s/'/\\'/g;  
   return $string;  
 }  
   
212  sub testDsnForTables {  sub testDsnForTables {
213    my $dsn = shift;    my $dsn = shift;
214    connectTarget($dsn);    connectTarget($dsn);
# Line 203  sub testDsnForTables { Line 219  sub testDsnForTables {
219    return 1 if ($bool_tablesHere);    return 1 if ($bool_tablesHere);
220  }  }
221    
 1;  
222    1;
Legend:
Removed from v.1.1  
changed lines
  Added in v.1.11
MailToCvsAdmin">MailToCvsAdmin
 ViewVC Help
Powered by ViewVC 1.1.26 RSS 2.0 feed