mirror of
https://github.com/percona/percona-toolkit.git
synced 2025-12-19 01:09:21 +08:00
Compare commits
7 Commits
dependabot
...
test_jenki
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
6d1479df59 | ||
|
|
8e519885b5 | ||
|
|
fea3cea697 | ||
|
|
38d8bf5050 | ||
|
|
70bd9164f8 | ||
|
|
ba4f650fad | ||
|
|
49b4293207 |
@@ -192,8 +192,9 @@ like(
|
|||||||
},
|
},
|
||||||
);
|
);
|
||||||
|
|
||||||
|
diag($output);
|
||||||
$output =~ /.*Chunk: (\d+)\n/ms;
|
$output =~ /.*Chunk: (\d+)\n/ms;
|
||||||
my $last_chunk = int($1);
|
my $last_chunk = int($1) or diag($output);
|
||||||
|
|
||||||
ok(
|
ok(
|
||||||
$last_chunk * $chunk_size + int($copied_rows) == $num_rows,
|
$last_chunk * $chunk_size + int($copied_rows) == $num_rows,
|
||||||
|
|||||||
@@ -11,6 +11,7 @@ use warnings FATAL => 'all';
|
|||||||
use English qw(-no_match_vars);
|
use English qw(-no_match_vars);
|
||||||
use Test::More;
|
use Test::More;
|
||||||
use Time::Local;
|
use Time::Local;
|
||||||
|
use Data::Dumper;
|
||||||
|
|
||||||
use PerconaTest;
|
use PerconaTest;
|
||||||
use Sandbox;
|
use Sandbox;
|
||||||
@@ -20,10 +21,11 @@ my $dp = new DSNParser(opts=>$dsn_opts);
|
|||||||
my $sb = new Sandbox(basedir => '/tmp', DSNParser => $dp);
|
my $sb = new Sandbox(basedir => '/tmp', DSNParser => $dp);
|
||||||
my $dbh = $sb->get_dbh_for('source');
|
my $dbh = $sb->get_dbh_for('source');
|
||||||
|
|
||||||
my $output = `$trunk/bin/pt-table-checksum h=127.1,P=12345,u=msandbox,p=msandbox --set-vars innodb_lock_wait_timeout=3 --chunk-size=50 -d sakila --buffer-stdout 2>&1 | tee | ts '%m-%dT%H:%M:%S'`;
|
my $output = `$trunk/bin/pt-table-checksum h=127.1,P=12345,u=msandbox,p=msandbox,s=1 --set-vars innodb_lock_wait_timeout=3 --chunk-size=50 -d sakila --buffer-stdout 2>&1 | tee | ts '%m-%dT%H:%M:%S'`;
|
||||||
|
|
||||||
my @lines = split(/\n/, $output);
|
my @lines = split(/\n/, $output);
|
||||||
my @times = ( $lines[3] =~ m/\d\d-\d\dT\d\d:\d\d:\d\d/g );
|
my @times = ( $lines[3] =~ m/\d\d-\d\dT\d\d:\d\d:\d\d/g );
|
||||||
|
diag(Dumper(@times));
|
||||||
|
|
||||||
is(
|
is(
|
||||||
scalar(@times),
|
scalar(@times),
|
||||||
@@ -41,7 +43,7 @@ cmp_ok(
|
|||||||
"Print delay is expected for the buffered output"
|
"Print delay is expected for the buffered output"
|
||||||
) or diag($output);
|
) or diag($output);
|
||||||
|
|
||||||
$output = `$trunk/bin/pt-table-checksum h=127.1,P=12345,u=msandbox,p=msandbox --set-vars innodb_lock_wait_timeout=3 --chunk-size=50 -d sakila 2>&1 | tee | ts '%m-%dT%H:%M:%S'`;
|
$output = `$trunk/bin/pt-table-checksum h=127.1,P=12345,u=msandbox,p=msandbox,s=1 --set-vars innodb_lock_wait_timeout=3 --chunk-size=50 -d sakila 2>&1 | tee | ts '%m-%dT%H:%M:%S'`;
|
||||||
|
|
||||||
@lines = split(/\n/, $output);
|
@lines = split(/\n/, $output);
|
||||||
@times = ( $lines[3] =~ m/\d\d-\d\dT\d\d:\d\d:\d\d/g );
|
@times = ( $lines[3] =~ m/\d\d-\d\dT\d\d:\d\d:\d\d/g );
|
||||||
@@ -62,7 +64,7 @@ cmp_ok(
|
|||||||
"STDOUT is buffered by default"
|
"STDOUT is buffered by default"
|
||||||
) or diag($output);
|
) or diag($output);
|
||||||
|
|
||||||
$output = `$trunk/bin/pt-table-checksum h=127.1,P=12345,u=msandbox,p=msandbox --set-vars innodb_lock_wait_timeout=3 --chunk-size=50 -d sakila --no-buffer-stdout 2>&1 | tee | ts '%m-%dT%H:%M:%S'`;
|
$output = `$trunk/bin/pt-table-checksum h=127.1,P=12345,u=msandbox,p=msandbox,s=1 --set-vars innodb_lock_wait_timeout=3 --chunk-size=50 -d sakila --no-buffer-stdout 2>&1 | tee | ts '%m-%dT%H:%M:%S'`;
|
||||||
|
|
||||||
@lines = split(/\n/, $output);
|
@lines = split(/\n/, $output);
|
||||||
@times = ( $lines[3] =~ m/\d\d-\d\dT\d\d:\d\d:\d\d/g );
|
@times = ( $lines[3] =~ m/\d\d-\d\dT\d\d:\d\d:\d\d/g );
|
||||||
@@ -83,7 +85,7 @@ cmp_ok(
|
|||||||
"Print delay is not expected when buffering is disabled"
|
"Print delay is not expected when buffering is disabled"
|
||||||
) or diag($output);
|
) or diag($output);
|
||||||
|
|
||||||
$output = `$trunk/bin/pt-table-checksum h=127.1,P=12345,u=msandbox,p=msandbox --set-vars innodb_lock_wait_timeout=3 --chunk-size=50 -d sakila --nobuffer-stdout 2>&1 | tee | ts '%m-%dT%H:%M:%S'`;
|
$output = `$trunk/bin/pt-table-checksum h=127.1,P=12345,u=msandbox,p=msandbox,s=1 --set-vars innodb_lock_wait_timeout=3 --chunk-size=50 -d sakila --nobuffer-stdout 2>&1 | tee | ts '%m-%dT%H:%M:%S'`;
|
||||||
|
|
||||||
@lines = split(/\n/, $output);
|
@lines = split(/\n/, $output);
|
||||||
@times = ( $lines[3] =~ m/\d\d-\d\dT\d\d:\d\d:\d\d/g );
|
@times = ( $lines[3] =~ m/\d\d-\d\dT\d\d:\d\d:\d\d/g );
|
||||||
|
|||||||
@@ -294,7 +294,7 @@ if ( -x "$ENV{PERCONA_TOOLKIT_SANDBOX}/bin/mysqlbinlog" ) {
|
|||||||
chomp $mysqlbinlog;
|
chomp $mysqlbinlog;
|
||||||
}
|
}
|
||||||
|
|
||||||
$output = `$mysqlbinlog /tmp/12345/data/$row->{file} --start-position=$row->{position} | grep 'use ' | grep -v '^# Warning' | grep -v 'pseudo_replica_mode' | sort -u | sed -e 's/\`//g'`;
|
$output = `$mysqlbinlog /tmp/12345/data/$row->{file} --start-position=$row->{position} | grep 'use ' | grep -v '^# Warning' | grep -v 'pseudo_replica_mode' | LOCALE=en_US.utf8 LANG=en_US.UTF-8 sort -u | sed -e 's/\`//g'`;
|
||||||
|
|
||||||
my $use_dbs = "use mysql/*!*/;
|
my $use_dbs = "use mysql/*!*/;
|
||||||
use percona/*!*/;
|
use percona/*!*/;
|
||||||
@@ -317,7 +317,7 @@ $row = $source_dbh->selectrow_hashref("show ${source_status} status");
|
|||||||
|
|
||||||
pt_table_checksum::main(@args, qw(--quiet --replicate-database percona));
|
pt_table_checksum::main(@args, qw(--quiet --replicate-database percona));
|
||||||
|
|
||||||
$output = `$mysqlbinlog /tmp/12345/data/$row->{file} --start-position=$row->{position} | grep 'use ' | grep -v '^# Warning' | grep -v 'pseudo_replica_mode' | sort -u | sed -e 's/\`//g'`;
|
$output = `$mysqlbinlog /tmp/12345/data/$row->{file} --start-position=$row->{position} | grep 'use ' | grep -v '^# Warning' | grep -v 'pseudo_replica_mode' | LOCALE=en_US.utf8 LANG=en_US.UTF-8 sort -u | sed -e 's/\`//g'`;
|
||||||
|
|
||||||
is(
|
is(
|
||||||
$output,
|
$output,
|
||||||
|
|||||||
Reference in New Issue
Block a user