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};
114 my $obj = DBM::Deep->new({
116 base_offset => $self->offset,
117 # staleness => $self->staleness,
118 storage => $self->engine->storage,
119 engine => $self->engine,
122 if ( $self->engine->storage->{autobless} ) {
123 my $classname = $self->get_classname;
124 if ( defined $classname ) {
125 bless $obj, $classname;
129 # We're not exporting, so just return.
130 unless ( $args->{export} ) {
134 # We shouldn't export if this is still referred to.
135 if ( $self->get_refcount > 1 ) {
145 # We're not ready to be removed yet.
146 if ( $self->decrement_refcount > 0 ) {
150 $self->engine->storage->delete_from(
151 'datas', { ref_id => $self->offset },
154 $self->engine->storage->delete_from(
155 'datas', { value => $self->offset, data_type => 'R' },
158 $self->SUPER::free( @_ );
161 sub increment_refcount {
163 my $refcount = $self->get_refcount;
165 $self->write_refcount( $refcount );
169 sub decrement_refcount {
171 my $refcount = $self->get_refcount;
173 $self->write_refcount( $refcount );
179 my ($rows) = $self->engine->storage->read_from(
180 'refs', $self->offset,
183 return $rows->[0]{refcount};
189 $self->engine->storage->{dbh}->do(
190 "UPDATE refs SET refcount = ? WHERE id = ?", undef,