/[cvs]/nfo/perl/libs/Data/Storage/Handler/DBI.pm
ViewVC logotype

Diff of /nfo/perl/libs/Data/Storage/Handler/DBI.pm

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

revision 1.2 by joko, Fri Oct 25 11:43:27 2002 UTC revision 1.3 by joko, Sun Nov 17 06:34:39 2002 UTC
# Line 3  Line 3 
3  #  $Id$  #  $Id$
4  #  #
5  #  $Log$  #  $Log$
6    #  Revision 1.3  2002/11/17 06:34:39  joko
7    #  + locator metadata can now be reached via ->{locator}
8    #  - sub hash2sql now taken from libdb
9    #
10  #  Revision 1.2  2002/10/25 11:43:27  joko  #  Revision 1.2  2002/10/25 11:43:27  joko
11  #  + enhanced robustness  #  + enhanced robustness
12  #  + more logging for debug-levels  #  + more logging for debug-levels
# Line 21  use warnings; Line 25  use warnings;
25  use base ("Data::Storage::Handler::Abstract");  use base ("Data::Storage::Handler::Abstract");
26    
27  use DBI;  use DBI;
28    use Data::Dumper;
29    use libdb;
30    
31  # get logger instance  # get logger instance
32  my $logger = Log::Dispatch::Config->instance;  my $logger = Log::Dispatch::Config->instance;
# Line 35  sub connect { Line 41  sub connect {
41      my $self = shift;      my $self = shift;
42            
43      # create handle      # create handle
44        if ( my $dsn = $self->{dbi}->{dsn} ) {        if ( my $dsn = $self->{locator}->{dbi}->{dsn} ) {
45          #if ( my $dsn = $self->{locator}->{dsn} ) {
46          $logger->debug( __PACKAGE__ . "->connect( dsn $dsn )" );          $logger->debug( __PACKAGE__ . "->connect( dsn $dsn )" );
47                    
48          # HACK:          # HACK:
# Line 45  sub connect { Line 52  sub connect {
52                    
53          #use Data::Dumper; print Dumper($self->{dbi});          #use Data::Dumper; print Dumper($self->{dbi});
54                    
55          $self->{COREHANDLE} = DBI->connect(          $self->{COREHANDLE} = DBI->connect( $dsn, '', '', $self->{locator}->{dbi} );
           $dsn, '', '', {  
             RaiseError => $self->{dbi}->{RaiseError},  
             #RaiseError => 1,  
             PrintError => $self->{dbi}->{PrintError},  
             HandleError => $self->{dbi}->{HandleError},  
           }  
         );  
56          if (!$self->{COREHANDLE}) {          if (!$self->{COREHANDLE}) {
57            $logger->warning( __PACKAGE__ . "->connect failed: " . DBI::errstr );            $logger->warning( __PACKAGE__ . "->connect failed: " . DBI::errstr );
58            return;            return;
59          }          }
60        }        }
61        $self->configureCOREHANDLE();        $self->configureCOREHANDLE();
62        
63        $self->{locator}->{status}->{connected} = 1;
64    
65      return 1;      return 1;
66            
67  }  }
# Line 68  sub configureCOREHANDLE { Line 70  sub configureCOREHANDLE {
70    
71    my $self = shift;    my $self = shift;
72    
73    $logger->debug( __PACKAGE__ . "->_configureCOREHANDLE" );    $logger->debug( __PACKAGE__ . "->configureCOREHANDLE" );
74    
75    # apply configured modifications    # apply configured modifications
76      if (exists $self->{dbi}->{trace_level} && exists $self->{dbi}->{trace_file}) {      if (exists $self->{locator}->{dbi}->{trace_level} && exists $self->{locator}->{dbi}->{trace_file}) {
77        $self->{COREHANDLE}->trace($self->{dbi}->{trace_level}, $self->{dbi}->{trace_file});        $self->{COREHANDLE}->trace($self->{locator}->{dbi}->{trace_level}, $self->{locator}->{dbi}->{trace_file});
78      }      }
79      if (exists $self->{dbi}->{RaiseError}) {      if (exists $self->{locator}->{dbi}->{RaiseError}) {
80        $self->{COREHANDLE}->{RaiseError} = $self->{dbi}->{RaiseError};        $self->{COREHANDLE}->{RaiseError} = $self->{locator}->{dbi}->{RaiseError};
81      }      }
82      if (exists $self->{dbi}->{PrintError}) {      if (exists $self->{locator}->{dbi}->{PrintError}) {
83        $self->{COREHANDLE}->{PrintError} = $self->{dbi}->{PrintError};        $self->{COREHANDLE}->{PrintError} = $self->{locator}->{dbi}->{PrintError};
84      }      }
85      if (exists $self->{dbi}->{HandleError}) {      if (exists $self->{locator}->{dbi}->{HandleError}) {
86        $self->{COREHANDLE}->{HandleError} = $self->{dbi}->{HandleError};        $self->{COREHANDLE}->{HandleError} = $self->{locator}->{dbi}->{HandleError};
87      }      }
88    
89  }  }
# Line 101  sub _sendSql { Line 103  sub _sendSql {
103      }      }
104    }    }
105        
106      #print "prepare sql: $sql\n";
107      
108    my $sth = $self->{COREHANDLE}->prepare($sql);    my $sth = $self->{COREHANDLE}->prepare($sql);
109    $sth->execute();    $sth->execute();
110    return $sth;    return $sth;
# Line 124  sub quoteSql { Line 128  sub quoteSql {
128    return $string;    return $string;
129  }  }
130    
 sub hash2Sql {  
   
   my $self = shift;  
     
   my $table = shift;  
   my $hash = shift;  
   my $mode = shift;  
   my $crit = shift;  
     
   my $sql;  
   if ($mode eq 'SQL_INSERT') {  
     $sql = "INSERT INTO $table (#fields#) VALUES (#values#);";  
   }  
   if ($mode eq '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;  
 }  
   
131    
132  sub getChildNodes {  sub getChildNodes {
133    
134    my $self = shift;    my $self = shift;
135    my @nodes;    my @nodes;
136    
137      $logger->debug( __PACKAGE__ . "->getChildNodes()" );
138    
139    if (my $result = $self->sendCommand( 'SHOW TABLES;' ) ) {    if (my $result = $self->sendCommand( 'SHOW TABLES;' ) ) {
140        my $dbname = getDbNameByDsn($self->{locator}->{dbi}->{dsn});
141        my $key = "Tables_in_$dbname";
142      while ( my $row = $result->_getNextEntry() ) {      while ( my $row = $result->_getNextEntry() ) {
143        push @nodes, $row;        push @nodes, $row->{$key};
144      }      }
145    }    }
146        
Legend:
Removed from v.1.2  
changed lines
  Added in v.1.3
MailToCvsAdmin">MailToCvsAdmin
 ViewVC Help
Powered by ViewVC 1.1.26 RSS 2.0 feed