[dbsrgits/DBM-Deep.git] / t / 34_transaction_arrays.t

use strict;
use Test::More tests => 47;
use Test::Deep;
use t::common qw( new_fh );

use_ok( 'DBM::Deep' );

my ($fh, $filename) = new_fh();
my $db1 = DBM::Deep->new(
    file => $filename,
    locking => 1,
    autoflush => 1,
    num_txns  => 16,
    type => DBM::Deep->TYPE_ARRAY,
);

my $db2 = DBM::Deep->new(
    file => $filename,
    locking => 1,
    autoflush => 1,
    num_txns  => 16,
    type => DBM::Deep->TYPE_ARRAY,
);

$db1->[0] = 'y';
is( $db1->[0], 'y', "Before transaction, DB1's 0 is Y" );
is( $db2->[0], 'y', "Before transaction, DB2's 0 is Y" );

$db1->begin_work;

    is( $db1->[0], 'y', "DB1 transaction started, no actions - DB1's 0 is Y" );
    is( $db2->[0], 'y', "DB1 transaction started, no actions - DB2's 0 is Y" );

    $db1->[0] = 'z';
    is( $db1->[0], 'z', "Within DB1 transaction, DB1's 0 is Z" );
    is( $db2->[0], 'y', "Within DB1 transaction, DB2's 0 is still Y" );

    $db2->[1] = 'foo';
    is( $db2->[1], 'foo', "DB2 set 1 within DB1's transaction, so DB2 can see it" );
    ok( !exists $db1->[1], "Since 1 was added after the transaction began, DB1 doesn't see it." );

    cmp_ok( scalar(@$db1), '==', 1, "DB1 has 1 element" );
    cmp_ok( scalar(@$db2), '==', 2, "DB2 has 2 elements" );

$db1->rollback;

is( $db1->[0], 'y', "After rollback, DB1's 0 is Y" );
is( $db2->[0], 'y', "After rollback, DB2's 0 is Y" );

is( $db1->[1], 'foo', "After DB1 transaction is over, DB1 can see 1" );
is( $db2->[1], 'foo', "After DB1 transaction is over, DB2 can still see 1" );

cmp_ok( scalar(@$db1), '==', 2, "DB1 now has 2 elements" );
cmp_ok( scalar(@$db2), '==', 2, "DB2 still has 2 elements" );

$db1->begin_work;

    is( $db1->[0], 'y', "DB1 transaction started, no actions - DB1's 0 is Y" );
    is( $db2->[0], 'y', "DB1 transaction started, no actions - DB2's 0 is Y" );

    $db1->[2] = 'z';
    is( $db1->[2], 'z', "Within DB1 transaction, DB1's 2 is Z" );
    ok( !exists $db2->[2], "Within DB1 transaction, DB2 cannot see 2" );

    cmp_ok( scalar(@$db1), '==', 3, "DB1 has 3 elements" );
    cmp_ok( scalar(@$db2), '==', 2, "DB2 has 2 elements" );

$db1->commit;

is( $db1->[0], 'y', "After rollback, DB1's 0 is Y" );
is( $db2->[0], 'y', "After rollback, DB2's 0 is Y" );

is( $db1->[2], 'z', "After DB1 transaction is over, DB1 can still see 2" );
is( $db2->[2], 'z', "After DB1 transaction is over, DB2 can now see 2" );

cmp_ok( scalar(@$db1), '==', 3, "DB1 now has 2 elements" );
cmp_ok( scalar(@$db2), '==', 3, "DB2 still has 2 elements" );

$db1->begin_work;

    push @$db1, 'foo';
    unshift @$db1, 'bar';

    cmp_ok( scalar(@$db1), '==', 5, "DB1 now has 5 elements" );
    cmp_ok( scalar(@$db2), '==', 3, "DB2 still has 3 elements" );

    is( $db1->[0], 'bar' );
    is( $db1->[-1], 'foo' );

$db1->rollback;

cmp_ok( scalar(@$db1), '==', 3, "DB1 is back to 3 elements" );
cmp_ok( scalar(@$db2), '==', 3, "DB2 still has 3 elements" );

$db1->begin_work;

    push @$db1, 'foo';
    unshift @$db1, 'bar';

    cmp_ok( scalar(@$db1), '==', 5, "DB1 now has 5 elements" );
    cmp_ok( scalar(@$db2), '==', 3, "DB2 still has 3 elements" );

$db1->commit;

cmp_ok( scalar(@$db1), '==', 5, "DB1 is still at 5 elements" );
cmp_ok( scalar(@$db2), '==', 5, "DB2 now has 5 elements" );

is( $db1->[0], 'bar' );
is( $db1->[-1], 'foo' );

is( $db2->[0], 'bar' );
is( $db2->[-1], 'foo' );

$db1->begin_work;

    @$db1 = (); # clear()

    cmp_ok( scalar(@$db1), '==', 0, "DB1 now has 0 elements" );
    cmp_ok( scalar(@$db2), '==', 5, "DB2 still has 5 elements" );

$db1->rollback;

