--- nfo/perl/libs/Data/Transfer/Sync/StorageInterface.pm 2003/02/21 01:47:53 1.6 +++ nfo/perl/libs/Data/Transfer/Sync/StorageInterface.pm 2003/04/09 07:53:34 1.9 @@ -1,4 +1,4 @@ -## $Id: StorageInterface.pm,v 1.6 2003/02/21 01:47:53 joko Exp $ +## $Id: StorageInterface.pm,v 1.9 2003/04/09 07:53:34 joko Exp $ ## ## Copyright (c) 2002 Andreas Motl ## @@ -6,6 +6,15 @@ ## ## ---------------------------------------------------------------------------------------- ## $Log: StorageInterface.pm,v $ +## Revision 1.9 2003/04/09 07:53:34 joko +## minor namespace update +## +## Revision 1.8 2003/04/09 07:27:02 joko +## minor update (just cosmetics) +## +## Revision 1.7 2003/03/27 15:31:16 joko +## fixes to modules regarding new namespace(s) below Data::Mungle::* +## ## Revision 1.6 2003/02/21 01:47:53 joko ## renamed core function ## @@ -45,8 +54,8 @@ use Data::Dumper; use Hash::Merge qw( merge ); -use libdb qw( hash2Sql ); -use Data::Transform::Deep qw( merge_to ); +use shortcuts::database qw( hash2sql ); +use Data::Mungle::Transform::Deep qw( merge_to ); # get logger instance @@ -177,10 +186,6 @@ ] }; - # trace - #print "query:", "\n"; - #print Dumper($query); - # send query and fetch first entry from result my $result = $self->{meta}->{$descent}->{storage}->sendQuery($query); my $entry = $result->getNextEntry(); @@ -353,10 +358,10 @@ # TODO: wrap this around '$storageHandle->sendQuery(...)'!? my $sql_main; if (lc($action) eq 'insert') { - $sql_main = hash2Sql($self->{meta}->{$descent}->{accessorName}, $map, 'SQL_INSERT'); + $sql_main = hash2sql($self->{meta}->{$descent}->{accessorName}, $map, 'SQL_INSERT'); } elsif (lc $action eq 'update') { $crit ||= "$self->{meta}->{$descent}->{IdentProvider}->{arg}='$self->{node}->{$descent}->{ident}'"; - $sql_main = hash2Sql($self->{meta}->{$descent}->{accessorName}, $map, 'SQL_UPDATE', $crit); + $sql_main = hash2sql($self->{meta}->{$descent}->{accessorName}, $map, 'SQL_UPDATE', $crit); } my $sqlHandle = $self->{meta}->{$descent}->{storage}->sendCommand($sql_main); @@ -498,25 +503,20 @@ } elsif (lc $action eq 'update') { - # get fresh object from orm first + # Get fresh object from orm first. + # TODO: Review, is a 'sendQuery' required in this place? + # By now: NO! It's more expensive and we can just expect existing objects for update operations. + # If it doesn't exist either, we assume the engine will fail on issuing the 'update' operation later... $object = $self->{meta}->{$descent}->{storage}->load($self->{node}->{$descent}->{ident}); -#print Dumper($self->{node}); - # mix in values - #print Dumper($object); - # TODO: use Hash::Merge here??? - merge_to($object, $map); - #print Dumper($object); - #exit; + merge_to($object, $map); # update orm - $self->{meta}->{$descent}->{storage}->update($object); + $self->{meta}->{$descent}->{storage}->update($object); } -#exit; - my $error = 0; # handle new style callbacks - this is a HACK - do this without an eval!