Add new test for conflicts

diff --git a/MANIFEST b/MANIFEST
index f0c6b78cb44a005795b89d6497b405bab1f2c5f1..5f8c87c4d5fc8ac17037b257a6c7a1c2ca0c1153 100644 (file)
--- a/MANIFEST
+++ b/MANIFEST
@@ -46,6 +46,7 @@ t/20-redis.t
 t/20-sqlite.t
 t/30-crash.t
 t/30-delta.t
+t/40-conflict.t
 t/40-customcode-exception.t
 t/40-serializable.t
 t/98-cleanup.t

diff --git a/t/40-conflict.t b/t/40-conflict.t
new file mode 100644 (file)
index 0000000..fc96eb3
--- /dev/null
+++ b/t/40-conflict.t
@@ -0,0 +1,114 @@
+#!/usr/bin/env perl
+# -*-mode:cperl; indent-tabs-mode: nil-*-
+
+## Test of conflicts
+
+use 5.008003;
+use strict;
+use warnings;
+use Data::Dumper;
+use lib 't','.';
+use DBD::Pg;
+use Test::More;
+
+use vars qw/ $dbhX $dbhA $dbhB $dbhC $dbhD $res $command $t $SQL %pkey %sth %sql $sth $count $val /;
+
+use BucardoTesting;
+my $bct = BucardoTesting->new({location => 'conflict'})
+    or BAIL_OUT "Creation of BucardoTesting object failed\n";
+
+END {
+    $bct and $bct->stop_bucardo($dbhX);
+    $dbhX and $dbhX->disconnect();
+    $dbhA and $dbhA->disconnect();
+    $dbhB and $dbhB->disconnect();
+    $dbhC and $dbhC->disconnect();
+}
+
+## Get A, B, and C created, emptied out, and repopulated with sample data
+$dbhA = $bct->repopulate_cluster('A');
+$dbhB = $bct->repopulate_cluster('B');
+$dbhC = $bct->repopulate_cluster('C');
+$dbhD = $bct->repopulate_cluster('D');
+
+## Store into hashes for convenience
+
+my %dbh = (A=>$dbhA, B=>$dbhB, C=>$dbhC, D=>$dbhD);
+
+## Create a bucardo database, and install Bucardo into it
+$dbhX = $bct->setup_bucardo('A');
+
+## Teach Bucardo about three databases
+for my $name (qw/ A B C D/) {
+    $t = "Adding database from cluster $name works";
+    my ($dbuser,$dbport,$dbhost) = $bct->add_db_args($name);
+    $command = "bucardo add db $name dbname=bucardo_test user=$dbuser port=$dbport host=$dbhost";
+    $res = $bct->ctl($command);
+    like ($res, qr/Added database "$name"/, $t);
+}
+
+$bct->ctl('bucardo remove dbgroup ctest');
+$bct->ctl('bucardo remove relgroup ctest');
+
+## Create a new dbgroup with three sources and one target
+$t = q{Created a new dbgroup ctest for ( A <=> B <=> C ) -> D};
+$res = $bct->ctl('bucardo add dbgroup ctest A:source B:source C:source D:target');
+like ($res, qr/Created dbgroup "ctest"/, $t);
+
+## Create a new relgroup with all tables
+$t = q{Created a new relgroup ctest};
+$res = $bct->ctl('bucardo add relgroup ctest all');
+like ($res, qr/Created relgroup "ctest"/, $t);
+
+## Create a new sync
+$t = q{Created a new sync named ctest};
+$res = $bct->ctl('bucardo add sync ctest dbgroup=ctest relgroup=ctest autokick=false');
+like ($res, qr/Added sync "ctest"/, $t);
+
+## Start listening for a syncdone message
+$dbhX->do('LISTEN bucardo_syncdone_ctest');
+$dbhX->commit();
+
+## Start up Bucardo
+$bct->restart_bucardo($dbhX);
+
+## No conflict, just update some rows to make sure the sync is working
+$bct->add_row_to_database('A', 1);
+$bct->ctl('bucardo kick sync ctest 10');
+$bct->check_for_row([[1]], [qw/ B C D/]);
+
+## Create a conflict
+$bct->add_row_to_database('A', 2);
+$bct->add_row_to_database('B', 2);
+$bct->add_row_to_database('C', 2);
+
+$bct->ctl('bucardo kick sync ctest 10');
+$bct->check_for_row([[1],[2]], [qw/ B C D/]);
+
+$t = q{Cannot set conflict handler to invalid database name};
+$res = $bct->ctl('bucardo update sync ctest conflict="a b c"');
+like($res, qr{is not a db for this sync}, $t);
+
+## Create another conflict, but change our tactics
+$t = q{Set conflict handler to valid database name list};
+$res = $bct->ctl('bucardo update sync ctest conflict="C A B"');
+like($res, qr{Set conflict strategy}, $t);
+
+$bct->ctl('bucardo reload sync ctest');
+
+$bct->update_row_in_database('A', 1, 111);
+$bct->update_row_in_database('C', 1, 333);
+$bct->update_row_in_database('B', 1, 222);
+
+## Database C should be the winner
+$bct->ctl('bucardo kick sync ctest 10');
+$bct->check_for_row([[2],[333]], [qw/ A B C D/]);
+
+## Same thing, but C is not changed, so A should win
+$bct->update_row_in_database('A', 1, 1111);
+$bct->update_row_in_database('B', 1, 2222);
+$bct->ctl('bucardo kick sync ctest 10');
+$bct->check_for_row([[2],[1111]], [qw/ A B C D/]);
+
+done_testing();
+exit;