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
|
use strict;
use warnings;
use Test::More;
use Test::Exception;
use DBIx::Class::Optional::Dependencies ();
use lib qw(t/lib);
use DBICTest;
plan skip_all => 'Test segfaults on Win32' if $^O eq 'MSWin32';
for my $type (qw/PG MYSQL/) {
SKIP: {
skip "Skipping $type tests without DBICTEST_${type}_DSN", 1
unless $ENV{"DBICTEST_${type}_DSN"};
if ($type eq 'PG') {
skip "skipping Pg tests without dependencies installed", 1
unless DBIx::Class::Optional::Dependencies->req_ok_for('test_rdbms_pg');
}
elsif ($type eq 'MYSQL') {
skip "skipping MySQL tests without dependencies installed", 1
unless DBIx::Class::Optional::Dependencies->req_ok_for('test_rdbms_mysql');
}
my $schema = DBICTest::Schema->connect (@ENV{map { "DBICTEST_${type}_${_}" } qw/DSN USER PASS/});
# emulate a singleton-factory, just cache the object *somewhere in a different package*
# to induce out-of-order destruction
$DBICTest::FakeSchemaFactory::schema = $schema;
# so we can see the retry exceptions (if any)
$ENV{DBIC_DBIRETRY_DEBUG} = 1;
ok (!$schema->storage->connected, "$type: start disconnected");
lives_ok (sub {
$schema->txn_do (sub {
ok ($schema->storage->connected, "$type: transaction starts connected");
my $pid = fork();
SKIP: {
skip "Fork failed: $!", 1 if (! defined $pid);
if ($pid) {
note "Parent $$ sleeping...";
wait();
note "Parent $$ woken up after child $pid exit";
}
else {
note "Child $$ terminating";
exit 0;
}
ok ($schema->storage->connected, "$type: parent still connected (in txn_do)");
}
});
});
ok ($schema->storage->connected, "$type: parent still connected (outside of txn_do)");
undef $DBICTest::FakeSchemaFactory::schema;
}
}
done_testing;
|
