« back to all changes in this revision
Viewing changes to tests/test_delayed_insert.pl
- browse files at revision 28.1.30
- compare with another revision
- download diff
- download tarball
- view history from revision 28.1.30
- Committer: Monty Taylor
- Date: 2008-07-02 06:27:14 UTC
- mto: (28.2.1 packaging) (77.1.30 codestyle)
- mto: This revision was merged to the branch mainline in revision 51.
- Revision ID: monty@inaugust.com-20080702062714-0q5i32n5urs5s951
Removed mysql_upgrade and tests/
- files removed:
- client/mysql_upgrade.c
- tests
- files modified:
- Makefile.am
added
removed
tests/test_delayed_insert.pl
1
#!/usr/bin/perl -w
2
3
# This is a test for INSERT DELAYED
4
#
5
6
$opt_loop_count=10000; # Change this to make test harder/easier
7
8
##################### Standard benchmark inits ##############################
9
10
use DBI;
11
use Getopt::Long;
12
use Benchmark;
13
14
package main;
15
16
$opt_skip_create=$opt_skip_in=$opt_verbose=$opt_fast_insert=
17
$opt_lock_tables=$opt_debug=$opt_skip_delete=$opt_fast=$opt_force=0;
18
$opt_host=$opt_user=$opt_password=""; $opt_db="test";
19
20
GetOptions("host=s","db=s","loop-count=i","skip-create","skip-in","skip-delete",
21
"verbose","fast-insert","lock-tables","debug","fast","force") || die "Aborted";
22
$opt_verbose=$opt_debug=$opt_lock_tables=$opt_fast_insert=$opt_fast=$opt_skip_in=$opt_force=undef; # Ignore warnings from these
23
24
print "Testing 8 multiple connections to a server with 1 insert, 2 delayed\n";
25
print "insert, 1 update, 1 delete, 1 flush tables and 3 select connections.\n";
26
27
$firsttable = "bench_f1";
28
$secondtable = "bench_f2";
29
30
####
31
#### Start timeing and start test
32
####
33
34
$start_time=new Benchmark;
35
if (!$opt_skip_create)
36
{
37
$dbh = DBI->connect("DBI:mysql:$opt_db:$opt_host") || die $DBI::errstr;
38
$Mysql::QUIET = 1;
39
$dbh->do("drop table if exists $firsttable,$secondtable");
40
$Mysql::QUIET = 0;
41
42
print "Creating tables $firsttable and $secondtable in database $opt_db\n";
43
$dbh->do("create table $firsttable (id int(6) not null, info varchar(32), marker char(1), primary key(id))") or die $DBI::errstr;
44
$dbh->do("create table $secondtable (id int(6) not null, row int(3) not null,value double, primary key(id,row))") or die $DBI::errstr;
45
46
$dbh->disconnect;
47
}
48
$|= 1; # Autoflush
49
50
####
51
#### Start the tests
52
####
53
54
test_1() if (($pid=fork()) == 0); $work{$pid}="insert";
55
test_delayed_1() if (($pid=fork()) == 0); $work{$pid}="delayed_insert1";
56
test_delayed_2() if (($pid=fork()) == 0); $work{$pid}="delayed_insert2";
57
test_2() if (($pid=fork()) == 0); $work{$pid}="update";
58
test_3() if (($pid=fork()) == 0); $work{$pid}="select1";
59
test_4() if (($pid=fork()) == 0); $work{$pid}="select2";
60
test_5() if (($pid=fork()) == 0); $work{$pid}="select3";
61
test_del() if (($pid=fork()) == 0); $work{$pid}="delete";
62
test_flush() if (($pid=fork()) == 0); $work{$pid}="flush";
63
64
$errors=0;
65
while (($pid=wait()) != -1)
66
{
67
$ret=$?/256;
68
print "thread '" . $work{$pid} . "' finished with exit code $ret\n";
69
$errors++ if ($ret != 0);
70
}
71
72
if (!$opt_skip_delete && !$errors)
73
{
74
$dbh = DBI->connect("DBI:mysql:$opt_db:$opt_host") || die $DBI::errstr;
75
$dbh->do("drop table $firsttable");
76
$dbh->do("drop table $secondtable");
77
}
78
print ($errors ? "Test failed\n" :"Test ok\n");
79
80
$end_time=new Benchmark;
81
print "Total time: " .
82
timestr(timediff($end_time, $start_time),"noc") . "\n";
83
84
exit(0);
85
86
#
87
# Insert records in the two tables
88
#
89
90
sub test_1
91
{
92
my ($dbh,$tmpvar,$rows,$found,$i);
93
94
$dbh = DBI->connect("DBI:mysql:$opt_db:$opt_host") || die $DBI::errstr;
95
$tmpvar=1;
96
$rows=$found=0;
97
for ($i=0 ; $i < $opt_loop_count; $i++)
98
{
99
$tmpvar^= ((($tmpvar + 63) + $i)*3 % 100000);
100
$dbh->do("insert into $firsttable values ($i,'This is entry $i','')") || die "Got error on insert: $DBI::errstr\n";
101
$row_count=($i % 7)+1;
102
$rows+=1+$row_count;
103
for ($j=0 ; $j < $row_count; $j++)
104
{
105
$dbh->do("insert into $secondtable values ($i,$j,0)") || die "Got error on insert: $DBI::errstr\n";
106
}
107
}
108
$dbh->disconnect;
109
print "Test_1: Inserted $rows rows\n";
110
exit(0);
111
}
112
113
114
sub test_delayed_1
115
{
116
my ($dbh,$tmpvar,$rows,$found,$i,$id);
117
118
$dbh = DBI->connect("DBI:mysql:$opt_db:$opt_host") || die $DBI::errstr;
119
$tmpvar=1;
120
$rows=$found=0;
121
for ($i=0 ; $i < $opt_loop_count; $i++)
122
{
123
$tmpvar^= ((($tmpvar + 63) + $i)*3 % 100000);
124
$id=$i+$opt_loop_count;
125
$dbh->do("insert delayed into $firsttable values ($id,'This is entry $id','')") || die "Got error on insert: $DBI::errstr\n";
126
$row_count=($i % 7)+1;
127
$rows+=1+$row_count;
128
for ($j=0 ; $j < $row_count; $j++)
129
{
130
$dbh->do("insert into $secondtable values ($id,$j,0)") || die "Got error on insert: $DBI::errstr\n";
131
}
132
if (($tmpvar % 100) == 0)
133
{
134
$dbh->do("select max(info) from $firsttable") || die "Got error on select max(info): $DBI::errstr\n";
135
$dbh->do("select max(value) from $secondtable") || die "Got error on select max(info): $DBI::errstr\n";
136
$found+=2;
137
}
138
}
139
$dbh->disconnect;
140
print "Test_1: Inserted delayed $rows rows, found $found rows\n";
141
exit(0);
142
}
143
144
145
sub test_delayed_2
146
{
147
my ($dbh,$tmpvar,$rows,$found,$i,$id);
148
149
$dbh = DBI->connect("DBI:mysql:$opt_db:$opt_host") || die $DBI::errstr;
150
$tmpvar=1;
151
$rows=$found=0;
152
for ($i=0 ; $i < $opt_loop_count; $i++)
153
{
154
$tmpvar^= ((($tmpvar + 63) + $i)*3 % 100000);
155
$id=$i+$opt_loop_count*2;
156
$dbh->do("insert delayed into $firsttable values ($id,'This is entry $id','')") || die "Got error on insert: $DBI::errstr\n";
157
$row_count=($i % 7)+1;
158
$rows+=1+$row_count;
159
for ($j=0 ; $j < $row_count; $j++)
160
{
161
$dbh->do("insert delayed into $secondtable values ($id,$j,0)") || die "Got error on insert: $DBI::errstr\n";
162
}
163
if (($tmpvar % 100) == 0)
164
{
165
$dbh->do("select max(info) from $firsttable") || die "Got error on select max(info): $DBI::errstr\n";
166
$dbh->do("select max(value) from $secondtable") || die "Got error on select max(info): $DBI::errstr\n";
167
$found+=2;
168
}
169
}
170
$dbh->disconnect;
171
print "Test_1: Inserted delayed $rows rows, found $found rows\n";
172
exit(0);
173
}
174
175
#
176
# Update records in both tables
177
#
178
179
sub test_2
180
{
181
my ($dbh,$id,$tmpvar,$rows,$found,$i,$max_id,$tmp,$sth,$count);
182
183
$dbh = DBI->connect("DBI:mysql:$opt_db:$opt_host") || die $DBI::errstr;
184
$tmpvar=111111;
185
$rows=$found=$max_id=$id=0;
186
for ($i=0 ; $i < $opt_loop_count ; $i++)
187
{
188
$tmp=(($tmpvar + 63) + $i)*3;
189
$tmp=$tmp-int($tmp/100000)*100000;
190
$tmpvar^= $tmp;
191
$tmp=$tmpvar - int($tmpvar/10)*10;
192
if ($max_id*$tmp == 0)
193
{
194
$max_id=0;
195
$sth=$dbh->prepare("select max(id) from $firsttable where marker=''");
196
$sth->execute() || die "Got error select max: $DBI::errstr\n";
197
if ((@row = $sth->fetchrow_array()) && defined($row[0]))
198
{
199
$found++;
200
$max_id=$id=$row[0];
201
}
202
$sth->finish;
203
}
204
else
205
{
206
$id= $tmpvar % ($max_id-1)+1;
207
}
208
if ($id)
209
{
210
($count=$dbh->do("update $firsttable set marker='x' where id=$id")) || die "Got error update $firsttable: $DBI::errstr\n";
211
$rows+=$count;
212
if ($count > 0)
213
{
214
$count=$dbh->do("update $secondtable set value=$i where id=$id") || die "Got error update $firsttable: $DBI::errstr\n";
215
$rows+=$count;
216
}
217
}
218
}
219
$dbh->disconnect;
220
print "Test_2: Found $found rows, Updated $rows rows\n";
221
exit(0);
222
}
223
224
225
#
226
# select records
227
#
228
229
sub test_3
230
{
231
my ($dbh,$id,$tmpvar,$rows,$i,$count);
232
$dbh = DBI->connect("DBI:mysql:$opt_db:$opt_host") || die $DBI::errstr;
233
$tmpvar=222222;
234
$rows=0;
235
for ($i=0 ; $i < $opt_loop_count ; $i++)
236
{
237
$tmpvar^= ((($tmpvar + 63) + $i)*3 % 100000);
238
$id=$tmpvar % $opt_loop_count;
239
$count=$dbh->do("select id from $firsttable where id=$id") || die "Got error on select from $firsttable: $DBI::errstr\n";
240
$rows+=$count;
241
}
242
$dbh->disconnect;
243
print "Test_3: Found $rows rows\n";
244
exit(0);
245
}
246
247
248
#
249
# Note that this uses row=1 and in some cases won't find any matching
250
# records
251
#
252
253
sub test_4
254
{
255
my ($dbh,$id,$tmpvar,$rows,$i,$count);
256
$dbh = DBI->connect("DBI:mysql:$opt_db:$opt_host") || die $DBI::errstr;
257
$tmpvar=333333;
258
$rows=0;
259
for ($i=0 ; $i < $opt_loop_count; $i++)
260
{
261
$tmpvar^= ((($tmpvar + 63) + $i)*3 % 100000);
262
$id=$tmpvar % $opt_loop_count;
263
$count=$dbh->do("select id from $secondtable where id=$id") || die "Got error on select from $secondtable: $DBI::errstr\n";
264
$rows+=$count;
265
}
266
$dbh->disconnect;
267
print "Test_4: Found $rows rows\n";
268
exit(0);
269
}
270
271
272
sub test_5
273
{
274
my ($dbh,$id,$tmpvar,$rows,$i,$max_id,$count,$sth);
275
$dbh = DBI->connect("DBI:mysql:$opt_db:$opt_host") || die $DBI::errstr;
276
$tmpvar=444444;
277
$rows=$max_id=0;
278
for ($i=0 ; $i < $opt_loop_count ; $i++)
279
{
280
$tmpvar^= ((($tmpvar + 63) + $i)*3 % 100000);
281
if ($max_id == 0 || ($tmpvar % 10 == 0))
282
{
283
$sth=$dbh->prepare("select max(id) from $firsttable");
284
$sth->execute() || die "Got error select max: $DBI::errstr\n";
285
if ((@row = $sth->fetchrow_array()) && defined($row[0]))
286
{
287
$max_id=$id=$row[0];
288
}
289
else
290
{
291
$id=0;
292
}
293
$sth->finish;
294
}
295
else
296
{
297
$id= $tmpvar % $max_id;
298
}
299
$count=$dbh->do("select value from $firsttable,$secondtable where $firsttable.id=$id and $secondtable.id=$firsttable.id") || die "Got error on select from $secondtable: $DBI::errstr\n";
300
$rows+=$count;
301
}
302
$dbh->disconnect;
303
print "Test_5: Found $rows rows\n";
304
exit(0);
305
}
306
307
308
#
309
# Delete the smallest row
310
#
311
312
sub test_del
313
{
314
my ($dbh,$min_id,$i,$sth,$rows);
315
$dbh = DBI->connect("DBI:mysql:$opt_db:$opt_host") || die $DBI::errstr;
316
$rows=0;
317
for ($i=0 ; $i < $opt_loop_count/3; $i++)
318
{
319
$sth=$dbh->prepare("select min(id) from $firsttable");
320
$sth->execute() || die "Got error on select from $firsttable: $DBI::errstr\n";
321
if ((@row = $sth->fetchrow_array()) && defined($row[0]))
322
{
323
$min_id=$row[0];
324
}
325
$sth->finish;
326
$dbh->do("delete from $firsttable where id = $min_id") || die "Got error on DELETE from $firsttable: $DBI::errstr\n";
327
$rows++;
328
}
329
$dbh->disconnect;
330
print "Test_del: Deleted $rows rows\n";
331
exit(0);
332
}
333
334
335
#
336
# Do a flush tables once in a while
337
#
338
339
sub test_flush
340
{
341
my ($dbh,$sth,$found1,$last_found1,$i,@row);
342
$found1=0; $last_found1=-1;
343
344
$dbh = DBI->connect("DBI:mysql:$opt_db:$opt_host",
345
$opt_user, $opt_password,
346
{ PrintError => 0}) || die $DBI::errstr;
347
348
for ($i=0; $found1 != $last_found1 ; $i++)
349
{
350
$sth=$dbh->prepare("flush tables") || die "Got error on prepare: $dbh->errstr\n";
351
$sth->execute || die $dbh->errstr;
352
$sth->finish;
353
354
$sth=$dbh->prepare("select count(*) from $firsttable") || die "Got error on prepare: $dbh->errstr\n";
355
$sth->execute || die $dbh->errstr;
356
@row = $sth->fetchrow_array();
357
$last_found1=$found1;
358
$found1= $row[0];
359
$sth->finish;
360
sleep(5);
361
}
362
$dbh->disconnect; $dbh=0;
363
print "flush: Did $i repair/checks\n";
364
exit(0);
365
}
Loggerhead is a web-based interface for Breezy
Version: 2.0.1