Eval entire checksum op for each tbl. Use "percona" as default db for checksums table.

This commit is contained in:
Daniel Nichter
2011-09-15 11:46:57 -06:00
parent bc2401ebf5
commit 32ade00663
+6 -5
View File
@@ -4128,8 +4128,8 @@ sub _iterate_dbh {
if ( !$engine || $self->engine_is_allowed($engine) ) {
my $ddl;
if ( my $du = $self->{TableParser} ) {
$ddl = $du->get_create_table($dbh, $self->{db}, $tbl);
if ( my $tp = $self->{TableParser} ) {
$ddl = $tp->get_create_table($dbh, $self->{db}, $tbl);
}
return {
@@ -4807,6 +4807,7 @@ sub main {
TABLE:
while ( my $tbl = $schema_iter->next_schema_object() ) {
eval {
use_repl_db(
dbh => $dbh,
tbl => $tbl,
@@ -4833,12 +4834,12 @@ sub main {
);
$tbl->{checksum_results}->{start_time} = time;
eval {
1 while $nibble_iter->next();
};
if ($EVAL_ERROR) {
warn "Error checksumming $tbl->{db}.$tbl->{tbl}: $EVAL_ERROR\n";
$tbl->{checksum_results}->{errors}++;
print_checksum_results(tbl => $tbl);
}
$exit_status |= 1 if $tbl->{checksum_results}->{errors};
@@ -4968,7 +4969,7 @@ sub print_checksum_results {
$res->{n_rows} || 0,
$res->{n_chunks} || 0,
$res->{skipped} || 0,
sprintf('%.3f', time - ($res->{start_time} || 0)),
sprintf('%.3f', $res->{start_time} ? time - $res->{start_time} : 0),
"$tbl->{db}.$tbl->{tbl}";
return;
@@ -5967,7 +5968,7 @@ ordered by C<id>, but C<id> and C<parent_id> are otherwise ignored.
=item --replicate
type: string; default: percona_toolkit.checksums
type: string; default: percona.checksums
Replicate checksums to slaves.