1 package DBIx::Class::Storage::TxnScopeGuard;
5 use Scalar::Util qw(weaken blessed refaddr);
7 use DBIx::Class::_Util qw(is_exception detected_reinvoked_destructor);
12 my ($class, $storage) = @_;
19 # we are starting with an already set $@ - in order for things to work we need to
20 # be able to recognize it upon destruction - store its weakref
21 # recording it before doing the txn_begin stuff
23 # FIXME FRAGILE - any eval that fails but *does not* rethrow between here
24 # and the unwind will trample over $@ and invalidate the entire mechanism
25 # There got to be a saner way of doing this...
27 # Deliberately *NOT* using is_exception - if someone left a misbehaving
28 # antipattern value in $@, it's not our business to whine about it
30 $guard->{existing_exception_ref} = (length ref $@) ? $@ : \$@
31 ) if( defined $@ and length $@ );
35 weaken( $guard->{dbh} = $storage->_dbh );
37 bless $guard, ref $class || $class;
45 $self->{storage}->throw_exception("Refusing to execute multiple commits on scope guard $self")
46 if $self->{inactivated};
48 # FIXME - this assumption may be premature: a commit may fail and a rollback
49 # *still* be necessary. Currently I am not aware of such scenarious, but I
50 # also know the deferred constraint handling is *severely* undertested.
51 # Making the change of "fire txn and never come back to this" in order to
52 # address RT#107159, but this *MUST* be reevaluated later.
53 $self->{inactivated} = 1;
54 $self->{storage}->txn_commit;
58 return if &detected_reinvoked_destructor;
60 return if $_[0]->{inactivated};
63 # grab it before we've done volatile stuff below
64 my $current_exception = (
68 ! defined $_[0]->{existing_exception_ref}
70 refaddr( (length ref $@) ? $@ : \$@ ) != refaddr($_[0]->{existing_exception_ref})
78 # if our dbh is not ours anymore, the $dbh weakref will go undef
79 $_[0]->{storage}->_verify_pid unless DBIx::Class::_ENV_::BROKEN_FORK;
80 return unless defined $_[0]->{dbh};
83 carp 'A DBIx::Class::Storage::TxnScopeGuard went out of scope without explicit commit or error. Rolling back'
84 unless defined $current_exception;
88 my $rollback_exception = $_[0]->{storage}->__delicate_rollback(
89 defined $current_exception
94 ! defined $current_exception
97 "********************* ROLLBACK FAILED!!! ********************",
98 "\nA rollback operation failed after the guard went out of scope.",
99 'This is potentially a disastrous situation, check your data for',
100 "consistency: $rollback_exception"
104 $@ = $current_exception
105 if DBIx::Class::_ENV_::UNSTABLE_DOLLARAT;
107 # Dummy NEXTSTATE ensuring the all temporaries on the stack are garbage
108 # collected before leaving this scope. Depending on the code above, this
109 # may very well be just a preventive measure guarding future modifications
119 DBIx::Class::Storage::TxnScopeGuard - Scope-based transaction handling
124 my ($self, $schema) = @_;
126 my $guard = $schema->txn_scope_guard;
128 # Multiple database operations here
135 An object that behaves much like L<Scope::Guard>, but hardcoded to do the
136 right thing with transactions in DBIx::Class.
142 Creating an instance of this class will start a new transaction (by
143 implicitly calling L<DBIx::Class::Storage/txn_begin>. Expects a
144 L<DBIx::Class::Storage> object as its only argument.
148 Commit the transaction, and stop guarding the scope. If this method is not
149 called and this object goes out of scope (e.g. an exception is thrown) then
150 the transaction is rolled back, via L<DBIx::Class::Storage/txn_rollback>
156 L<DBIx::Class::Schema/txn_scope_guard>.
158 L<Scope::Guard> by chocolateboy (inspiration for this module)
160 =head1 FURTHER QUESTIONS?
162 Check the list of L<additional DBIC resources|DBIx::Class/GETTING HELP/SUPPORT>.
164 =head1 COPYRIGHT AND LICENSE
166 This module is free software L<copyright|DBIx::Class/COPYRIGHT AND LICENSE>
167 by the L<DBIx::Class (DBIC) authors|DBIx::Class/AUTHORS>. You can
168 redistribute it and/or modify it under the same terms as the
169 L<DBIx::Class library|DBIx::Class/COPYRIGHT AND LICENSE>.