Skip to content

Commit

Permalink
PT-2375 - fixed pt-table-sync for tables with generated columns
Browse files Browse the repository at this point in the history
Previously, pt-table-sync generated DML statements that included
the generated columns of a table, which is however rejected by
the database and not necessary for the required sync statements.
  • Loading branch information
hpoettker committed Sep 15, 2024
1 parent 206404f commit a29a293
Show file tree
Hide file tree
Showing 4 changed files with 102 additions and 1 deletion.
4 changes: 4 additions & 0 deletions bin/pt-table-sync
Original file line number Diff line number Diff line change
Expand Up @@ -3708,6 +3708,7 @@ sub sort_cols {
my @cols;
if ( $self->{tbl_struct} ) {
my $pos = $self->{tbl_struct}->{col_posn};
my $is_col = $self->{tbl_struct}->{is_col};
my @not_in_tbl;
@cols = sort {
$pos->{$a} <=> $pos->{$b}
Expand All @@ -3721,6 +3722,9 @@ sub sort_cols {
1;
}
}
grep {
$is_col->{$_}
}
sort keys %$row;
push @cols, @not_in_tbl if @not_in_tbl;
}
Expand Down
7 changes: 6 additions & 1 deletion lib/ChangeHandler.pm
Original file line number Diff line number Diff line change
Expand Up @@ -462,7 +462,8 @@ sub get_changes {


# Sub: sort_cols
# Sort a row's columns based on their real order in the table.
# Sort a row's columns based on their real order in the table, and remove
# generated columns.
# This requires that the optional tbl_struct arg was passed to <new()>.
# If not, the rows are sorted alphabetically.
#
Expand All @@ -476,6 +477,7 @@ sub sort_cols {
my @cols;
if ( $self->{tbl_struct} ) {
my $pos = $self->{tbl_struct}->{col_posn};
my $is_col = $self->{tbl_struct}->{is_col};
my @not_in_tbl;
@cols = sort {
$pos->{$a} <=> $pos->{$b}
Expand All @@ -489,6 +491,9 @@ sub sort_cols {
1;
}
}
grep {
$is_col->{$_}
}
sort keys %$row;
push @cols, @not_in_tbl if @not_in_tbl;
}
Expand Down
80 changes: 80 additions & 0 deletions t/pt-table-sync/pt-2375.t
Original file line number Diff line number Diff line change
@@ -0,0 +1,80 @@
#!/usr/bin/env perl

BEGIN {
die "The PERCONA_TOOLKIT_BRANCH environment variable is not set.\n"
unless $ENV{PERCONA_TOOLKIT_BRANCH} && -d $ENV{PERCONA_TOOLKIT_BRANCH};
unshift @INC, "$ENV{PERCONA_TOOLKIT_BRANCH}/lib";
};

use strict;
use warnings FATAL => 'all';
use English qw(-no_match_vars);
use Test::More;

use PerconaTest;
use Sandbox;
require "$trunk/bin/pt-table-sync";

my $dp = new DSNParser(opts=>$dsn_opts);
my $sb = new Sandbox(basedir => '/tmp', DSNParser => $dp);
my $master_dbh = $sb->get_dbh_for('master');
my $slave1_dbh = $sb->get_dbh_for('slave1');

if ( !$master_dbh ) {
plan skip_all => 'Cannot connect to sandbox master';
}
elsif ( !$slave1_dbh ) {
plan skip_all => 'Cannot connect to sandbox slave1';
}
else {
plan tests => 3;
}

my $output;

# #############################################################################
# Test generated REPLACE statements.
# #############################################################################
$sb->load_file('master', "t/pt-table-sync/samples/pt-2375.sql");
$sb->wait_for_slaves();
$slave1_dbh->do("delete from `test`.`test_table` where `id`=1");

$output = remove_traces(output(
sub { pt_table_sync::main('--sync-to-master',
'h=127.0.0.1,P=12346,u=msandbox,p=msandbox',
qw(-t test.test_table --print --execute))
},
));
chomp($output);
is(
$output,
"REPLACE INTO `test`.`test_table`(`id`, `value`) VALUES ('1', '24');",
"Generated columns are not used in REPLACE statements"
);

# #############################################################################
# Test generated UPDATE statements.
# #############################################################################
$sb->load_file('master', "t/pt-table-sync/samples/pt-2375.sql");
$sb->wait_for_slaves();
$slave1_dbh->do("update `test`.`test_table` set `value`=55 where `id`=2");

$output = remove_traces(output(
sub { pt_table_sync::main(qw(--print --execute),
"h=127.0.0.1,P=12346,u=msandbox,p=msandbox,D=test,t=test_table",
"h=127.0.0.1,P=12345,u=msandbox,p=msandbox,D=test,t=test_table");
}
));
chomp($output);
is(
$output,
"UPDATE `test`.`test_table` SET `value`='55' WHERE `id`='2' LIMIT 1;",
"Generated columns are not used in UPDATE statements"
);

# #############################################################################
# Done.
# #############################################################################
$sb->wipe_clean($master_dbh);
ok($sb->ok(), "Sandbox servers") or BAIL_OUT(__FILE__ . " broke the sandbox");
exit;
12 changes: 12 additions & 0 deletions t/pt-table-sync/samples/pt-2375.sql
Original file line number Diff line number Diff line change
@@ -0,0 +1,12 @@
DROP DATABASE IF EXISTS test;
CREATE DATABASE test;
USE test;

CREATE TABLE `test_table` (
`id` INT AUTO_INCREMENT PRIMARY KEY,
`value` INT NOT NULL,
`derived_value` INT AS (2*`value`)
) ENGINE=InnoDB;

INSERT INTO `test_table` (`value`) VALUES (24);
INSERT INTO `test_table` (`value`) VALUES (42);

0 comments on commit a29a293

Please sign in to comment.