percona/percona-toolkit
1
0
Fork 0
mirror of https://github.com/percona/percona-toolkit.git synced 2025-09-17 17:27:57 +00:00
Code Issues Packages Projects Releases Wiki Activity

Handle MySQL instance ID for MySQL 5.0.

Browse Source
This commit is contained in:
Daniel Nichter
2012-08-31 10:01:12 -06:00
parent e5a7db8ea2
commit 0e3eac65a0
2 changed files with 47 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
lib/Pingback.pm
View File

@@ -307,11 +307,32 @@ sub _generate_identifier {
my $dbh = $instance->{dbh};
my $dsn = $instance->{dsn};
# MySQL 5.1+ has @@hostname and @@port
# MySQL 5.0 has @@hostname but port only in SHOW VARS
# MySQL 4.x has nothing, so we use the dsn
my $sql = q{SELECT CONCAT(@@hostname, @@port)};
PTDEBUG && _d($sql);
my ($name) = eval { $dbh->selectrow_array($sql) };
if ( $EVAL_ERROR ) { # assume that it's MySQL 4.x
if ( $EVAL_ERROR ) {
# MySQL 4.x or 5.0
PTDEBUG && _d($EVAL_ERROR);
$sql = q{SELECT @@hostname};
PTDEBUG && _d($sql);
($name) = eval { $dbh->selectrow_array($sql) };
if ( $EVAL_ERROR ) {
# MySQL 4.x
PTDEBUG && _d($EVAL_ERROR);
$name = ($dsn->{h} || 'localhost') . ($dsn->{P} || 3306);
}
else {
# MySQL 5.0
$sql = q{SHOW VARIABLES LIKE 'port'};
PTDEBUG && _d($sql);
my (undef, $port) = eval { $dbh->selectrow_array($sql) };
PTDEBUG && _d('port:', $port);
$name .= $port || '';
}
}
my $id = md5_hex($name);
if ( $ENV{PTVCDEBUG} || PTDEBUG ) {

31
t/lib/Pingback.t
View File

@@ -35,11 +35,10 @@ if ( $master_dbh ) {
(undef, $mysql_distro)
= $master_dbh->selectrow_array("SHOW VARIABLES LIKE 'version_comment'");
my $sql = q{SELECT CONCAT(@@hostname, @@port)};
my ($name) = $master_dbh->selectrow_array($sql);
$master_id = md5_hex($name);
(undef, $slave1_id) = Pingback::_generate_identifier( { dbh => $slave1_dbh } );
(undef, $master_id) = Pingback::_generate_identifier(
{ dbh => $master_dbh, dsn => { h => '127.1', P => 12345 }});
(undef, $slave1_id) = Pingback::_generate_identifier(
{ dbh => $slave1_dbh, dsn => { h => '127.1', P => 12346 }});
$master_inst = {
id => $master_id,
@@ -283,12 +282,28 @@ is(
SKIP: {
skip 'Cannot connect to sandbox master', 2 unless $master_dbh;
skip 'Requires MySQL 5.0.38 or newer', unless $sandbox_version ge '5.0.38';
my $expect_master_id;
if ( $sandbox_version ge '5.1' ) {
my $sql = q{SELECT CONCAT(@@hostname, @@port)};
my ($name) = $master_dbh->selectrow_array($sql);
$expect_master_id = md5_hex($name);
}
elsif ( $sandbox_version eq '5.0' ) {
my $sql = q{SELECT @@hostname};
my ($hostname) = $master_dbh->selectrow_array($sql);
$sql = q{SHOW VARIABLES LIKE 'port'};
my (undef, $port) = $master_dbh->selectrow_array($sql);
$expect_master_id = md5_hex($hostname . $port);
}
else {
$expect_master_id = md5_hex("localhost", 12345);
}
is(
Pingback::_generate_identifier( { dbh => $master_dbh, dsn => undef } ),
$master_id,
"_generate_identifier() works with a dbh"
$expect_master_id,
"_generate_identifier() for MySQL $sandbox_version"
);
# The time limit file already exists (see previous tests), but this is