| 3 |
# $Id$ |
# $Id$ |
| 4 |
# |
# |
| 5 |
# $Log$ |
# $Log$ |
| 6 |
|
# Revision 1.31 2003/04/05 21:24:09 joko |
| 7 |
|
# modified 'sub getChildNodes': now contains code from 'querySchema' |
| 8 |
|
# |
| 9 |
|
# Revision 1.30 2003/03/27 15:31:14 joko |
| 10 |
|
# fixes to modules regarding new namespace(s) below Data::Mungle::* |
| 11 |
|
# |
| 12 |
|
# Revision 1.29 2003/02/21 01:47:18 joko |
| 13 |
|
# purged old code |
| 14 |
|
# minor cosmetics |
| 15 |
|
# |
| 16 |
|
# Revision 1.28 2003/02/20 20:20:26 joko |
| 17 |
|
# tried to get auto-disconnect working again - failed with that |
| 18 |
|
# |
| 19 |
# Revision 1.27 2003/01/31 06:30:59 joko |
# Revision 1.27 2003/01/31 06:30:59 joko |
| 20 |
# + enabled 'sendQuery' |
# + enabled 'sendQuery' |
| 21 |
# |
# |
| 54 |
# + fix: encapsulated object-loading inside an 'eval' |
# + fix: encapsulated object-loading inside an 'eval' |
| 55 |
# |
# |
| 56 |
# Revision 1.15 2002/12/05 13:55:21 joko |
# Revision 1.15 2002/12/05 13:55:21 joko |
| 57 |
# + now utilizing 'object2hash' instead of 'var_deref' |
# + now utilizing 'expand' instead of 'var_deref' |
| 58 |
# + played around with having fresh-objects - no progress.... |
# + played around with having fresh-objects - no progress.... |
| 59 |
# |
# |
| 60 |
# Revision 1.14 2002/12/05 09:40:30 jonen |
# Revision 1.14 2002/12/05 09:40:30 jonen |
| 127 |
use base ("Data::Storage::Handler"); |
use base ("Data::Storage::Handler"); |
| 128 |
use base ("Data::Storage::Handler::Abstract"); |
use base ("Data::Storage::Handler::Abstract"); |
| 129 |
|
|
| 130 |
use Tangram; |
|
| 131 |
use Data::Dumper; |
use Data::Dumper; |
| 132 |
|
use Tangram; |
| 133 |
|
|
| 134 |
use DesignPattern::Object; |
use DesignPattern::Object; |
| 135 |
use Data::Storage::Result::Tangram; |
use Data::Storage::Result::Tangram; |
| 136 |
use Data::Compare::Struct qw( isEmpty ); |
use Data::Mungle::Compare::Struct qw( isEmpty ); |
| 137 |
use Data::Transform::Deep qw( object2hash ); |
use Data::Mungle::Transform::Deep qw( expand ); |
|
use Data::Transform::Encode qw( var2utf8 ); |
|
| 138 |
|
|
| 139 |
# get logger instance |
# get logger instance |
| 140 |
my $logger = Log::Dispatch::Config->instance; |
my $logger = Log::Dispatch::Config->instance; |
| 234 |
sub getChildNodes { |
sub getChildNodes { |
| 235 |
|
|
| 236 |
my $self = shift; |
my $self = shift; |
| 237 |
my @nodes; |
my $mode = shift; |
| 238 |
|
$mode ||= 'core'; |
| 239 |
|
|
| 240 |
|
$logger->debug( __PACKAGE__ . "->getChildNodes($mode)" ); |
| 241 |
|
|
| 242 |
$logger->debug( __PACKAGE__ . "->getChildNodes()" ); |
if ($mode eq 'core') { |
| 243 |
|
|
| 244 |
# create new DBI - Data::Storage - object from already connected DBI::db - handle inside the current COREHANDLE |
my @nodes; |
| 245 |
#my $loc = new Data::Storage::Locator( type => "DBI", dbi => { db => $self->{COREHANDLE}->{db} }); |
|
| 246 |
#my $loc = new Data::Storage::Locator( type => "DBI", COREHANDLE => $self->{COREHANDLE}->{db} ); |
# create new DBI - Data::Storage - object from already connected DBI::db - handle inside the current COREHANDLE |
| 247 |
|
#my $loc = new Data::Storage::Locator( type => "DBI", dbi => { db => $self->{COREHANDLE}->{db} }); |
| 248 |
|
#my $loc = new Data::Storage::Locator( type => "DBI", COREHANDLE => $self->{COREHANDLE}->{db} ); |
| 249 |
|
|
| 250 |
|
# todo: should we retrieve information from the schema here |
| 251 |
|
# rather than poorly getting table names from underlying dbi? |
| 252 |
|
my $storage = $self->_getSubLayerHandle(); |
| 253 |
|
@nodes = @{$storage->getChildNodes()}; |
| 254 |
|
#$storage->_configureCOREHANDLE(); |
| 255 |
|
#print "getchildnodes\n"; |
| 256 |
|
#print Dumper($self); |
| 257 |
|
#if (my $result = $self->sendCommand( 'SHOW TABLES;' ) ) { |
| 258 |
|
|
| 259 |
|
# TODO: REVIEW |
| 260 |
|
#$storage->disconnect(); |
| 261 |
|
|
| 262 |
|
$self->{meta}->{childnodes} = \@nodes; |
| 263 |
|
|
| 264 |
|
return \@nodes; |
| 265 |
|
|
| 266 |
# todo: should we retrieve information from the schema here |
} elsif ($mode eq 'root') { |
| 267 |
# rather than poorly getting table names from underlying dbi? |
|
| 268 |
my $storage = $self->_getSubLayerHandle(); |
# FIXME: this will return *all* known classes to 'Class::Tangram', |
| 269 |
@nodes = @{$storage->getChildNodes()}; |
# which might not be what you expect since more than one instance |
| 270 |
#$storage->_configureCOREHANDLE(); |
# of Tangram may be in memory and Class::Tangram seems to |
| 271 |
#print "getchildnodes\n"; |
# offer no methods to determine this or filter its result(s) according |
| 272 |
#print Dumper($self); |
# to a specific database. |
| 273 |
#if (my $result = $self->sendCommand( 'SHOW TABLES;' ) ) { |
my @object_names = Class::Tangram::known_classes(); |
| 274 |
|
my @concret_names; |
| 275 |
|
my $o_cnt; |
| 276 |
|
foreach (sort @object_names) { |
| 277 |
|
push @concret_names, $_ if (!Class::Tangram::class_is_abstract($_)); |
| 278 |
|
$o_cnt++; |
| 279 |
|
} |
| 280 |
|
|
| 281 |
# TODO: REVIEW |
my $result = { |
| 282 |
#$storage->disconnect(); |
all => \@object_names, |
| 283 |
|
concrete => \@concret_names, |
| 284 |
|
}; |
| 285 |
|
return $result; |
| 286 |
|
|
| 287 |
$self->{meta}->{childnodes} = \@nodes; |
} |
| 288 |
|
|
|
return \@nodes; |
|
| 289 |
|
|
| 290 |
} |
} |
| 291 |
|
|
|
|
|
| 292 |
sub testIntegrity { |
sub testIntegrity { |
| 293 |
|
|
| 294 |
my $self = shift; |
my $self = shift; |
| 678 |
# build options (a callback to unload autovivified objects) for 'expand' |
# build options (a callback to unload autovivified objects) for 'expand' |
| 679 |
# TODO: use $logger to write to debug here! |
# TODO: use $logger to write to debug here! |
| 680 |
my $cb; # = sub {}; |
my $cb; # = sub {}; |
| 681 |
|
|
| 682 |
|
# deactivated way to get rid of used instances, if requested |
| 683 |
=pod |
=pod |
| 684 |
if ($options->{destroy}) { |
if ($options->{destroy}) { |
| 685 |
$options->{cb}->{destroy} = sub { |
$options->{cb}->{destroy} = sub { |
| 686 |
print "================ DESTROY", "\n"; |
print "================ DESTROY", "\n"; |
| 687 |
my $object = shift; |
my $object = shift; |
| 688 |
#print Dumper($object); |
#print Dumper($object); |
| 689 |
$self->{_COREHANDLE}->unload($object); |
$self->{_COREHANDLE}->unload($object); |
| 690 |
#undef($object); |
#undef($object); |
| 691 |
}; |
}; |
| 692 |
} |
} |
| 693 |
=cut |
=cut |
| 694 |
|
|
| 695 |
my $hash = object2hash($obj, $options); |
my $hash = expand($obj, $options); |
| 696 |
#$options->{cb}->{destroy}->($obj); |
|
| 697 |
#$self->{_COREHANDLE}->unload($obj); |
# old (unsuccessful) attempts to get rid of used instances, if requested |
| 698 |
|
|
| 699 |
# convert values in hash to utf8 to be ready for (e.g.) encapsulation in XML |
# V1: |
| 700 |
# now done in object2hash |
#$options->{cb}->{destroy}->($obj); |
| 701 |
#var2utf8($hash) if ($options->{utf8}); |
#$self->{_COREHANDLE}->unload($obj); |
| 702 |
|
|
| 703 |
# old (wrong) attempts to get rid of used instances, if requested |
# V2: |
| 704 |
#$obj->clear_refs; |
#$obj->clear_refs; |
| 705 |
#$self->{COREHANDLE}->unload($obj) if($options->{destroy}); |
#$self->{COREHANDLE}->unload($obj) if($options->{destroy}); |
| 706 |
#$obj->DESTROY; |
#$obj->DESTROY; |
| 730 |
return $storage->testAvailability(); |
return $storage->testAvailability(); |
| 731 |
} |
} |
| 732 |
|
|
| 733 |
|
sub disconnect2 { |
| 734 |
|
my $self = shift; |
| 735 |
|
my $storage = $self->_getSubLayerHandle(); |
| 736 |
|
print "DISC!", "\n"; |
| 737 |
|
|
| 738 |
|
my $storage_ll = $storage->{_COREHANDLE}; |
| 739 |
|
$storage_ll->disconnect(); |
| 740 |
|
|
| 741 |
|
print Dumper($storage); |
| 742 |
|
exit; |
| 743 |
|
|
| 744 |
|
#$self->{_COREHANDLE} |
| 745 |
|
#$storage->disconnect(); |
| 746 |
|
$self->{dataStorageLayer}->disconnect(); |
| 747 |
|
} |
| 748 |
|
|
| 749 |
1; |
1; |
| 750 |
__END__ |
__END__ |