/[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.8 by joko, Thu Dec 12 02:48:58 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  ##    Revision 1.8  2002/12/12 02:48:58  joko
16  ##    + played with fixing disconnectTarget  ##    + played with fixing disconnectTarget
17  ##  ##
# Line 38  use warnings; Line 48  use warnings;
48  require Exporter;  require Exporter;
49  our @ISA = qw( Exporter );  our @ISA = qw( Exporter );
50  our @EXPORT_OK = 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
                               quotesql  
55                                testDsnForTables testDbServer                                testDsnForTables testDbServer
56                                );                                );
57    
58    
59  use libp qw( croak );  use Carp;
60  use DBI;  use DBI;
61  use Data::Dumper;  use Data::Dumper;
62    
63  use constant SQL_INSERT => 10;  use shortcuts::database qw( dsn2dbname );
 use constant SQL_UPDATE => 11;  
 use constant SQL_SELECT => 12;  
64    
65  my $dbmeta_ref_cache;  my $dbmeta_ref_cache;
66    
# Line 85  sub testDbServer { Line 91  sub testDbServer {
91  }  }
92    
93    
 # TODO: handle usage of "$crit" in an abstract way somehow  
 sub hash2Sql {  
     
   my $table = shift;  
   my $hash = shift;  
   my $mode = shift;  
   my $crit = shift;  
     
   my $sql;  
   $mode = SQL_SELECT if ($mode eq 'SQL_SELECT' || $mode eq 'SELECT');  
   $mode = SQL_INSERT if ($mode eq 'SQL_INSERT' || $mode eq 'INSERT');  
   $mode = SQL_UPDATE if ($mode eq 'SQL_UPDATE' || $mode eq 'UPDATE');  
   
   if ($mode == SQL_SELECT) {  
     $sql = "SELECT #fields# FROM $table WHERE $crit";  
   } elsif ($mode == SQL_INSERT) {  
     $sql = "INSERT INTO $table (#fields#) VALUES (#values#)";  
   } elsif ($mode == SQL_UPDATE) {  
     $sql = "UPDATE $table SET #fields-values# WHERE $crit";  
   }  
     
   my (@fields, @values);  
   foreach my $key (keys %{$hash}) {  
     push @fields, $key;  
     push @values, $hash->{$key};  
   }  
   # quote each element  
   map { if (defined $_) { $_ = "'$_'" } else { $_ = "null" } } @values;  
     
   my $fields = join(', ', @fields);  
   my $values = join(', ', @values);  
   my $fields_values = '';  
   my $fc = 0;  
   foreach (@fields) {  
     $fields_values .= $_ . '=' . $values[$fc] . ', ';  
     $fc++;  
   }  
   $fields_values = substr($fields_values, 0, -2);  
     
   $sql =~ s/#fields#/$fields/;  
   $sql =~ s/#values#/$values/;  
   $sql =~ s/#fields-values#/$fields_values/;  
     
   return $sql;  
 }  
94    
95  sub patch_dbmeta {  sub patch_dbmeta {
96        
# Line 203  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 233  sub sqlDbAction { Line 187  sub sqlDbAction {
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 rdbms-database $dbname ($dsn) ...";    print "  - creating rdbms-database $dbname ($dsn) ...";
192    my $sql;    my $sql;
193    $sql = "CREATE DATABASE $dbname;";    $sql = "CREATE DATABASE $dbname;";
# Line 248  sub createSqlDb { Line 202  sub createSqlDb {
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;  
   if ($string) {  
     $string =~ s/'/\\'/g;  
   }  
   return $string;  
 }  
   
212  sub testDsnForTables {  sub testDsnForTables {
213    my $dsn = shift;    my $dsn = shift;
214    connectTarget($dsn);    connectTarget($dsn);
Legend:
Removed from v.1.8  
changed lines
  Added in v.1.11
MailToCvsAdmin">MailToCvsAdmin
 ViewVC Help
Powered by ViewVC 1.1.26 RSS 2.0 feed