cmp_ok( scalar(@$db1), '==', 5, "DB1 now has 5 elements" );
cmp_ok( scalar(@$db2), '==', 5, "DB2 still has 5 elements" );
Commit	Line	Data
504185fb	1	use strict;
f9a320bb	2	use Test::More tests => 47;
504185fb	3	use Test::Deep;
	4	use t::common qw( new_fh );
	5
	6	use_ok( 'DBM::Deep' );
	7
	8	my ($fh, $filename) = new_fh();
	9	my $db1 = DBM::Deep->new(
	10	file => $filename,
	11	locking => 1,
	12	autoflush => 1,
2120a181	13	num_txns => 16,
504185fb	14	type => DBM::Deep->TYPE_ARRAY,
	15	);
	16
	17	my $db2 = DBM::Deep->new(
	18	file => $filename,
	19	locking => 1,
	20	autoflush => 1,
2120a181	21	num_txns => 16,
504185fb	22	type => DBM::Deep->TYPE_ARRAY,
	23	);
	24
	25	$db1->[0] = 'y';
	26	is( $db1->[0], 'y', "Before transaction, DB1's 0 is Y" );
	27	is( $db2->[0], 'y', "Before transaction, DB2's 0 is Y" );
	28
	29	$db1->begin_work;
	30
	31	is( $db1->[0], 'y', "DB1 transaction started, no actions - DB1's 0 is Y" );
	32	is( $db2->[0], 'y', "DB1 transaction started, no actions - DB2's 0 is Y" );
	33
	34	$db1->[0] = 'z';
	35	is( $db1->[0], 'z', "Within DB1 transaction, DB1's 0 is Z" );
	36	is( $db2->[0], 'y', "Within DB1 transaction, DB2's 0 is still Y" );
	37
	38	$db2->[1] = 'foo';
	39	is( $db2->[1], 'foo', "DB2 set 1 within DB1's transaction, so DB2 can see it" );
	40	ok( !exists $db1->[1], "Since 1 was added after the transaction began, DB1 doesn't see it." );
	41
	42	cmp_ok( scalar(@$db1), '==', 1, "DB1 has 1 element" );
	43	cmp_ok( scalar(@$db2), '==', 2, "DB2 has 2 elements" );
	44
	45	$db1->rollback;
	46
	47	is( $db1->[0], 'y', "After rollback, DB1's 0 is Y" );
	48	is( $db2->[0], 'y', "After rollback, DB2's 0 is Y" );
	49
	50	is( $db1->[1], 'foo', "After DB1 transaction is over, DB1 can see 1" );
	51	is( $db2->[1], 'foo', "After DB1 transaction is over, DB2 can still see 1" );
	52
	53	cmp_ok( scalar(@$db1), '==', 2, "DB1 now has 2 elements" );
	54	cmp_ok( scalar(@$db2), '==', 2, "DB2 still has 2 elements" );
	55
c0780c5e	56	$db1->begin_work;
	57
	58	is( $db1->[0], 'y', "DB1 transaction started, no actions - DB1's 0 is Y" );
	59	is( $db2->[0], 'y', "DB1 transaction started, no actions - DB2's 0 is Y" );
	60
	61	$db1->[2] = 'z';
	62	is( $db1->[2], 'z', "Within DB1 transaction, DB1's 2 is Z" );
	63	ok( !exists $db2->[2], "Within DB1 transaction, DB2 cannot see 2" );
	64
	65	cmp_ok( scalar(@$db1), '==', 3, "DB1 has 3 elements" );
	66	cmp_ok( scalar(@$db2), '==', 2, "DB2 has 2 elements" );
	67
	68	$db1->commit;
	69
	70	is( $db1->[0], 'y', "After rollback, DB1's 0 is Y" );
	71	is( $db2->[0], 'y', "After rollback, DB2's 0 is Y" );
	72
	73	is( $db1->[2], 'z', "After DB1 transaction is over, DB1 can still see 2" );
	74	is( $db2->[2], 'z', "After DB1 transaction is over, DB2 can now see 2" );
	75
	76	cmp_ok( scalar(@$db1), '==', 3, "DB1 now has 2 elements" );
	77	cmp_ok( scalar(@$db2), '==', 3, "DB2 still has 2 elements" );
	78
51458ec9	79	$db1->begin_work;
	80
	81	push @$db1, 'foo';
	82	unshift @$db1, 'bar';
	83
	84	cmp_ok( scalar(@$db1), '==', 5, "DB1 now has 5 elements" );
	85	cmp_ok( scalar(@$db2), '==', 3, "DB2 still has 3 elements" );
	86
	87	is( $db1->[0], 'bar' );
	88	is( $db1->[-1], 'foo' );
	89
	90	$db1->rollback;
	91
	92	cmp_ok( scalar(@$db1), '==', 3, "DB1 is back to 3 elements" );
	93	cmp_ok( scalar(@$db2), '==', 3, "DB2 still has 3 elements" );
	94
	95	$db1->begin_work;
	96
	97	push @$db1, 'foo';
	98	unshift @$db1, 'bar';
	99
	100	cmp_ok( scalar(@$db1), '==', 5, "DB1 now has 5 elements" );
	101	cmp_ok( scalar(@$db2), '==', 3, "DB2 still has 3 elements" );
	102
	103	$db1->commit;
	104
	105	cmp_ok( scalar(@$db1), '==', 5, "DB1 is still at 5 elements" );
	106	cmp_ok( scalar(@$db2), '==', 5, "DB2 now has 5 elements" );
	107
	108	is( $db1->[0], 'bar' );
	109	is( $db1->[-1], 'foo' );
	110
	111	is( $db2->[0], 'bar' );
	112	is( $db2->[-1], 'foo' );
f9a320bb	113
	114	$db1->begin_work;
	115
	116	@$db1 = (); # clear()
	117
	118	cmp_ok( scalar(@$db1), '==', 0, "DB1 now has 0 elements" );
	119	cmp_ok( scalar(@$db2), '==', 5, "DB2 still has 5 elements" );
	120
	121	$db1->rollback;
	122
	123	cmp_ok( scalar(@$db1), '==', 5, "DB1 now has 5 elements" );
	124	cmp_ok( scalar(@$db2), '==', 5, "DB2 still has 5 elements" );
	125