/[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.9 by joko, Thu Dec 5 07:58:20 2002 UTC revision 1.16 by joko, Fri Apr 11 01:17:18 2003 UTC
# Line 3  Line 3 
3  #  $Id$  #  $Id$
4  #  #
5  #  $Log$  #  $Log$
6    #  Revision 1.16  2003/04/11 01:17:18  joko
7    #  sendQuery:
8    #  + introduced crud action 'DELETE'
9    #  + some pre-flight checks
10    #
11    #  Revision 1.15  2003/04/09 07:53:33  joko
12    #  minor namespace update
13    #
14    #  Revision 1.14  2003/04/09 06:06:04  joko
15    #  sendQuery now is capable of doing 'SELECT'- or 'INSERT'-queries
16    #
17    #  Revision 1.13  2003/04/08 23:06:45  joko
18    #  renamed core database helper functions
19    #
20    #  Revision 1.12  2003/01/30 22:28:21  joko
21    #  + implemented new concrete methods
22    #
23    #  Revision 1.11  2002/12/19 16:31:05  joko
24    #  + sub dropDb
25    #  + sub rebuildDb
26    #
27    #  Revision 1.10  2002/12/15 02:02:22  joko
28    #  + fixed logging-message
29    #
30  #  Revision 1.9  2002/12/05 07:58:20  joko  #  Revision 1.9  2002/12/05 07:58:20  joko
31  #  + now using Tie::SecureHash as a base for the COREHANDLE  #  + now using Tie::SecureHash as a base for the COREHANDLE
32  #  + former public COREHANDLE becomes private _COREHANDLE now  #  + former public COREHANDLE becomes private _COREHANDLE now
# Line 44  use warnings; Line 68  use warnings;
68    
69  use base ("Data::Storage::Handler::Abstract");  use base ("Data::Storage::Handler::Abstract");
70    
71    
72  use DBI;  use DBI;
73  use Data::Dumper;  use Data::Dumper;
74  use libdb qw( getDbNameByDsn hash2Sql );  use shortcuts::database qw( hash2sql dsn2dbname );
75  use Data::Storage::Result::DBI;  use Data::Storage::Result::DBI;
76    
77    
78  # get logger instance  # get logger instance
79  my $logger = Log::Dispatch::Config->instance;  my $logger = Log::Dispatch::Config->instance;
80    
# Line 123  sub _sendSql { Line 149  sub _sendSql {
149    my $self = shift;    my $self = shift;
150    my $sql = shift;    my $sql = shift;
151        
152      # pre-flight check: is $sql defined?
153      if (!$sql) {
154        $logger->warning( __PACKAGE__ . "->_sendSql: \$sql was empty." );
155        return;
156      }
157      
158    # two-level handling for implicit connect:    # two-level handling for implicit connect:
159    # if there's no corehandle ...    # if there's no corehandle ...
160    if (!$self->{_COREHANDLE}) {    if (!$self->{_COREHANDLE}) {
# Line 158  sub getChildNodes { Line 190  sub getChildNodes {
190    my $locator = $self->{locator};    my $locator = $self->{locator};
191    #print Dumper($locator); exit;    #print Dumper($locator); exit;
192    if (my $result = $self->sendCommand( 'SHOW TABLES;' ) ) {    if (my $result = $self->sendCommand( 'SHOW TABLES;' ) ) {
193      my $dbname = getDbNameByDsn($self->{locator}->{dbi}->{dsn});      my $dbname = dsn2dbname($self->{locator}->{dbi}->{dsn});
194      my $key = "Tables_in_$dbname";      my $key = "Tables_in_$dbname";
195      while ( my $row = $result->getNextEntry() ) {      while ( my $row = $result->getNextEntry() ) {
196        push @nodes, $row->{$key};        push @nodes, $row->{$key};
# Line 183  sub getListUnfiltered { Line 215  sub getListUnfiltered {
215  sub sendQuery {  sub sendQuery {
216    my $self = shift;    my $self = shift;
217    my $query = shift;    my $query = shift;
218    
219      $logger->debug( __PACKAGE__ . "->sendQuery" );
220    
221      my $crud = $query->{options}->{crud};
222      $crud ||= $query->{options}->{action};
223      $crud ||= 'RETRIEVE';
224    
225      if (my $guid = $query->{options}->{GUID}) {
226        $query->{criterias} = [ { key => 'guid', op => 'eq', val => $guid } ];
227      }
228    
229      # check criterias (load & save)
230    #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}';";
231    #my $result = $self->{metainfo}->{$descent}->{storage}->sendCommand($sql);    #my $result = $self->{metainfo}->{$descent}->{storage}->sendCommand($sql);
232    my @crits;    my @crits;
# Line 191  sub sendQuery { Line 235  sub sendQuery {
235      $op = '=' if lc $_->{op} eq 'eq';      $op = '=' if lc $_->{op} eq 'eq';
236      push @crits, "$_->{key}$op'$_->{val}'";      push @crits, "$_->{key}$op'$_->{val}'";
237    }    }
   my $subnodes = {};  
   map { $subnodes->{$_}++ } @{$query->{subnodes}};  
238    # HACK: this is hardcoded ;(    expand possibilities!    # HACK: this is hardcoded ;(    expand possibilities!
239    my $crit = join(' AND ', @crits);    my $crit = join(' AND ', @crits);
240    my $sql = hash2Sql($query->{node}, $subnodes, 'SELECT', $crit);    
241    return $self->sendCommand($sql);    # check subnodes (load)
242      my $subnodes = {};
243      map { $subnodes->{$_}++ } @{$query->{subnodes}};
244      
245      # check payload (save)
246      #print Dumper($query->{payload});
247      #$subnodes ||= $query->{payload};
248      
249      # dispatch action
250      if ($crud eq 'RETRIEVE') {
251        my $sql = hash2sql($query->{node}, $subnodes, 'SELECT', $crit);
252        return $self->sendCommand($sql);
253    
254      } elsif ($crud eq 'UPDATE') {
255        my $sql = hash2sql($query->{node}, $query->{payload}, 'UPDATE', $crit);
256        $self->sendCommand($sql);
257    
258      } elsif ($crud eq 'DELETE') {
259        my $sql = hash2sql($query->{node}, $query->{payload}, 'DELETE', $crit);
260        $self->sendCommand($sql);
261    
262      }
263    
264  }  }
265    
266  sub eraseAll {  sub eraseAll {
267    my $self = shift;    my $self = shift;
268    my $classname = shift;    my $classname = shift;
269      $logger->debug( __PACKAGE__ . "->eraseAll" );
270    my $sql = "DELETE FROM $classname";    my $sql = "DELETE FROM $classname";
271    $self->sendCommand($sql);    $self->sendCommand($sql);
272  }  }
# Line 255  sub getCOREHANDLE2 { Line 320  sub getCOREHANDLE2 {
320    return $self->{_COREHANDLE};    return $self->{_COREHANDLE};
321  }  }
322    
323    sub dropDb {
324      my $self = shift;
325      my $dsn = $self->{locator}->{dbi}->{dsn};
326    
327      $logger->debug( __PACKAGE__ .  "->dropDb( dsn $dsn )" );
328    
329      $dsn =~ s/database=(.+?);//;
330      my $database_name = $1;
331    
332      my $ok;
333      
334      if ( my $dbh = DBI->connect($dsn, '', '', {
335                                                          PrintError => 0,
336                                                          } ) ) {
337        if ($database_name) {
338          if ($dbh->do("DROP DATABASE $database_name;")) {
339            $ok = 1;
340          }
341        }
342    
343        $dbh->disconnect();
344    
345      }
346      
347      return $ok;
348    }
349    
350    sub rebuildDb {
351      my $self = shift;
352      $logger->info( __PACKAGE__ . "->rebuildDb()" );
353      my @results;
354    
355      # sum up results (bool (0/1)) in array
356      #push @results, $self->retreatSchema();
357      push @results, $self->dropDb();
358      push @results, $self->createDb();
359      #push @results, $self->deploySchema();
360    
361      # scan array for "bad ones"
362      my $res = 1;
363      map {
364        $res = 0 if (!$_);
365      } @results;
366      
367      return $res;
368    }
369    
370    sub testAvailability {
371      my $self = shift;
372      my $status = $self->testDsn();
373      $self->{locator}->{status}->{available} = $status;
374      return $status;
375    }
376    
377    sub testDsn {
378      my $self = shift;
379      my $dsn = $self->{locator}->{dbi}->{dsn};
380      my $result;
381      if ( my $dbh = DBI->connect($dsn, '', '', {
382                                                          PrintError => 0,
383                                                          } ) ) {
384        
385        # TODO: REVIEW
386        $dbh->disconnect();
387        
388        return 1;
389      } else {
390        $logger->warning( __PACKAGE__ .  "[$self->{locator}->{type}]" . "->testDsn(): " . "DBI-error: " . $DBI::errstr );
391      }
392    }
393    
394  1;  1;
395    __END__
Legend:
Removed from v.1.9  
changed lines
  Added in v.1.16
MailToCvsAdmin">MailToCvsAdmin
 ViewVC Help
Powered by ViewVC 1.1.26 RSS 2.0 feed