← Back to branch summary

~percona-toolkit-dev/percona-toolkit/2.2

« back to all changes in this revision

Viewing changes to t/pt-online-schema-change/cleanup.t

Merge fix-pt-osc-drop-bug-1188002.

Show diffs side-by-side

added added

removed removed

Lines of Context:
t/pt-online-schema-change/cleanup.t
 
1
#!/usr/bin/env perl
 
2
 
 
3
BEGIN {
 
4
   die "The PERCONA_TOOLKIT_BRANCH environment variable is not set.\n"
 
5
      unless $ENV{PERCONA_TOOLKIT_BRANCH} && -d $ENV{PERCONA_TOOLKIT_BRANCH};
 
6
   unshift @INC, "$ENV{PERCONA_TOOLKIT_BRANCH}/lib";
 
7
};
 
8
 
 
9
use strict;
 
10
use warnings FATAL => 'all';
 
11
use English qw(-no_match_vars);
 
12
use Test::More;
 
13
 
 
14
use PerconaTest;
 
15
use Sandbox;
 
16
require "$trunk/bin/pt-online-schema-change";
 
17
require VersionParser;
 
18
 
 
19
use Time::HiRes qw(sleep);
 
20
use Data::Dumper;
 
21
$Data::Dumper::Indent    = 1;
 
22
$Data::Dumper::Sortkeys  = 1;
 
23
$Data::Dumper::Quotekeys = 0;
 
24
 
 
25
my $dp         = new DSNParser(opts=>$dsn_opts);
 
26
my $sb         = new Sandbox(basedir => '/tmp', DSNParser => $dp);
 
27
my $dbh1 = $sb->get_dbh_for('master');
 
28
my $dbh2 = $sb->get_dbh_for('master');
 
29
 
 
30
if ( !$dbh1 || !$dbh2 ) {
 
31
   plan skip_all => 'Cannot connect to sandbox master';
 
32
}
 
33
elsif ( $sandbox_version lt '5.5' ) {
 
34
   plan skip_all => "Metadata locks require MySQL 5.5 and newer";
 
35
}
 
36
 
 
37
my $output;
 
38
my $master_dsn = $sb->dsn_for('master');
 
39
my $sample     = "t/pt-online-schema-change/samples";
 
40
my $plugin     = "$trunk/$sample/plugins";
 
41
my $exit;
 
42
my $rows;
 
43
 
 
44
# Loads pt_osc.t with cols id (pk), c (unique index),, d.
 
45
$sb->load_file('master', "$sample/basic_no_fks_innodb.sql");
 
46
 
 
47
# #############################################################################
 
48
# Meta-block on create_triggers.
 
49
# #############################################################################
 
50
 
 
51
($output) = full_output(
 
52
   sub { pt_online_schema_change::main(
 
53
      "$master_dsn,D=pt_osc,t=t",
 
54
      qw(--statistics --execute --tries drop_triggers:1:0.01),
 
55
      qw(--set-vars lock_wait_timeout=1 --print --no-swap-tables),
 
56
      '--plugin', "$plugin/make_drop_trigger_fail.pm",
 
57
   )},
 
58
   stderr => 1,
 
59
);
 
60
 
 
61
my $triggers = $dbh1->selectall_arrayref("SHOW TRIGGERS FROM pt_osc");
 
62
is(
 
63
   @$triggers,
 
64
   3,
 
65
   "Bug 1188002: triggers not dropped"
 
66
) or diag(Dumper($triggers));
 
67
 
 
68
my $tables = $dbh1->selectall_arrayref("SHOW TABLES FROM pt_osc");
 
69
is_deeply(
 
70
   $tables,
 
71
   [ ['_t_new'], ['t'] ],
 
72
   "Bug 1188002: new table not dropped"
 
73
) or diag(Dumper($tables));
 
74
 
 
75
# #############################################################################
 
76
# Done.
 
77
# #############################################################################
 
78
$sb->wipe_clean($dbh1);
 
79
ok($sb->ok(), "Sandbox servers") or BAIL_OUT(__FILE__ . " broke the sandbox");
 
80
done_testing;