3 |
# $Id$ |
# $Id$ |
4 |
# |
# |
5 |
# $Log$ |
# $Log$ |
6 |
|
# Revision 1.26 2003/01/30 22:29:47 joko |
7 |
|
# + fixed module usage (removed dependency on 'libp.pm') |
8 |
|
# |
9 |
|
# Revision 1.25 2003/01/19 02:30:05 joko |
10 |
|
# + fix: modified call to '_initSchema' |
11 |
|
# |
12 |
|
# Revision 1.24 2002/12/22 14:13:01 joko |
13 |
|
# + sub dropDb |
14 |
|
# |
15 |
# Revision 1.23 2002/12/19 16:31:53 joko |
# Revision 1.23 2002/12/19 16:31:53 joko |
16 |
# +- renamed sub to 'rebuildDb' |
# +- renamed sub to 'rebuildDb' |
17 |
# |
# |
113 |
|
|
114 |
use Tangram; |
use Tangram; |
115 |
use Data::Dumper; |
use Data::Dumper; |
116 |
use libp qw( getNewPerlObjectByPkgName ); |
use DesignPattern::Object; |
117 |
use Data::Storage::Result::Tangram; |
use Data::Storage::Result::Tangram; |
118 |
use Data::Compare::Struct qw( isEmpty ); |
use Data::Compare::Struct qw( isEmpty ); |
119 |
use Data::Transform::Deep qw( object2hash ); |
use Data::Transform::Deep qw( object2hash ); |
120 |
use Data::Transform::Encode qw( var2utf8 ); |
use Data::Transform::Encode qw( var2utf8 ); |
121 |
|
|
|
|
|
122 |
# get logger instance |
# get logger instance |
123 |
my $logger = Log::Dispatch::Config->instance; |
my $logger = Log::Dispatch::Config->instance; |
124 |
|
|
138 |
my $self = shift; |
my $self = shift; |
139 |
$logger->debug( __PACKAGE__ . "->_initSchema()" ); |
$logger->debug( __PACKAGE__ . "->_initSchema()" ); |
140 |
#if (!$schema_tangram) { |
#if (!$schema_tangram) { |
141 |
my $obj = getNewPerlObjectByPkgName($self->{locator}->{schema}, { EXPORT_OBJECTS => $self->{locator}->{classnames}, want_transactions => $self->{locator}->{want_transactions} } ); |
#my $obj = getNewPerlObjectByPkgName($self->{locator}->{schema}, { EXPORT_OBJECTS => $self->{locator}->{classnames}, want_transactions => $self->{locator}->{want_transactions} } ); |
142 |
|
my $obj = DesignPattern::Object->fromPackage($self->{locator}->{schema}, { 'EXPORT_OBJECTS' => $self->{locator}->{classnames}, 'want_transactions' => $self->{locator}->{want_transactions} } ); |
143 |
$schema_tangram = $obj->getSchema(); |
$schema_tangram = $obj->getSchema(); |
144 |
#} |
#} |
145 |
if (!$schema_tangram) { |
if (!$schema_tangram) { |
172 |
my $self = shift; |
my $self = shift; |
173 |
|
|
174 |
my $dsn = shift; |
my $dsn = shift; |
175 |
|
|
176 |
|
#print Dumper($self); |
177 |
|
#exit; |
178 |
|
|
179 |
|
# TODO: re-enable |
180 |
$dsn ||= $self->{locator}->{dbi}->{dsn}; |
$dsn ||= $self->{locator}->{dbi}->{dsn}; |
|
|
|
181 |
$logger->debug( __PACKAGE__ . "->connect( dsn $dsn )" ); |
$logger->debug( __PACKAGE__ . "->connect( dsn $dsn )" ); |
182 |
|
|
183 |
#my $storage = Tangram::Relational->connect( $schema, $dsn ); |
#my $storage = Tangram::Relational->connect( $schema, $dsn ); |
189 |
# return; |
# return; |
190 |
# } |
# } |
191 |
|
|
192 |
return unless $self->_initSchema(); |
#return unless $self->_initSchema(); |
193 |
|
$self->_initSchema(); |
194 |
|
|
195 |
# create the main tangram storage object |
# create the main tangram storage object |
196 |
#$self->{COREHANDLE} = Tangram::Relational->connect( $schema, $dsn ); |
#$self->{COREHANDLE} = Tangram::Relational->connect( $schema, $dsn ); |
317 |
$logger->debug( __PACKAGE__ . "->configureCOREHANDLE" ); |
$logger->debug( __PACKAGE__ . "->configureCOREHANDLE" ); |
318 |
|
|
319 |
#my $subLayer = $self->_getSubLayerHandle(); |
#my $subLayer = $self->_getSubLayerHandle(); |
320 |
|
#print Dumper($self); |
321 |
|
#exit; |
322 |
|
|
323 |
# apply configured modifications |
# apply configured modifications |
324 |
if (exists $self->{dbi}->{trace_level} && exists $self->{dbi}->{trace_file}) { |
if (exists $self->{dbi}->{trace_level} && exists $self->{dbi}->{trace_file}) { |
661 |
return $self->{_COREHANDLE}; |
return $self->{_COREHANDLE}; |
662 |
} |
} |
663 |
|
|
664 |
|
sub dropDb { |
665 |
|
my $self = shift; |
666 |
|
my $storage = $self->_getSubLayerHandle(); |
667 |
|
return $storage->dropDb(); |
668 |
|
} |
669 |
|
|
670 |
|
sub testAvailability { |
671 |
|
my $self = shift; |
672 |
|
my $storage = $self->_getSubLayerHandle(); |
673 |
|
return $storage->testAvailability(); |
674 |
|
} |
675 |
|
|
676 |
1; |
1; |
677 |
|
__END__ |