test-insert.sh
上传用户:tsgydb
上传日期:2007-04-14
资源大小:10674k
文件大小:45k
源码类别:

MySQL数据库

开发平台:

Visual C++

  1. #!@PERL@
  2. # Copyright (C) 2000 MySQL AB & MySQL Finland AB & TCX DataKonsult AB
  3. #
  4. # This library is free software; you can redistribute it and/or
  5. # modify it under the terms of the GNU Library General Public
  6. # License as published by the Free Software Foundation; either
  7. # version 2 of the License, or (at your option) any later version.
  8. #
  9. # This library is distributed in the hope that it will be useful,
  10. # but WITHOUT ANY WARRANTY; without even the implied warranty of
  11. # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  12. # Library General Public License for more details.
  13. #
  14. # You should have received a copy of the GNU Library General Public
  15. # License along with this library; if not, write to the Free
  16. # Software Foundation, Inc., 59 Temple Place - Suite 330, Boston,
  17. # MA 02111-1307, USA
  18. #
  19. # Test of creating a simple table and inserting $record_count records in it,
  20. # $opt_loop_count rows in order, $opt_loop_count rows in reverse order and
  21. # $opt_loop_count rows in random order
  22. #
  23. # changes made for Oracle compatibility
  24. # - $limits{'func_odbc_mod'} is OK from crash-me, but it fails here so set we
  25. #   set it to 0 in server-cfg
  26. # - the default server config runs out of rollback segments, so I added a couple
  27. #   of disconnect/connects to reset
  28. ##################### Standard benchmark inits ##############################
  29. use DBI;
  30. use Benchmark;
  31. $opt_loop_count=100000; # number of rows/3
  32. $small_loop_count=10; # Loop for full table retrieval
  33. $range_loop_count=$small_loop_count*50;
  34. $many_keys_loop_count=$opt_loop_count;
  35. $opt_read_key_loop_count=$opt_loop_count;
  36. chomp($pwd = `pwd`); $pwd = "." if ($pwd eq '');
  37. require "$pwd/bench-init.pl" || die "Can't read Configuration file: $!n";
  38. if ($opt_loop_count < 256)
  39. {
  40.   $opt_loop_count=256; # Some tests must have some data to work!
  41. }
  42. if ($opt_small_test)
  43. {
  44.   $opt_loop_count/=100;
  45.   $many_keys_loop_count=$opt_loop_count/10;
  46.   $range_loop_count=10;
  47.   $opt_read_key_loop_count=10;
  48. }
  49. elsif ($opt_small_tables)
  50. {
  51.   $opt_loop_count=10000; # number of rows/3
  52.   $many_keys_loop_count=$opt_loop_count;
  53.   $opt_read_key_loop_count=10;
  54. }
  55. elsif ($opt_small_key_tables)
  56. {
  57.   $many_keys_loop_count/=10;
  58. }
  59. print "Testing the speed of inserting data into 1 table and do some selects on it.n";
  60. print "The tests are done with a table that has $opt_loop_count rows.nn";
  61. ####
  62. #### Generating random keys
  63. ####
  64. print "Generating random keysn";
  65. $random[$opt_loop_count]=0;
  66. for ($i=0 ; $i < $opt_loop_count ; $i++)
  67. {
  68.   $random[$i]=$i+$opt_loop_count;
  69. }
  70. my $tmpvar=1;
  71. for ($i=0 ; $i < $opt_loop_count ; $i++)
  72. {
  73.   $tmpvar^= ((($tmpvar + 63) + $i)*3 % $opt_loop_count);
  74.   $swap=$tmpvar % $opt_loop_count;
  75.   $tmp=$random[$i]; $random[$i]=$random[$swap]; $random[$swap]=$tmp;
  76. }
  77. $total_rows=$opt_loop_count*3;
  78. ####
  79. ####  Connect and start timeing
  80. ####
  81. $start_time=new Benchmark;
  82. $dbh = $server->connect();
  83. ####
  84. #### Create needed tables
  85. ####
  86. goto keys_test if ($opt_stage == 2);
  87. goto select_test if ($opt_skip_create);
  88. print "Creating tablesn";
  89. $dbh->do("drop table bench1" . $server->{'drop_attr'});
  90. $dbh->do("drop table bench2" . $server->{'drop_attr'});
  91. $dbh->do("drop table bench3" . $server->{'drop_attr'});
  92. do_many($dbh,$server->create("bench1",
  93.      ["id int NOT NULL",
  94.       "id2 int NOT NULL",
  95.       "id3 int NOT NULL",
  96.       "dummy1 char(30)"],
  97.      ["primary key (id,id2)",
  98.      "index index_id3 (id3)"]));
  99. if ($opt_lock_tables)
  100. {
  101.   $sth = $dbh->do("LOCK TABLES bench1 WRITE") || die $DBI::errstr;
  102. }
  103. ####
  104. #### Insert $total_rows records in order, in reverse order and random.
  105. ####
  106. $loop_time=new Benchmark;
  107. if ($opt_fast_insert)
  108. {
  109.   $query="insert into bench1 values ";
  110. }
  111. else
  112. {
  113.   $query="insert into bench1 (id,id2,id3,dummy1) values ";
  114. }
  115. if (($opt_fast || $opt_fast_insert) && $limits->{'insert_multi_value'})
  116. {
  117.   $query_size=$server->{'limits'}->{'query_size'};
  118.   print "Inserting $opt_loop_count multiple-value rows in ordern";
  119.   $res=$query;
  120.   for ($i=0 ; $i < $opt_loop_count ; $i++)
  121.   {
  122.     $tmp= "($i,$i,$i,'ABCDEFGHIJ'),";
  123.     if (length($tmp)+length($res) < $query_size)
  124.     {
  125.       $res.= $tmp;
  126.     }
  127.     else
  128.     {
  129.       $sth = $dbh->do(substr($res,0,length($res)-1)) or die $DBI::errstr;
  130.       $res=$query . $tmp;
  131.     }
  132.   }
  133.   print "Inserting $opt_loop_count multiple-value rows in reverse ordern";
  134.   for ($i=0 ; $i < $opt_loop_count ; $i++)
  135.   {
  136.     $tmp= "(" . ($total_rows-1-$i) . "," .($total_rows-1-$i) .
  137.       "," .($total_rows-1-$i) . ",'BCDEFGHIJK'),";
  138.     if (length($tmp)+length($res) < $query_size)
  139.     {
  140.       $res.= $tmp;
  141.     }
  142.     else
  143.     {
  144.       $sth = $dbh->do(substr($res,0,length($res)-1)) or die $DBI::errstr;
  145.       $res=$query . $tmp;
  146.     }
  147.   }
  148.   print "Inserting $opt_loop_count multiple-value rows in random ordern";
  149.   for ($i=0 ; $i < $opt_loop_count ; $i++)
  150.   {
  151.     $tmp= "(" . $random[$i] . "," . $random[$i] . "," . $random[$i] .
  152.       ",'CDEFGHIJKL')," or die $DBI::errstr;
  153.     if (length($tmp)+length($res) < $query_size)
  154.     {
  155.       $res.= $tmp;
  156.     }
  157.     else
  158.     {
  159.       $sth = $dbh->do(substr($res,0,length($res)-1)) or die $DBI::errstr;
  160.       $res=$query . $tmp;
  161.     }
  162.   }
  163.   $sth = $dbh->do(substr($res,0,length($res)-1)) or die $DBI::errstr;
  164. }
  165. else
  166. {
  167.   print "Inserting $opt_loop_count rows in ordern";
  168.   for ($i=0 ; $i < $opt_loop_count ; $i++)
  169.   {
  170.     $sth = $dbh->do($query . "($i,$i,$i,'ABCDEFGHIJ')") or die $DBI::errstr;
  171.   }
  172.   print "Inserting $opt_loop_count rows in reverse ordern";
  173.   for ($i=0 ; $i < $opt_loop_count ; $i++)
  174.   {
  175.     $sth = $dbh->do($query . "(" . ($total_rows-1-$i) . "," .
  176.     ($total_rows-1-$i) . "," .
  177.     ($total_rows-1-$i) . ",'BCDEFGHIJK')")
  178.       or die $DBI::errstr;
  179.   }
  180.   print "Inserting $opt_loop_count rows in random ordern";
  181.   for ($i=0 ; $i < $opt_loop_count ; $i++)
  182.   {
  183.     $sth = $dbh->do($query . "(". $random[$i] . "," . $random[$i] .
  184.     "," . $random[$i] . ",'CDEFGHIJKL')") or die $DBI::errstr;
  185.   }
  186. }
  187. $end_time=new Benchmark;
  188. print "Time for insert (" . ($total_rows) . "): " .
  189.   timestr(timediff($end_time, $loop_time),"all") . "nn";
  190. if ($opt_lock_tables)
  191. {
  192.   $sth = $dbh->do("UNLOCK TABLES") || die $DBI::errstr;
  193. }
  194. if ($opt_fast && defined($server->{vacuum}))
  195. {
  196.   $server->vacuum(1,$dbh,"bench1");
  197. }
  198. if ($opt_lock_tables)
  199. {
  200.   $sth = $dbh->do("LOCK TABLES bench1 WRITE") || die $DBI::errstr;
  201. }
  202. ####
  203. #### insert $opt_loop_count records with duplicate id
  204. ####
  205. if ($limits->{'unique_index'})
  206. {
  207.   print "Testing insert of duplicatesn";
  208.   $loop_time=new Benchmark;
  209.   for ($i=0 ; $i < $opt_loop_count ; $i++)
  210.   {
  211.     $tmpvar^= ((($tmpvar + 63) + $i)*3 % $opt_loop_count);
  212.     $tmp=$tmpvar % ($total_rows);
  213.     $tmpquery = "$query ($tmp,$tmp,2,'D')";
  214.     if ($dbh->do($tmpquery))
  215.     {
  216.       die "Didn't get an error when inserting duplicate record $tmpn";
  217.     }
  218.   }
  219.   $end_time=new Benchmark;
  220.   print "Time for insert_duplicates (" . ($opt_loop_count) . "): " .
  221.   timestr(timediff($end_time, $loop_time),"all") . "nn";
  222. }
  223. #if ($opt_fast && defined($server->{vacuum}))
  224. #{
  225. #  $server->vacuum(1,$dbh);
  226. #}
  227. ####
  228. #### Do some selects on the table
  229. ####
  230. select_test:
  231. print "Retrieving data from the tablen";
  232. $loop_time=new Benchmark;
  233. $error=0;
  234. # It's really a small table, so we can try a select on everything
  235. $count=0;
  236. for ($i=1 ; $i <= $small_loop_count ; $i++)
  237. {
  238.   if (($found_rows=fetch_all_rows($dbh,"select id from bench1")) !=
  239.       $total_rows)
  240.   {
  241.     if (!$error++)
  242.     {
  243.       print "Warning: Got $found_rows rows when selecting a whole table of " . ($total_rows) . " rowsnContact the database or DBD author!n";
  244.     }
  245.   }
  246.   $count+=$found_rows;
  247. }
  248. $end_time=new Benchmark;
  249. print "Time for select_big ($small_loop_count:$count): " .
  250.     timestr(timediff($end_time, $loop_time),"all") . "n";
  251. #
  252. # Do a lot of different ORDER BY queries
  253. #
  254. $loop_time=new Benchmark;
  255. $estimated=$rows=0;
  256. for ($i=1 ; $i <= $small_loop_count ; $i++)
  257. {
  258.   $rows+=fetch_all_rows($dbh,"select id,id2 from bench1 order by id,id2",1);
  259.   $end_time=new Benchmark;
  260.   last if ($estimated=predict_query_time($loop_time,$end_time,$i,$i,
  261.  $small_loop_count));
  262. }
  263. if ($estimated)
  264. { print "Estimated time"; }
  265. else
  266. { print "Time"; }
  267. print " for order_by_big_key ($small_loop_count:$rows): " .
  268.   timestr(timediff($end_time, $loop_time),"all") . "n";
  269. $loop_time=new Benchmark;
  270. $estimated=$rows=0;
  271. for ($i=1 ; $i <= $small_loop_count ; $i++)
  272. {
  273.   $rows+=fetch_all_rows($dbh,"select id,id2 from bench1 order by id desc, id2 desc",1);
  274.   $end_time=new Benchmark;
  275.   last if ($estimated=predict_query_time($loop_time,$end_time,$i,$i,
  276.  $small_loop_count));
  277. }
  278. if ($estimated)
  279. { print "Estimated time"; }
  280. else
  281. { print "Time"; }
  282. print " for order_by_big_key_desc ($small_loop_count:$rows): " .
  283.   timestr(timediff($end_time, $loop_time),"all") . "n";
  284. $loop_time=new Benchmark;
  285. $estimated=$rows=0;
  286. for ($i=1 ; $i <= $small_loop_count ; $i++)
  287. {
  288.   $rows+=fetch_all_rows($dbh,"select id from bench1 order by id desc",1);
  289.   $end_time=new Benchmark;
  290.   last if ($estimated=predict_query_time($loop_time,$end_time,$i,$i,
  291.  $small_loop_count));
  292. }
  293. if ($estimated)
  294. { print "Estimated time"; }
  295. else
  296. { print "Time"; }
  297. print " for order_by_big_key_prefix ($small_loop_count:$rows): " .
  298.   timestr(timediff($end_time, $loop_time),"all") . "n";
  299. $loop_time=new Benchmark;
  300. $estimated=$rows=0;
  301. for ($i=1 ; $i <= $small_loop_count ; $i++)
  302. {
  303.   $rows+=fetch_all_rows($dbh,"select id3 from bench1 order by id3",1);
  304.   $end_time=new Benchmark;
  305.   last if ($estimated=predict_query_time($loop_time,$end_time,$i,$i,
  306.  $small_loop_count));
  307. }
  308. if ($estimated)
  309. { print "Estimated time"; }
  310. else
  311. { print "Time"; }
  312. print " for order_by_big_key2 ($small_loop_count:$rows): " .
  313.   timestr(timediff($end_time, $loop_time),"all") . "n";
  314. $sel=$limits->{'order_by_unused'} ? "id2" : "*";
  315. $loop_time=new Benchmark;
  316. $estimated=$rows=0;
  317. for ($i=1 ; $i <= $small_loop_count ; $i++)
  318. {
  319.   $rows+=fetch_all_rows($dbh,"select $sel from bench1 order by id3",1);
  320.   $end_time=new Benchmark;
  321.   last if ($estimated=predict_query_time($loop_time,$end_time,$i,$i,
  322.  $small_loop_count));
  323. }
  324. if ($estimated)
  325. { print "Estimated time"; }
  326. else
  327. { print "Time"; }
  328. print " for order_by_big_key_diff ($small_loop_count:$rows): " .
  329.   timestr(timediff($end_time, $loop_time),"all") . "n";
  330. $sel=$limits->{'order_by_unused'} ? "id" : "*";
  331. $loop_time=new Benchmark;
  332. $estimated=$rows=0;
  333. for ($i=1 ; $i <= $small_loop_count ; $i++)
  334. {
  335.   $rows+=fetch_all_rows($dbh,"select $sel from bench1 order by id2,id3",1);
  336.   $end_time=new Benchmark;
  337.   last if ($estimated=predict_query_time($loop_time,$end_time,$i,$i,
  338.  $small_loop_count));
  339. }
  340. if ($estimated)
  341. { print "Estimated time"; }
  342. else
  343. { print "Time"; }
  344. print " for order_by_big ($small_loop_count:$rows): " .
  345.   timestr(timediff($end_time, $loop_time),"all") . "n";
  346. $sel=$limits->{'order_by_unused'} ? "dummy1" : "dummy1,id3";
  347. $loop_time=new Benchmark;
  348. $estimated=$rows=0;
  349. for ($i=1 ; $i <= $range_loop_count ; $i++)
  350. {
  351.   $start=$opt_loop_count/$range_loop_count*$i;
  352.   $end=$start+$i;
  353.   $rows+=fetch_all_rows($dbh,"select $sel from bench1 where id>=$start and id <= $end order by id3",1);
  354.   $end_time=new Benchmark;
  355.   last if ($estimated=predict_query_time($loop_time,$end_time,$i,$i,
  356.  $range_loop_count));
  357. }
  358. if ($estimated)
  359. { print "Estimated time"; }
  360. else
  361. { print "Time"; }
  362. print " for order_by_range ($range_loop_count:$rows): " .
  363.   timestr(timediff($end_time, $loop_time),"all") . "n";
  364. $sel=$limits->{'order_by_unused'} ? "dummy1" : "dummy1,id";
  365. $loop_time=new Benchmark;
  366. $estimated=$rows=0;
  367. for ($i=1 ; $i <= $range_loop_count ; $i++)
  368. {
  369.   $start=$opt_loop_count/$range_loop_count*$i;
  370.   $end=$start+$i;
  371.   $rows+=fetch_all_rows($dbh,"select $sel from bench1 where id>=$start and id <= $end order by id",1);
  372.   $end_time=new Benchmark;
  373.   last if ($estimated=predict_query_time($loop_time,$end_time,$i,$i,
  374.  $range_loop_count));
  375. }
  376. if ($estimated)
  377. { print "Estimated time"; }
  378. else
  379. { print "Time"; }
  380. print " for order_by_key_prefix ($range_loop_count:$rows): " .
  381.   timestr(timediff($end_time, $loop_time),"all") . "n";
  382. $sel=$limits->{'order_by_unused'} ? "id2" : "id2,id3";
  383. $loop_time=new Benchmark;
  384. $estimated=$rows=0;
  385. for ($i=1 ; $i <= $range_loop_count ; $i++)
  386. {
  387.   $start=$opt_loop_count/$range_loop_count*$i;
  388.   $end=$start+$range_loop_count;
  389.   $rows+=fetch_all_rows($dbh,"select $sel from bench1 where id3>=$start and id3 <= $end order by id3",1);
  390.   $end_time=new Benchmark;
  391.   last if ($estimated=predict_query_time($loop_time,$end_time,$i,$i,
  392.  $range_loop_count));
  393. }
  394. if ($estimated)
  395. { print "Estimated time"; }
  396. else
  397. { print "Time"; }
  398. print " for order_by_key2_diff ($range_loop_count:$rows): " .
  399.   timestr(timediff($end_time, $loop_time),"all") . "n";
  400. #
  401. # Test of select on 2 different keys with or
  402. # (In this case database can only use keys if they do an automatic union).
  403. #
  404. $loop_time=new Benchmark;
  405. $estimated=0;
  406. $rows=0;
  407. $count=0;
  408. for ($i=1 ; $i <= $range_loop_count ; $i++)
  409. {
  410.   my $rnd=$i;
  411.   my $rnd2=$random[$i];
  412.   $rows+=fetch_all_rows($dbh,"select id2 from bench1 where id=$rnd or id3=$rnd2",1);
  413.   $count++;
  414.   $end_time=new Benchmark;
  415.   last if ($estimated=predict_query_time($loop_time,$end_time,$count,$count,
  416.  $range_loop_count));
  417. }
  418. if ($estimated)
  419. { print "Estimated time"; }
  420. else
  421. { print "Time"; }
  422. print " for select_diff_key ($count:$rows): " .
  423.   timestr(timediff($end_time, $loop_time),"all") . "n";
  424. # Test select that is very popular when using ODBC
  425. check_or_range("id","select_range_prefix");
  426. check_or_range("id3","select_range_key2");
  427. # Check reading on direct key on id and id3
  428. check_select_key("*","id","select_key_prefix");
  429. check_select_key2("*","id","id2","select_key");
  430. check_select_key2("id,id2","id","id2","select_key_return_key");
  431. check_select_key("*","id3","select_key2");
  432. check_select_key("id3","id3","select_key2_return_key");
  433. check_select_key("id,id2","id3","select_key2_return_prim");
  434. ####
  435. #### A lot of simple selects on ranges
  436. ####
  437. @Q=("select * from bench1 where !id!=3 or !id!=2 or !id!=1 or !id!=4 or !id!=16 or !id!=10",
  438.     6,
  439.     "select * from bench1 where !id!>=" . ($total_rows-1) ." or !id!<1",
  440.     2,
  441.     "select * from bench1 where !id!>=1 and !id!<=2",
  442.     2,
  443.     "select * from bench1 where (!id!>=1 and !id!<=2) or (!id!>=1 and !id!<=2)",
  444.     2,
  445.     "select * from bench1 where !id!>=1 and !id!<=10 and !id!<=5",
  446.     5,
  447.     "select * from bench1 where (!id!>0 and !id!<2) or !id!>=" . ($total_rows-1),
  448.     2,
  449.     "select * from bench1 where (!id!>0 and !id!<2) or (!id!>= " . ($opt_loop_count/2) . " and !id! <= " . ($opt_loop_count/2+2) . ") or !id! = " . ($opt_loop_count/2-1),
  450.     5,
  451.     "select * from bench1 where (!id!>=5 and !id!<=10) or (!id!>=1 and !id!<=4)",
  452.     10,
  453.     "select * from bench1 where (!id!=1 or !id!=2) and (!id!=3 or !id!=4)",
  454.     0,
  455.     "select * from bench1 where (!id!=1 or !id!=2) and (!id!=2 or !id!=3)",
  456.     1,
  457.     "select * from bench1 where (!id!=1 or !id!=5 or !id!=20 or !id!=40) and (!id!=1 or !id!>=20 or !id!=4)",
  458.     3,
  459.     "select * from bench1 where ((!id!=1 or !id!=3) or (!id!>1 and !id!<3)) and !id!<=2",
  460.     2,
  461.     "select * from bench1 where (!id! >= 0 and !id! < 4) or (!id! >=4 and !id! < 6)",
  462.     6,
  463.     "select * from bench1 where !id! <= -1 or (!id! >= 0 and !id! <= 5) or (!id! >=4 and !id! < 6) or (!id! >=6 and !id! <=7) or (!id!>7 and !id! <= 8)",
  464.     9,
  465.     "select * from bench1 where (!id!>=1 and !id!<=2 or !id!>=4 and !id!<=5) or (!id!>=0 and !id! <=10)",
  466.     11,
  467.     "select * from bench1 where (!id!>=1 and !id!<=2 or !id!>=4 and !id!<=5) or (!id!>2 and !id! <=10)",
  468.     10,
  469.     "select * from bench1 where (!id!>1 or !id! <1) and !id!<=2",
  470.     2,
  471.     "select * from bench1 where !id! <= 2 and (!id!>1 or !id! <=1)",
  472.     3,
  473.     "select * from bench1 where (!id!>=1 or !id! <1) and !id!<=2",
  474.     3,
  475.     "select * from bench1 where (!id!>=1 or !id! <=2) and !id!<=2",
  476.     3
  477.     );
  478. print "nTest of compares with simple rangesn";
  479. check_select_range("id","select_range_prefix");
  480. check_select_range("id3","select_range_key2");
  481. ####
  482. #### Some group queries
  483. ####
  484. if ($limits->{'group_functions'})
  485. {
  486.   $loop_time=new Benchmark;
  487.   $count=1;
  488.   $estimated=0;
  489.   for ($tests=0 ; $tests < $small_loop_count ; $tests++)
  490.   {
  491.     $sth=$dbh->prepare($query="select count(*) from bench1") or die $DBI::errstr;
  492.     $sth->execute or die $sth->errstr;
  493.     if (($sth->fetchrow_array)[0] != $total_rows)
  494.     {
  495.       print "Warning: '$query' returned wrong resultn";
  496.     }
  497.     $sth->finish;
  498.     # min, max in keys are very normal
  499.     $count+=7;
  500.     fetch_all_rows($dbh,"select min(id) from bench1");
  501.     fetch_all_rows($dbh,"select max(id) from bench1");
  502.     fetch_all_rows($dbh,"select sum(id+0.0) from bench1");
  503.     fetch_all_rows($dbh,"select min(id3),max(id3),sum(id3 +0.0) from bench1");
  504.     if ($limits->{'group_func_sql_min_str'})
  505.     {
  506.       fetch_all_rows($dbh,"select min(dummy1),max(dummy1) from bench1");
  507.     }
  508.     $count++;
  509.     $sth=$dbh->prepare($query="select count(*) from bench1 where id >= " .
  510.        ($opt_loop_count*2)) or die $DBI::errstr;
  511.     $sth->execute or die $DBI::errstr;
  512.     if (($sth->fetchrow_array)[0] != $opt_loop_count)
  513.     {
  514.       print "Warning: '$query' returned wrong resultn";
  515.     }
  516.     $sth->finish;
  517.     $count++;
  518.     $sth=$dbh->prepare($query="select count(*),sum(id+0.0),min(id),max(id),avg(id+0.0) from bench1") or die $DBI::errstr;
  519.     $sth->execute or die $DBI::errstr;
  520.     @row=$sth->fetchrow_array;
  521.     if ($row[0] != $total_rows ||
  522. int($row[1]+0.5) != int((($total_rows-1)/2*$total_rows)+0.5) ||
  523. $row[2] != 0 ||
  524. $row[3] != $total_rows-1 ||
  525. 1-$row[4]/(($total_rows-1)/2) > 0.001)
  526.     {
  527.       # PostgreSQL 6.3 fails here
  528.       print "Warning: '$query' returned wrong result: @rown";
  529.     }
  530.     $sth->finish;
  531.     if ($limits->{'func_odbc_mod'})
  532.     {
  533.       $tmp="mod(id,10)";
  534.       if ($limits->{'func_extra_%'})
  535.       {
  536. $tmp="id % 10"; # For postgreSQL
  537.       }
  538.       $count++;
  539.       if ($limits->{'group_by_alias'}) {
  540. if (fetch_all_rows($dbh,$query=$server->query("select $tmp as last_digit,count(*) from bench1 group by last_digit")) != 10)
  541. {
  542.   print "Warning: '$query' returned wrong number of rowsn";
  543. }
  544.       } elsif ($limits->{'group_by_position'}) {
  545. if (fetch_all_rows($dbh,$query=$server->query("select $tmp,count(*) from bench1 group by 1")) != 10)
  546. {
  547.   print "Warning: '$query' returned wrong number of rowsn";
  548. }
  549.       }
  550.     }
  551.     if ($limits->{'order_by_position'} && $limits->{'group_by_position'})
  552.     {
  553.       $count++;
  554.       if (fetch_all_rows($dbh, $query="select id,id3,dummy1 from bench1 where id < 100+$count-$count group by id,id3,dummy1 order by id desc,id3,dummy1") != 100)
  555.       {
  556. print "Warning: '$query' returned wrong number of rowsn";
  557.       }
  558.     }
  559.     $end_time=new Benchmark;
  560.     last if ($estimated=predict_query_time($loop_time,$end_time,$count,$tests,
  561.    $small_loop_count));
  562.   }
  563.   print_time($estimated);
  564.   print " for select_group ($count): " .
  565.       timestr(timediff($end_time, $loop_time),"all") . "n";
  566.   $loop_time=new Benchmark;
  567.   $count=$estimated=0;
  568.   for ($tests=1 ; $tests <= $range_loop_count*5 ; $tests++)
  569.   {
  570.     $count+=6;
  571.     fetch_all_rows($dbh,"select min(id) from bench1");
  572.     fetch_all_rows($dbh,"select max(id) from bench1");
  573.     fetch_all_rows($dbh,"select min(id2) from bench1 where id=$tests");
  574.     fetch_all_rows($dbh,"select max(id2) from bench1 where id=$tests");
  575.     if ($limits->{'group_func_sql_min_str'})
  576.     {
  577.       fetch_all_rows($dbh,"select min(dummy1) from bench1 where id=$tests");
  578.       fetch_all_rows($dbh,"select max(dummy1) from bench1 where id=$tests");
  579.     }
  580.     $end_time=new Benchmark;
  581.     last if ($estimated=predict_query_time($loop_time,$end_time,$count,$tests,
  582.    $range_loop_count*5));
  583.   }
  584.   if ($estimated)
  585.   { print "Estimated time"; }
  586.   else
  587.   { print "Time"; }
  588.   print " for min_max_on_key ($count): " .
  589.       timestr(timediff($end_time, $loop_time),"all") . "n";
  590.   $loop_time=new Benchmark;
  591.   $count=$estimated=0;
  592.   for ($tests=1 ; $tests <= $small_loop_count ; $tests++)
  593.   {
  594.     $count+=6;
  595.     fetch_all_rows($dbh,"select min(id2) from bench1");
  596.     fetch_all_rows($dbh,"select max(id2) from bench1");
  597.     fetch_all_rows($dbh,"select min(id3) from bench1 where id2=$tests");
  598.     fetch_all_rows($dbh,"select max(id3) from bench1 where id2=$tests");
  599.     if ($limits->{'group_func_sql_min_str'})
  600.     {
  601.       fetch_all_rows($dbh,"select min(dummy1) from bench1 where id2=$tests");
  602.       fetch_all_rows($dbh,"select max(dummy1) from bench1 where id2=$tests");
  603.     }
  604.     $end_time=new Benchmark;
  605.     last if ($estimated=predict_query_time($loop_time,$end_time,$count,$tests,
  606.    $range_loop_count));
  607.   }
  608.   if ($estimated)
  609.   { print "Estimated time"; }
  610.   else
  611.   { print "Time"; }
  612.   print " for min_max ($count): " .
  613.       timestr(timediff($end_time, $loop_time),"all") . "n";
  614.   $loop_time=new Benchmark;
  615.   $count=0;
  616.   $total=$opt_loop_count*3;
  617.   for ($tests=0 ; $tests < $total ; $tests+=$total/100)
  618.   {
  619.     $count+=1;
  620.     fetch_all_rows($dbh,"select count(id) from bench1 where id < $tests");
  621.   }
  622.   $end_time=new Benchmark;
  623.   print "Time for count_on_key ($count): " .
  624.       timestr(timediff($end_time, $loop_time),"all") . "n";
  625.   $loop_time=new Benchmark;
  626.   $count=0;
  627.   for ($tests=0 ; $tests < $total ; $tests+=$total/100)
  628.   {
  629.     $count+=1;
  630.     fetch_all_rows($dbh,"select count(dummy1) from bench1 where id2 < $tests");
  631.   }
  632.   $end_time=new Benchmark;
  633.   print "Time for count ($count): " .
  634.       timestr(timediff($end_time, $loop_time),"all") . "n";
  635.   if ($limits->{'group_distinct_functions'})
  636.   {
  637.     $loop_time=new Benchmark;
  638.     $count=$estimated=0;
  639.     for ($tests=1 ; $tests <= $small_loop_count ; $tests++)
  640.     {
  641.       $count+=2;
  642.       fetch_all_rows($dbh,"select count(distinct dummy1) from bench1");
  643.       fetch_all_rows($dbh,"select dummy1,count(distinct id) from bench1 group by dummy1");
  644.       $end_time=new Benchmark;
  645.       last if ($estimated=predict_query_time($loop_time,$end_time,$count,$tests,
  646.      $small_loop_count));
  647.     }
  648.     if ($estimated)
  649.     { print "Estimated time"; }
  650.     else
  651.     { print "Time"; }
  652.     print " for count_distinct_big ($count): " .
  653.     timestr(timediff($end_time, $loop_time),"all") . "n";
  654.   }
  655. }
  656. if ($server->small_rollback_segment())
  657. {
  658.   $dbh->disconnect; # close connection
  659.   $dbh = $server->connect();
  660. }
  661. ####
  662. #### Some updates on the table
  663. ####
  664. $loop_time=new Benchmark;
  665. if ($limits->{'functions'})
  666. {
  667.   print "nTesting update of keys with functionsn";
  668.   my $update_loop_count=$opt_loop_count/2;
  669.   for ($i=0 ; $i < $update_loop_count ; $i++)
  670.   {
  671.     my $tmp=$opt_loop_count+$random[$i]; # $opt_loop_count*2 <= $tmp < $total_rows
  672.     $sth = $dbh->do("update bench1 set id3=-$tmp where id3=$tmp") or die $DBI::errstr;
  673.   }
  674.   $end_time=new Benchmark;
  675.   print "Time for update_of_key ($update_loop_count):  " .
  676.     timestr(timediff($end_time, $loop_time),"all") . "n";
  677.   if ($opt_lock_tables)
  678.   {
  679.     do_query($dbh,"UNLOCK TABLES");
  680.   }
  681.   if ($opt_fast && defined($server->{vacuum}))
  682.   {
  683.     $server->vacuum(1,$dbh,"bench1");
  684.   }
  685.   if ($opt_lock_tables)
  686.   {
  687.     $sth = $dbh->do("LOCK TABLES bench1 WRITE") || die $DBI::errstr;
  688.   }
  689.   if ($server->small_rollback_segment())
  690.   {
  691.     $dbh->disconnect; # close connection
  692.     $dbh = $server->connect();
  693.   }
  694.   $loop_time=new Benchmark;
  695.   $count=0;
  696.   $step=int($opt_loop_count/$range_loop_count+1);
  697.   for ($i= 0 ; $i < $opt_loop_count ; $i+= $step)
  698.   {
  699.     $count++;
  700.     $sth=$dbh->do("update bench1 set id3= 0-id3 where id3 >= 0 and id3 <= $i") or die $DBI::errstr;
  701.   }
  702.   if ($server->small_rollback_segment())
  703.   {
  704.     $dbh->disconnect; # close connection
  705.     $dbh = $server->connect();
  706.   }
  707.   $count++;
  708.   $sth=$dbh->do("update bench1 set id3= 0-id3 where id3 >= 0 and id3 < $opt_loop_count") or die $DBI::errstr;
  709.   if ($server->small_rollback_segment())
  710.   {
  711.     $dbh->disconnect; # close connection
  712.     $dbh = $server->connect();
  713.   }
  714.   $count++;
  715.   $sth=$dbh->do("update bench1 set id3= 0-id3 where id3 >= $opt_loop_count and id3 < ". ($opt_loop_count*2)) or die $DBI::errstr;
  716.   #
  717.   # Check that everything was updated
  718.   # In principle we shouldn't time this in the update loop..
  719.   #
  720.   if ($server->small_rollback_segment())
  721.   {
  722.     $dbh->disconnect; # close connection
  723.     $dbh = $server->connect();
  724.   }
  725.   $row_count=0;
  726.   if (($sth=$dbh->prepare("select count(*) from bench1 where id3>=0"))
  727.       && $sth->execute)
  728.   {
  729.     ($row_count)=$sth->fetchrow;
  730.   }
  731.   $result=1 + $opt_loop_count-$update_loop_count;
  732.   if ($row_count != $result)
  733.   {
  734.     print "Warning: Update check returned $row_count instead of $resultn";
  735.   }
  736.   $sth->finish;
  737.   if ($server->small_rollback_segment())
  738.   {
  739.     $dbh->disconnect; # close connection
  740.     $dbh = $server->connect();
  741.   }
  742.   #restore id3 to 0 <= id3 < $total_rows/10 or 0<= id3 < $total_rows
  743.   my $func=($limits->{'func_odbc_floor'}) ? "floor((0-id3)/20)" : "0-id3";
  744.   $count++;
  745.   $sth=$dbh->do($query="update bench1 set id3=$func where id3<0") or die $DBI::errstr;
  746.   $end_time=new Benchmark;
  747.   print "Time for update_of_key_big ($count): " .
  748.     timestr(timediff($end_time, $loop_time),"all") . "nn";
  749. }
  750. else
  751. {
  752.   print "nTesting update of keys in loopsn";
  753.   #
  754.   # This is for mSQL that doesn't have functions. Do we really need this ????
  755.   #
  756.   $sth=$dbh->prepare("select id3 from bench1 where id3 >= 0") or die $DBI::errstr;
  757.   $sth->execute or die $DBI::errstr;
  758.   $count=0;
  759.   while (@tmp = $sth->fetchrow_array)
  760.   {
  761.     my $tmp1 = "-$tmp[0]";
  762.     my $sth1 = $dbh->do("update bench1 set id3 = $tmp1 where id3 = $tmp[0]");
  763.     $count++;
  764.     $end_time=new Benchmark;
  765.     if (($end_time->[0] - $loop_time->[0]) > $opt_time_limit)
  766.     {
  767.       print "note: Aborting update loop because of timeoutn";
  768.       last;
  769.     }
  770.   }
  771.   $sth->finish;
  772.   # Check that everything except id3=0 was updated
  773.   # In principle we shouldn't time this in the update loop..
  774.   #
  775.   if (fetch_all_rows($dbh,$query="select * from bench1 where id3>=0") != 1)
  776.   {
  777.     if ($count == $total_rows)
  778.     {
  779.       print "Warning: Wrong information after update: Found '$row_count' rows, but should have been: 1n";
  780.     }
  781.   }
  782.   #restore id3 to 0 <= id3 < $total_rows
  783.   $sth=$dbh->prepare("select id3 from bench1 where id3 < 0") or die $DBI::errstr;
  784.   $sth->execute or die $DBI::errstr;
  785.   while (@tmp = $sth->fetchrow_array)
  786.   {
  787.     $count++;
  788.     my $tmp1 = floor((0-$tmp[0])/10);
  789.     my $sth1 = $dbh->do("update bench1 set id3 = $tmp1 where id3 = $tmp[0]");
  790.   }
  791.   $sth->finish;
  792.   $end_time=new Benchmark;
  793.   $estimated=predict_query_time($loop_time,$end_time,$count,$count,
  794. $opt_loop_count*6);
  795.   if ($estimated)
  796.   { print "Estimated time"; }
  797.   else
  798.   { print "Time"; }
  799.   print " for update_of_key ($count): " .
  800.     timestr(timediff($end_time, $loop_time),"all") . "nn";
  801. }
  802. if ($opt_fast && defined($server->{vacuum}))
  803. {
  804.   if ($opt_lock_tables)
  805.   {
  806.     do_query($dbh,"UNLOCK TABLES");
  807.   }
  808.   $server->vacuum(1,$dbh,"bench1");
  809.   if ($opt_lock_tables)
  810.   {
  811.     $sth = $dbh->do("LOCK TABLES bench1 WRITE") || die $DBI::errstr;
  812.   }
  813. }
  814. #
  815. # Testing some simple updates
  816. #
  817. print "Testing update with keyn";
  818. $loop_time=new Benchmark;
  819. for ($i=0 ; $i < $opt_loop_count*3 ; $i++)
  820. {
  821.   $sth = $dbh->do("update bench1 set dummy1='updated' where id=$i and id2=$i") or die $DBI::errstr;
  822. }
  823. $end_time=new Benchmark;
  824. print "Time for update_with_key (" . ($opt_loop_count*3) . "):  " .
  825.   timestr(timediff($end_time, $loop_time),"all") . "n";
  826. $loop_time=new Benchmark;
  827. for ($i=0 ; $i < $opt_loop_count*3 ; $i+=3)
  828. {
  829.   $sth = $dbh->do("update bench1 set dummy1='updated' where id=$i") or die $DBI::errstr;
  830. }
  831. $end_time=new Benchmark;
  832. print "Time for update_with_key_prefix (" . ($opt_loop_count) . "):  " .
  833.   timestr(timediff($end_time, $loop_time),"all") . "n";
  834. print "nTesting update of all rowsn";
  835. $loop_time=new Benchmark;
  836. for ($i=0 ; $i < $small_loop_count ; $i++)
  837. {
  838.   $sth = $dbh->do("update bench1 set dummy1='updated $i'") or die $DBI::errstr;
  839. }
  840. $end_time=new Benchmark;
  841. print "Time for update_big ($small_loop_count):  " .
  842.   timestr(timediff($end_time, $loop_time),"all") . "n";
  843. #
  844. # Testing left outer join
  845. #
  846. if ($limits->{'func_odbc_floor'} && $limits->{'left_outer_join'})
  847. {
  848.   if ($opt_lock_tables)
  849.   {
  850.     $sth = $dbh->do("LOCK TABLES bench1 a READ, bench1 b READ") || die $DBI::errstr;
  851.   }
  852.   print "nTesting left outer joinn";
  853.   $loop_time=new Benchmark;
  854.   $count=0;
  855.   for ($i=0 ; $i < $small_loop_count ; $i++)
  856.   {
  857.     $count+=fetch_all_rows($dbh,"select count(*) from bench1 as a left outer join bench1 as b on (a.id2=b.id3)");
  858.   }
  859.   $end_time=new Benchmark;
  860.   print "Time for outer_join_on_key ($small_loop_count:$count):  " .
  861.     timestr(timediff($end_time, $loop_time),"all") . "n";
  862.   $loop_time=new Benchmark;
  863.   $count=0;
  864.   for ($i=0 ; $i < $small_loop_count ; $i++)
  865.   {
  866.     $count+=fetch_all_rows($dbh,"select count(a.dummy1),count(b.dummy1) from bench1 as a left outer join bench1 as b on (a.id2=b.id3)");
  867.   }
  868.   $end_time=new Benchmark;
  869.   print "Time for outer_join ($small_loop_count:$count):  " .
  870.     timestr(timediff($end_time, $loop_time),"all") . "n";
  871.   $count=0;
  872.   $loop_time=new Benchmark;
  873.   for ($i=0 ; $i < $small_loop_count ; $i++)
  874.   {
  875.     $count+=fetch_all_rows($dbh,"select count(a.dummy1),count(b.dummy1) from bench1 as a left outer join bench1 as b on (a.id2=b.id3) where b.id3 is not null");
  876.   }
  877.   $end_time=new Benchmark;
  878.   print "Time for outer_join_found ($small_loop_count:$count):  " .
  879.     timestr(timediff($end_time, $loop_time),"all") . "n";
  880.   $count=$estimated=0;
  881.   $loop_time=new Benchmark;
  882.   for ($i=1 ; $i <= $small_loop_count ; $i++)
  883.   {
  884.     $count+=fetch_all_rows($dbh,"select count(a.dummy1),count(b.dummy1) from bench1 as a left outer join bench1 as b on (a.id2=b.id3) where b.id3 is null");
  885.     $end_time=new Benchmark;
  886.     last if ($estimated=predict_query_time($loop_time,$end_time,
  887.    $count,$i,
  888.    $range_loop_count));
  889.   }
  890.   if ($estimated)
  891.   { print "Estimated time"; }
  892.   else
  893.   { print "Time"; }
  894.   print " for outer_join_not_found ($range_loop_count:$count):  " .
  895.     timestr(timediff($end_time, $loop_time),"all") . "n";
  896.   if ($opt_lock_tables)
  897.   {
  898.     $sth = $dbh->do("LOCK TABLES bench1 WRITE") || die $DBI::errstr;
  899.   }
  900. }
  901. if ($server->small_rollback_segment())
  902. {
  903.   $dbh->disconnect; # close connection
  904.   $dbh = $server->connect();
  905. }
  906. ####
  907. #### Test INSERT INTO ... SELECT
  908. ####
  909. if ($limits->{'insert_select'})
  910. {
  911.   if ($opt_lock_tables)
  912.   {
  913.     $sth = $dbh->do("UNLOCK TABLES") || die $DBI::errstr;
  914.   }
  915.   print "nTesting INSERT INTO ... SELECTn";
  916.   do_many($dbh,$server->create("bench2",
  917.        ["id int NOT NULL",
  918. "id2 int NOT NULL",
  919. "id3 int NOT NULL",
  920. "dummy1 char(30)"],
  921.        ["primary key (id,id2)"]));
  922.   do_many($dbh,$server->create("bench3",
  923.        ["id int NOT NULL",
  924. "id2 int NOT NULL",
  925. "id3 int NOT NULL",
  926. "dummy1 char(30)"],
  927.        ["primary key (id,id2)",
  928. "index index_id3 (id3)"]));
  929.   $loop_time=new Benchmark;
  930.   $sth = $dbh->do("INSERT INTO bench2 SELECT * from bench1") ||
  931.     die $DBI::errstr;
  932.   $end_time=new Benchmark;
  933.   print "Time for insert_select_1_key (1):  " .
  934.     timestr(timediff($end_time, $loop_time),"all") . "n";
  935.   $loop_time=new Benchmark;
  936.   $sth = $dbh->do("INSERT INTO bench3 SELECT * from bench1") ||
  937.     die $DBI::errstr;
  938.   $end_time=new Benchmark;
  939.   print "Time for insert_select_2_keys (1):  " .
  940.     timestr(timediff($end_time, $loop_time),"all") . "n";
  941.   $loop_time=new Benchmark;
  942.   $sth = $dbh->do("DROP TABLE bench2" . $server->{'drop_attr'}) ||
  943.     die $DBI::errstr;
  944.   $sth = $dbh->do("DROP TABLE bench3" . $server->{'drop_attr'}) ||
  945.     die $DBI::errstr;
  946.   $end_time=new Benchmark;
  947.   print "Time for drop table(2): " .
  948.     timestr(timediff($end_time, $loop_time),"all") . "n";
  949.   if ($opt_fast && defined($server->{vacuum}))
  950.   {
  951.     $server->vacuum(1,$dbh);
  952.   }
  953.   if ($server->small_rollback_segment())
  954.   {
  955.     $dbh->disconnect; # close connection
  956.     $dbh = $server->connect();
  957.   }
  958.   if ($opt_lock_tables)
  959.   {
  960.     $sth = $dbh->do("LOCK TABLES bench1 WRITE") || die $DBI::errstr;
  961.   }
  962. }
  963. ####
  964. #### Do some deletes on the table
  965. ####
  966. if (!$opt_skip_delete)
  967. {
  968.   print "nTesting deleten";
  969.   $loop_time=new Benchmark;
  970.   $count=0;
  971.   for ($i=0 ; $i < $opt_loop_count ; $i+=10)
  972.   {
  973.     $count++;
  974.     $tmp=$opt_loop_count+$random[$i]; # $opt_loop_count*2 <= $tmp < $total_rows
  975.     $dbh->do("delete from bench1 where id3=$tmp") or die $DBI::errstr;
  976.   }
  977.   $end_time=new Benchmark;
  978.   print "Time for delete_key ($count): " .
  979.     timestr(timediff($end_time, $loop_time),"all") . "n";
  980.   if ($server->small_rollback_segment())
  981.   {
  982.     $dbh->disconnect; # close connection
  983.     $dbh = $server->connect();
  984.   }
  985.   $count=0;
  986.   $loop_time=new Benchmark;
  987.   for ($i= 0 ; $i < $opt_loop_count ; $i+=$opt_loop_count/10)
  988.   {
  989.     $sth=$dbh->do("delete from bench1 where id3 >= 0 and id3 <= $i") or die $DBI::errstr;
  990.     $count++;
  991.   }
  992.   $count+=2;
  993.   if ($server->small_rollback_segment())
  994.   {
  995.     $dbh->disconnect; # close connection
  996.     $dbh = $server->connect();
  997.   }
  998.   $sth=$dbh->do("delete from bench1 where id3 >= 0 and id3 <= $opt_loop_count") or die $DBI::errstr;
  999.   if ($server->small_rollback_segment())
  1000.   {
  1001.     $dbh->disconnect; # close connection
  1002.     $dbh = $server->connect();
  1003.   }
  1004.   $sth=$dbh->do("delete from bench1 where id >= $opt_loop_count and id <= " . ($opt_loop_count*2) ) or die $DBI::errstr;
  1005.   if ($server->small_rollback_segment())
  1006.   {
  1007.     $dbh->disconnect; # close connection
  1008.     $dbh = $server->connect();
  1009.   }
  1010.   if ($opt_fast)
  1011.   {
  1012.     $sth=$dbh->do("delete from bench1") or die $DBI::errstr;
  1013.   }
  1014.   else
  1015.   {
  1016.     $sth = $dbh->do("delete from bench1 where id3 < " . ($total_rows)) or die $DBI::errstr;
  1017.   }
  1018.   $end_time=new Benchmark;
  1019.   print "Time for delete_all ($count): " .
  1020.     timestr(timediff($end_time, $loop_time),"all") . "nn";
  1021.   if ($opt_lock_tables)
  1022.   {
  1023.     $sth = $dbh->do("UNLOCK TABLES") || die $DBI::errstr;
  1024.   }
  1025.   $sth = $dbh->do("drop table bench1" . $server->{'drop_attr'}) or die $DBI::errstr;
  1026. }
  1027. if ($server->small_rollback_segment())
  1028. {
  1029.   $dbh->disconnect; # close connection
  1030.   $dbh = $server->connect();
  1031. }
  1032. if ($opt_fast && defined($server->{vacuum}))
  1033. {
  1034.   $server->vacuum(1,$dbh);
  1035. }
  1036. keys_test:
  1037. #
  1038. # Test of insert in table with many keys
  1039. # This test assumes that the server really create the keys!
  1040. #
  1041. my @fields=(); my @keys=();
  1042. $keys=min($limits->{'max_index'},16);   # 16 is more than enough
  1043. $seg= min($limits->{'max_index_parts'},$keys,16); # 16 is more than enough
  1044. print "Insert into table with $keys keys and with a primary key with $seg partsn";
  1045. # Make keys on the most important types
  1046. @types=(0,0,0,1,0,0,0,1,1,1,1,1,1,1,1,1,1); # A 1 for each char field
  1047. push(@fields,"field1 tinyint not null");
  1048. push(@fields,"field2 mediumint not null");
  1049. push(@fields,"field3 smallint not null");
  1050. push(@fields,"field4 char(16) not null");
  1051. push(@fields,"field5 integer not null");
  1052. push(@fields,"field6 float not null");
  1053. push(@fields,"field7 double not null");
  1054. for ($i=8 ; $i <= $keys ; $i++)
  1055. {
  1056.   push(@fields,"field$i char(6) not null"); # Should be relatively fair
  1057. }
  1058. # First key contains many segments
  1059. $query="primary key (";
  1060. for ($i= 1 ; $i <= $seg ; $i++)
  1061. {
  1062.   $query.= "field$i,";
  1063. }
  1064. substr($query,-1)=")";
  1065. push (@keys,$query);
  1066. #Create other keys
  1067. for ($i=2 ; $i <= $keys ; $i++)
  1068. {
  1069.   push(@keys,"index index$i (field$i)");
  1070. }
  1071. do_many($dbh,$server->create("bench1",@fields,@keys));
  1072. if ($opt_lock_tables)
  1073. {
  1074.   $dbh->do("LOCK TABLES bench1 WRITE") || die $DBI::errstr;
  1075. }
  1076. if ($server->small_rollback_segment())
  1077. {
  1078.   $dbh->disconnect; # close connection
  1079.   $dbh = $server->connect();
  1080. }
  1081. $loop_time=new Benchmark;
  1082. $fields=$#fields;
  1083. if (($opt_fast || $opt_fast_insert) && $limits->{'insert_multi_value'})
  1084. {
  1085.   $query_size=$server->{'limits'}->{'query_size'};
  1086.   $query="insert into bench1 values ";
  1087.   $res=$query;
  1088.   for ($i=0; $i < $many_keys_loop_count; $i++)
  1089.   {
  1090.     $rand=$random[$i];
  1091.     $tmp="(" . ($i & 127) . ",$rand," . ($i & 32766) .
  1092.       ",'ABCDEF$rand',0,";
  1093.     for ($j=5; $j <= $fields ; $j++)
  1094.     {
  1095.       $tmp.= ($types[$j] == 0) ? "$rand," : "'$rand',";
  1096.     }
  1097.     substr($tmp,-1)=")";
  1098.     if (length($tmp)+length($res) < $query_size)
  1099.     {
  1100.       $res.= $tmp . ",";
  1101.     }
  1102.     else
  1103.     {
  1104.       $sth = $dbh->do(substr($res,0,length($res)-1)) or die $DBI::errstr;
  1105.       $res=$query . $tmp . ",";
  1106.     }
  1107.   }
  1108.   $sth = $dbh->do(substr($res,0,length($res)-1)) or die $DBI::errstr;
  1109. }
  1110. else
  1111. {
  1112.   for ($i=0; $i < $many_keys_loop_count; $i++)
  1113.   {
  1114.     $rand=$random[$i];
  1115.     $query="insert into bench1 values (" . ($i & 127) . ",$rand," . ($i & 32767) .
  1116.       ",'ABCDEF$rand',0,";
  1117.     for ($j=5; $j <= $fields ; $j++)
  1118.     {
  1119.       $query.= ($types[$j] == 0) ? "$rand," : "'$rand',";
  1120.     }
  1121.     substr($query,-1)=")";
  1122.     print "query1: $queryn" if ($opt_debug);
  1123.     $dbh->do($query) or die "Got error $DBI::errstr with query: $queryn";
  1124.   }
  1125. }
  1126. $end_time=new Benchmark;
  1127. print "Time for insert_key ($many_keys_loop_count): " .
  1128.   timestr(timediff($end_time, $loop_time),"all") . "nn";
  1129. if ($server->small_rollback_segment())
  1130. {
  1131.   $dbh->disconnect; # close connection
  1132.   $dbh = $server->connect();
  1133. }
  1134. if ($opt_fast && defined($server->{vacuum}))
  1135. {
  1136.   if ($opt_lock_tables)
  1137.   {
  1138.     do_query($dbh,"UNLOCK TABLES");
  1139.   }
  1140.   $server->vacuum(1,$dbh,"bench1");
  1141.   if ($opt_lock_tables)
  1142.   {
  1143.     $sth = $dbh->do("LOCK TABLES bench1 WRITE") || die $DBI::errstr;
  1144.   }
  1145. }
  1146. #
  1147. # update one key of the above
  1148. #
  1149. print "Testing update of keysn";
  1150. $loop_time=new Benchmark;
  1151. for ($i=0 ; $i< 256; $i++)
  1152. {
  1153.   $dbh->do("update bench1 set field5=1 where field1=$i")
  1154.     or die "Got error $DBI::errstr with query: update bench1 set field5=1 where field1=$in";
  1155. }
  1156. $end_time=new Benchmark;
  1157. print "Time for update_of_primary_key_many_keys (256): " .
  1158.   timestr(timediff($end_time, $loop_time),"all") . "nn";
  1159. if ($server->small_rollback_segment())
  1160. {
  1161.   $dbh->disconnect; # close connection
  1162.   $dbh = $server->connect();
  1163. }
  1164. if ($opt_fast && defined($server->{vacuum}))
  1165. {
  1166.   if ($opt_lock_tables)
  1167.   {
  1168.     do_query($dbh,"UNLOCK TABLES");
  1169.   }
  1170.   $server->vacuum(1,$dbh,"bench1");
  1171.   if ($opt_lock_tables)
  1172.   {
  1173.     $sth = $dbh->do("LOCK TABLES bench1 WRITE") || die $DBI::errstr;
  1174.   }
  1175. }
  1176. if ($server->small_rollback_segment())
  1177. {
  1178.   $dbh->disconnect; # close connection
  1179.   $dbh = $server->connect();
  1180. }
  1181. #
  1182. # Delete everything from table
  1183. #
  1184. print "Deleting rows from the tablen";
  1185. $loop_time=new Benchmark;
  1186. $count=0;
  1187. for ($i=0 ; $i < 128 ; $i++)
  1188. {
  1189.   $count++;
  1190.   $dbh->do("delete from bench1 where field1 = $i") or die $DBI::errstr;
  1191. }
  1192. $end_time=new Benchmark;
  1193. print "Time for delete_big_many_keys ($count): " .
  1194. timestr(timediff($end_time, $loop_time),"all") . "nn";
  1195. print "Deleting everything from tablen";
  1196. $count=1;
  1197. if ($opt_fast)
  1198. {
  1199.   $dbh->do("delete from bench1") or die $DBI::errstr;
  1200. }
  1201. else
  1202. {
  1203.   $dbh->do("delete from bench1 where field1 > 0") or die $DBI::errstr;
  1204. }
  1205. if ($opt_lock_tables)
  1206. {
  1207.   $sth = $dbh->do("UNLOCK TABLES") || die $DBI::errstr;
  1208. }
  1209. $end_time=new Benchmark;
  1210. print "Time for delete_all_many_keys ($count): " .
  1211.   timestr(timediff($end_time, $loop_time),"all") . "nn";
  1212. $sth = $dbh->do("drop table bench1" . $server->{'drop_attr'}) or die $DBI::errstr;
  1213. if ($opt_fast && defined($server->{vacuum}))
  1214. {
  1215.   $server->vacuum(1,$dbh);
  1216. }
  1217. #
  1218. # Test multi value inserts if the server supports it
  1219. #
  1220. if ($limits->{'insert_multi_value'})
  1221. {
  1222.   $query_size=$limits->{'query_size'}; # Same limit for all databases
  1223.   $sth = $dbh->do("drop table bench1" . $server->{'drop_attr'});
  1224.   do_many($dbh,$server->create("bench1",
  1225.        ["id int NOT NULL",
  1226. "id2 int NOT NULL",
  1227. "id3 int NOT NULL",
  1228. "dummy1 char(30)"],
  1229.        ["primary key (id,id2)",
  1230.        "index index_id3 (id3)"]));
  1231.   if ($opt_lock_tables)
  1232.   {
  1233.     $sth = $dbh->do("LOCK TABLES bench1 write") || die $DBI::errstr;
  1234.   }
  1235.   $loop_time=new Benchmark;
  1236.   print "Inserting $opt_loop_count rows with multiple valuesn";
  1237.   $query="insert into bench1 values ";
  1238.   $res=$query;
  1239.   for ($i=0 ; $i < $opt_loop_count ; $i++)
  1240.   {
  1241.     my $tmp= "($i,$i,$i,'EFGHIJKLM'),";
  1242.     if (length($i)+length($res) < $query_size)
  1243.     {
  1244.       $res.= $tmp;
  1245.     }
  1246.     else
  1247.     {
  1248.       do_query($dbh,substr($res,0,length($res)-1));
  1249.       $res=$query .$tmp;
  1250.     }
  1251.   }
  1252.   do_query($dbh,substr($res,0,length($res)-1));
  1253.   if ($opt_lock_tables)
  1254.   {
  1255.     $sth = $dbh->do("UNLOCK TABLES ") || die $DBI::errstr;
  1256.   }
  1257.   $end_time=new Benchmark;
  1258.   print "Time for multiple_value_insert (" . ($opt_loop_count) . "): " .
  1259.     timestr(timediff($end_time, $loop_time),"all") . "nn";
  1260.   if ($opt_fast && defined($server->{vacuum}))
  1261.   {
  1262.     $server->vacuum(1,$dbh);
  1263.   }
  1264.   if ($opt_lock_tables)
  1265.   {
  1266.     $sth = $dbh->do("UNLOCK TABLES ") || die $DBI::errstr;
  1267.   }
  1268.   # A big table may take a while to drop
  1269.   $loop_time=new Benchmark;
  1270.   $sth = $dbh->do("drop table bench1" . $server->{'drop_attr'}) or die $DBI::errstr;
  1271.   $end_time=new Benchmark;
  1272.   print "Time for drop table(1): " .
  1273.     timestr(timediff($end_time, $loop_time),"all") . "nn";
  1274. }
  1275. ####
  1276. #### End of benchmark
  1277. ####
  1278. $dbh->disconnect; # close connection
  1279. end_benchmark($start_time);
  1280. ###
  1281. ### Some help functions
  1282. ###
  1283. # Do some sample selects on direct key
  1284. # First select finds a row, the second one doesn't find.
  1285. sub check_select_key
  1286. {
  1287.   my ($sel_columns,$column,$check)= @_;
  1288.   my ($loop_time,$end_time,$i,$tmp_var,$tmp,$count,$row_count,$estimated);
  1289.   $estimated=0;
  1290.   $loop_time=new Benchmark;
  1291.   $count=0;
  1292.   for ($i=1 ; $i <= $opt_read_key_loop_count; $i++)
  1293.   {
  1294.     $count+=2;
  1295.     $tmpvar^= ((($tmpvar + 63) + $i)*3 % $opt_loop_count);
  1296.     $tmp=$tmpvar % ($total_rows);
  1297.     fetch_all_rows($dbh,"select $sel_columns from bench1 where $column=$tmp")
  1298.       or die $DBI::errstr;
  1299.     $tmp+=$total_rows;
  1300.     defined($row_count=fetch_all_rows($dbh,"select $sel_columns from bench1 where $column=$tmp")) or die $DBI::errstr;
  1301.     die "Found $row_count rows on impossible id: $tmpn" if ($row_count);
  1302.     $end_time=new Benchmark;
  1303.     last if ($estimated=predict_query_time($loop_time,$end_time,$count,$i,
  1304.    $opt_loop_count));
  1305.   }
  1306.   if ($estimated)
  1307.   { print "Estimated time"; }
  1308.   else
  1309.   { print "Time"; }
  1310.   print " for $check ($count): " .
  1311.     timestr(timediff($end_time, $loop_time),"all") . "n";
  1312. }
  1313. # Same as above, but select on 2 columns
  1314. sub check_select_key2
  1315. {
  1316.   my ($sel_columns,$column,$column2,$check)= @_;
  1317.   my ($loop_time,$end_time,$i,$tmp_var,$tmp,$count,$row_count,$estimated);
  1318.   $estimated=0;
  1319.   $loop_time=new Benchmark;
  1320.   $count=0;
  1321.   for ($i=1 ; $i <= $opt_read_key_loop_count; $i++)
  1322.   {
  1323.     $count+=2;
  1324.     $tmpvar^= ((($tmpvar + 63) + $i)*3 % $opt_loop_count);
  1325.     $tmp=$tmpvar % ($total_rows);
  1326.     fetch_all_rows($dbh,"select $sel_columns from bench1 where $column=$tmp and $column2=$tmp")
  1327.       or die $DBI::errstr;
  1328.     $tmp+=$total_rows;
  1329.     defined($row_count=fetch_all_rows($dbh,"select $sel_columns from bench1 where $column=$tmp and $column2=$tmp")) or die $DBI::errstr;
  1330.     die "Found $row_count rows on impossible id: $tmpn" if ($row_count);
  1331.     $end_time=new Benchmark;
  1332.     last if ($estimated=predict_query_time($loop_time,$end_time,$count,$i,
  1333.    $opt_loop_count));
  1334.   }
  1335.   if ($estimated)
  1336.   { print "Estimated time"; }
  1337.   else
  1338.   { print "Time"; }
  1339.   print " for $check ($count): " .
  1340.     timestr(timediff($end_time, $loop_time),"all") . "n";
  1341. }
  1342. #
  1343. # Search using some very simple queries
  1344. #
  1345. sub check_select_range
  1346. {
  1347.   my ($column,$check)= @_;
  1348.   my ($loop_time,$end_time,$i,$tmp_var,$tmp,$query,$rows,$estimated);
  1349.   $estimated=0;
  1350.   $loop_time=new Benchmark;
  1351.   $found=$count=0;
  1352.   for ($test=1 ; $test <= $range_loop_count; $test++)
  1353.   {
  1354.     $count+=$#Q+1;
  1355.     for ($i=0 ; $i < $#Q ; $i+=2)
  1356.     {
  1357.       $query=$Q[$i];
  1358.       $rows=$Q[$i+1];
  1359.       $query =~ s/!id!/$column/g;
  1360.       if (($row_count=fetch_all_rows($dbh,$query)) != $rows)
  1361.       {
  1362. if ($row_count == undef())
  1363. {
  1364.   die "Got error: $DBI::errstr when executing $queryn";
  1365. }
  1366. die "'$query' returned wrong number of rows: $row_count instead of $rowsn";
  1367.       }
  1368.       $found+=$row_count;
  1369.     }
  1370.     $end_time=new Benchmark;
  1371.     last if ($estimated=predict_query_time($loop_time,$end_time,$count,$test,
  1372.    $range_loop_count));
  1373.   }
  1374.   if ($estimated)
  1375.   { print "Estimated time"; }
  1376.   else
  1377.   { print "Time"; }
  1378.   print " for $check ($count:$found): " .
  1379.     timestr(timediff($end_time, $loop_time),"all") . "n";
  1380. }
  1381. #
  1382. # SELECT * from bench where col=x or col=x or col=x ...
  1383. sub check_or_range
  1384. {
  1385.   my ($column,$check)= @_;
  1386.   my ($loop_time,$end_time,$i,$tmp_var,$tmp,$columns,$estimated,$found,
  1387.       $or_part,$count,$loop_count);
  1388.   $columns=min($limits->{'max_columns'},50,($limits->{'query_size'}-50)/13);
  1389.   $columns=$columns- ($columns % 4); # Make Divisible by 4
  1390.   $estimated=0;
  1391.   $loop_time=new Benchmark;
  1392.   $found=0;
  1393.   # The number of tests must be divisible by the following
  1394.   $tmp= $limits->{'func_extra_in_num'} ? 15 : 10; 
  1395.   # We need to calculate the exact number of test to make 'Estimated' right
  1396.   $loop_count=$range_loop_count*10+$tmp-1;
  1397.   $loop_count=$loop_count- ($loop_count % $tmp);
  1398.   
  1399.   for ($count=0 ; $count < $loop_count ; )
  1400.   {
  1401.     for ($rowcnt=0; $rowcnt <= $columns; $rowcnt+= $columns/4)
  1402.     {
  1403.       my $query="select * from bench1 where ";
  1404.       my $or_part= "$column = 1";
  1405.       $count+=2;
  1406.       for ($i=1 ; $i < $rowcnt ; $i++)
  1407.       {
  1408. $tmpvar^= ((($tmpvar + 63) + $i)*3 % $opt_loop_count);
  1409. $tmp=$tmpvar % ($opt_loop_count*4);
  1410. $or_part.=" or $column=$tmp";
  1411.       }
  1412.       print $query . $or_part . "n" if ($opt_debug);
  1413.       ($rows=fetch_all_rows($dbh,$query . $or_part)) or die $DBI::errstr;
  1414.       $found+=$rows;
  1415.       if ($limits->{'func_extra_in_num'})
  1416.       {
  1417. my $in_part=$or_part; # Same query, but use 'func_extra_in_num' instead.
  1418. $in_part=~ s/ = / IN (/;
  1419. $in_part=~ s/ or $column=/,/g;
  1420. $in_part.= ")";
  1421. fetch_all_rows($dbh,$query . $in_part) or die $DBI::errstr;
  1422. $count++;
  1423.       }
  1424.       # Do it a little harder by setting a extra range
  1425.       defined(($rows=fetch_all_rows($dbh,"$query($or_part) and $column < 10"))) or die $DBI::errstr;
  1426.       $found+=$rows;
  1427.     }
  1428.     $end_time=new Benchmark;
  1429.     last if ($estimated=predict_query_time($loop_time,$end_time,$count,$count,
  1430.    $loop_count));
  1431.   }
  1432.   if ($estimated)
  1433.   { print "Estimated time"; }
  1434.   else
  1435.   { print "Time"; }
  1436.   print " for $check ($count:$found): " .
  1437.     timestr(timediff($end_time, $loop_time),"all") . "n";
  1438. }