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
|
use strict; use warnings;
use Test::More tests => 41;
use lib 't/lib';
use Hook::Guard;
use DBIx::Connector;
my $CLASS = 'DBIx::Connector';
ok my $conn = $CLASS->new( 'dbi:ExampleP:dummy', '', '' ),
'Get a connection';
# Mock the savepoint driver methods.
my @driver_meth = map Hook::Guard->new( $_ )->replace( sub { shift } ),
do { package DBIx::Connector::Driver; \*savepoint, \*release, \*rollback_to };
# Test with no existing dbh.
my $connect_meth = Hook::Guard->new( \*DBIx::Connector::_connect )->prepend(sub {
pass '_connect should be called';
});
ok my $dbh = $conn->dbh, 'Fetch the database handle';
ok !$conn->{_in_run}, '_in_run should be false';
ok $dbh->{AutoCommit}, 'AutoCommit should be true';
ok !$conn->in_txn, 'in_txn() should return false';
is $conn->{_svp_depth}, 0, 'Depth should be 0';
# This should just pass to txn.
ok $conn->svp( ping => sub {
ok !shift->{AutoCommit}, 'Inside, we should be in a transaction';
ok $conn->in_txn, 'in_txn() should know all about it';
ok $conn->{_in_run}, '_in_run should be true';
is $conn->{_svp_depth}, 0, 'Depth should be 0';
}), 'Do something with no existing handle';
$connect_meth->restore;
ok !$conn->{_in_run}, '_in_run should be false again';
ok $dbh->{AutoCommit}, 'Transaction should be committed';
ok !$conn->in_txn, 'in_txn() should know know that, too';
is $conn->{_svp_depth}, 0, 'Depth should still be 0 again';
# Test with instantiated dbh.
is $conn->{_dbh}, $dbh, 'The dbh should be stored';
ok $conn->connected, 'We should be connected';
ok $conn->svp( ping => sub {
my $dbha = shift;
is $dbha, $dbh, 'The handle should have been passed';
is $_, $dbh, 'It should also be in $_';
ok !$dbha->{AutoCommit}, 'We should be in a transaction';
ok $conn->in_txn, 'in_txn() should know all about it';
}), 'Do something with existing handle';
# Run the same test from inside a transaction, so we're sure that the svp
# code executes properly. This is because svp must be called from inside a
# txn. If it's not, it just dispatches to txn() and returns.
ok $conn->txn(ping => sub {
$conn->svp(sub {
my $dbha = shift;
is $conn->{_mode}, 'ping', 'Should be in ping mode';
is $dbha, $dbh, 'The handle should have been passed';
is $_, $dbh, 'It should also be in $_';
ok !$dbha->{AutoCommit}, 'We should be in a transaction';
ok $conn->in_txn, 'in_txn() should know it, too';
});
}), 'Do something inside a transaction';
# Test the return value. Gotta do it inside a transaction.
$conn->txn(sub {
ok my $foo = $conn->svp( ping => sub {
return (2, 3, 5);
}), 'Do in scalar context';
is $foo, 5, 'The return value should be the last value';
ok my @foo = $conn->svp( ping => sub {
return (2, 3, 5);
}), 'Do in array context';
is_deeply \@foo, [2, 3, 5], 'The return value should be the list';
});
# Make sure nested calls work.
$conn->svp( ping => sub {
my $dbh = shift;
ok !$dbh->{AutoCommit}, 'Inside, we should be in a transaction';
ok $conn->in_txn, 'in_txn() should know all about it';
is $conn->{_svp_depth}, 0, 'Depth should be 0';
local $dbh->{Active} = 0;
$conn->svp( ping => sub {
is shift, $dbh, 'Nested svp should always get the current dbh';
ok !$dbh->{AutoCommit}, 'Nested txn_runup should be in the txn';
ok $conn->in_txn, 'in_txn() should know all about it, too';
is $conn->{_svp_depth}, 1, 'Depth should be 1';
});
is $conn->{_svp_depth}, 0, 'Depth should be 0 again';
});
|
