/[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.1 by cvsjoko, Thu Oct 10 03:44:07 2002 UTC revision 1.4 by jonen, Sun Nov 17 08:46:42 2002 UTC
# Line 3  Line 3 
3  #  $Id$  #  $Id$
4  #  #
5  #  $Log$  #  $Log$
6    #  Revision 1.4  2002/11/17 08:46:42  jonen
7    #  + wrapped eval around DBI->connect to prevent deaths
8    #
9    #  Revision 1.3  2002/11/17 06:34:39  joko
10    #  + locator metadata can now be reached via ->{locator}
11    #  - sub hash2sql now taken from libdb
12    #
13    #  Revision 1.2  2002/10/25 11:43:27  joko
14    #  + enhanced robustness
15    #  + more logging for debug-levels
16    #
17  #  Revision 1.1  2002/10/10 03:44:07  cvsjoko  #  Revision 1.1  2002/10/10 03:44:07  cvsjoko
18  #  + new  #  + new
19  #  #
# Line 17  use warnings; Line 28  use warnings;
28  use base ("Data::Storage::Handler::Abstract");  use base ("Data::Storage::Handler::Abstract");
29    
30  use DBI;  use DBI;
31    use Data::Dumper;
32    use libdb;
33    
34  # get logger instance  # get logger instance
35  my $logger = Log::Dispatch::Config->instance;  my $logger = Log::Dispatch::Config->instance;
# Line 31  sub connect { Line 44  sub connect {
44      my $self = shift;      my $self = shift;
45            
46      # create handle      # create handle
47        if ( my $dsn = $self->{dbi}->{dsn} ) {        if ( my $dsn = $self->{locator}->{dbi}->{dsn} ) {
48          $logger->debug( __PACKAGE__ . "->connect($dsn)" );        #if ( my $dsn = $self->{locator}->{dsn} ) {
49          $self->{COREHANDLE} = DBI->connect($dsn);          $logger->debug( __PACKAGE__ . "->connect( dsn $dsn )" );
50            
51            # HACK:
52            # set errorhandler before actually calling DBI->connect
53            # in order to catch errors from the very beginning
54            #DBI->{HandleError} = $self->{dbi}->{HandleError};
55            
56            #use Data::Dumper; print Dumper($self->{dbi});
57            
58            eval {
59              $self->{COREHANDLE} = DBI->connect( $dsn, '', '', $self->{locator}->{dbi} );
60              if (!$self->{COREHANDLE}) {
61                $logger->warning( __PACKAGE__ . "->connect failed: " . DBI::errstr );
62                return;
63              }
64            };
65            $logger->warning( __PACKAGE__ . "->connect failed: " . $@ ) if $@;
66    
67        }        }
68        $self->configureCOREHANDLE();        $self->configureCOREHANDLE();
69    
70        $self->{locator}->{status}->{connected} = 1;
71    
72        return 1;
73            
74  }  }
75    
# Line 43  sub configureCOREHANDLE { Line 77  sub configureCOREHANDLE {
77    
78    my $self = shift;    my $self = shift;
79    
80    $logger->debug( __PACKAGE__ . "->_configureCOREHANDLE" );    $logger->debug( __PACKAGE__ . "->configureCOREHANDLE" );
81    
82    # apply configured modifications    # apply configured modifications
83      if (exists $self->{dbi}->{trace_level} && exists $self->{dbi}->{trace_file}) {      if (exists $self->{locator}->{dbi}->{trace_level} && exists $self->{locator}->{dbi}->{trace_file}) {
84        $self->{COREHANDLE}->trace($self->{dbi}->{trace_level}, $self->{dbi}->{trace_file});        $self->{COREHANDLE}->trace($self->{locator}->{dbi}->{trace_level}, $self->{locator}->{dbi}->{trace_file});
85      }      }
86      if (exists $self->{dbi}->{RaiseError}) {      if (exists $self->{locator}->{dbi}->{RaiseError}) {
87        $self->{COREHANDLE}->{RaiseError} = $self->{dbi}->{RaiseError};        $self->{COREHANDLE}->{RaiseError} = $self->{locator}->{dbi}->{RaiseError};
88      }      }
89      if (exists $self->{dbi}->{PrintError}) {      if (exists $self->{locator}->{dbi}->{PrintError}) {
90        $self->{COREHANDLE}->{PrintError} = $self->{dbi}->{PrintError};        $self->{COREHANDLE}->{PrintError} = $self->{locator}->{dbi}->{PrintError};
91      }      }
92      if (exists $self->{dbi}->{HandleError}) {      if (exists $self->{locator}->{dbi}->{HandleError}) {
93        $self->{COREHANDLE}->{HandleError} = $self->{dbi}->{HandleError};        $self->{COREHANDLE}->{HandleError} = $self->{locator}->{dbi}->{HandleError};
94      }      }
95    
96  }  }
# Line 64  sub configureCOREHANDLE { Line 98  sub configureCOREHANDLE {
98  sub _sendSql {  sub _sendSql {
99    my $self = shift;    my $self = shift;
100    my $sql = shift;    my $sql = shift;
101      
102      # two-level handling for implicit connect:
103      # if there's no corehandle ...
104      if (!$self->{COREHANDLE}) {
105        # ... try to connect, but ...
106        $self->connect();
107        # ... if this still fails, there's something wrong probably, so we won't continue
108        if (!$self->{COREHANDLE}) {
109          return;
110        }
111      }
112      
113      #print "prepare sql: $sql\n";
114      
115    my $sth = $self->{COREHANDLE}->prepare($sql);    my $sth = $self->{COREHANDLE}->prepare($sql);
116    $sth->execute();    $sth->execute();
117    return $sth;    return $sth;
# Line 72  sub _sendSql { Line 120  sub _sendSql {
120  sub sendCommand {  sub sendCommand {
121    my $self = shift;    my $self = shift;
122    my $command = shift;    my $command = shift;
123      #$logger->debug( __PACKAGE__ . "->sendCommand( command $command )" );
124    my $cmdHandle = $self->_sendSql($command);    my $cmdHandle = $self->_sendSql($command);
125    my $result = Data::Storage::Result::DBI->new( RESULTHANDLE => $cmdHandle );    my $result = Data::Storage::Result::DBI->new( RESULTHANDLE => $cmdHandle );
126    return $result;    return $result;
# Line 86  sub quoteSql { Line 135  sub quoteSql {
135    return $string;    return $string;
136  }  }
137    
 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;  
 }  
   
138    
139  sub getChildNodes {  sub getChildNodes {
140    
141    my $self = shift;    my $self = shift;
142    my @nodes;    my @nodes;
143    
144      $logger->debug( __PACKAGE__ . "->getChildNodes()" );
145    
146    if (my $result = $self->sendCommand( 'SHOW TABLES;' ) ) {    if (my $result = $self->sendCommand( 'SHOW TABLES;' ) ) {
147        my $dbname = getDbNameByDsn($self->{locator}->{dbi}->{dsn});
148        my $key = "Tables_in_$dbname";
149      while ( my $row = $result->_getNextEntry() ) {      while ( my $row = $result->_getNextEntry() ) {
150        push @nodes, $row;        push @nodes, $row->{$key};
151      }      }
152    }    }
153        
# Line 157  use base ("Data::Storage::Result"); Line 168  use base ("Data::Storage::Result");
168  sub DESTROY {  sub DESTROY {
169    my $self = shift;    my $self = shift;
170    #$logger->debug( __PACKAGE__ . "->" . "DESTROY" );    #$logger->debug( __PACKAGE__ . "->" . "DESTROY" );
171    $self->{RESULTHANDLE}->finish();    $self->{RESULTHANDLE} && $self->{RESULTHANDLE}->finish();
172  }  }
173    
174  sub _getNextEntry {  sub _getNextEntry {
175    my $self = shift;    my $self = shift;
176    return $self->{RESULTHANDLE}->fetchrow_hashref;    $self->{RESULTHANDLE} && return $self->{RESULTHANDLE}->fetchrow_hashref;
177  }  }
178    
179    
 1;  
180    1;
Legend:
Removed from v.1.1  
changed lines
  Added in v.1.4
MailToCvsAdmin">MailToCvsAdmin
 ViewVC Help
Powered by ViewVC 1.1.26 RSS 2.0 feed