mirror of
https://github.com/percona/percona-toolkit.git
synced 2025-09-14 15:33:49 +00:00
91ef89f904
* PT-2114 Incorrect casting of BIT columns by pt-archiver Added special handling of BIT columns, because by default Perl does not properly recognizes this type and creates invalid query for MySQL. Removed debugging comment from t/pt-table-checksum/pt-226.t Added test case. * PT-2114 Incorrect casting of BIT columns by pt-archiver Removed debugging comments from t/pt-deadlock-logger/standard_options.t and t/pt-table-checksum/fnv_64.t * PT-2114 Incorrect casting of BIT columns by pt-archiver Added test for archiving BIT columns. * PT-2114 Incorrect casting of BIT columns by pt-archiver Added test for bulk operations * PT-2114 Incorrect casting of BIT columns by pt-archiver Added more tests for BIT columns * PT-2114 Incorrect casting of BIT columns by pt-archiver - Improved fix for PT-2123, so it works with 5.7 - Fixed tests for PT-2114, so they work with 5.7
287 lines
7.5 KiB
Perl
287 lines
7.5 KiB
Perl
#!/usr/bin/env perl
|
|
|
|
BEGIN {
|
|
die "The PERCONA_TOOLKIT_BRANCH environment variable is not set.\n"
|
|
unless $ENV{PERCONA_TOOLKIT_BRANCH} && -d $ENV{PERCONA_TOOLKIT_BRANCH};
|
|
unshift @INC, "$ENV{PERCONA_TOOLKIT_BRANCH}/lib";
|
|
};
|
|
|
|
use strict;
|
|
use warnings FATAL => 'all';
|
|
use English qw(-no_match_vars);
|
|
use Test::More;
|
|
|
|
use PerconaTest;
|
|
use Sandbox;
|
|
require "$trunk/bin/pt-archiver";
|
|
|
|
my $dp = new DSNParser(opts=>$dsn_opts);
|
|
my $sb = new Sandbox(basedir => '/tmp', DSNParser => $dp);
|
|
my $dbh = $sb->get_dbh_for('master');
|
|
|
|
if ( !$dbh ) {
|
|
plan skip_all => 'Cannot connect to sandbox master';
|
|
}
|
|
else {
|
|
plan tests => 23;
|
|
}
|
|
|
|
my $output;
|
|
|
|
# #############################################################################
|
|
# PT-2114: Incorrect casting of BIT columns by pt-archiver
|
|
# #############################################################################
|
|
$sb->load_file('master', 't/pt-archiver/samples/pt-2114.sql');
|
|
|
|
my $zero_rows = $dbh->selectall_arrayref('select id, hex(val) from pt_2114.t1 where val = 0');
|
|
my $exit_status;
|
|
|
|
$output = output(
|
|
sub { $exit_status = pt_archiver::main(
|
|
'--source', 'h=127.1,P=12345,D=pt_2114,t=t1,u=msandbox,p=msandbox,A=utf8mb4',
|
|
'--where', '(val) in (select a.val from pt_2114.t1_tmp a where id =2)',
|
|
'--purge')
|
|
},
|
|
);
|
|
|
|
is (
|
|
$exit_status,
|
|
0,
|
|
"PT-2114 exit status OK",
|
|
);
|
|
|
|
my $left_rows = $dbh->selectall_arrayref('select id, hex(val) from pt_2114.t1');
|
|
|
|
is_deeply(
|
|
$zero_rows,
|
|
$left_rows,
|
|
"PT-2114 Only rows with val=0 left in the table"
|
|
);
|
|
|
|
my $count_rows = $dbh->selectrow_arrayref('select count(*) from pt_2114.t1');
|
|
|
|
is (
|
|
@{$count_rows}[0],
|
|
4,
|
|
"PT-2114 Four rows left in the table"
|
|
);
|
|
|
|
# #############################################################################
|
|
# Reloading dump to perform archiving
|
|
# #############################################################################
|
|
$sb->load_file('master', 't/pt-archiver/samples/pt-2114.sql');
|
|
|
|
my $one_rows = $dbh->selectall_arrayref('select id, hex(val) from pt_2114.t1 where val = 1');
|
|
|
|
$output = output(
|
|
sub { $exit_status = pt_archiver::main(
|
|
'--source', 'h=127.1,P=12345,D=pt_2114,t=t1,u=msandbox,p=msandbox,A=utf8mb4',
|
|
'--dest', 'h=127.1,P=12345,D=pt_2114,t=t2,u=msandbox,p=msandbox,A=utf8mb4',
|
|
'--where', '(val) in (select a.val from pt_2114.t1_tmp a where id =2)',
|
|
)
|
|
},
|
|
);
|
|
|
|
is (
|
|
$exit_status,
|
|
0,
|
|
"PT-2114 exit status OK",
|
|
);
|
|
|
|
$left_rows = $dbh->selectall_arrayref('select id, hex(val) from pt_2114.t1');
|
|
|
|
is_deeply(
|
|
$zero_rows,
|
|
$left_rows,
|
|
"PT-2114 Only rows with val=0 left in the table"
|
|
);
|
|
|
|
$count_rows = $dbh->selectrow_arrayref('select count(*) from pt_2114.t1');
|
|
|
|
is (
|
|
@{$count_rows}[0],
|
|
4,
|
|
"PT-2114 Four rows left in the table"
|
|
);
|
|
|
|
my $archived_rows = $dbh->selectall_arrayref('select id, hex(val) from pt_2114.t2');
|
|
|
|
is_deeply(
|
|
$one_rows,
|
|
$archived_rows,
|
|
"PT-2114 Correct rows archived"
|
|
);
|
|
|
|
# #############################################################################
|
|
# Reloading dump to perform archiving
|
|
# #############################################################################
|
|
$sb->load_file('master', 't/pt-archiver/samples/pt-2114.sql');
|
|
|
|
$output = output(
|
|
sub { $exit_status = pt_archiver::main(
|
|
'--source', 'h=127.1,P=12345,D=pt_2114,t=t1,u=msandbox,p=msandbox,A=utf8mb4,L=yes',
|
|
'--dest', 'h=127.1,P=12345,D=pt_2114,t=t2,u=msandbox,p=msandbox,A=utf8mb4,L=yes',
|
|
'--where', '(val) in (select a.val from pt_2114.t1_tmp a where id =2)',
|
|
'--bulk-insert', '--limit', '10')
|
|
},
|
|
);
|
|
|
|
is (
|
|
$exit_status,
|
|
0,
|
|
"PT-2114 exit status OK",
|
|
);
|
|
|
|
$left_rows = $dbh->selectall_arrayref('select id, hex(val) from pt_2114.t1');
|
|
|
|
is_deeply(
|
|
$zero_rows,
|
|
$left_rows,
|
|
"PT-2114 Only rows with val=0 left in the table with --bulk-insert"
|
|
);
|
|
|
|
$count_rows = $dbh->selectrow_arrayref('select count(*) from pt_2114.t1');
|
|
|
|
is (
|
|
@{$count_rows}[0],
|
|
4,
|
|
"PT-2114 Four rows left in the table"
|
|
);
|
|
|
|
$archived_rows = $dbh->selectall_arrayref('select id, hex(val) from pt_2114.t2');
|
|
|
|
is_deeply(
|
|
$one_rows,
|
|
$archived_rows,
|
|
"PT-2114 Correct rows archived with --bulk-insert"
|
|
);
|
|
|
|
# #############################################################################
|
|
# Reloading dump to perform archiving
|
|
# #############################################################################
|
|
$sb->load_file('master', 't/pt-archiver/samples/pt-2114.sql');
|
|
|
|
$output = output(
|
|
sub { $exit_status = pt_archiver::main(
|
|
'--source', 'h=127.1,P=12345,D=pt_2114,t=t1,u=msandbox,p=msandbox,A=utf8mb4,L=yes',
|
|
'--where', '(val) in (select a.val from pt_2114.t1_tmp a where id =2)',
|
|
'--bulk-delete', '--purge', '--limit', '10')
|
|
},
|
|
);
|
|
|
|
is (
|
|
$exit_status,
|
|
0,
|
|
"PT-2114 exit status OK",
|
|
);
|
|
|
|
$left_rows = $dbh->selectall_arrayref('select id, hex(val) from pt_2114.t1');
|
|
|
|
is_deeply(
|
|
$zero_rows,
|
|
$left_rows,
|
|
"PT-2114 Only rows with val=0 left in the table with --bulk-delete"
|
|
);
|
|
|
|
$count_rows = $dbh->selectrow_arrayref('select count(*) from pt_2114.t1');
|
|
|
|
is (
|
|
@{$count_rows}[0],
|
|
4,
|
|
"PT-2114 Four rows left in the table"
|
|
);
|
|
|
|
# #############################################################################
|
|
# Reloading dump to perform archiving
|
|
# #############################################################################
|
|
$sb->load_file('master', 't/pt-archiver/samples/pt-2114.sql');
|
|
|
|
# Archiving into a file
|
|
$output = output(
|
|
sub { $exit_status = pt_archiver::main(
|
|
'--where', '(val) in (select a.val from pt_2114.t1_tmp a where id =2)',
|
|
'--source', 'h=127.1,P=12345,D=pt_2114,t=t1,u=msandbox,p=msandbox,A=utf8mb4,L=yes',
|
|
'--file', 'archive.%D.%t', '-c', 'id'
|
|
)
|
|
},
|
|
);
|
|
|
|
is (
|
|
$exit_status,
|
|
0,
|
|
"PT-2114 exit status OK",
|
|
);
|
|
|
|
ok(-f 'archive.pt_2114.t1', 'PT-2114 Archive file written OK');
|
|
|
|
$output = `cat archive.pt_2114.t1`;
|
|
is($output, <<EOF
|
|
123
|
|
125
|
|
128
|
|
130
|
|
EOF
|
|
, 'PT-2114 Correct rows archived into the file');
|
|
`rm -f archive.pt_2114.t1`;
|
|
|
|
$left_rows = $dbh->selectall_arrayref('select id, hex(val) from pt_2114.t1');
|
|
|
|
is_deeply(
|
|
$zero_rows,
|
|
$left_rows,
|
|
"PT-2114 Only rows with val=0 left in the table after archiving into the file"
|
|
);
|
|
|
|
$count_rows = $dbh->selectrow_arrayref('select count(*) from pt_2114.t1');
|
|
|
|
is (
|
|
@{$count_rows}[0],
|
|
4,
|
|
"PT-2114 Four rows left in the table"
|
|
);
|
|
|
|
# #############################################################################
|
|
# Longer BIT values
|
|
# Loading dump to perform archiving
|
|
# #############################################################################
|
|
$sb->load_file('master', 't/pt-archiver/samples/pt-2114-2.sql');
|
|
my $not_archived_rows = $dbh->selectall_arrayref("select id, hex(val) from pt_2114.t1 where val = b'1111000010'");
|
|
|
|
$output = output(
|
|
sub { $exit_status = pt_archiver::main(
|
|
'--source', 'h=127.1,P=12345,D=pt_2114,t=t1,u=msandbox,p=msandbox,A=utf8mb4',
|
|
'--where', '(val) in (select a.val from pt_2114.t1_tmp a where id =2)',
|
|
'--purge')
|
|
},
|
|
);
|
|
|
|
is (
|
|
$exit_status,
|
|
0,
|
|
"PT-2114 exit status OK",
|
|
);
|
|
|
|
$left_rows = $dbh->selectall_arrayref('select id, hex(val) from pt_2114.t1');
|
|
|
|
is_deeply(
|
|
$not_archived_rows,
|
|
$left_rows,
|
|
"PT-2114 Only rows with val=0 left in the table"
|
|
);
|
|
|
|
$count_rows = $dbh->selectrow_arrayref('select count(*) from pt_2114.t1');
|
|
|
|
is (
|
|
@{$count_rows}[0],
|
|
4,
|
|
"PT-2114 Four rows left in the table"
|
|
);
|
|
|
|
|
|
# #############################################################################
|
|
# Done.
|
|
# #############################################################################
|
|
$sb->wipe_clean($dbh);
|
|
ok($sb->ok(), "Sandbox servers") or BAIL_OUT(__FILE__ . " broke the sandbox");
|
|
exit;
|