/[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.10 by joko, Sun Dec 15 02:02:22 2002 UTC revision 1.13 by joko, Tue Apr 8 23:06:45 2003 UTC
# Line 3  Line 3 
3  #  $Id$  #  $Id$
4  #  #
5  #  $Log$  #  $Log$
6    #  Revision 1.13  2003/04/08 23:06:45  joko
7    #  renamed core database helper functions
8    #
9    #  Revision 1.12  2003/01/30 22:28:21  joko
10    #  + implemented new concrete methods
11    #
12    #  Revision 1.11  2002/12/19 16:31:05  joko
13    #  + sub dropDb
14    #  + sub rebuildDb
15    #
16  #  Revision 1.10  2002/12/15 02:02:22  joko  #  Revision 1.10  2002/12/15 02:02:22  joko
17  #  + fixed logging-message  #  + fixed logging-message
18  #  #
# Line 47  use warnings; Line 57  use warnings;
57    
58  use base ("Data::Storage::Handler::Abstract");  use base ("Data::Storage::Handler::Abstract");
59    
60    
61  use DBI;  use DBI;
62  use Data::Dumper;  use Data::Dumper;
63  use libdb qw( getDbNameByDsn hash2Sql );  use shortcuts::db qw( hash2sql dsn2dbname );
64  use Data::Storage::Result::DBI;  use Data::Storage::Result::DBI;
65    
66    
67  # get logger instance  # get logger instance
68  my $logger = Log::Dispatch::Config->instance;  my $logger = Log::Dispatch::Config->instance;
69    
# Line 161  sub getChildNodes { Line 173  sub getChildNodes {
173    my $locator = $self->{locator};    my $locator = $self->{locator};
174    #print Dumper($locator); exit;    #print Dumper($locator); exit;
175    if (my $result = $self->sendCommand( 'SHOW TABLES;' ) ) {    if (my $result = $self->sendCommand( 'SHOW TABLES;' ) ) {
176      my $dbname = getDbNameByDsn($self->{locator}->{dbi}->{dsn});      my $dbname = dsn2dbname($self->{locator}->{dbi}->{dsn});
177      my $key = "Tables_in_$dbname";      my $key = "Tables_in_$dbname";
178      while ( my $row = $result->getNextEntry() ) {      while ( my $row = $result->getNextEntry() ) {
179        push @nodes, $row->{$key};        push @nodes, $row->{$key};
# Line 201  sub sendQuery { Line 213  sub sendQuery {
213    map { $subnodes->{$_}++ } @{$query->{subnodes}};    map { $subnodes->{$_}++ } @{$query->{subnodes}};
214    # HACK: this is hardcoded ;(    expand possibilities!    # HACK: this is hardcoded ;(    expand possibilities!
215    my $crit = join(' AND ', @crits);    my $crit = join(' AND ', @crits);
216    my $sql = hash2Sql($query->{node}, $subnodes, 'SELECT', $crit);    my $sql = hash2sql($query->{node}, $subnodes, 'SELECT', $crit);
217    return $self->sendCommand($sql);    return $self->sendCommand($sql);
218  }  }
219    
# Line 262  sub getCOREHANDLE2 { Line 274  sub getCOREHANDLE2 {
274    return $self->{_COREHANDLE};    return $self->{_COREHANDLE};
275  }  }
276    
277    sub dropDb {
278      my $self = shift;
279      my $dsn = $self->{locator}->{dbi}->{dsn};
280    
281      $logger->debug( __PACKAGE__ .  "->dropDb( dsn $dsn )" );
282    
283      $dsn =~ s/database=(.+?);//;
284      my $database_name = $1;
285    
286      my $ok;
287      
288      if ( my $dbh = DBI->connect($dsn, '', '', {
289                                                          PrintError => 0,
290                                                          } ) ) {
291        if ($database_name) {
292          if ($dbh->do("DROP DATABASE $database_name;")) {
293            $ok = 1;
294          }
295        }
296    
297        $dbh->disconnect();
298    
299      }
300      
301      return $ok;
302    }
303    
304    sub rebuildDb {
305      my $self = shift;
306      $logger->info( __PACKAGE__ . "->rebuildDb()" );
307      my @results;
308    
309      # sum up results (bool (0/1)) in array
310      #push @results, $self->retreatSchema();
311      push @results, $self->dropDb();
312      push @results, $self->createDb();
313      #push @results, $self->deploySchema();
314    
315      # scan array for "bad ones"
316      my $res = 1;
317      map {
318        $res = 0 if (!$_);
319      } @results;
320      
321      return $res;
322    }
323    
324    sub testAvailability {
325      my $self = shift;
326      my $status = $self->testDsn();
327      $self->{locator}->{status}->{available} = $status;
328      return $status;
329    }
330    
331    sub testDsn {
332      my $self = shift;
333      my $dsn = $self->{locator}->{dbi}->{dsn};
334      my $result;
335      if ( my $dbh = DBI->connect($dsn, '', '', {
336                                                          PrintError => 0,
337                                                          } ) ) {
338        
339        # TODO: REVIEW
340        $dbh->disconnect();
341        
342        return 1;
343      } else {
344        $logger->warning( __PACKAGE__ .  "[$self->{locator}->{type}]" . "->testDsn(): " . "DBI-error: " . $DBI::errstr );
345      }
346    }
347    
348  1;  1;
349    __END__

Legend:
Removed from v.1.10  
changed lines
  Added in v.1.13

MailToCvsAdmin">MailToCvsAdmin
ViewVC Help
Powered by ViewVC 1.1.26 RSS 2.0 feed