1 package DBM::Deep::Sector::DBI::Reference;
6 use warnings FATAL => 'all';
8 use base 'DBM::Deep::Sector::DBI';
15 my $e = $self->engine;
17 unless ( $self->offset ) {
18 my $classname = Scalar::Util::blessed( delete $self->{data} );
19 $self->{offset} = $self->engine->storage->write_to(
21 ref_type => $self->type,
22 classname => $classname,
26 my ($rows) = $self->engine->storage->read_from(
27 refs => $self->offset,
31 $self->{type} = $rows->[0]{ref_type};
41 my ($rows) = $self->engine->storage->read_from(
42 datas => { ref_id => $self->offset, key => $args->{key} },
46 return unless $rows->[0]{id};
59 if ( ( $args->{value}->type || 'S' ) eq 'S' ) {
60 $args->{value}{offset} = $self->engine->storage->write_to(
61 datas => $args->{value}{offset},
62 ref_id => $self->offset,
65 value => $args->{value}{data},
68 $args->{value}->reload;
71 # Write the Scalar of the Reference
72 $self->engine->storage->write_to(
74 ref_id => $self->offset,
77 value => $args->{value}{offset},
86 my $old_value = $self->get_data_for({
92 $data = $old_value->data({ export => 1 });
101 my ($rows) = $self->engine->storage->read_from(
102 'refs', $self->offset,
105 return unless @$rows;
106 return $rows->[0]{classname};
109 # Look to hoist this method into a ::Reference trait
116 unless ( $obj = $self->engine->cache->{ $self->offset } ) {
117 $obj = DBM::Deep->new({
119 base_offset => $self->offset,
120 storage => $self->engine->storage,
121 engine => $self->engine,
124 if ( $self->engine->storage->{autobless} ) {
125 my $classname = $self->get_classname;
126 if ( defined $classname ) {
127 bless $obj, $classname;
131 $self->engine->cache->{$self->offset} = $obj;
134 # We're not exporting, so just return.
135 unless ( $args->{export} ) {
139 # We shouldn't export if this is still referred to.
140 if ( $self->get_refcount > 1 ) {
150 # We're not ready to be removed yet.
151 return if $self->decrement_refcount > 0;
153 # Rebless the object into DBM::Deep::Null.
154 eval { %{ $self->engine->cache->{ $self->offset } } = (); };
155 eval { @{ $self->engine->cache->{ $self->offset } } = (); };
156 bless $self->engine->cache->{ $self->offset }, 'DBM::Deep::Null';
157 delete $self->engine->cache->{ $self->offset };
159 $self->engine->storage->delete_from(
160 'datas', { ref_id => $self->offset },
163 $self->engine->storage->delete_from(
164 'datas', { value => $self->offset, data_type => 'R' },
167 $self->SUPER::free( @_ );
170 sub increment_refcount {
172 my $refcount = $self->get_refcount;
174 $self->write_refcount( $refcount );
178 sub decrement_refcount {
180 my $refcount = $self->get_refcount;
182 $self->write_refcount( $refcount );
188 my ($rows) = $self->engine->storage->read_from(
189 'refs', $self->offset,
192 return $rows->[0]{refcount};
198 $self->engine->storage->{dbh}->do(
199 "UPDATE refs SET refcount = ? WHERE id = ?", undef,