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

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

Parent Directory | Revision Log | View Patch Patch

-revision 1.10 by joko,
Sun Dec 15 02:02:22 2002 UTC
+revision 1.17 by joko,
Sat Jun 19 01:49:47 2004 UTC
 Line 3
  #  $Id$
  #
  #  $Log$
+ #  Revision 1.17  2004/06/19 01:49:47  joko
+ #  (re-)activated "getCOREHANDLE"
+ #
+ #  Revision 1.16  2003/04/11 01:17:18  joko
+ #  sendQuery:
+ #  + introduced crud action 'DELETE'
+ #  + some pre-flight checks
+ #
+ #  Revision 1.15  2003/04/09 07:53:33  joko
+ #  minor namespace update
+ #
+ #  Revision 1.14  2003/04/09 06:06:04  joko
+ #  sendQuery now is capable of doing 'SELECT'- or 'INSERT'-queries
+ #
+ #  Revision 1.13  2003/04/08 23:06:45  joko
+ #  renamed core database helper functions
+ #
+ #  Revision 1.12  2003/01/30 22:28:21  joko
+ #  + implemented new concrete methods
+ #
+ #  Revision 1.11  2002/12/19 16:31:05  joko
+ #  + sub dropDb
+ #  + sub rebuildDb
+ #
  #  Revision 1.10  2002/12/15 02:02:22  joko
  #  + fixed logging-message
  #
-Line 47 
 use warnings;
+Line 71 
 use warnings;
  use base ("Data::Storage::Handler::Abstract");
  use DBI;
  use Data::Dumper;
- use libdb qw( getDbNameByDsn hash2Sql );
+ use shortcuts::database qw( hash2sql dsn2dbname );
  use Data::Storage::Result::DBI;
  # get logger instance
  my $logger = Log::Dispatch::Config->instance;
-Line 126 
 sub _sendSql {
+Line 152 
 sub _sendSql {
    my $self = shift;
    my $sql = shift;
+   # pre-flight check: is $sql defined?
+   if (!$sql) {
+     $logger->warning( __PACKAGE__ . "->_sendSql: \$sql was empty." );
+     return;
+   }
    # two-level handling for implicit connect:
    # if there's no corehandle ...
    if (!$self->{_COREHANDLE}) {
-Line 161 
 sub getChildNodes {
+Line 193 
 sub getChildNodes {
    my $locator = $self->{locator};
    #print Dumper($locator); exit;
    if (my $result = $self->sendCommand( 'SHOW TABLES;' ) ) {
-     my $dbname = getDbNameByDsn($self->{locator}->{dbi}->{dsn});
+     my $dbname = dsn2dbname($self->{locator}->{dbi}->{dsn});
      my $key = "Tables_in_$dbname";
      while ( my $row = $result->getNextEntry() ) {
        push @nodes, $row->{$key};
-Line 189 
 sub sendQuery {
+Line 221 
 sub sendQuery {
    $logger->debug( __PACKAGE__ . "->sendQuery" );
+   my $crud = $query->{options}->{crud};
+   $crud ||= $query->{options}->{action};
+   $crud ||= 'RETRIEVE';
+   if (my $guid = $query->{options}->{GUID}) {
+     $query->{criterias} = [ { key => 'guid', op => 'eq', val => $guid } ];
+   }
+   # check criterias (load & save)
    #my $sql = "SELECT cs FROM $self->{metainfo}->{$descent}->{node} WHERE $self->{metainfo}->{$descent}->{IdentProvider}->{arg}='$self->{entry}->{source}->{ident}';";
    #my $result = $self->{metainfo}->{$descent}->{storage}->sendCommand($sql);
    my @crits;
-Line 197 
 sub sendQuery {
+Line 238 
 sub sendQuery {
      $op = '=' if lc $_->{op} eq 'eq';
      push @crits, "$_->{key}$op'$_->{val}'";
    }
-   my $subnodes = {};
-   map { $subnodes->{$_}++ } @{$query->{subnodes}};
    # HACK: this is hardcoded ;(    expand possibilities!
    my $crit = join(' AND ', @crits);
-   my $sql = hash2Sql($query->{node}, $subnodes, 'SELECT', $crit);
-   return $self->sendCommand($sql);
+   # check subnodes (load)
+   my $subnodes = {};
+   map { $subnodes->{$_}++ } @{$query->{subnodes}};
+   # check payload (save)
+   #print Dumper($query->{payload});
+   #$subnodes ||= $query->{payload};
+   # dispatch action
+   if ($crud eq 'RETRIEVE') {
+     my $sql = hash2sql($query->{node}, $subnodes, 'SELECT', $crit);
+     return $self->sendCommand($sql);
+   } elsif ($crud eq 'UPDATE') {
+     my $sql = hash2sql($query->{node}, $query->{payload}, 'UPDATE', $crit);
+     $self->sendCommand($sql);
+   } elsif ($crud eq 'DELETE') {
+     my $sql = hash2sql($query->{node}, $query->{payload}, 'DELETE', $crit);
+     $self->sendCommand($sql);
+   }
  }
  sub eraseAll {
-Line 257 
 sub createDb {
+Line 318 
 sub createDb {
  }
- sub getCOREHANDLE2 {
+ sub getCOREHANDLE {
    my $self = shift;
    return $self->{_COREHANDLE};
  }
+ sub dropDb {
+   my $self = shift;
+   my $dsn = $self->{locator}->{dbi}->{dsn};
+   $logger->debug( __PACKAGE__ .  "->dropDb( dsn $dsn )" );
+   $dsn =~ s/database=(.+?);//;
+   my $database_name = $1;
+   my $ok;
+   if ( my $dbh = DBI->connect($dsn, '', '', {
+                                                       PrintError => 0,
+                                                       } ) ) {
+     if ($database_name) {
+       if ($dbh->do("DROP DATABASE $database_name;")) {
+         $ok = 1;
+       }
+     }
+     $dbh->disconnect();
+   }
+   return $ok;
+ }
+ sub rebuildDb {
+   my $self = shift;
+   $logger->info( __PACKAGE__ . "->rebuildDb()" );
+   my @results;
+   # sum up results (bool (0/1)) in array
+   #push @results, $self->retreatSchema();
+   push @results, $self->dropDb();
+   push @results, $self->createDb();
+   #push @results, $self->deploySchema();
+   # scan array for "bad ones"
+   my $res = 1;
+   map {
+     $res = 0 if (!$_);
+   } @results;
+   return $res;
+ }
+ sub testAvailability {
+   my $self = shift;
+   my $status = $self->testDsn();
+   $self->{locator}->{status}->{available} = $status;
+   return $status;
+ }
+ sub testDsn {
+   my $self = shift;
+   my $dsn = $self->{locator}->{dbi}->{dsn};
+   my $result;
+   if ( my $dbh = DBI->connect($dsn, '', '', {
+                                                       PrintError => 0,
+                                                       } ) ) {
+     # TODO: REVIEW
+     $dbh->disconnect();
+     return 1;
+   } else {
+     $logger->warning( __PACKAGE__ .  "[$self->{locator}->{type}]" . "->testDsn(): " . "DBI-error: " . $DBI::errstr );
+   }
+ }
 ;
+ __END__

 Legend:



Removed from v.1.10
 


changed lines


 
Added in v.1.17
 Legend:



Removed from v.1.10
 


changed lines


 
Added in v.1.17
-Removed from v.1.10
+Added in v.1.17

MailToCvsAdmin">MailToCvsAdmin	ViewVC Help
Powered by ViewVC 1.1.26