percona/percona-toolkit
1
0
Fork 0
mirror of https://github.com/percona/percona-toolkit.git synced 2025-12-25 02:01:13 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #769 from percona/PT-2295_Fix_tests_on_distributions

Browse Source 
PT-2295 - fix tests on distributions
This commit is contained in:
Sveta Smirnova
2024-03-15 16:24:29 +03:00
committed by GitHub
parent da2e22b785 f46aad842b
commit e9ec7213f4
29 changed files with 152 additions and 39 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
bin/pt-archiver
View File

@@ -4076,8 +4076,14 @@ sub get_master_status {
return;
}
my $sth = $self->{sths}->{$dbh}->{MASTER_STATUS}
my $sth;
if ( $self->{sths}->{$dbh} && $dbh && $self->{sths}->{$dbh} == $dbh ) {
$sth = $self->{sths}->{$dbh}->{MASTER_STATUS}
||= $dbh->prepare('SHOW MASTER STATUS');
}
else {
$sth = $dbh->prepare('SHOW MASTER STATUS');
}
PTDEBUG && _d($dbh, 'SHOW MASTER STATUS');
$sth->execute();
my ($ms) = @{$sth->fetchall_arrayref({})};
@@ -4728,7 +4734,9 @@ sub lost_connection {
my ($self, $e) = @_;
return 0 unless $e;
return $e =~ m/MySQL server has gone away/
|| $e =~ m/Server has gone away/
|| $e =~ m/Lost connection to MySQL server/
|| $e =~ m/Lost connection to server/
|| $e =~ m/Server shutdown in progress/;
}

2
bin/pt-config-diff
View File

@@ -2433,7 +2433,9 @@ sub lost_connection {
my ($self, $e) = @_;
return 0 unless $e;
return $e =~ m/MySQL server has gone away/
|| $e =~ m/Server has gone away/
|| $e =~ m/Lost connection to MySQL server/
|| $e =~ m/Lost connection to server/
|| $e =~ m/Server shutdown in progress/;
}

2
bin/pt-deadlock-logger
View File

@@ -2777,7 +2777,9 @@ sub lost_connection {
my ($self, $e) = @_;
return 0 unless $e;
return $e =~ m/MySQL server has gone away/
|| $e =~ m/Server has gone away/
|| $e =~ m/Lost connection to MySQL server/
|| $e =~ m/Lost connection to server/
|| $e =~ m/Server shutdown in progress/;
}

2
bin/pt-fk-error-logger
View File

@@ -1931,7 +1931,9 @@ sub lost_connection {
my ($self, $e) = @_;
return 0 unless $e;
return $e =~ m/MySQL server has gone away/
|| $e =~ m/Server has gone away/
|| $e =~ m/Lost connection to MySQL server/
|| $e =~ m/Lost connection to server/
|| $e =~ m/Server shutdown in progress/;
}

8
bin/pt-heartbeat
View File

@@ -553,8 +553,14 @@ sub get_master_status {
return;
}
my $sth = $self->{sths}->{$dbh}->{MASTER_STATUS}
my $sth;
if ( $self->{sths}->{$dbh} && $dbh && $self->{sths}->{$dbh} == $dbh ) {
$sth = $self->{sths}->{$dbh}->{MASTER_STATUS}
||= $dbh->prepare('SHOW MASTER STATUS');
}
else {
$sth = $dbh->prepare('SHOW MASTER STATUS');
}
PTDEBUG && _d($dbh, 'SHOW MASTER STATUS');
$sth->execute();
my ($ms) = @{$sth->fetchall_arrayref({})};

16
bin/pt-kill
View File

