mirror of
https://github.com/percona/percona-toolkit.git
synced 2025-12-23 02:00:56 +08:00
PT-118 Updated tests for pt-table-checksum/error_handling.t
This commit is contained in:
@@ -662,9 +662,9 @@ my %checksum_result_col = (
|
|||||||
rows => 3,
|
rows => 3,
|
||||||
diff_rows => 4,
|
diff_rows => 4,
|
||||||
chunks => 5,
|
chunks => 5,
|
||||||
skipped => 6,
|
skipped => 5,
|
||||||
time => 7,
|
time => 6,
|
||||||
table => 8,
|
table => 7,
|
||||||
);
|
);
|
||||||
sub count_checksum_results {
|
sub count_checksum_results {
|
||||||
my ($output, $column, $table) = @_;
|
my ($output, $column, $table) = @_;
|
||||||
@@ -697,7 +697,7 @@ sub normalize_checksum_results {
|
|||||||
open my $fh, ">", $tmp_file or die "Cannot open $tmp_file: $OS_ERROR";
|
open my $fh, ">", $tmp_file or die "Cannot open $tmp_file: $OS_ERROR";
|
||||||
printf $fh $output;
|
printf $fh $output;
|
||||||
close $fh;
|
close $fh;
|
||||||
my $normal_output = `cat $tmp_file | awk '/^[0-9 ]/ {print \$2 " " \$3 " " \$4 " " \$5 " " \$6 " " \$8} /^[A-Z]/ {print \$0}'`;
|
my $normal_output = `cat $tmp_file | awk '/^[0-9 ]/ {print \$2 " " \$3 " " \$4 " " \$5 " " \$6 " " \$7 " " \$9} /^[A-Z]/ {print \$0}'`;
|
||||||
`rm $tmp_file >/dev/null`;
|
`rm $tmp_file >/dev/null`;
|
||||||
return $normal_output;
|
return $normal_output;
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -700,7 +700,7 @@ my %checksum_result_col = (
|
|||||||
chunks => 5,
|
chunks => 5,
|
||||||
skipped => 6,
|
skipped => 6,
|
||||||
time => 7,
|
time => 7,
|
||||||
table => 8,
|
table => 7,
|
||||||
);
|
);
|
||||||
sub count_checksum_results {
|
sub count_checksum_results {
|
||||||
my ($output, $column, $table) = @_;
|
my ($output, $column, $table) = @_;
|
||||||
@@ -733,7 +733,7 @@ sub normalize_checksum_results {
|
|||||||
open my $fh, ">", $tmp_file or die "Cannot open $tmp_file: $OS_ERROR";
|
open my $fh, ">", $tmp_file or die "Cannot open $tmp_file: $OS_ERROR";
|
||||||
printf $fh $output;
|
printf $fh $output;
|
||||||
close $fh;
|
close $fh;
|
||||||
my $normal_output = `cat $tmp_file | awk '/^[0-9 ]/ {print \$2 " " \$3 " " \$4 " " \$5 " " \$6 " " \$8} /^[A-Z]/ {print \$0}'`;
|
my $normal_output = `cat $tmp_file | awk '/^[0-9 ]/ {print \$2 " " \$3 " " \$4 " " \$5 " " \$6 " " \$7 " " \$9} /^[A-Z]/ {print \$0}'`;
|
||||||
if ( wantarray ) {
|
if ( wantarray ) {
|
||||||
my $original_output = `cat $tmp_file`;
|
my $original_output = `cat $tmp_file`;
|
||||||
return $normal_output, $original_output;
|
return $normal_output, $original_output;
|
||||||
|
|||||||
@@ -61,13 +61,13 @@ $output = output(
|
|||||||
qw(--chunk-time 0 --chunk-size 100) ) },
|
qw(--chunk-time 0 --chunk-size 100) ) },
|
||||||
stderr => 1,
|
stderr => 1,
|
||||||
);
|
);
|
||||||
|
#1
|
||||||
like(
|
like(
|
||||||
$output,
|
$output,
|
||||||
qr/MySQL error 1265: Data truncated/,
|
qr/MySQL error 1265: Data truncated/,
|
||||||
"MySQL error 1265: Data truncated for column"
|
"MySQL error 1265: Data truncated for column"
|
||||||
);
|
);
|
||||||
|
#2
|
||||||
my (@errors) = $output =~ m/error/;
|
my (@errors) = $output =~ m/error/;
|
||||||
is(
|
is(
|
||||||
scalar @errors,
|
scalar @errors,
|
||||||
@@ -91,16 +91,16 @@ $output = output(
|
|||||||
|
|
||||||
my $original_output;
|
my $original_output;
|
||||||
($output, $original_output) = PerconaTest::normalize_checksum_results($output);
|
($output, $original_output) = PerconaTest::normalize_checksum_results($output);
|
||||||
|
#3
|
||||||
like(
|
like(
|
||||||
$original_output,
|
$original_output,
|
||||||
qr/Lock wait timeout exceeded/,
|
qr/Lock wait timeout exceeded/,
|
||||||
"Warns about lock wait timeout"
|
"Warns about lock wait timeout"
|
||||||
);
|
);
|
||||||
|
#4
|
||||||
like(
|
like(
|
||||||
$output,
|
$output,
|
||||||
qr/^0 0 0 1 1 sakila.city/m,
|
qr/^0 0 0 0 1 1 sakila.city/m,
|
||||||
"Skips chunk that times out"
|
"Skips chunk that times out"
|
||||||
);
|
);
|
||||||
|
|
||||||
@@ -129,7 +129,7 @@ unlike(
|
|||||||
|
|
||||||
like(
|
like(
|
||||||
$output,
|
$output,
|
||||||
qr/^0 0 600 1 0 sakila.city/m,
|
qr/^0 0 600 0 1 0 sakila.city/m,
|
||||||
"Checksum retried after lock wait timeout"
|
"Checksum retried after lock wait timeout"
|
||||||
);
|
);
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user