#############################################################################
## Name: Object.pm
## Purpose: HDB::Object - Base class for persistent Class::HPLOO objects.
## Author: Graciliano M. P.
## Modified by:
## Created: 21/09/2004
## RCS-ID:
## Copyright: (c) 2004 Graciliano M. P.
## Licence: This program is free software; you can redistribute it and/or
## modify it under the same terms as Perl itself
#############################################################################
use Class::HPLOO qw(alloo base) ;
class HDB::Object[0.02] {
use HDB ;
*WITH_HPL = \&HDB::WITH_HPL ;
*HPL_MAIN = \&HDB::HPL_MAIN ;
my ( %NEW_IDS , %OBJ_TABLE , %OBJ_TABLE_LOADER , $DID_REQUIRED ) ;
use overload (
'bool' => '_OVER_bool' ,
'""' => '_OVER_string' ,
'fallback' => 1 ,
) ;
sub _OVER_bool { 1 ;}
sub _OVER_string {
my $class = $this->__CLASS__ ;
my $id = $this->__ID__ ;
if ( !$id ) {
$this->hdb_save ;
$id = $this->__ID__ ;
}
my $ident = "hdbobj__$class\__$id" ;
$ident =~ s/::/_/gs ;
return $ident ;
}
sub do_require {
return if $DID_REQUIRED ;
$DID_REQUIRED = 1 ;
my $hpl = &HPL_MAIN() ;
if ( $hpl ) {
$hpl->use_cached('Hash::NoRef') ;
}
else {
eval(" use Hash::NoRef ") ;
}
tie( %OBJ_TABLE , 'Hash::NoRef' ) ;
}
sub RESET {
%OBJ_TABLE_LOADER = () ;
%OBJ_TABLE = () ;
%NEW_IDS = () ;
return 1 ;
}
sub load {
$CLASS = $this ? ref $this : shift(@_) ;
my @where ;
foreach my $i ( @_ ) {
if ( $i =~ /^\d+$/s ) { push(@where , "id == $i") ;}
else { push(@where , $i) ;}
}
return if !$CLASS->hdb_table_exists() ;
my $hdb_obj = $CLASS->hdb ;
my @sel = $hdb_obj->select( $CLASS , (@where ? ['?',@where] : ()) , (!wantarray ? (limit => '1') : () ) , '@%' ) ;
return if !@sel ;
do_require() ;
my @obj ;
foreach my $sel_i ( @sel ) {
next if !$sel_i ;
push(@obj , _build_obj($CLASS , $sel_i , $hdb_obj) ) ;
next ;
if ( $OBJ_TABLE{"$CLASS/$$sel_i{id}"} ) {
delete $OBJ_TABLE_LOADER{"$CLASS/$$sel_i{id}"} ;
push(@obj , $OBJ_TABLE{"$CLASS/$$sel_i{id}"} ) ;
}
else {
my $loader ;
if ( $OBJ_TABLE_LOADER{"$CLASS/$$sel_i{id}"} ) {
$loader = $OBJ_TABLE_LOADER{"$CLASS/$$sel_i{id}"} ;
}
else {
$loader = HDB::Object::Loader::create_loader($CLASS , $sel_i , $hdb_obj) ;
$OBJ_TABLE_LOADER{"$CLASS/$$sel_i{id}"} = $loader ;
}
push(@obj , $loader) ;
}
}
return if !@obj ;
return @obj if wantarray ;
return $obj[0] ;
}
sub select {
my ( @list , $attr , $id ) ;
if ( $#_ == 0 ) { ( $attr ) = @_ ;}
elsif ( $#_ == 1 ) { ( $attr , $id ) = @_ ;}
elsif ( $#_ > 1 ) { ( $id , @list ) = @_ ;}
my $ret ;
if ( @list ) {
foreach my $list_i ( @list ) {
if ( (UNIVERSAL::isa($list_i , 'HDB::Object') && $list_i->{__ID__} == $id) || (ref($list_i) eq 'HDB::Object::Loader' && $list_i->__ID__ == $id) ) {
$ret = $list_i ;
last ;
}
}
}
else {
if ( ref( $this->{$attr} ) eq 'ARRAY' ) {
foreach my $list_i ( @{ $this->{$attr} } ) {
if ( (UNIVERSAL::isa($list_i , 'HDB::Object') && $list_i->{__ID__} == $id) || (ref($list_i) eq 'HDB::Object::Loader' && $list_i->__ID__ == $id) ) {
$ret = $list_i ;
last ;
}
}
}
elsif ( (UNIVERSAL::isa($this->{$attr} , 'HDB::Object') && $this->{$attr}->{__ID__} == $id) || (ref($this->{$attr}) eq 'HDB::Object::Loader' && $this->{$attr}->__ID__ == $id) ) {
$ret = $this->{$attr} ;
}
}
return $ret ;
}
sub _build_obj ($CLASS , $sel , $hdb_obj) {
my $obj_ident = "$CLASS/$$sel{id}" ;
##print "BUILD OBJ>> $CLASS , $sel , $hdb_obj [$OBJ_TABLE{$obj_ident}]\n" ;
return $OBJ_TABLE{$obj_ident} if $OBJ_TABLE{$obj_ident} ;
my $this = bless({} , $CLASS) ;
$hdb_obj ||= $CLASS->hdb ;
&{"$CLASS\::CLASS_HPLOO_TIE_KEYS"}($this) ;
foreach my $Key ( keys %$sel ) {
if ( $Key =~ /^hdbobj__(\w*?)__(\w+)/ ) {
my ( $class_obj , $attr , $id ) = ($1,$2 , $$sel{$Key}) ;
$this->{CLASS_HPLOO_ATTR}{$attr} = $this->_build_ref_obj($class_obj,$id) ;
}
elsif ( $Key =~ /^hdbstore__(\w*?)__(\w+)/ ) {
my ( $class_obj , $attr , $freeze ) = ($1,$2 , $$sel{$Key}) ;
eval('use Storable qw()') ;
if ( !$@ ) {
eval {
my $thaw = Storable::thaw($freeze) ;
$this->{CLASS_HPLOO_ATTR}{$attr} = ref($thaw) eq 'ARRAY' ? $$thaw[0] : undef ;
};
}
}
elsif ( exists $this->{CLASS_HPLOO_ATTR}{$Key} ) { $this->{CLASS_HPLOO_ATTR}{$Key} = $$sel{$Key} ;}
}
$this->{__ID__} = $$sel{id} ;
$this->{__HDB_OBJ__} = $hdb_obj ;
my @ref_tables = $this->hdb_ref_tables ;
foreach my $ref_tables_i ( @ref_tables ) {
my ($class_main , $class_obj , $attr) = ( $ref_tables_i =~ /^hdbref__(\w*?)__(\w*?)__(\w+)/ );
$class_obj .= '_' if $class_main eq $class_obj ;
my @sel = $this->hdb->select( $ref_tables_i , "$class_main == $this->{__ID__}" , cols => "$class_obj" , '@$') ;
$this->{CLASS_HPLOO_ATTR}{$attr} = [] ;
foreach my $sel_i ( @sel ) {
push( @{ $this->{CLASS_HPLOO_ATTR}{$attr} } , $this->_build_ref_obj($class_obj,$sel_i) ) ;
}
}
foreach my $Key ( keys %OBJ_TABLE ) {
delete $OBJ_TABLE{$Key} if !defined $OBJ_TABLE{$Key} ;
}
delete $OBJ_TABLE_LOADER{$obj_ident} ;
$OBJ_TABLE{$obj_ident} = $this ;
return $this ;
}
sub hdb_refresh {
return if !$this || !$this->{__ID__} ;
my $hdb_obj = $this->hdb ;
return if !$hdb_obj ;
my $sel = $hdb_obj->select( $this->__CLASS__ , "id == $this->{__ID__}" , '$%' ) ;
print "REF>> $sel\n" ;
}
sub _build_ref_obj ($class_obj , $id){
$class_obj =~ s/_$// ;
$class_obj =~ s/_/::/gs ;
if ( UNIVERSAL::isa($class_obj,'HDB::Object') ) {
return $class_obj->load($id) ;
}
return ;
}
sub __ID__ {
return $this->{__ID__} ;
}
sub hdb_obj_changed {
return 1 if ( exists $this->{CLASS_HPLOO_CHANGED} && $this->{CLASS_HPLOO_CHANGED} && ref $this->{CLASS_HPLOO_CHANGED} eq 'HASH' && %{ $this->{CLASS_HPLOO_CHANGED} }) ;
return ;
}
sub hdb {
my $dbobj = UNIVERSAL::isa($this , 'HASH') ? $this->{__HDB_OBJ__} : undef ;
if ( !$dbobj ) { $dbobj = HDB->HPLOO ;}
if ( !$dbobj && WITH_HPL() ) {
my $hpl = HPL_MAIN() ;
if ( defined $hpl->env->{DOCUMENT_ROOT} ) {
my $db_dir = $hpl->env->{DOCUMENT_ROOT} . '/db' ;
my $db_file = "$db_dir/hploo.db" ;
$dbobj = HDB->new(
type => 'sqlite' ,
db => $db_file ,
) if -d $db_dir && -w $db_dir && (!-e $db_file || -w $db_file) ;
}
}
if ( !$dbobj ) {
warn("Can't find the predefined HPLOO database connection!") ;
return ;
}
if ( UNIVERSAL::isa($this , 'HASH') && !$this->{__HDB_OBJ__} ) {
$this->{__HDB_OBJ__} = $dbobj ;
}
return $dbobj ;
}
sub hdb_table_exists {
$CLASS = $this ? ref $this : shift(@_) ;
my $CLASS_HPLOO_HASH = $CLASS->GET_CLASS_HPLOO_HASH ;
return 1 if ( (time - $CLASS_HPLOO_HASH->{HDB_TABLE_CHK}) < 2 ) ;
my %table_hash = $this ? $this->hdb->tables_hash : $CLASS->hdb->tables_hash ;
my $table = $this ? $this->__CLASS__ : $CLASS ;
$table = HDB::CMDS::_format_table_name($table) ;
if ( $table_hash{$table} ) {
$CLASS_HPLOO_HASH->{HDB_TABLE_CHK} = time ;
return 1 ;
}
$CLASS_HPLOO_HASH->{HDB_TABLE_CHK} = undef ;
return ;
}
sub hdb_create_table {
my $class_hploo = $this->GET_CLASS_HPLOO_HASH ;
my $CLASS = $this->__CLASS__ ;
if ( $CLASS !~ /^\w+(?:::\w+)*$/ ) {
warn("Can't use class name '$CLASS' as a table name!!!\n") ;
}
$CLASS =~ s/:+/_/gs ;
my @cols ;
foreach my $order_i ( @{$class_hploo->{ATTR_ORDER}} ) {
my $tp = $class_hploo->{ATTR}{$order_i}{tp} ;
my ( $col_name , $tp , $table_ref , @cols_ref ) = $this->_hdb_attr_type($order_i , $tp) ;
if ( $table_ref ) {
$this->hdb->create( $table_ref , @cols_ref ) ;
#print $this->hdb->sql . "\n" ;
}
else {
push(@cols , $col_name , $this->_hdb_col_type_hploo_2_hdb($tp) ) ;
}
}
warn("Can't store in the DB class $CLASS since the class doesn't have attributes!") if !@cols ;
$this->hdb->create( $CLASS , @cols ) ;
#print $this->hdb->sql . "\n" ;
}
sub hdb_ref_tables {
my $CLASS = $this ? $this->__CLASS__ : shift(@_) ;
my @tables = $this ? $this->hdb->tables : $CLASS->hdb->tables ;
$CLASS =~ s/:+/_/gs ;
my @ref ;
foreach my $tables_i ( @tables ) {
push(@ref , $tables_i) if $tables_i =~ /hdbref__$CLASS\__/ ;
}
return @ref ;
}
sub hdb_ref_to_me_tables {
my $CLASS = $this ? $this->__CLASS__ : shift(@_) ;
my @tables = $this ? $this->hdb->tables : $CLASS->hdb->tables ;
$CLASS =~ s/:+/_/gs ;
my @ref ;
foreach my $tables_i ( @tables ) {
push(@ref , $tables_i) if $tables_i =~ /hdbref__(\w+?)__$CLASS\__/ ;
}
return @ref ;
}
sub hdb_referenced_ids {
my $CLASS = $this ? $this->__CLASS__ : shift(@_) ;
my $this_or_class = $this || $CLASS ;
my $hdb_obj = shift(@_) || $this_or_class->hdb ;
my $class_obj = $CLASS ;
$class_obj =~ s/:+/_/gs ;
my $can_have_ref ;
my @ref_tables = $this_or_class->hdb_ref_to_me_tables ;
$can_have_ref = 1 if @ref_tables ;
my %ids_ok ;
foreach my $ref_tables_i ( @ref_tables ) {
my @sel = $hdb_obj->select( $ref_tables_i , cols => "$class_obj" , '@$') ;
@ids_ok{@sel} = (1) x @sel ;
}
foreach my $tables_i ( $hdb_obj->tables ) {
foreach my $cols_i ( $hdb_obj->names($class_obj) ) {
if ( $cols_i =~ /^hdbobj__$class_obj\__/ ) {
my @sel = $hdb_obj->select( $tables_i , cols => $cols_i , '@$') ;
@ids_ok{@sel} = (1) x @sel ;
$can_have_ref = 1 ;
}
}
}
return \%ids_ok if $can_have_ref ;
return ;
}
sub hdb_clean_unref {
my $CLASS = $this ? $this->__CLASS__ : shift(@_) ;
my $this_or_class = $this || $CLASS ;
my $hdb_obj = shift(@_) || $this_or_class->hdb ;
my $class_obj = $CLASS ;
$class_obj =~ s/:+/_/gs ;
my $ids_ok = $this_or_class->hdb_referenced_ids($hdb_obj) ;
$hdb_obj->delete( $class_obj , ["id != ?", ['AND'] , keys %$ids_ok]) if $ids_ok ;
}
sub _hdb_attr_type ( $attr , $tp ) {
my $CLASS = $this->__CLASS__ ;
$CLASS =~ s/:+/_/gs ;
my ( $tp1 ,$tp2 ) ;
if ( $tp =~ /(?:ref\s*)?(array\s*|hash\s*)?(&\w+|\w+(?:::\w+)*)/ ) { ( $tp1 ,$tp2 ) = ($1,$2) ;}
else { $tp2 = $tp ;}
my $is_hdbobj = UNIVERSAL::isa($tp2 , 'HDB::Object') ;
$tp2 =~ s/:+/_/gs ;
$tp = $tp2 ;
my $is_obj = ($tp =~ /^(?:boolean|integer|floating|string|sub_\w+|any|&\w+)$/ ) ? 0 : 1 ;
my $col_name ;
if ( !$is_hdbobj && $is_obj ) {
return( "hdbstore__$tp2\__$attr" , '*' ) ;
}
elsif ( $is_obj ) {
$col_name = "hdbobj__$tp2\__$attr" ;
$tp = 'integer' ;
}
else { $col_name = $attr ;}
my ($table_ref , @cols_ref) ;
if ( $tp1 eq 'array' ) {
$table_ref = "hdbref__$CLASS\__$tp2\__$attr" ;
$tp2 .= '_' if $CLASS eq $tp2 ;
@cols_ref = (
$CLASS => 'integer' ,
$tp2 => 'integer' ,
) ;
}
return( $col_name , $tp , $table_ref , @cols_ref ) ;
}
sub _hdb_col_type_hploo_2_hdb ( $hploo_type ) {
if ( $hploo_type =~ /(?:any|string)/i ) { return '*' ;}
elsif ( $hploo_type =~ /bool/i ) { return 'boolean' ;}
elsif ( $hploo_type =~ /int/i ) { return 'int' ;}
elsif ( $hploo_type =~ /float/i ) { return 'float' ;}
else { return '*' ;}
}
sub hdb_max_id {
my $max_id = $this->hdb->select( $this->__CLASS__ , cols => '>id' , '$' ) ;
return $max_id ;
}
sub hdb_delete {
return if !$this->hdb_table_exists ;
my $id = $this->{__ID__} ;
return if ( $id eq '' || !$this->hdb->select( $this->__CLASS__ , "id == $id" , cols => 'id' , '$' ) ) ;
$this->hdb->delete( $this->__CLASS__ , "id == $id" ) ;
%$this = () ;
return 1 ;
}
sub hdb_new_id {
my $id = $this->hdb_max_id + 1 ;
my $class = $this->__CLASS__ ;
while( $NEW_IDS{$class}{$id} ) { ++$id ;}
$NEW_IDS{$class}{$id} = 1 ;
return $id ;
}
sub hdb_save (%args) {
$this->hdb_create_table if !$this->hdb_table_exists ;
return if !$args{save_all} && !$this->hdb_obj_changed ;
my $class_hploo = $this->GET_CLASS_HPLOO_HASH ;
my $class_hploo_changed = $this->{CLASS_HPLOO_CHANGED} ;
$this->{CLASS_HPLOO_CHANGED} = undef ;
my $id = $this->{__ID__} ;
my $insert ;
if ( $id eq '' || ($id && !$this->hdb->select( $this->__CLASS__ , "id == $id" , cols => 'id' , '$' )) ) {
$id = $this->hdb_new_id ;
$insert = 1 ;
}
my @del_attr_keys ;
my $saved_classes = $args{saved_classes} || {} ;
foreach my $order_i ( @{$class_hploo->{ATTR_ORDER}} ) {
my $tp = $class_hploo->{ATTR}{$order_i}{tp} ;
my ( $col_name , $tp , $table_ref , @cols_ref ) = $this->_hdb_attr_type($order_i , $tp) ;
##print ">> $col_name , $tp , $table_ref , @cols_ref \n" ;
if ( $table_ref ) {
if ( ref $this->{$order_i} eq 'ARRAY' ) {
my (@ids , %ids , $c) ;
foreach my $attr_i ( @{$this->{$order_i}} ) {
if ( ref($attr_i) eq 'HDB::Object::Loader' ) {
my $id = $attr_i->[1]{id} ;
push(@ids , $id) ;
$ids{$id} = ++$c ;
}
elsif ( UNIVERSAL::isa($attr_i , 'HDB::Object') ) {
$attr_i->hdb_save( no_auto_clean_unref => 1 , saved_classes => $saved_classes ) ;
$$saved_classes{ $attr_i->__CLASS__ } = 1 ;
push(@ids , $attr_i->{__ID__}) ;
$ids{$attr_i->{__ID__}} = ++$c ;
}
}
my @sel = $this->hdb->select( $table_ref , "$cols_ref[0] == $id" , cols => "$cols_ref[2],id" , '@@') ;
my (@del_ids , %sel_ids , %sel_pos ) ;
#print "IDS[$this]>> @ids\n" ;
$c = 0 ;
foreach my $sel_i ( @sel ) {
$sel_ids{$$sel_i[0]} = ++$c ;
$sel_pos{$c} = $$sel_i[1] ;
push(@del_ids , $$sel_i[1]) if $ids{$$sel_i[0]} != $c ;
#print "SEL>> $$sel_i[0] , $$sel_i[1] [$c] >> $ids{$$sel_i[0]}\n" ;
}
my @dels = @del_ids[($#ids+1)..$#del_ids] ;
#print "DEL>> @dels\n" ;
$this->hdb->delete( $table_ref , ["$cols_ref[2] == ?" , @dels] ) if @dels ;
#print $this->hdb->sql . "\n" if @dels ;
foreach my $ids_i ( @ids ) {
if ( $ids{$ids_i} != $sel_ids{$ids_i} ) {
my $pos = $sel_pos{ $ids{$ids_i} } ;
if ( $pos ) {
$this->hdb->update( $table_ref , "id == $pos" , {$cols_ref[0] => $id , $cols_ref[2] => $ids_i}) ;
#print $this->hdb->sql . "\n" ;
}
else {
$this->hdb->insert( $table_ref , {$cols_ref[0] => $id , $cols_ref[2] => $ids_i}) ;
#print $this->hdb->sql . "\n" ;
}
}
}
}
elsif ( UNIVERSAL::isa($this->{$order_i} , 'HDB::Object') ) {
$this->{$order_i}->hdb_save( no_auto_clean_unref => 1 , , saved_classes => $saved_classes ) ;
$$saved_classes{ $this->{$order_i}->__CLASS__ } = 1 ;
}
}
elsif ( $col_name =~ /^hdbobj/ ) {
if ( ref($this->{$order_i}) eq 'HDB::Object::Loader' ) {
my $id = $this->{$order_i}->[1]{id} ;
$this->{CLASS_HPLOO_ATTR}{$col_name} = $id ;
}
elsif ( UNIVERSAL::isa($this->{$order_i} , 'HDB::Object') ) {
$this->{$order_i}->hdb_save( no_auto_clean_unref => 1 , saved_classes => $saved_classes , save_all => $args{save_all} ) ;
$$saved_classes{ $this->{$order_i}->__CLASS__ } = 1 ;
$this->{CLASS_HPLOO_ATTR}{$col_name} = $this->{$order_i}->{__ID__} ;
}
push(@del_attr_keys , $col_name) ;
}
elsif ( $col_name =~ /^hdbstore/ ) {
eval('use Storable qw()') ;
if ( !$@ ) {
eval {
$this->{CLASS_HPLOO_ATTR}{$col_name} = Storable::freeze( [$this->{$order_i}] ) ;
};
push(@del_attr_keys , $col_name) ;
}
}
}
my $ret ;
if ( $insert ) {
$this->{CLASS_HPLOO_ATTR}{id} = $this->{__ID__} = $id ;
push(@del_attr_keys , 'id') ;
$ret = $this->hdb->insert( $this->__CLASS__ , $this->{CLASS_HPLOO_ATTR} ) ;
}
else {
my %changeds ;
if ( $args{save_all} ) { %changeds = %{ $this->{CLASS_HPLOO_ATTR} } ;}
else {
foreach my $Key ( keys %$class_hploo_changed ) {
$changeds{$Key} = $this->{CLASS_HPLOO_ATTR}{$Key} ;
}
}
$ret = $this->hdb->update( $this->__CLASS__ , "id == $id" , \%changeds ) ;
}
foreach my $del_keys_i ( @del_attr_keys ) { delete $this->{CLASS_HPLOO_ATTR}{$del_keys_i} ;}
$$saved_classes{ $this->__CLASS__ } = 1 ;
if ( !$args{no_auto_clean_unref} ) {
foreach my $Key ( keys %$saved_classes ) {
if ( defined &{ $Key . '::AUTO_CLEAN_UNREF'} && &{ $Key . '::AUTO_CLEAN_UNREF'}() && (time - $class_hploo->{HDB_TABLE_AUTOCLS}{$Key}) > 2 ) {
$Key->hdb_clean_unref( $this->hdb ) ;
$class_hploo->{HDB_TABLE_AUTOCLS}{$Key} = time ;
}
}
}
return $ret ;
}
sub hdb_dump_table ($table) {
if ( !$this ) {
$this = $table || $_[0] ;
$table = $_[0] if $_[0] ;
}
return '' if !$this->hdb_table_exists ;
return $this->hdb->dump_table($table) ;
}
sub STORABLE_freeze ($cloning) {
return(
$this ,
{
(ref $this->{CLASS_HPLOO_ATTR} eq 'HASH' ? %{$this->{CLASS_HPLOO_ATTR}} : ()) ,
id => $this->{__ID__} ,
}
) ;
}
sub STORABLE_thaw ($cloning , $serial , $attrs) {
my $class = ref $this ;
$this->{__ID__} = delete $attrs->{id} ;
$this->{CLASS_HPLOO_ATTR} = {} ;
%{ $this->{CLASS_HPLOO_ATTR} } = %$attrs ;
&{"$class\::CLASS_HPLOO_TIE_KEYS"}($this) ;
$this->hdb ;
return ;
}
sub DESTROY {
return if !%$this ;
$this->hdb_save ;
}
}
################################################################################
{ package HDB::Object::Loader ;
use strict qw(vars) ;
use vars qw($AUTOLOAD) ;
use overload (
'bool' => \&HDB::Object::_OVER_bool ,
'""' => \&HDB::Object::_OVER_string ,
'%{}' => '_OVER_hash' ,
'fallback' => 1 ,
);
sub _OVER_hash {
_build($_[0]) ; return $_[0] ;
if ( !$_[0][3] ) {
my %hash = (1) ;
$_[0][3] = \%hash ;
$_[0][4] = tie( %hash , 'HDB::Object::Loader::TieHandler' , @{$_[0]}[0..2] ) ;
}
if ( $_[0][4] && $_[0][4]->[3] ) {
$_[0] = $_[0][4]->[3] ;
return $_[0] ;
}
return $_[0][3] ;
}
sub create_loader { bless [ @_ ] ;}
sub _build {
my @args = @{$_[0]} ;
$_[0] = HDB::Object::_build_obj(@args) ;
die "INTERNAL ERROR: Cannot build instance of '$args[0]'\n" unless defined $_[0] ;
# This can occur if the class wasn't loaded correctly.
die "INTERNAL ERROR: _build() failed to build a new object\n" if ref($_[0]) eq __PACKAGE__;
return $_[0] ;
}
sub __CLASS__ {
return $_[0][0] ;
}
sub __ID__ {
return $_[0][1]{id} ;
}
sub can {
_build($_[0]);
$_[0]->can($_[1]);
}
sub isa {
$_[0][0]->isa($_[1]) ;
}
sub AUTOLOAD {
my ($subname) = $AUTOLOAD =~ /([^:]+)$/ ;
my $realclass = $_[0][0] ;
_build( $_[0] ) ;
my $func = $_[0]->can( $subname );
die "Cannot call '$subname' on an instance of '$realclass'\n" unless ref( $func ) eq 'CODE';
goto &$func ;
}
## Don't need to save if we haven't changed attributes:
sub DESTROY {
##_build($_[0]);
##$_[0]->DESTROY(@_[1..$#_]);
}
}
################################################################################
{ package HDB::Object::Loader::TieHandler ;
use strict qw(vars) ;
no warnings ;
sub TIEHASH { shift ; bless [ @_ ] ;}
my $val ;
sub FETCH { #print STDOUT "FETCH>> @_\n" ;
my $this = shift ;
my $key = shift ;
return $this->[1]{id} if $key eq '__ID__' ;
$this->[3] = HDB::Object::_build_obj( @{$this}[0..2] ) if !defined $this->[3] ;
return $this->[3]{$key} ;
}
sub STORE { #print STDOUT "STORE>> @_\n" ;
my $this = shift ;
my $key = shift ;
$this->[3] = HDB::Object::_build_obj( @{$this}[0..2] ) if !defined $this->[3] ;
return $this->[3]{$key} ;
}
sub DELETE { #print STDOUT "DELETE>> @_\n" ;
my $this = shift ;
my $key = shift ;
$this->[3] = HDB::Object::_build_obj( @{$this}[0..2] ) if !defined $this->[3] ;
return delete $this->[3]{$key} ;
}
sub EXISTS { #print STDOUT "EXISTS>> @_\n" ;
my $this = shift ;
my $key = shift ;
$this->[3] = HDB::Object::_build_obj( @{$this}[0..2] ) if !defined $this->[3] ;
return exists $this->[3]{$key} ;
}
sub FIRSTKEY { #print STDOUT "FIRSTKEY>> @_\n" ;
my $this = shift ;
$this->[3] = HDB::Object::_build_obj( @{$this}[0..2] ) if !defined $this->[3] ;
return (keys %{$this->[3]})[0] ;
}
sub NEXTKEY { #print STDOUT "NEXTKEY>> @_\n" ;
my $this = shift ;
my $keylast = shift ;
$this->[3] = HDB::Object::_build_obj( @{$this}[0..2] ) if !defined $this->[3] ;
my $ret_next ;
foreach my $keys_i ( keys %{$this->[3]} ) {
if ($ret_next) { return $keys_i ;}
if ($keys_i eq $keylast || !defined $keylast) { $ret_next = 1 ;}
}
return undef ;
}
sub CLEAR { #print STDOUT "CLEAR>> @_\n" ;
my $this = shift ;
$this->[3] = HDB::Object::_build_obj( @{$this}[0..2] ) if !defined $this->[3] ;
%{$this->[3]} = () ;
return ;
}
sub UNTIE {}
sub DESTROY {}
}
1 ;
__END__
=> NAME
HDB::Object - Base class for persistent Class::HPLOO objects.
=> DESCRIPTION
This is the base class for persistent Class::HPLOO objects.
This will automaticallt make Class::HPLOO classes persistent in any DB
handled by L<HDB>.
This persistence framework was built by a group of modules that handles specific
parts of the problem:
*> L<Class::HPLOO>
The class declaration and attribute handler.
*> L<HDB::Object>
The object persistence and class proxy.
*> L<HDB>
The DB connection and SQL communication for each DB type.
/*>
All of this will create a very automatic way to create persistent objects over a
relational DB, what is perfect for fast and easy creation of good systems.
For Web Systems this framework is automatically embeded into L<HPL>,
where you can count with a lot of resources for fast and powerful creations for
the Web.
=> USAGE
Here's an example of a class built with HDB::Object persistence.
use Class::HPLOO ;
class User extends HDB::Object {
use HDB::Object ;
attr( user , pass , name , int age ) ;
sub User( $user , $pass , $name , $age ) {
$this->{user} = $user ;
$this->{pass} = $pass ;
$this->{name} = $name ;
$this->{age} = time ;
}
}
B<You can see that is completly automatic and you don't need to care about the
serialization or even about the DB connection, tables and column types.>
=> METHODS
==> load (CONDITIONS)
Loads an object that exists in the database.
I<CONDITIONS> can be a sequence of WHERE conditions for HDB:
my $users_x = load User('id == 123') ;
my @users = load User('id <= 10' , 'id == 123' , 'name eq "joe"') ;
If I<CONDITIONS> is NOT paste, if wantarray it will return all the objects in the table, or it will return only the 1st:
my $user1 = load User() ;
my @all_users = load User() ;
==> hdb
Return the HDB object that handles the DB connection.
==> hdb_dump_table
Dump all the table content, returning that as a string.
==> hdb_table_exists
Retrun TRUE if the table for the HDB::Object was already created.
==> hdb_create_table
Create the table for the HDB::Object if it doesn't exists.
==> hdb_obj_changed
Return TRUE when the object was changed and need to be updated in the DB.
==> hdb_max_id
Return the max id in the object table.
==> hdb_delete
Delete the object from the database.
==> hdb_save
Save the object in the database.
I<** Note that you don't need to call this method directly, since when
the object is destroied from the memory it will be saved automatically.>
==> hdb_clean_unref
This will automatically clean objects from this table if they doesn't have
references in the database from another object. So, only call this if
you have a colection of objects that are referenced by others or you
will lose all the objects from the table:
Users::Level->hdb_clean_unref ;
You also can define the constant I<AUTO_CLEAN_UNREF> to automatically clean
unreferenced objects:
class Users::Level extends HDB::Object {
use constant AUTO_CLEAN_UNREF => 1 ;
...
}
==> hdb_referenced_ids
Return the IDs that have a reference to it.
=> DESTROY and AUTO SAVE OBJECT
The object will be automatically saved when the object is destroied.
So if you want to use this automatically save resource you can't overload the
sub DESTROY, or at least should call the super method:
class User extends HDB::Object {
...
sub DESTROY {
$this->SUPER::DESTROY ;
... # your destroy stuffs.
}
}
=> OBJECT REFERENCES
I<HDB::Object> will try to handle automatically attributes that make references
to other objects or list of objects.
When an atribute make a reference to an object that extends I<HDB::Object>,
only the ID to the object will be saved, making a reference to the ID
of the object table.
If an object doesn't extends I<HDB::Object> it will be serialized, using L<Storable>,
and stored in the coloumn value.
When an attribute have a list of objects, a reference table is created automatically:
attr( array Date::OBject dates )
=> OBJECT PROXY
The Object Proxy mechanism was inspirated on L<Class::LazyLoad>. The main idea
is that the object won't be created unless it's accessed. The proxy will be used only
when the object is loaded from the DB, not when you create a new object. So, when
you load an object from the DB, actually the DB will be accessed only when you use the
object.
An Object Proxy is very important to save memory and DB access, since if we don't
use a proxy is possible to have an object that loads all the DB in the memory due
it's object tree.
=> SEE ALSO
L<HPL>, L<HDB>, L<Class::HPLOO>, L<Class::LazyLoad>.
=> AUTHOR
Graciliano M. P. <gm@virtuasites.com.br>
I will appreciate any type of feedback (include your opinions and/or suggestions). ;-P
=> COPYRIGHT
This program is free software; you can redistribute it and/or
modify it under the same terms as Perl itself.