@@ -4353,8 +4353,14 @@ sub get_master_status {
return;
}
my $sth = $self->{sths}->{$dbh}->{MASTER_STATUS}
my $sth;
if ( $self->{sths}->{$dbh} && $dbh && $self->{sths}->{$dbh} == $dbh ) {
$sth = $self->{sths}->{$dbh}->{MASTER_STATUS}
||= $dbh->prepare('SHOW MASTER STATUS');
}
else {
$sth = $dbh->prepare('SHOW MASTER STATUS');
}
PTDEBUG && _d($dbh, 'SHOW MASTER STATUS');
$sth->execute();
my ($ms) = @{$sth->fetchall_arrayref({})};
@@ -5543,7 +5549,9 @@ sub lost_connection {
my ($self, $e) = @_;
return 0 unless $e;
return $e =~ m/MySQL server has gone away/
|| $e =~ m/Server has gone away/
|| $e =~ m/Lost connection to MySQL server/
|| $e =~ m/Lost connection to server/
|| $e =~ m/Server shutdown in progress/;
}
@@ -7177,6 +7185,8 @@ sub main {
# The 1st pattern means that MySQL itself died or was stopped.
# The 2nd pattern means that our cxn was killed (KILL <id>).
if ( $error =~ m/MySQL server has gone away/
|| $error =~ m/Server has gone away/
|| $error =~ m/Lost connection to server/
|| $error =~ m/Lost connection to MySQL server/ ) {
eval {
$dbh = $cxn->connect();
@@ -7210,6 +7220,8 @@ sub main {
# The 1st pattern means that MySQL itself died or was stopped.
# The 2nd pattern means that our cxn was killed (KILL <id>).
if ( $error =~ m/MySQL server has gone away/
|| $error =~ m/Server has gone away/
|| $error =~ m/Lost connection to server/
|| $error =~ m/Lost connection to MySQL server/ ) {
eval {
$dbh = $cxn->connect();
@@ -7299,6 +7311,8 @@ sub main {
# The 1st pattern means that MySQL itself died or was stopped.
# The 2nd pattern means that our cxn was killed (KILL <id>).
if ( $error =~ m/MySQL server has gone away/
|| $error =~ m/Server has gone away/
|| $error =~ m/Lost connection to server/
|| $error =~ m/Lost connection to MySQL server/ ) {
eval {
$log_dbh = $log_cxn->connect();

2
bin/pt-mysql-summary
View File

@@ -2571,7 +2571,7 @@ report_mysql_summary () {
fi
fi
local has_rocksdb=$(cat $dir/mysql-plugins | grep -i 'rocksdb.*active.*storage engine')
local has_rocksdb="$(cat $dir/mysql-plugins | grep -i 'rocksdb.*active.*storage engine')"
if [ ! -z "$has_rocksdb" ]; then
section "RocksDB"
section_rocksdb "$dir/mysql-variables" "$dir/mysql-status"

20
bin/pt-online-schema-change
View File

@@ -4039,7 +4039,9 @@ sub lost_connection {
my ($self, $e) = @_;
return 0 unless $e;
return $e =~ m/MySQL server has gone away/
|| $e =~ m/Server has gone away/
|| $e =~ m/Lost connection to MySQL server/
|| $e =~ m/Lost connection to server/
|| $e =~ m/Server shutdown in progress/;
}
@@ -4639,8 +4641,14 @@ sub get_master_status {
return;
}
my $sth = $self->{sths}->{$dbh}->{MASTER_STATUS}
my $sth;
if ( $self->{sths}->{$dbh} && $dbh && $self->{sths}->{$dbh} == $dbh ) {
$sth = $self->{sths}->{$dbh}->{MASTER_STATUS}
||= $dbh->prepare('SHOW MASTER STATUS');
}
else {
$sth = $dbh->prepare('SHOW MASTER STATUS');
}
PTDEBUG && _d($dbh, 'SHOW MASTER STATUS');
$sth->execute();
my ($ms) = @{$sth->fetchall_arrayref({})};
@@ -9364,6 +9372,7 @@ sub main {
# and the mentioned test error doesn't arise
my $original_error = $EVAL_ERROR;
my $original_error_code = $?;
foreach my $task ( reverse @cleanup_tasks ) {
eval {
@@ -9373,7 +9382,14 @@ sub main {
warn "Error cleaning up: $EVAL_ERROR\n";
}
}
die $original_error if $original_error; # rethrow original error
# rethrow original error
# we do not call _die here, because it prints messages to STDOUT
if ($original_error) {
print STDERR $original_error;
exit $original_error_code;
}
return;
}
);

8
bin/pt-query-digest
View File

@@ -10947,8 +10947,14 @@ sub get_master_status {
return;
}
my $sth = $self->{sths}->{$dbh}->{MASTER_STATUS}
my $sth;
if ( $self->{sths}->{$dbh} && $dbh && $self->{sths}->{$dbh} == $dbh ) {
$sth = $self->{sths}->{$dbh}->{MASTER_STATUS}
||= $dbh->prepare('SHOW MASTER STATUS');
}
else {
$sth = $dbh->prepare('SHOW MASTER STATUS');
}
PTDEBUG && _d($dbh, 'SHOW MASTER STATUS');
$sth->execute();
my ($ms) = @{$sth->fetchall_arrayref({})};

8
bin/pt-slave-find
View File

@@ -2689,8 +2689,14 @@ sub get_master_status {
return;
}
my $sth = $self->{sths}->{$dbh}->{MASTER_STATUS}
my $sth;
if ( $self->{sths}->{$dbh} && $dbh && $self->{sths}->{$dbh} == $dbh ) {
$sth = $self->{sths}->{$dbh}->{MASTER_STATUS}
||= $dbh->prepare('SHOW MASTER STATUS');
}
else {
$sth = $dbh->prepare('SHOW MASTER STATUS');
}
PTDEBUG && _d($dbh, 'SHOW MASTER STATUS');
$sth->execute();
my ($ms) = @{$sth->fetchall_arrayref({})};

8
bin/pt-slave-restart
View File

@@ -3100,8 +3100,14 @@ sub get_master_status {
return;
}
my $sth = $self->{sths}->{$dbh}->{MASTER_STATUS}
my $sth;
if ( $self->{sths}->{$dbh} && $dbh && $self->{sths}->{$dbh} == $dbh ) {
$sth = $self->{sths}->{$dbh}->{MASTER_STATUS}
||= $dbh->prepare('SHOW MASTER STATUS');
}
else {
$sth = $dbh->prepare('SHOW MASTER STATUS');
}
PTDEBUG && _d($dbh, 'SHOW MASTER STATUS');
$sth->execute();
my ($ms) = @{$sth->fetchall_arrayref({})};

10
bin/pt-table-checksum
View File

@@ -3738,7 +3738,9 @@ sub lost_connection {
my ($self, $e) = @_;
return 0 unless $e;
return $e =~ m/MySQL server has gone away/
|| $e =~ m/Server has gone away/
|| $e =~ m/Lost connection to MySQL server/
|| $e =~ m/Lost connection to server/
|| $e =~ m/Server shutdown in progress/;
}
@@ -5602,8 +5604,14 @@ sub get_master_status {
return;
}
my $sth = $self->{sths}->{$dbh}->{MASTER_STATUS}
my $sth;
if ( $self->{sths}->{$dbh} && $dbh && $self->{sths}->{$dbh} == $dbh ) {
$sth = $self->{sths}->{$dbh}->{MASTER_STATUS}
||= $dbh->prepare('SHOW MASTER STATUS');
}
else {
$sth = $dbh->prepare('SHOW MASTER STATUS');
}
PTDEBUG && _d($dbh, 'SHOW MASTER STATUS');
$sth->execute();
my ($ms) = @{$sth->fetchall_arrayref({})};

8
bin/pt-table-sync
View File

@@ -7118,8 +7118,14 @@ sub get_master_status {
return;
}
my $sth = $self->{sths}->{$dbh}->{MASTER_STATUS}
my $sth;
if ( $self->{sths}->{$dbh} && $dbh && $self->{sths}->{$dbh} == $dbh ) {
$sth = $self->{sths}->{$dbh}->{MASTER_STATUS}
||= $dbh->prepare('SHOW MASTER STATUS');
}
else {
$sth = $dbh->prepare('SHOW MASTER STATUS');
}
PTDEBUG && _d($dbh, 'SHOW MASTER STATUS');
$sth->execute();
my ($ms) = @{$sth->fetchall_arrayref({})};

2
bin/pt-upgrade
View File

@@ -2604,7 +2604,9 @@ sub lost_connection {
my ($self, $e) = @_;
return 0 unless $e;
return $e =~ m/MySQL server has gone away/
|| $e =~ m/Server has gone away/
|| $e =~ m/Lost connection to MySQL server/
|| $e =~ m/Lost connection to server/
|| $e =~ m/Server shutdown in progress/;
}

2
lib/Cxn.pm
View File

@@ -204,7 +204,9 @@ sub lost_connection {
my ($self, $e) = @_;
return 0 unless $e;
return $e =~ m/MySQL server has gone away/
|| $e =~ m/Server has gone away/
|| $e =~ m/Lost connection to MySQL server/
|| $e =~ m/Lost connection to server/
|| $e =~ m/Server shutdown in progress/;
# The 1st pattern means that MySQL itself died or was stopped.
# The 2nd pattern means that our cxn was killed (KILL <id>).

8
lib/MasterSlave.pm
View File

@@ -538,8 +538,14 @@ sub get_master_status {
return;
}
my $sth = $self->{sths}->{$dbh}->{MASTER_STATUS}
my $sth;
if ( $self->{sths}->{$dbh} && $dbh && $self->{sths}->{$dbh} == $dbh ) {
$sth = $self->{sths}->{$dbh}->{MASTER_STATUS}
||= $dbh->prepare('SHOW MASTER STATUS');
}
else {
$sth = $dbh->prepare('SHOW MASTER STATUS');
}
PTDEBUG && _d($dbh, 'SHOW MASTER STATUS');
$sth->execute();
my ($ms) = @{$sth->fetchall_arrayref({})};

2
lib/bash/report_mysql_info.sh
View File

@@ -1547,7 +1547,7 @@ report_mysql_summary () {
fi
fi
local has_rocksdb=$(cat $dir/mysql-plugins | grep -i 'rocksdb.*active.*storage engine')
local has_rocksdb="$(cat $dir/mysql-plugins | grep -i 'rocksdb.*active.*storage engine')"
if [ ! -z "$has_rocksdb" ]; then
section "RocksDB"
section_rocksdb "$dir/mysql-variables" "$dir/mysql-status"

16
t/lib/KeySize.t
View File

@@ -17,6 +17,7 @@ use Quoter;
use DSNParser;
use Sandbox;
use PerconaTest;
require VersionParser;
my $dp = new DSNParser(opts=>$dsn_opts);
my $sb = new Sandbox(basedir => '/tmp', DSNParser => $dp);
@@ -64,13 +65,18 @@ is(
# Populate the table to make the WHERE possible.
$dbh->do('INSERT INTO test.dupe_key VALUE (1,2,3),(4,5,6),(7,8,9),(0,0,0)');
is_deeply(
[$ks->get_key_size(%key)],
[20, 'a'],
'Single column int key'
);
SKIP: {
skip "MySQL error https://bugs.mysql.com/bug.php?id=113892", 1 if ($sandbox_version ge '8.0' and VersionParser->new($dbh) ge '8.0.35');
is_deeply(
[$ks->get_key_size(%key)],
[20, 'a'],
'Single column int key'
);
}
$key{name} = 'a_2';
$key{cols} = $key{tbl_struct}->{keys}->{'a_2'}->{cols};
is_deeply(
[$ks->get_key_size(%key)],
[40, 'a_2'],

2
t/lib/TableParser.t
View File

@@ -753,7 +753,7 @@ SKIP: {
# msandbox user does not have GRANT privs.
my $root_dbh = DBI->connect(
"DBI:mysql:host=127.0.0.1;port=12345;mysql_ssl=1", 'root', 'msandbox',
"DBI:mysql:host=127.0.0.1;port=12345", 'root', 'msandbox',
{ PrintError => 0, RaiseError => 1 });
$root_dbh->do(q[CREATE USER 'user'@'%' IDENTIFIED BY '';] ) || die($root_dbh->errstr);

10
t/lib/bash/collect.sh
View File

@@ -169,7 +169,7 @@ fi
# Try longer run time.
# ###########################################################################
parse_options "$BIN_DIR/pt-stalk" --run-time 2 -- --defaults-file=/tmp/12345/my.sandbox.cnf
parse_options "$BIN_DIR/pt-stalk" --run-time 3 -- --defaults-file=/tmp/12345/my.sandbox.cnf
rm $PT_TMPDIR/collect/*
@@ -193,7 +193,11 @@ CMD_OPCONTROL=""
OPT_COLLECT_OPROFILE=""
iters=$(cat $p-df | grep -c '^TS ')
is "$iters" "2" "2 iteration/2s run time"
# We need to adjust result on slow machines
if [ $iters -eq 2 ]; then
iters=3;
fi
is "$iters" "3" "2 or 3 iteration/3s run time"
is \
"$(cat "$fake_out")" \
@@ -204,7 +208,7 @@ if [ -f "$p-vmstat" ]; then
n=$(awk '/[ ]*[0-9]/ { n += 1 } END { print n }' "$p-vmstat")
is \
"$n" \
"2" \
"3" \
"vmstat runs for --run-time seconds (bug 955860)"
else
is "1" "1" "SKIP vmstat not installed"

5
t/pt-archiver/pt-2064.t
View File

@@ -37,6 +37,9 @@ $sb->create_dbs($master_dbh, ['test']);
$sb->load_file('master', 't/pt-archiver/samples/table1.sql');
$sb->wait_for_slaves();
my $old_innodb_lock_wait_timeout = `/tmp/12345/use -ss -e 'select \@\@global.innodb_lock_wait_timeout'`;
chomp $old_innodb_lock_wait_timeout;
$master_dbh->do('set global innodb_lock_wait_timeout=1');
$master_dbh->do('begin');
@@ -59,7 +62,7 @@ unlike(
# #############################################################################
# Done.
# #############################################################################
$master_dbh->do('set global innodb_lock_wait_timeout=DEFAULT');
$master_dbh->do("set global innodb_lock_wait_timeout=$old_innodb_lock_wait_timeout");
$sb->wipe_clean($master_dbh);
ok($sb->ok(), "Sandbox servers") or BAIL_OUT(__FILE__ . " broke the sandbox");

4
t/pt-online-schema-change/pt-169.t
View File

@@ -63,7 +63,7 @@ is(
$exit_status,
$ERROR_UPDATING_FKS,
"--alter rename columns with uppercase names -> exit status 0",
);
) or diag($output);
# 2
# Since drop_swap has failed, the clueanup process should be skipped and the new table
@@ -73,7 +73,7 @@ is (
$row->{how_many},
1,
"Correct number of rows",
);
) or diag($row);
$master_dbh->do("DROP DATABASE IF EXISTS test");

4
t/pt-query-digest/explain.t
View File

@@ -145,9 +145,11 @@ ok(
: $sandbox_version ge '5.6' ? "t/pt-query-digest/samples/issue_1196-output-5.6.txt"
: $sandbox_version ge '5.1' ? "t/pt-query-digest/samples/issue_1196-output.txt"
: "t/pt-query-digest/samples/issue_1196-output-5.0.txt"),
keep_output => 1,
),
"--explain sparkline uses event db and doesn't crash ea (issue 1196)"
);
) or diag(`cat /tmp/percona-toolkit-test-output.txt`);
diag(`rm /tmp/percona-toolkit-test-output.txt`);
# #############################################################################
# Done.

1
t/pt-stalk/plugin.t
View File

@@ -70,5 +70,6 @@ foreach my $hook (qw(
diag(`rm $pid_file 2>/dev/null`);
diag(`rm $log_file 2>/dev/null`);
diag(`rm -rf $dest 2>/dev/null`);
$sb->wipe_clean($dbh);
ok($sb->ok(), "Sandbox servers") or BAIL_OUT(__FILE__ . " broke the sandbox");
done_testing;

1
t/pt-stalk/pt-stalk-replication.t
View File

@@ -78,5 +78,6 @@ is(
cleanup();
$sb->wipe_clean($dbh);
ok($sb->ok(), "Sandbox servers") or BAIL_OUT(__FILE__ . " broke the sandbox");
done_testing;

4
t/pt-stalk/pt-stalk.t
View File

@@ -507,7 +507,7 @@ is(
$output,
0,
"Retention test 3: tests, matched auto-generated patern, are removed"
);
) or diag(`ls -l $dest`);
# ###########################################################################
# Test if retention by size works as expected
@@ -993,8 +993,8 @@ SKIP: {
# Done.
# #############################################################################
cleanup();
diag(`rm -rf $dest 2>/dev/null`);
$sb->wipe_clean($dbh);
ok($sb->ok(), "Sandbox servers") or BAIL_OUT(__FILE__ . " broke the sandbox");
done_testing;

14
t/pt-table-checksum/basics.t
View File

@@ -77,20 +77,22 @@ sub reset_repl_db {
# from this table after they have been added, so we cannot remove them when wipe cleaning
# sandbox. See https://dev.mysql.com/doc/refman/8.0/en/privileges-provided.html#static-dynamic-privileges
# This test often fails if run after other tests, we need to see what is wrong
# So we will re-run failed code if test does not pass.
# This test randomly reports diffs for tables with TIMESTAMP columns
# that have ON UPDATE action.
# Therefore we are filtering such tables from the diff
my $cmd = sub { pt_table_checksum::main(@args) };
diag(output($cmd)) if not ok(
ok(
no_diff(
$cmd,
"$sample/default-results-$sandbox_version.txt",
sed_out => '\'/mysql.plugin$/d; /percona_test.checksums$/d; /mysql.help_category$/d; /mysql.help_keyword$/d; /mysql.help_relation$/d; /mysql.help_topic$/d\'',
post_pipe => 'sed \'/mysql.plugin$/d; /percona_test.checksums$/d; /mysql.help_category$/d; /mysql.help_keyword$/d; /mysql.help_relation$/d; /mysql.help_topic$/d; /mysql.ndb_binlog_index$/d; /mysql.global_grants$/d\' | ' .
sed_out => '\'/mysql.plugin$/d; /percona_test.checksums$/d; /mysql.help_category$/d; /mysql.help_keyword$/d; /mysql.help_relation$/d; /mysql.help_topic$/d; /mysql.columns_priv$/d; /mysql.engine_cost$/d; /mysql.general_log$/d; /mysql.innodb_index_stats$/d; /mysql.innodb_table_stats$/d; /mysql.password_history$/d; /mysql.procs_priv$/d; /mysql.proxies_priv$/d; /mysql.server_cost$/d; /mysql.slow_log$/d; /mysql.tables_priv$/d\'',
post_pipe => 'sed \'/mysql.plugin$/d; /percona_test.checksums$/d; /mysql.help_category$/d; /mysql.help_keyword$/d; /mysql.help_relation$/d; /mysql.help_topic$/d; /mysql.ndb_binlog_index$/d; /mysql.global_grants$/d; /mysql.columns_priv$/d; /mysql.engine_cost$/d; /mysql.general_log$/d; /mysql.innodb_index_stats$/d; /mysql.innodb_table_stats$/d; /mysql.password_history$/d; /mysql.procs_priv$/d; /mysql.proxies_priv$/d; /mysql.server_cost$/d; /mysql.slow_log$/d; /mysql.tables_priv$/d\' | ' .
'awk \'{print $2 " " $3 " " $4 " " $7 " " $9}\'',
keep_ouput => 1,
),
"Default checksum"
);
) or diag($test_diff);
# On fast machines, the chunk size will probably be be auto-adjusted so
# large that all tables will be done in a single chunk without an index.

4
t/pt-table-checksum/progress.t
View File

@@ -48,7 +48,7 @@ else {
# worse. This is a random stab in the dark. There is a problem either way.)
my $master_dsn = 'h=127.1,P=12345,u=msandbox,p=msandbox';
my @args = ($master_dsn, qw(--set-vars innodb_lock_wait_timeout=3),
'--chunk-size', '200');
'--chunk-size', '50');
my $output;
my $row;
my $scripts = "$trunk/t/pt-table-checksum/scripts/";
@@ -83,7 +83,7 @@ like(
$output,
qr/Replica h=127.0.0.1,P=12347 is stopped/,
"--progress for slave lag"
);
) or diag($output);
like(
$output,

8
t/pt-table-sync/specify_column_or_index.t
View File

@@ -35,21 +35,23 @@ $sb->wipe_clean($master_dbh);
$sb->wipe_clean($slave_dbh);
# #############################################################################
# Issue 376: Permit specifying an index for mk-table-sync
# Issue 376: Permit specifying an index for pt-table-sync
# #############################################################################
diag(`/tmp/12345/use < $trunk/t/pt-table-sync/samples/issue_375.sql`);
sleep 1;
$output = `$trunk/bin/pt-table-sync --sync-to-master h=127.1,P=12346,u=msandbox,p=msandbox -d issue_375 --print -v -v --chunk-size 50 --chunk-index updated_at`;
# We cannot rely on the exact time here, because pt-osc uses EXPLAIN to calculate rows range
# and EXPLAIN does not guarantee accuracy of results.
like(
$output,
qr/FROM `issue_375`.`t` FORCE INDEX \(`updated_at`\) WHERE \(`updated_at` > 0 AND `updated_at` < '2009-09-05 02:38:12'/,
qr/FROM `issue_375`.`t` FORCE INDEX \(`updated_at`\) WHERE \(`updated_at` > 0 AND `updated_at` < '2009-09-05 02:\d\d:\d\d'/,
'--chunk-index',
);
$output = `$trunk/bin/pt-table-sync --sync-to-master h=127.1,P=12346,u=msandbox,p=msandbox -d issue_375 --print -v -v --chunk-size 50 --chunk-column updated_at`;
like(
$output,
qr/FROM `issue_375`.`t` FORCE INDEX \(`updated_at`\) WHERE \(`updated_at` > 0 AND `updated_at` < '2009-09-05 02:38:12'/,
qr/FROM `issue_375`.`t` FORCE INDEX \(`updated_at`\) WHERE \(`updated_at` > 0 AND `updated_at` < '2009-09-05 02:\d\d:\d\d'/,
'--chunk-column',
);