All tests pass except for the transaction tests under MySQL. InnoDB sucks
[dbsrgits/DBM-Deep.git] / t / 35_transaction_multiple.t
CommitLineData
dec950d0 1use strict;
0e3e3555 2use warnings FATAL => 'all';
3
4use Test::More;
dec950d0 5use Test::Deep;
0e3e3555 6use t::common qw( new_dbm );
dec950d0 7
8use_ok( 'DBM::Deep' );
9
4f034d8f 10if ( $ENV{NO_TEST_TRANSACTIONS} ) {
11 done_testing;
12 exit;
13}
14
0e3e3555 15my $dbm_factory = new_dbm(
dec950d0 16 locking => 1,
17 autoflush => 1,
2120a181 18 num_txns => 16,
dec950d0 19);
20
0e3e3555 21while ( my $dbm_maker = $dbm_factory->() ) {
22 my $db1 = $dbm_maker->();
23 my $db2 = $dbm_maker->();
24 my $db3 = $dbm_maker->();
dec950d0 25
0e3e3555 26 $db1->{foo} = 'bar';
27 is( $db1->{foo}, 'bar', "Before transaction, DB1's foo is bar" );
28 is( $db2->{foo}, 'bar', "Before transaction, DB2's foo is bar" );
29 is( $db3->{foo}, 'bar', "Before transaction, DB3's foo is bar" );
dec950d0 30
0e3e3555 31 $db1->begin_work;
dec950d0 32
0e3e3555 33 is( $db1->{foo}, 'bar', "Before transaction work, DB1's foo is bar" );
34 is( $db2->{foo}, 'bar', "Before transaction work, DB2's foo is bar" );
35 is( $db3->{foo}, 'bar', "Before transaction work, DB3's foo is bar" );
dec950d0 36
0e3e3555 37 $db1->{foo} = 'bar2';
dec950d0 38
0e3e3555 39 is( $db1->{foo}, 'bar2', "After DB1 foo to bar2, DB1's foo is bar2" );
40 is( $db2->{foo}, 'bar', "After DB1 foo to bar2, DB2's foo is bar" );
41 is( $db3->{foo}, 'bar', "After DB1 foo to bar2, DB3's foo is bar" );
dec950d0 42
0e3e3555 43 $db1->{bar} = 'foo';
dec950d0 44
0e3e3555 45 ok( exists $db1->{bar}, "After DB1 set bar to foo, DB1's bar exists" );
46 ok( !exists $db2->{bar}, "After DB1 set bar to foo, DB2's bar doesn't exist" );
47 ok( !exists $db3->{bar}, "After DB1 set bar to foo, DB3's bar doesn't exist" );
48
49 $db2->begin_work;
dec950d0 50
0e3e3555 51 is( $db1->{foo}, 'bar2', "After DB2 transaction begin, DB1's foo is still bar2" );
52 is( $db2->{foo}, 'bar', "After DB2 transaction begin, DB2's foo is still bar" );
53 is( $db3->{foo}, 'bar', "After DB2 transaction begin, DB3's foo is still bar" );
dec950d0 54
0e3e3555 55 ok( exists $db1->{bar}, "After DB2 transaction begin, DB1's bar exists" );
56 ok( !exists $db2->{bar}, "After DB2 transaction begin, DB2's bar doesn't exist" );
57 ok( !exists $db3->{bar}, "After DB2 transaction begin, DB3's bar doesn't exist" );
dec950d0 58
0e3e3555 59 $db2->{foo} = 'bar333';
dec950d0 60
0e3e3555 61 is( $db1->{foo}, 'bar2', "After DB2 foo to bar2, DB1's foo is bar2" );
62 is( $db2->{foo}, 'bar333', "After DB2 foo to bar2, DB2's foo is bar333" );
63 is( $db3->{foo}, 'bar', "After DB2 foo to bar2, DB3's foo is bar" );
dec950d0 64
0e3e3555 65 $db2->{bar} = 'mybar';
dec950d0 66
0e3e3555 67 ok( exists $db1->{bar}, "After DB2 set bar to mybar, DB1's bar exists" );
68 ok( exists $db2->{bar}, "After DB2 set bar to mybar, DB2's bar exists" );
69 ok( !exists $db3->{bar}, "After DB2 set bar to mybar, DB3's bar doesn't exist" );
dec950d0 70
0e3e3555 71 is( $db1->{bar}, 'foo', "DB1's bar is still foo" );
72 is( $db2->{bar}, 'mybar', "DB2's bar is now mybar" );
dec950d0 73
0e3e3555 74 $db2->{mykey} = 'myval';
dec950d0 75
0e3e3555 76 ok( !exists $db1->{mykey}, "After DB2 set mykey to myval, DB1's mykey doesn't exist" );
77 ok( exists $db2->{mykey}, "After DB2 set mykey to myval, DB2's mykey exists" );
78 ok( !exists $db3->{mykey}, "After DB2 set mykey to myval, DB3's mykey doesn't exist" );
dec950d0 79
0e3e3555 80 cmp_bag( [ keys %$db1 ], [qw( foo bar )], "DB1 keys correct" );
81 cmp_bag( [ keys %$db2 ], [qw( foo bar mykey )], "DB2 keys correct" );
82 cmp_bag( [ keys %$db3 ], [qw( foo )], "DB3 keys correct" );
dec950d0 83
0e3e3555 84 $db1->commit;
dec950d0 85
0e3e3555 86 is( $db1->{foo}, 'bar2', "After DB1 commit, DB1's foo is bar2" );
87 is( $db2->{foo}, 'bar333', "After DB1 commit, DB2's foo is bar333" );
88 is( $db3->{foo}, 'bar2', "After DB1 commit, DB3's foo is bar2" );
dec950d0 89
0e3e3555 90 is( $db1->{bar}, 'foo', "DB1's bar is still foo" );
91 is( $db2->{bar}, 'mybar', "DB2's bar is still mybar" );
92 is( $db3->{bar}, 'foo', "DB3's bar is now foo" );
dec950d0 93
0e3e3555 94 cmp_bag( [ keys %$db1 ], [qw( foo bar )], "DB1 keys correct" );
95 cmp_bag( [ keys %$db2 ], [qw( foo bar mykey )], "DB2 keys correct" );
96 cmp_bag( [ keys %$db3 ], [qw( foo bar )], "DB3 keys correct" );
dec950d0 97
0e3e3555 98 $db2->commit;
dec950d0 99
0e3e3555 100 is( $db1->{foo}, 'bar333', "After DB2 commit, DB1's foo is bar333" );
101 is( $db2->{foo}, 'bar333', "After DB2 commit, DB2's foo is bar333" );
102 is( $db3->{foo}, 'bar333', "After DB2 commit, DB3's foo is bar333" );
dec950d0 103
0e3e3555 104 is( $db1->{bar}, 'mybar', "DB1's bar is now mybar" );
105 is( $db2->{bar}, 'mybar', "DB2's bar is still mybar" );
106 is( $db3->{bar}, 'mybar', "DB3's bar is now mybar" );
dec950d0 107
0e3e3555 108 cmp_bag( [ keys %$db1 ], [qw( foo bar mykey )], "DB1 keys correct" );
109 cmp_bag( [ keys %$db2 ], [qw( foo bar mykey )], "DB2 keys correct" );
110 cmp_bag( [ keys %$db3 ], [qw( foo bar mykey )], "DB3 keys correct" );
111}
dec950d0 112
0e3e3555 113done_testing;