← Back to branch summary

~percona-toolkit-dev/percona-toolkit/release-2.2.2

« back to all changes in this revision

Viewing changes to t/lib/CompareQueryTimes.t

  • Committer: Daniel Nichter
  • Date: 2011-06-24 17:22:06 UTC
  • Revision ID: daniel@percona.com-20110624172206-c7q4s4ad6r260zz6
Add lib/, t/lib/, and sandbox/.  All modules are updated and passing on MySQL 5.1.

Show diffs side-by-side

added added

removed removed

Lines of Context:
t/lib/CompareQueryTimes.t
 
1
#!/usr/bin/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 ReportFormatter;
 
15
use Transformers;
 
16
use DSNParser;
 
17
use Sandbox;
 
18
use CompareQueryTimes;
 
19
use MaatkitTest;
 
20
 
 
21
my $dp  = new DSNParser(opts=>$dsn_opts);
 
22
my $sb  = new Sandbox(basedir => '/tmp', DSNParser => $dp);
 
23
my $dbh = $sb->get_dbh_for('master');
 
24
 
 
25
if ( !$dbh ) {
 
26
   plan skip_all => "Cannot connect to sandbox master";
 
27
}
 
28
else {
 
29
   plan tests => 24;
 
30
}
 
31
 
 
32
$sb->create_dbs($dbh, ['test']);
 
33
 
 
34
Transformers->import(qw(make_checksum));
 
35
 
 
36
my $ct;
 
37
my $report;
 
38
my $hosts = [
 
39
   { dbh => $dbh, name => 'server1' },
 
40
   { dbh => $dbh, name => 'server2' },
 
41
];
 
42
 
 
43
sub get_id {
 
44
   return make_checksum(@_);
 
45
}
 
46
 
 
47
# #############################################################################
 
48
# Test it.
 
49
# #############################################################################
 
50
 
 
51
# diag(`/tmp/12345/use < samples/compare-warnings.sql`);
 
52
 
 
53
$ct = new CompareQueryTimes(
 
54
   get_id => \&get_id,
 
55
);
 
56
 
 
57
isa_ok($ct, 'CompareQueryTimes');
 
58
 
 
59
# #############################################################################
 
60
# Test query time comparison.
 
61
# #############################################################################
 
62
sub compare {
 
63
   my ( $t1, $t2 ) = @_;
 
64
   return $ct->compare(
 
65
      events => [
 
66
         { fingerprint => 'foo', Query_time => $t1, },
 
67
         { fingerprint => 'foo', Query_time => $t2, },
 
68
      ],
 
69
   );
 
70
}
 
71
 
 
72
sub test_compare_query_times {
 
73
   my ( $t1, $t2, $diff, $comment ) = @_;
 
74
   my %diff = compare($t1, $t2);
 
75
   my $msg  = sprintf("compare t %.6f vs. %.6f %s",
 
76
      $t1, $t2, ($comment || ''));
 
77
   is(
 
78
      $diff{different_query_times},
 
79
      $diff,
 
80
      $msg,
 
81
   );
 
82
}
 
83
 
 
84
test_compare_query_times(0, 0, 0);
 
85
test_compare_query_times(0, 0.000001, 1, 'increase from zero');
 
86
test_compare_query_times(0.000001, 0.000005, 0, 'no increase in bucket');
 
87
test_compare_query_times(0.000001, 0.000010, 1, '1 bucket diff on edge');
 
88
test_compare_query_times(0.000008, 0.000018, 1, '1 bucket diff');
 
89
test_compare_query_times(0.000001, 10, 1, 'full bucket range diff on edges');
 
90
test_compare_query_times(0.000008, 1000000, 1, 'huge diff');
 
91
 
 
92
# Thresholds
 
93
test_compare_query_times(0.000001, 0.000006, 1, '1us threshold');
 
94
test_compare_query_times(0.000010, 0.000020, 1, '10us threshold');
 
95
test_compare_query_times(0.000100, 0.000200, 1, '100us threshold');
 
96
test_compare_query_times(0.001000, 0.006000, 1, '1ms threshold');
 
97
test_compare_query_times(0.010000, 0.015000, 1, '10ms threshold');
 
98
test_compare_query_times(0.100000, 0.150000, 1, '100ms threshold');
 
99
test_compare_query_times(1.000000, 1.200000, 1, '1s threshold');
 
100
test_compare_query_times(10.0,     10.1,     1, '10s threshold');
 
101
 
 
102
# #############################################################################
 
103
# Test the main actions, which don't do much.
 
104
# #############################################################################
 
105
my $event = {
 
106
   fingerprint => 'set @a=?',
 
107
   arg         => 'set @a=3',
 
108
   sampleno    => 4,
 
109
};
 
110
 
 
111
$dbh->do('set @a=1');
 
112
is_deeply(
 
113
   $dbh->selectcol_arrayref('select @a'),
 
114
   [1],
 
115
   '@a set'
 
116
);
 
117
 
 
118
is_deeply(
 
119
   $ct->before_execute(event => $event),
 
120
   $event,
 
121
   "before_execute() doesn't modify event"
 
122
);
 
123
 
 
124
$ct->execute(event => $event, dbh => $dbh);
 
125
 
 
126
ok(
 
127
   exists $event->{Query_time}
 
128
   && $event->{Query_time} >= 0,
 
129
   'execute() set Query_time'
 
130
);
 
131
 
 
132
is_deeply(
 
133
   $dbh->selectcol_arrayref('select @a'),
 
134
   [3],
 
135
   'Query was actually executed'
 
136
);
 
137
 
 
138
is_deeply(
 
139
   $ct->after_execute(event => $event),
 
140
   $event,
 
141
   "after_execute() doesn't modify event"
 
142
);
 
143
 
 
144
 
 
145
# #############################################################################
 
146
# Test the reports.
 
147
# #############################################################################
 
148
$ct->reset();
 
149
compare(0.000100, 0.000250);
 
150
 
 
151
$report = <<EOF;
 
152
# Significant query time differences
 
153
# Query ID           server1 server2 %Increase %Threshold
 
154
# ================== ======= ======= ========= ==========
 
155
# EDEF654FCCC4A4D8-0   100us   250us    150.00        100
 
156
EOF
 
157
 
 
158
is(
 
159
   $ct->report(hosts => $hosts),
 
160
   $report,
 
161
   'report in bucket difference'
 
162
);
 
163
 
 
164
$ct->reset();
 
165
compare(0.000100, 1.100251);
 
166
 
 
167
$report = <<EOF;
 
168
# Big query time differences
 
169
# Query ID           server1 server2 Difference
 
170
# ================== ======= ======= ==========
 
171
# EDEF654FCCC4A4D8-0   100us      1s         1s
 
172
EOF
 
173
 
 
174
is(
 
175
   $ct->report(hosts => $hosts),
 
176
   $report,
 
177
   'report in bucket difference'
 
178
);
 
179
 
 
180
# #############################################################################
 
181
# Done.
 
182
# #############################################################################
 
183
my $output = '';
 
184
{
 
185
   local *STDERR;
 
186
   open STDERR, '>', \$output;
 
187
   $ct->_d('Complete test coverage');
 
188
}
 
189
like(
 
190
   $output,
 
191
   qr/Complete test coverage/,
 
192
   '_d() works'
 
193
);
 
194
$sb->wipe_clean($dbh);
 
195
exit;