1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
|
package DBIx::Class::Storage::TxnScopeGuard;
use strict;
use warnings;
use Carp::Clan qw/^DBIx::Class/;
use Try::Tiny;
use namespace::clean;
sub new {
my ($class, $storage) = @_;
$storage->txn_begin;
bless [ 0, $storage ], ref $class || $class;
}
sub commit {
my $self = shift;
$self->[1]->txn_commit;
$self->[0] = 1;
}
sub DESTROY {
my ($dismiss, $storage) = @{$_[0]};
return if $dismiss;
my $exception = $@;
{
local $@;
carp 'A DBIx::Class::Storage::TxnScopeGuard went out of scope without explicit commit or error. Rolling back.'
unless $exception;
my $rollback_exception;
try { $storage->txn_rollback }
catch { $rollback_exception = shift };
if (defined $rollback_exception && $rollback_exception !~ /DBIx::Class::Storage::NESTED_ROLLBACK_EXCEPTION/) {
if ($exception) {
$exception = "Transaction aborted: ${exception} "
."Rollback failed: ${rollback_exception}";
}
else {
carp (join ' ',
"********************* ROLLBACK FAILED!!! ********************",
"\nA rollback operation failed after the guard went out of scope.",
'This is potentially a disastrous situation, check your data for',
"consistency: $rollback_exception"
);
}
}
}
$@ = $exception;
}
1;
__END__
=head1 NAME
DBIx::Class::Storage::TxnScopeGuard - Scope-based transaction handling
=head1 SYNOPSIS
sub foo {
my ($self, $schema) = @_;
my $guard = $schema->txn_scope_guard;
# Multiple database operations here
$guard->commit;
}
=head1 DESCRIPTION
An object that behaves much like L<Scope::Guard>, but hardcoded to do the
right thing with transactions in DBIx::Class.
=head1 METHODS
=head2 new
Creating an instance of this class will start a new transaction (by
implicitly calling L<DBIx::Class::Storage/txn_begin>. Expects a
L<DBIx::Class::Storage> 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 (e.g. an exception is thrown) then
the transaction is rolled back, via L<DBIx::Class::Storage/txn_rollback>
=cut
=head1 SEE ALSO
L<DBIx::Class::Schema/txn_scope_guard>.
=head1 AUTHOR
Ash Berlin, 2008.
Inspired by L<Scope::Guard> by chocolateboy.
This module is free software. It may be used, redistributed and/or modified
under the same terms as Perl itself.
=cut
|
