percona/percona-toolkit
1
0
Fork 0
mirror of https://github.com/percona/percona-toolkit.git synced 2025-09-10 13:11:32 +00:00
Code Issues Packages Projects Releases Wiki Activity

Update the rest of the modules to use the updated version_check

Browse Source
This commit is contained in:
Brian Fraser
2012-08-27 22:30:48 -03:00
parent 98338b6508
commit 6eee6ac6f6
17 changed files with 83 additions and 36 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
bin/pt-archiver
View File

@@ -5393,7 +5393,7 @@ sub main {
if ( $o->get('version-check') && (!$o->has('quiet') || !$o->get('quiet')) ) {
Pingback::version_check(
{ dbh => $src->{dbh}, dsn => $src->{dsn} },
( $dst ? { dbh => $dst->{dbh}, dsn => $dst->{dsn} } : () )
( $dst ? { dbh => $dst->{dbh}, dsn => $dst->{dsn} } : () ),
);
}

5
bin/pt-config-diff
View File

@@ -4050,6 +4050,7 @@ sub main {
push @configs, new MySQLConfig(
dbh => $cxn->dbh(),
dsn => $cxn->dsn(),
%common_modules,
);
push @config_names, $cxn->name();
@@ -4075,7 +4076,9 @@ sub main {
# Do the version-check
# ########################################################################
if ( $o->get('version-check') && (!$o->has('quiet') || !$o->get('quiet')) ) {
Pingback::version_check($configs[0]->{dbh});
Pingback::version_check(
map { +{ dbh => $_->{dbh}, dsn => $_->{dsn} } } @configs
);
}
# #########################################################################

5
bin/pt-deadlock-logger
View File

@@ -3600,7 +3600,10 @@ sub main {
# Do the version-check
# ########################################################################
if ( $o->get('version-check') && (!$o->has('quiet') || !$o->get('quiet')) ) {
Pingback::version_check($dbh);
Pingback::version_check(
{ dbh => $dbh, dsn => $source_dsn },
($dest_dsn ? { dbh => $dest_dsn, dsn => $dest_dsn } : ()),
);
}
# ########################################################################

2
bin/pt-duplicate-key-checker
View File

@@ -4453,7 +4453,7 @@ sub main {
# Do the version-check
# ########################################################################
if ( $o->get('version-check') && (!$o->has('quiet') || !$o->get('quiet')) ) {
Pingback::version_check($dbh);
Pingback::version_check({dbh => $dbh, dsn => $dsn});
}
# #######################################################################

2
bin/pt-find
View File

@@ -3621,7 +3621,7 @@ sub main {
# Do the version-check
# ########################################################################
if ( $o->get('version-check') && (!$o->has('quiet') || !$o->get('quiet')) ) {
Pingback::version_check($dbh);
Pingback::version_check({dbh => $dbh, dsn => $dsn});
}
# ########################################################################

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

@@ -3245,7 +3245,10 @@ sub main {
# Do the version-check
# ########################################################################
if ( $o->get('version-check') && (!$o->has('quiet') || !$o->get('quiet')) ) {
Pingback::version_check($dbh);
Pingback::version_check(
{ dbh => $dbh, dsn => $src_dsn },
($dst_dbh ? { dbh => $dst_dbh, dsn => $dst_dsn } : ()),
);
}
# ########################################################################

2
bin/pt-heartbeat
View File

@@ -4741,7 +4741,7 @@ sub main {
# Do the version-check
# ########################################################################
if ( $o->get('version-check') && (!$o->has('quiet') || !$o->get('quiet')) ) {
Pingback::version_check($dbh);
Pingback::version_check({dbh => $dbh, dsn => $dsn});
}
# ########################################################################

8
bin/pt-index-usage
View File

@@ -5951,6 +5951,7 @@ sub main {
# but get_cxn() required a defined dsn arg so use an empty hashref.
# ##########################################################################
my ($dbh, $si_dbh, $res_dbh);
my $res_dsn;
my $res_db;
eval {
my $dsn = $dp->parse_options($o) || {};
@@ -5971,7 +5972,7 @@ sub main {
);
# dbh for --save-results-database
if ( my $res_dsn = $o->get('save-results-database') ) {
if ( $res_dsn = $o->get('save-results-database') ) {
# To make --create-save-results-database work we have to
# temporarily remove the D from the DSN to avoid the error
@@ -6084,7 +6085,10 @@ sub main {
# Do the version-check
# ########################################################################
if ( $o->get('version-check') && (!$o->has('quiet') || !$o->get('quiet')) ) {
Pingback::version_check($dbh);
Pingback::version_check(
{ dbh => $dbh, dsn => $dsn },
($res_dbh ? { dbh => $res_dbh, dsn => $res_dsn } : ()),
);
}
# ########################################################################

4
bin/pt-kill
View File

@@ -6233,7 +6233,9 @@ sub main {
# Do the version-check
# ########################################################################
if ( $o->get('version-check') && (!$o->has('quiet') || !$o->get('quiet')) ) {
Pingback::version_check($dbh);
Pingback::version_check(
($dbh ? { dbh => $dbh, dsn => $cxn->dsn() } : ())
);
}
# ########################################################################

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

@@ -7123,13 +7123,6 @@ sub main {
die "This tool requires MySQL 5.0.10 or newer.\n";
}
# ########################################################################
# Do the version-check
# ########################################################################
if ( $o->get('version-check') && (!$o->has('quiet') || !$o->get('quiet')) ) {
Pingback::version_check($cxn->dbh());
}
# ########################################################################
# Setup lag and load monitors.
# ########################################################################
@@ -7297,6 +7290,16 @@ sub main {
}
}
# ########################################################################
# Do the version-check
# ########################################################################
if ( $o->get('version-check') && (!$o->has('quiet') || !$o->get('quiet')) ) {
Pingback::version_check(
map { +{ dbh => $_->dbh(), dsn => $_->dsn() } }
$cxn, ($slaves ? @$slaves : ())
);
}
# ########################################################################
# Setup and check the original table.
# ########################################################################

10
bin/pt-query-advisor
View File

@@ -7187,10 +7187,11 @@ sub main {
# #########################################################################
# Try to connect to MySQL.
# #########################################################################
my $dbh;
my ($dbh, $dsn);
eval {
$dsn = $dp->parse_options($o);
$dbh = get_cxn(
dsn => $dp->parse_options($o),
dsn => $dsn,
%common_modules
);
};
@@ -7460,7 +7461,10 @@ sub main {
# Do the version-check
# ########################################################################
if ( $o->get('version-check') && (!$o->has('quiet') || !$o->get('quiet')) ) {
Pingback::version_check($dbh);
Pingback::version_check(
($review_dbh ? { dbh => $review_dbh, dsn => $review_dsn } : ()),
($dbh ? { dbh => $dbh, dsn => $dsn } : ()),
);
}
# #########################################################################

12
bin/pt-query-digest
View File

@@ -13324,9 +13324,10 @@ sub main {
);
} # input
my $ps_dsn;
{ # event
my $misc;
if ( my $ps_dsn = $o->get('processlist') ) {
if ( $ps_dsn = $o->get('processlist') ) {
my $ms = new MasterSlave(
OptionParser => $o,
DSNParser => $dp,
@@ -14022,6 +14023,7 @@ sub main {
}
} # sample
my $ex_dsn;
{ # execute throttle and execute
my $et;
if ( my $et_args = $o->get('execute-throttle') ) {
@@ -14060,7 +14062,7 @@ sub main {
);
} # execute throttle
if ( my $ex_dsn = $o->get('execute') ) {
if ( $ex_dsn = $o->get('execute') ) {
if ( $o->get('ask-pass') ) {
$ex_dsn->{p} = OptionParser::prompt_noecho("Enter password for "
. "--execute: ");
@@ -14258,7 +14260,11 @@ sub main {
# Do the version-check
# ########################################################################
if ( $o->get('version-check') && (!$o->has('quiet') || !$o->get('quiet')) ) {
Pingback::version_check($qv_dbh || $ps_dbh || $ex_dbh);
Pingback::version_check(
($qv_dbh ? { dbh => $qv_dbh, dsn => $review_dsn } : ()),
($ps_dbh ? { dbh => $ps_dbh, dsn => $ps_dsn } : ()),
($ex_dbh ? { dbh => $ex_dbh, dsn => $ex_dsn } : ()),
);
}
# ##########################################################################

8
bin/pt-slave-delay
View File

@@ -3639,7 +3639,13 @@ sub main {
# Do the version-check
# ########################################################################
if ( $o->get('version-check') && (!$o->has('quiet') || !$o->get('quiet')) ) {
Pingback::version_check($slave_dbh);
my $tmp_master_dsn = $master_dsn
? $master_dsn
: { h => $status->{master_host}, P => $status->{master_port} };
Pingback::version_check(
{ dbh => $slave_dbh, dsn => $slave_dsn },
{ dbh => $master_dbh, dsn => $tmp_master_dsn },
);
}
# If the I/O thread isn't running when the program starts,

16
bin/pt-slave-restart
View File

@@ -4279,13 +4279,6 @@ sub main {
$daemon->make_PID_file();
}
# ########################################################################
# Do the version-check
# ########################################################################
if ( $o->get('version-check') && (!$o->has('quiet') || !$o->get('quiet')) ) {
Pingback::version_check($dbh);
}
# ########################################################################
# Start monitoring the slave.
# ########################################################################
@@ -4327,6 +4320,15 @@ sub main {
}
);
# ########################################################################
# Do the version-check
# ########################################################################
if ( $o->get('version-check') && (!$o->has('quiet') || !$o->get('quiet')) ) {
Pingback::version_check(
{ dbh => $dbh, dsn => $dsn }, @servers_to_watch,
);
}
# Watch each server found.
my $must_fork = @servers_to_watch > 1;
foreach my $host ( @servers_to_watch ) {

9
bin/pt-table-sync
View File

@@ -9534,7 +9534,14 @@ sub main {
# Do the version-check
# ########################################################################
if ( $o->get('version-check') && (!$o->has('quiet') || !$o->get('quiet')) ) {
Pingback::version_check($dsns[0]->{dbh});
Pingback::version_check(
map {
+{
dbh => $_->{dbh} || get_cxn($_, %args),
dsn => $_,
}
} @dsns
);
}
# ########################################################################

4
bin/pt-upgrade
View File

@@ -11701,7 +11701,9 @@ sub main {
# Do the version-check
# ########################################################################
if ( $o->get('version-check') && (!$o->has('quiet') || !$o->get('quiet')) ) {
Pingback::version_check($hosts->[0]->{dbh});
Pingback::version_check(
map { +{ dbh => $_->{dbh}, dsn => $_->{dsn} } } @$hosts
);
}
# ########################################################################

8
bin/pt-variable-advisor
View File

@@ -4532,10 +4532,10 @@ sub main {
# ##########################################################################
# Connect to MySQL if any of the input sources is mysql.
# ##########################################################################
my $dbh;
my ($dbh, $dsn);
if ( $need_dbh ) {
my $dsn_defaults = $dp->parse_options($o);
my $dsn = $dp->parse(shift @ARGV, $dsn_defaults);
$dsn = $dp->parse(shift @ARGV, $dsn_defaults);
if ( $o->get('ask-pass') ) {
$dsn->{p} = OptionParser::prompt_noecho("Enter password: ");
@@ -4565,7 +4565,9 @@ sub main {
# Do the version-check
# ########################################################################
if ( $o->get('version-check') && (!$o->has('quiet') || !$o->get('quiet')) ) {
Pingback::version_check($dbh);
Pingback::version_check(
($dbh ? { dbh => $dbh, dsn => $dsn } : ()),
);
}
# #########################################################################