/[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.14 by joko, Wed Apr 9 06:06:04 2003 UTC
# Line 3  Line 3 
3  #  $Id$  #  $Id$
4  #  #
5  #  $Log$  #  $Log$
6    #  Revision 1.14  2003/04/09 06:06:04  joko
7    #  sendQuery now is capable of doing 'SELECT'- or 'INSERT'-queries
8    #
9    #  Revision 1.13  2003/04/08 23:06:45  joko
10    #  renamed core database helper functions
11    #
12    #  Revision 1.12  2003/01/30 22:28:21  joko
13    #  + implemented new concrete methods
14    #
15    #  Revision 1.11  2002/12/19 16:31:05  joko
16    #  + sub dropDb
17    #  + sub rebuildDb
18    #
19  #  Revision 1.10  2002/12/15 02:02:22  joko  #  Revision 1.10  2002/12/15 02:02:22  joko
20  #  + fixed logging-message  #  + fixed logging-message
21  #  #
# Line 47  use warnings; Line 60  use warnings;
60    
61  use base ("Data::Storage::Handler::Abstract");  use base ("Data::Storage::Handler::Abstract");
62    
63    
64  use DBI;  use DBI;
65  use Data::Dumper;  use Data::Dumper;
66  use libdb qw( getDbNameByDsn hash2Sql );  use shortcuts::db qw( hash2sql dsn2dbname );
67  use Data::Storage::Result::DBI;  use Data::Storage::Result::DBI;
68    
69    
70  # get logger instance  # get logger instance
71  my $logger = Log::Dispatch::Config->instance;  my $logger = Log::Dispatch::Config->instance;
72    
# Line 161  sub getChildNodes { Line 176  sub getChildNodes {
176    my $locator = $self->{locator};    my $locator = $self->{locator};
177    #print Dumper($locator); exit;    #print Dumper($locator); exit;
178    if (my $result = $self->sendCommand( 'SHOW TABLES;' ) ) {    if (my $result = $self->sendCommand( 'SHOW TABLES;' ) ) {
179      my $dbname = getDbNameByDsn($self->{locator}->{dbi}->{dsn});      my $dbname = dsn2dbname($self->{locator}->{dbi}->{dsn});
180      my $key = "Tables_in_$dbname";      my $key = "Tables_in_$dbname";
181      while ( my $row = $result->getNextEntry() ) {      while ( my $row = $result->getNextEntry() ) {
182        push @nodes, $row->{$key};        push @nodes, $row->{$key};
# Line 189  sub sendQuery { Line 204  sub sendQuery {
204    
205    $logger->debug( __PACKAGE__ . "->sendQuery" );    $logger->debug( __PACKAGE__ . "->sendQuery" );
206    
207      my $action = $query->{options}->{action};
208      $action ||= 'load';
209    
210      if (my $guid = $query->{options}->{GUID}) {
211        $query->{criterias} = [ { key => 'guid', op => 'eq', val => $guid } ];
212      }
213    
214      # check criterias (load & save)
215    #my $sql = "SELECT cs FROM $self->{metainfo}->{$descent}->{node} WHERE $self->{metainfo}->{$descent}->{IdentProvider}->{arg}='$self->{entry}->{source}->{ident}';";    #my $sql = "SELECT cs FROM $self->{metainfo}->{$descent}->{node} WHERE $self->{metainfo}->{$descent}->{IdentProvider}->{arg}='$self->{entry}->{source}->{ident}';";
216    #my $result = $self->{metainfo}->{$descent}->{storage}->sendCommand($sql);    #my $result = $self->{metainfo}->{$descent}->{storage}->sendCommand($sql);
217    my @crits;    my @crits;
# Line 197  sub sendQuery { Line 220  sub sendQuery {
220      $op = '=' if lc $_->{op} eq 'eq';      $op = '=' if lc $_->{op} eq 'eq';
221      push @crits, "$_->{key}$op'$_->{val}'";      push @crits, "$_->{key}$op'$_->{val}'";
222    }    }
   my $subnodes = {};  
   map { $subnodes->{$_}++ } @{$query->{subnodes}};  
223    # HACK: this is hardcoded ;(    expand possibilities!    # HACK: this is hardcoded ;(    expand possibilities!
224    my $crit = join(' AND ', @crits);    my $crit = join(' AND ', @crits);
225    my $sql = hash2Sql($query->{node}, $subnodes, 'SELECT', $crit);    
226    return $self->sendCommand($sql);    # check subnodes (load)
227      my $subnodes = {};
228      map { $subnodes->{$_}++ } @{$query->{subnodes}};
229      
230      # check payload (save)
231      #print Dumper($query->{payload});
232      #$subnodes ||= $query->{payload};
233      
234      # dispatch action
235      if ($action eq 'load') {
236        my $sql = hash2sql($query->{node}, $subnodes, 'SELECT', $crit);
237        return $self->sendCommand($sql);
238      } elsif ($action eq 'save') {
239        my $sql = hash2sql($query->{node}, $query->{payload}, 'UPDATE', $crit);
240        $self->sendCommand($sql);
241      }
242    
243  }  }
244    
245  sub eraseAll {  sub eraseAll {
# Line 262  sub getCOREHANDLE2 { Line 299  sub getCOREHANDLE2 {
299    return $self->{_COREHANDLE};    return $self->{_COREHANDLE};
300  }  }
301    
302    sub dropDb {
303      my $self = shift;
304      my $dsn = $self->{locator}->{dbi}->{dsn};
305    
306      $logger->debug( __PACKAGE__ .  "->dropDb( dsn $dsn )" );
307    
308      $dsn =~ s/database=(.+?);//;
309      my $database_name = $1;
310    
311      my $ok;
312      
313      if ( my $dbh = DBI->connect($dsn, '', '', {
314                                                          PrintError => 0,
315                                                          } ) ) {
316        if ($database_name) {
317          if ($dbh->do("DROP DATABASE $database_name;")) {
318            $ok = 1;
319          }
320        }
321    
322        $dbh->disconnect();
323    
324      }
325      
326      return $ok;
327    }
328    
329    sub rebuildDb {
330      my $self = shift;
331      $logger->info( __PACKAGE__ . "->rebuildDb()" );
332      my @results;
333    
334      # sum up results (bool (0/1)) in array
335      #push @results, $self->retreatSchema();
336      push @results, $self->dropDb();
337      push @results, $self->createDb();
338      #push @results, $self->deploySchema();
339    
340      # scan array for "bad ones"
341      my $res = 1;
342      map {
343        $res = 0 if (!$_);
344      } @results;
345      
346      return $res;
347    }
348    
349    sub testAvailability {
350      my $self = shift;
351      my $status = $self->testDsn();
352      $self->{locator}->{status}->{available} = $status;
353      return $status;
354    }
355    
356    sub testDsn {
357      my $self = shift;
358      my $dsn = $self->{locator}->{dbi}->{dsn};
359      my $result;
360      if ( my $dbh = DBI->connect($dsn, '', '', {
361                                                          PrintError => 0,
362                                                          } ) ) {
363        
364        # TODO: REVIEW
365        $dbh->disconnect();
366        
367        return 1;
368      } else {
369        $logger->warning( __PACKAGE__ .  "[$self->{locator}->{type}]" . "->testDsn(): " . "DBI-error: " . $DBI::errstr );
370      }
371    }
372    
373  1;  1;
374    __END__
Legend:
Removed from v.1.10  
changed lines
  Added in v.1.14
MailToCvsAdmin">MailToCvsAdmin
 ViewVC Help
Powered by ViewVC 1.1.26 RSS 2.0 feed