| 3 |
# $Id$ |
# $Id$ |
| 4 |
# |
# |
| 5 |
# $Log$ |
# $Log$ |
| 6 |
|
# Revision 1.20 2002/12/16 20:49:17 jonen |
| 7 |
|
# + added sub 'getObjectByGuid()' |
| 8 |
|
# + added functionality to use 'getObjectByGuid' at 'getObjectAsHash()' |
| 9 |
|
# |
| 10 |
|
# Revision 1.19 2002/12/16 06:46:09 joko |
| 11 |
|
# + attempt to introduce a generic '_patchSchema' - cancelled! |
| 12 |
|
# |
| 13 |
|
# Revision 1.18 2002/12/13 21:48:07 joko |
| 14 |
|
# + fix to 'sub sendQuery' |
| 15 |
|
# |
| 16 |
|
# Revision 1.17 2002/12/12 02:51:09 joko |
| 17 |
|
# + cosmetics |
| 18 |
|
# |
| 19 |
|
# Revision 1.16 2002/12/11 06:54:10 joko |
| 20 |
|
# + fix: encapsulated object-loading inside an 'eval' |
| 21 |
|
# |
| 22 |
# Revision 1.15 2002/12/05 13:55:21 joko |
# Revision 1.15 2002/12/05 13:55:21 joko |
| 23 |
# + now utilizing 'object2hash' instead of 'var_deref' |
# + now utilizing 'object2hash' instead of 'var_deref' |
| 24 |
# + played around with having fresh-objects - no progress.... |
# + played around with having fresh-objects - no progress.... |
| 128 |
$logger->error( __PACKAGE__ . "->_initSchema: No Schema available for $self->{schema}" ); |
$logger->error( __PACKAGE__ . "->_initSchema: No Schema available for $self->{schema}" ); |
| 129 |
return 0; |
return 0; |
| 130 |
} |
} |
| 131 |
|
#$self->_patchSchema(); |
| 132 |
return 1; |
return 1; |
| 133 |
} |
} |
| 134 |
|
|
| 135 |
|
sub _patchSchema { |
| 136 |
|
my $self = shift; |
| 137 |
|
foreach (keys %{$schema_tangram->{classes}}) { |
| 138 |
|
next if $schema_tangram->{classes}->{$_}->{abstract}; |
| 139 |
|
#next if ($_ ne 'TsBankAccount'); |
| 140 |
|
#$_ ne 'AbstractAccount' && |
| 141 |
|
print "class: $_", "\n"; |
| 142 |
|
#print Dumper($schema_tangram->{classes}->{$_}); |
| 143 |
|
# create new string property named 'guid' |
| 144 |
|
my $tstring = Tangram::String->new(); |
| 145 |
|
$tstring->{name} = $tstring->{col} = 'guid'; |
| 146 |
|
# inject property into schema |
| 147 |
|
#$schema_tangram->{classes}->{$_}->{root}->{SPECS}->[0]->{fields}->{string}->{$tstring->{name}} = $tstring; |
| 148 |
|
print Dumper($schema_tangram->{classes}->{$_}->{root}->{SPECS}->[0]->{fields}); |
| 149 |
|
} |
| 150 |
|
} |
| 151 |
|
|
| 152 |
sub connect { |
sub connect { |
| 153 |
|
|
| 154 |
my $self = shift; |
my $self = shift; |
| 457 |
|
|
| 458 |
sub createSet { |
sub createSet { |
| 459 |
my $self = shift; |
my $self = shift; |
| 460 |
|
#print "-" x 80, "\n"; |
| 461 |
|
#print Dumper(@_); |
| 462 |
my @objects = @_; |
my @objects = @_; |
| 463 |
my $rh = Set::Object->new(); |
my $rh = Set::Object->new(); |
| 464 |
foreach (@objects) { |
foreach (@objects) { |
| 465 |
#print Dumper($_); |
if (!isEmpty($_)) { |
| 466 |
$rh->insert($_) if !isEmpty($_); |
#print Dumper($_); |
| 467 |
|
$rh->insert($_); |
| 468 |
|
} |
| 469 |
} |
} |
| 470 |
#print Dumper($rh->members()); |
#print Dumper($rh->members()); |
| 471 |
my $result = Data::Storage::Result::Tangram->new( RESULTHANDLE => $rh ); |
my $result = Data::Storage::Result::Tangram->new( RESULTHANDLE => $rh ); |
| 489 |
my $ident = $query->{criterias}->[0]->{val}; |
my $ident = $query->{criterias}->[0]->{val}; |
| 490 |
#print "load obj", "\n"; |
#print "load obj", "\n"; |
| 491 |
#return $self->createSet() if $ident == 5; |
#return $self->createSet() if $ident == 5; |
| 492 |
|
$self->{_COREHANDLE}->unload($ident); |
| 493 |
my $object = $self->{_COREHANDLE}->load($ident); |
my $object = $self->{_COREHANDLE}->load($ident); |
| 494 |
#print "get id", "\n"; |
#print "get id", "\n"; |
| 495 |
my $oid = $self->{_COREHANDLE}->id($object); |
my $oid = $self->{_COREHANDLE}->id($object); |
| 496 |
|
#print Dumper($object); |
| 497 |
|
#print "oid: $oid", "\n"; |
| 498 |
return $self->createSet($object); |
return $self->createSet($object); |
| 499 |
#return $self->createSet( $self->{COREHANDLE}->load('300090018') ); |
#return $self->createSet( $self->{COREHANDLE}->load('300090018') ); |
| 500 |
} |
} |
| 538 |
my $self = shift; |
my $self = shift; |
| 539 |
my $oid = shift; |
my $oid = shift; |
| 540 |
my $options = shift; |
my $options = shift; |
| 541 |
# TODO: create a deep_unload method |
|
| 542 |
|
# TODO: create a deep_unload method (currently _all_ objects are unloaded) |
| 543 |
# unload($oid) will only unload object, not deep object hashes |
# unload($oid) will only unload object, not deep object hashes |
| 544 |
$self->{_COREHANDLE}->unload() if($options->{destroy}); |
$self->{_COREHANDLE}->unload() if ($options->{destroy}); |
| 545 |
|
|
| 546 |
# TODO: review this |
# TODO: review this |
| 547 |
#if (!$self->{COREHANDLE}) { return; } |
#if (!$self->{COREHANDLE}) { return; } |
| 548 |
return $self->{_COREHANDLE}->load($oid); |
|
| 549 |
|
# TODO: review this |
| 550 |
|
my $object = eval('$self->{_COREHANDLE}->load($oid);'); |
| 551 |
|
print $@, "\n" if $@; |
| 552 |
|
|
| 553 |
|
return $object if $object; |
| 554 |
|
} |
| 555 |
|
|
| 556 |
|
sub getObjectByGuid { |
| 557 |
|
my $self = shift; |
| 558 |
|
my $guid = shift; |
| 559 |
|
my $options = shift; |
| 560 |
|
|
| 561 |
|
# Guid and Classname is needed |
| 562 |
|
if(!$guid || !$options->{classname}) { |
| 563 |
|
return; |
| 564 |
|
} |
| 565 |
|
|
| 566 |
|
# TODO: create a deep_unload method (currently _all_ objects are unloaded) |
| 567 |
|
# unload($oid) will only unload object, not deep object hashes |
| 568 |
|
$self->{_COREHANDLE}->unload() if ($options->{destroy}); |
| 569 |
|
|
| 570 |
|
# search for object with given Classname and Guid |
| 571 |
|
my $obj_tmp = $self->{_COREHANDLE}->remote($classname); |
| 572 |
|
my @result = $self->{_COREHANDLE}->select($obj_tmp, $obj_tmp->{guid} eq $guid); |
| 573 |
|
|
| 574 |
|
# we searched for global unique identifer of some object, |
| 575 |
|
# so it think we can trust there would be only one result |
| 576 |
|
if($result[0]) { |
| 577 |
|
return $result[0]; |
| 578 |
|
} else { |
| 579 |
|
return "No Object with Classname $classname and GUID $options->{guid} found!"; |
| 580 |
|
} |
| 581 |
|
|
| 582 |
} |
} |
| 583 |
|
|
| 584 |
sub getObjectAsHash { |
sub getObjectAsHash { |
| 585 |
my $self = shift; |
my $self = shift; |
| 586 |
my $oid = shift; |
my $oid = shift; |
| 587 |
my $options = shift; |
my $options = shift; |
| 588 |
my $obj = $self->getObject($oid, $options); |
my $obj; |
| 589 |
|
|
| 590 |
|
if($options->{guid}) { |
| 591 |
|
$obj = $self->getObjectByGuid($oid, $options); |
| 592 |
|
} else { |
| 593 |
|
$obj = $self->getObject($oid, $options); |
| 594 |
|
} |
| 595 |
|
|
| 596 |
# build options (a callback to unload autovivified objects) for 'expand' |
# build options (a callback to unload autovivified objects) for 'expand' |
| 597 |
# TODO: use $logger to write to debug here! |
# TODO: use $logger to write to debug here! |