1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
|
#!/usr/bin/perl -w
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";
};
# RowDiff-custom.t tests some of the basic RowDiff functionalities
# as RowDiff.t but uses a different Perl lib if the PT_PERL_LIB
# environment var is set. This allows us to test these functionalities
# against custom versions of DBI, DBD::mysql, etc. If PT_PERL_LIB
# is not set, then all these tests are skipped.
package MockSync;
sub new {
return bless [], shift;
}
sub same_row {
my ( $self, $lr, $rr ) = @_;
push @$self, 'same';
}
sub not_in_right {
my ( $self, $lr ) = @_;
push @$self, [ 'not in right', $lr];
}
sub not_in_left {
my ( $self, $rr ) = @_;
push @$self, [ 'not in left', $rr];
}
sub done_with_rows {
my ( $self ) = @_;
push @$self, 'done';
}
sub key_cols {
return [qw(a)];
}
# #############################################################################
package main;
BEGIN {
if ( defined $ENV{PT_PERL_LIB} ) {
die "The PT_PERL_LIB environment variable is not a valid directory: "
. $ENV{PT_PERL_LIB} unless -d $ENV{PT_PERL_LIB};
print "# Using Perl lib $ENV{PT_PERL_LIB}\n";
use lib ($ENV{PT_PERL_LIB} ? "$ENV{PT_PERL_LIB}" : ());
}
};
use strict;
use warnings FATAL => 'all';
use Test::More;
use English qw(-no_match_vars);
use DBI;
use DBD::mysql; # so we can print $DBD::mysql::VERSION
use PerconaTest;
plan skip_all => "PT_PERL_LIB env var is not set", 4
unless defined $ENV{PT_PERL_LIB};
print "# DBI v$DBI::VERSION\n"
. "# DBD::mysql v$DBD::mysql::VERSION\n";
use RowDiff;
use Sandbox;
use DSNParser;
use TableParser;
use Quoter;
my $d = new RowDiff(dbh => 1);
my $s = new MockSync();
my $q = new Quoter();
my $tp = new TableParser(Quoter => $q);
my $dp = new DSNParser(opts=>$dsn_opts);
# Connect to sandbox now to make sure it's running.
my $sb = new Sandbox(basedir => '/tmp', DSNParser => $dp);
my $master_dbh = $sb->get_dbh_for('master');
my $slave_dbh = $sb->get_dbh_for('slave1');
if ( !$master_dbh ) {
plan skip_all => "Cannot connect to sandbox master";
}
elsif ( !$slave_dbh ) {
plan skip_all => "Cannot connect to sandbox slave";
}
else {
plan tests => 5;
}
$sb->create_dbs($master_dbh, [qw(test)]);
$sb->load_file('master', 't/lib/samples/issue_11.sql');
my $tbl = $tp->parse(
$tp->get_create_table($master_dbh, 'test', 'issue_11'));
my $left_sth = $master_dbh->prepare('SELECT * FROM test.issue_11');
my $right_sth = $slave_dbh->prepare('SELECT * FROM test.issue_11');
$left_sth->execute();
$right_sth->execute();
$s = new MockSync();
$d->compare_sets(
left => $left_sth,
right => $right_sth,
syncer => $s,
tbl => $tbl,
);
is_deeply(
$s,
['done',],
'no rows (real DBI sth)',
);
$slave_dbh->do('INSERT INTO test.issue_11 VALUES (1,2,3)');
$left_sth = $master_dbh->prepare('SELECT * FROM test.issue_11');
$right_sth = $slave_dbh->prepare('SELECT * FROM test.issue_11');
$left_sth->execute();
$right_sth->execute();
$s = new MockSync();
$d->compare_sets(
left => $left_sth,
right => $right_sth,
syncer => $s,
tbl => $tbl,
);
is_deeply(
$s,
[
['not in left', { a => 1, b => 2, c => 3 },],
'done',
],
'right only (real DBI sth)',
);
$slave_dbh->do('TRUNCATE TABLE test.issue_11');
$master_dbh->do('SET SQL_LOG_BIN=0;');
$master_dbh->do('INSERT INTO test.issue_11 VALUES (1,2,3)');
$left_sth = $master_dbh->prepare('SELECT * FROM test.issue_11');
$right_sth = $slave_dbh->prepare('SELECT * FROM test.issue_11');
$left_sth->execute();
$right_sth->execute();
$s = new MockSync();
$d->compare_sets(
left => $left_sth,
right => $right_sth,
syncer => $s,
tbl => $tbl,
);
is_deeply(
$s,
[
[ 'not in right', { a => 1, b => 2, c => 3 },],
'done',
],
'left only (real DBI sth)',
);
$slave_dbh->do('INSERT INTO test.issue_11 VALUES (1,2,3)');
$left_sth = $master_dbh->prepare('SELECT * FROM test.issue_11');
$right_sth = $slave_dbh->prepare('SELECT * FROM test.issue_11');
$left_sth->execute();
$right_sth->execute();
$s = new MockSync();
$d->compare_sets(
left => $left_sth,
right => $right_sth,
syncer => $s,
tbl => $tbl,
);
is_deeply(
$s,
[
'same',
'done',
],
'one identical row (real DBI sth)',
);
$sb->wipe_clean($master_dbh);
$sb->wipe_clean($slave_dbh);
ok($sb->ok(), "Sandbox servers") or BAIL_OUT(__FILE__ . " broke the sandbox");
exit;
|
