innotest2
上传用户:romrleung
上传日期:2022-05-23
资源大小:18897k
文件大小:5k
源码类别:

MySQL数据库

开发平台:

Visual C++

  1. #!/usr/bin/perl
  2. ############################################################################
  3. #     Stress test for MySQL/InnoDB combined database
  4. #     (c) 2002 Innobase Oy & MySQL AB
  5. #
  6. ############################################################################
  7. use Cwd; use DBI;
  8. use Benchmark;
  9. $opt_loop_count = 100000;
  10. $pwd = cwd(); $pwd = "." if ($pwd eq ''); require "$pwd/bench-init.pl" || die "Can't read Configuration file: $!n";
  11. print "Innotest2: MySQL/InnoDB stress test in Perl for FOREIGN keysn";
  12. print "------------------------------------------------------------n";
  13. print "This is a randomized stress test for concurrent inserts,n";
  14. print "updates, deletes, commits and rollbacks with foreign keys withn";
  15. print "the ON DELETE ... clause. The test will generaten";
  16. print "also a lot of deadlocks, duplicate key errors, and other SQL errors.n";
  17. print "n";
  18. print "You should run innotest2, innotest2a, and innotest2b concurrently.n";
  19. print "The thing to watch is that the server does not crash or does notn";
  20. print "print to the .err log anything. Currently, due to a buglet in MySQL,n";
  21. print "warnings about MySQL lock reservations can appear in the .err log.n";
  22. print "The test will run very long, even several hours. You can killn";
  23. print "the perl processes running this test at any time and do CHECKn";
  24. print "TABLE on tables innotest2a, b, c, d in the 'test' database.n";
  25. print "n";
  26. print "Some of these stress tests will print a lot of SQL errorsn";
  27. print "to the standard output. That is not to be worried about.n";
  28. print "You can direct the output to a file like this:n";
  29. print "perl innotest2 > out2nn";
  30. print "Generating random keysn";
  31. $random[$opt_loop_count] = 0;
  32. $rnd_str[$opt_loop_count] = "a";
  33. for ($i = 0; $i < $opt_loop_count; $i++) {
  34. $random[$i] = ($i * 63857) % $opt_loop_count;
  35.    if (0 == ($random[$i] % 3)) {
  36.    $rnd_str[$i] = "khD";
  37. } else { if (1 == ($random[$i] % 3)) {
  38. $rnd_str[$i] = "khd";
  39. } else { if (2 == ($random[$i] % 3)) {
  40. $rnd_str[$i] = "kHd";
  41. }}}
  42. for ($j = 0; $j < (($i * 764877) % 10); $j++) {
  43. $rnd_str[$i] = $rnd_str[$i]."k";
  44. }
  45. }
  46. ####
  47. ####  Connect
  48. ####
  49. $dbh = $server->connect()
  50. || die $dbh->errstr;
  51. $dbh->do("set autocommit = 0");
  52. for ($i = 0; $i < 1; $i++) {
  53. print "loop $in";
  54. print "dropping table innotest2an";
  55. $dbh->do("drop table innotest2a");
  56. print "dropping table innotest2bn";
  57. $dbh->do("drop table innotest2b");
  58. print "dropping table innotest2cn";
  59. $dbh->do("drop table innotest2c");
  60. print "dropping table innotest2dn";
  61. $dbh->do("drop table innotest2d");
  62. print "creating table innotest2bn";
  63. $dbh->do(
  64. "create table innotest2b (A INT NOT NULL AUTO_INCREMENT, D INT NOT NULL, B VARCHAR(200) NOT NULL, C VARCHAR(175), PRIMARY KEY (A, D, B), INDEX (B, C), INDEX (C)) TYPE = INNODB")
  65. || die $dbh->errstr;
  66. print "creating table innotest2an";
  67. $dbh->do(
  68. "create table innotest2a (A INT NOT NULL AUTO_INCREMENT, D INT NOT NULL, B VARCHAR(200) NOT NULL, C VARCHAR(175), PRIMARY KEY (A, D, B), INDEX (B, C), INDEX (C), FOREIGN KEY (A, D) REFERENCES innotest2b (A, D) ON DELETE CASCADE) TYPE = INNODB")
  69. || die $dbh->errstr;
  70. print "creating table innotest2cn";
  71. $dbh->do(
  72. "create table innotest2c (A INT NOT NULL AUTO_INCREMENT, D INT NOT NULL, B VARCHAR(200) NOT NULL, C VARCHAR(175), PRIMARY KEY (A, D, B), INDEX (B, C), INDEX (C), FOREIGN KEY (A, D) REFERENCES innotest2a (A, D) ON DELETE CASCADE, FOREIGN KEY (B, C) REFERENCES innotest2a (B, C) ON DELETE CASCADE) TYPE = INNODB")
  73. || die $dbh->errstr;
  74. print "creating table innotest2dn";
  75. $dbh->do(
  76. "create table innotest2d (A INT AUTO_INCREMENT, D INT, B VARCHAR(200), C VARCHAR(175), UNIQUE KEY (A, D, B), INDEX (B, C), INDEX (C), FOREIGN KEY (C) REFERENCES innotest2c (C) ON DELETE SET NULL, FOREIGN KEY (B, C) REFERENCES innotest2c (B, C) ON DELETE SET NULL) TYPE = INNODB")
  77. || die $dbh->errstr;
  78. print "createdn";
  79. for ($j = 0; $j < $opt_loop_count - 10; $j = $j + 2) {
  80. $dbh->do(
  81. "insert into innotest2b (D, B, C) values (5, '".$rnd_str[$j]."' ,'".$rnd_str[$j]."')")
  82. || print $dbh->errstr;
  83. $dbh->do(
  84. "insert into innotest2a (D, B, C) values (5, '".$rnd_str[$j]."' ,'".$rnd_str[$j]."')")
  85. || print $dbh->errstr;
  86. $dbh->do(
  87. "insert into innotest2c (D, B, C) values (5, '".$rnd_str[$j]."' ,'".$rnd_str[$j]."')")
  88. || print $dbh->errstr;
  89. $dbh->do(
  90. "insert into innotest2d (D, B, C) values (5, '".$rnd_str[$j]."' ,'".$rnd_str[$j]."')")
  91. || print $dbh->errstr;
  92. $dbh->do("delete from innotest2b where A = ".$random[$random[$j]])
  93. || print $dbh->errstr;
  94. if (0 == ($j % 10)) {
  95. $dbh->do("commit");
  96. }
  97. if (0 == ($j % 39)) {
  98. $dbh->do("rollback");
  99. }
  100. if (0 == ($j % 1000)) {
  101. print "round $jn";
  102. }
  103. if (0 == ($j % 20000)) {
  104. print "Checking tables...n";
  105. $dbh->do("check table innotest2a");
  106. $dbh->do("check table innotest2b");
  107. $dbh->do("check table innotest2c");
  108. $dbh->do("check table innotest2d");
  109. print "Tables checked.n";
  110. }
  111. }
  112. $dbh->do("commit");
  113. }
  114. $dbh->disconnect; # close connection