--- nfo/perl/libs/Data/Transfer/Sync/StorageInterface.pm 2003/02/20 20:24:33 1.5 +++ nfo/perl/libs/Data/Transfer/Sync/StorageInterface.pm 2003/04/09 07:27:02 1.8 @@ -1,4 +1,4 @@ -## $Id: StorageInterface.pm,v 1.5 2003/02/20 20:24:33 joko Exp $ +## $Id: StorageInterface.pm,v 1.8 2003/04/09 07:27:02 joko Exp $ ## ## Copyright (c) 2002 Andreas Motl ## @@ -6,6 +6,15 @@ ## ## ---------------------------------------------------------------------------------------- ## $Log: StorageInterface.pm,v $ +## 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 +## ## Revision 1.5 2003/02/20 20:24:33 joko ## + additional pre-flight checks ## @@ -42,8 +51,8 @@ use Data::Dumper; use Hash::Merge qw( merge ); -use libdb qw( hash2Sql ); -use Data::Transform::Deep qw( hash2object ); +use shortcuts::db qw( hash2sql ); +use Data::Mungle::Transform::Deep qw( merge_to ); # get logger instance @@ -174,10 +183,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(); @@ -350,10 +355,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); @@ -471,7 +476,7 @@ # mix in (merge) values ... # TODO: use Hash::Merge here? benchmark! # no! we'd need a Object::Merge here! it's *...2object* - hash2object($object, $map); + merge_to($object, $map); # trace #print Dumper($object); @@ -495,25 +500,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??? - hash2object($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!