percona/percona-toolkit
1
0
Fork 0
mirror of https://github.com/percona/percona-toolkit.git synced 2025-09-25 05:44:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

Modernize and make pt-table-sync/master_master.t stable.

Browse Source
This commit is contained in:
Daniel Nichter
2012-06-06 22:13:20 -04:00
parent d2c63e1030
commit e43b4e15ca
1 changed files with 56 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

74
t/pt-table-sync/master_master.t
View File

@@ -9,40 +9,78 @@ BEGIN {
use strict;
use warnings FATAL => 'all';
use English qw(-no_match_vars);
use Test::More tests => 1;
use Test::More tests => 4;
use PerconaTest;
use Sandbox;
require "$trunk/bin/pt-table-sync";
my $output;
my $dp = new DSNParser(opts=>$dsn_opts);
my $sb = new Sandbox(basedir => '/tmp', DSNParser => $dp);
# #############################################################################
# Ensure that syncing master-master works OK
# #############################################################################
# Sometimes I skip this test if I'm proving mk-table-sync over and over.
SKIP: {
skip "I'm impatient", 1 if 0;
# Start up 12348 <-> 12349
diag('Starting master-master servers...');
diag(`$trunk/sandbox/start-sandbox master-master 12348 12349 >/dev/null`);
my $master1_dbh = $sb->get_dbh_for('master1');
my $master2_dbh = $sb->get_dbh_for('master2');
diag(`$trunk/sandbox/start-sandbox master-master 12348 12349 >/dev/null`);
diag(`/tmp/12348/use -e 'CREATE DATABASE test'`);
diag(`/tmp/12348/use < $trunk/t/pt-table-sync/samples/before.sql`);
# Load some tables and data (on both, since they're master-master).
$master1_dbh->do("CREATE DATABASE test");
$sb->load_file("master1", "t/pt-table-sync/samples/before.sql");
PerconaTest::wait_for_table($master2_dbh, "test.test1", "a=2");
# Make master2 different from master1
diag(`/tmp/12349/use -e 'set sql_log_bin=0;update test.test1 set b="mm" where a=1'`);
# Make master2 different from master1. So master2 has the _correct_ data,
# and the sync below will make master1 have that data too.
$master2_dbh->do("set sql_log_bin=0");
$master2_dbh->do("update test.test1 set b='mm' where a=1");
$master2_dbh->do("set sql_log_bin=1");
# This will make master1's data match the changed data on master2 (that is not
# a typo).
`$trunk/bin/pt-table-sync --no-check-slave --sync-to-master --print --execute h=127.0.0.1,P=12348,u=msandbox,p=msandbox,D=test,t=test1`;
sleep 1;
# This will make master1's data match the changed, correcct data on master2
# (that is _not_ a typo). The sync direction is therefore master2 -> master1
# because, given the command below, the given host master1 and with
# --sync-to-master that makes master2 "the" master with the correct data.
my $exit_status = 0;
my $output = output(
sub {
$exit_status = pt_table_sync::main(
qw(--no-check-slave --sync-to-master --print --execute),
"h=127.0.0.1,P=12348,u=msandbox,p=msandbox,D=test,t=test1")
},
);
$output = `/tmp/12348/use -e 'select b from test.test1 where a=1' -N`;
like($output, qr/mm/, 'Master-master sync worked');
# 0 = ok no diffs
# 1 = error
# >1 = sum(@status{@ChangeHandler::ACTIONS})
is(
$exit_status,
2,
"Exit status 2"
);
diag(`$trunk/sandbox/stop-sandbox 12348 12349 >/dev/null`);
};
like(
$output,
qr/REPLACE INTO `test`\.`test1`\s*\(`a`, `b`\) VALUES\s*\('1', 'mm'\)/,
"SQL to sync diff"
);
PerconaTest::wait_for_table($master1_dbh, "test.test1", "a=1 and b='mm'");
my $rows = $master1_dbh->selectall_arrayref("SELECT * FROM test.test1");
is_deeply(
$rows,
[ [1, 'mm'], [2, 'ca'] ],
"Diff row synced on master1"
);
diag('Stopping master-master servers...');
diag(`$trunk/sandbox/stop-sandbox 12348 12349 >/dev/null`);
# #############################################################################
# Done.
# #############################################################################
ok($sb->ok(), "Sandbox servers") or BAIL_OUT(__FILE__ . " broke the sandbox");
exit;