X-Git-Url: http://git.shadowcat.co.uk/gitweb/gitweb.cgi?a=blobdiff_plain;f=lib%2FDBIx%2FClass%2FStorage%2FTxnScopeGuard.pm;h=f686cce374ba7c62ef28c3768d7ae8dcd4348743;hb=7d216b101775c472b012b257d848f50d78b193c8;hp=122e0167d8c804c86ce1423779b786548280c46c;hpb=36099e8c8fd3925af465eeba58c637022b6d10e9;p=dbsrgits%2FDBIx-Class.git diff --git a/lib/DBIx/Class/Storage/TxnScopeGuard.pm b/lib/DBIx/Class/Storage/TxnScopeGuard.pm index 122e016..f686cce 100644 --- a/lib/DBIx/Class/Storage/TxnScopeGuard.pm +++ b/lib/DBIx/Class/Storage/TxnScopeGuard.pm @@ -3,12 +3,17 @@ package DBIx::Class::Storage::TxnScopeGuard; use strict; use warnings; use Carp::Clan qw/^DBIx::Class/; +use Try::Tiny; +use Scalar::Util qw/weaken/; +use namespace::clean; sub new { my ($class, $storage) = @_; $storage->txn_begin; - bless [ 0, $storage ], ref $class || $class; + my $guard = bless [ 0, $storage, $storage->_dbh ], ref $class || $class; + weaken ($guard->[2]); + $guard; } sub commit { @@ -23,6 +28,10 @@ sub DESTROY { return if $dismiss; + # if our dbh is not ours anymore, the weakref will go undef + $storage->_preserve_foreign_dbh; + return unless $_[0]->[2]; + my $exception = $@; { @@ -31,10 +40,13 @@ sub DESTROY { carp 'A DBIx::Class::Storage::TxnScopeGuard went out of scope without explicit commit or error. Rolling back.' unless $exception; - eval { $storage->txn_rollback }; - my $rollback_exception = $@; + my $rollback_exception; + # do minimal connectivity check due to weird shit like + # https://rt.cpan.org/Public/Bug/Display.html?id=62370 + try { $storage->_seems_connected && $storage->txn_rollback } + catch { $rollback_exception = shift }; - if ($rollback_exception && $rollback_exception !~ /DBIx::Class::Storage::NESTED_ROLLBACK_EXCEPTION/) { + if (defined $rollback_exception && $rollback_exception !~ /DBIx::Class::Storage::NESTED_ROLLBACK_EXCEPTION/) { if ($exception) { $exception = "Transaction aborted: ${exception} " ."Rollback failed: ${rollback_exception}"; @@ -76,7 +88,7 @@ DBIx::Class::Storage::TxnScopeGuard - Scope-based transaction handling =head1 DESCRIPTION An object that behaves much like L, but hardcoded to do the -right thing with transactions in DBIx::Class. +right thing with transactions in DBIx::Class. =head1 METHODS @@ -89,7 +101,7 @@ L object as its only argument. =head2 commit Commit the transaction, and stop guarding the scope. If this method is not -called and this object goes out of scope (i.e. an exception is thrown) then +called and this object goes out of scope (e.g. an exception is thrown) then the transaction is rolled back, via L =cut @@ -102,7 +114,7 @@ L. Ash Berlin, 2008. -Insipred by L by chocolateboy. +Inspired by L by chocolateboy. This module is free software. It may be used, redistributed and/or modified under the same terms as Perl itself.