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

Fully working but still untested pt-osc 2.1.

Browse Source
This commit is contained in:
Daniel Nichter
2012-03-22 12:04:41 -06:00
parent f5b49769c3
commit d5832f65e0
1 changed files with 57 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -5329,23 +5329,23 @@ sub main {
# ##################################################################### # #####################################################################
# Rename tables. # Rename tables.
# ##################################################################### # #####################################################################
# TODO my $old_tbl;
my $old_tbl = { if ( $o->get('rename-tables') ) {
}; eval {
# if ( $o->get('rename-tables') ) { $old_tbl = rename_tables(
# my $sql = "RENAME TABLE " orig_tbl => $orig_tbl,
# . "$orig_tbl->{name} TO $old_tbl->{name}," new_tbl => $new_tbl,
# . " $new_tbl->{name} TO $orig_tbl->{name}"; suffix => '_OLD',
# PTDEBUG && _d($sql); Cxn => $cxn,
# eval { Quoter => $q,
# $cxn->dbh()->do($sql); );
# }; };
# if ( $EVAL_ERROR ) { if ( $EVAL_ERROR ) {
# # XXX # XXX
# # TODO: drop_triggers(), what to do with data created by triggers? # TODO: drop_triggers(), what to do with data created by triggers?
# die "Error renaming the tables: $EVAL_ERROR\n"; die "Error renaming the tables: $EVAL_ERROR\n";
# } }
# } }
# ##################################################################### # #####################################################################
# Update foreign key constraints if there are child tables. # Update foreign key constraints if there are child tables.
@@ -5380,10 +5380,11 @@ sub main {
Quoter => $q, Quoter => $q,
); );
# if ( $o->get('drop-old-table') ) { if ( $old_tbl && $o->get('drop-old-table') ) {
# my $sql = "DROP TABLE IF EXISTS $old_tbl->{name}"; my $sql = "DROP TABLE IF EXISTS $old_tbl->{name}";
# $cxn->dbh()->do($sql) unless $o->get('print'); PTDEBUG && _d($sql);
# } $cxn->dbh()->do($sql);
}
}; };
if ( $EVAL_ERROR ) { if ( $EVAL_ERROR ) {
die "An unknown fatal error occurred: $EVAL_ERROR"; die "An unknown fatal error occurred: $EVAL_ERROR";
@@ -5436,6 +5437,41 @@ sub create_table_like {
die "Failed to find a unique new table name after serveral attempts.\n"; die "Failed to find a unique new table name after serveral attempts.\n";
} }
sub rename_tables {
my (%args) = @_;
my @required_args = qw(orig_tbl new_tbl Cxn Quoter);
foreach my $arg ( @required_args ) {
die "I need a $arg argument" unless $args{$arg};
}
my ($orig_tbl, $new_tbl, $cxn, $q) = @args{@required_args};
my $prefix = '_';
my $table_name = $orig_tbl->{tbl} . ($args{suffix} || '');
my $tries = 10; # don't try forever
while ( $tries-- ) {
$table_name = $prefix . $table_name;
my $sql = "RENAME TABLE $orig_tbl->{name} "
. "TO " . $q->quote($orig_tbl->{db}, $table_name)
. ", $new_tbl->{name} TO $orig_tbl->{name}";
PTDEBUG && _d($sql);
eval {
$cxn->dbh()->do($sql);
};
if ( $EVAL_ERROR ) {
next if $EVAL_ERROR =~ m/table.+?already exists/i;
die "Error renaming table: $EVAL_ERROR\n";
}
return { # success
db => $orig_tbl->{db},
tbl => $table_name,
name => $q->quote($orig_tbl->{db}, $table_name),
};
}
die "Failed to find a unique old table name after serveral attempts.\n";
}
sub check_orig_table { sub check_orig_table {
my ( %args ) = @_; my ( %args ) = @_;
my @required_args = qw(orig_tbl Cxn TableParser OptionParser Quoter); my @required_args = qw(orig_tbl Cxn TableParser OptionParser Quoter);