fork3_test.pl
上传用户:dzyhzl
上传日期:2019-04-29
资源大小:56270k
文件大小:4k
源码类别:

模拟服务器

开发平台:

C/C++

  1. #!/my/gnu/bin/perl -w
  2. #
  3. # This is a test with uses 3 processes to insert, delete and select
  4. #
  5. $opt_loop_count=100000; # Change this to make test harder/easier
  6. ##################### Standard benchmark inits ##############################
  7. use DBI;
  8. use Getopt::Long;
  9. use Benchmark;
  10. package main;
  11. $opt_skip_create=$opt_skip_in=$opt_verbose=$opt_fast_insert=
  12.   $opt_lock_tables=$opt_debug=$opt_skip_delete=$opt_fast=$opt_force=0;
  13. $opt_host=""; $opt_db="test";
  14. GetOptions("host=s","db=s","loop-count=i","skip-create","skip-in","skip-delete",
  15. "verbose","fast-insert","lock-tables","debug","fast","force") || die "Aborted";
  16. $opt_verbose=$opt_debug=$opt_lock_tables=$opt_fast_insert=$opt_fast=$opt_skip_in=$opt_force=undef;  # Ignore warnings from these
  17. print "Testing 3 multiple connections to a server with 1 insert, 1 deleten";
  18. print "and 1 select connections.n";
  19. $firsttable  = "bench_f1";
  20. ####  
  21. ####  Start timeing and start test
  22. ####
  23. $start_time=new Benchmark;
  24. if (!$opt_skip_create)
  25. {
  26.   $dbh = DBI->connect("DBI:mysql:$opt_db:$opt_host",
  27.       $opt_user, $opt_password,
  28.     { PrintError => 0}) || die $DBI::errstr;
  29.   $Mysql::QUIET = 1;
  30.   $dbh->do("drop table $firsttable");
  31.   $Mysql::QUIET = 0;
  32.   print "Creating table $firsttable in database $opt_dbn";
  33.   $dbh->do("create table $firsttable (id int(6) not null, info varchar(32), marker char(1), primary key(id))") || die $DBI::errstr;
  34.   $dbh->disconnect; $dbh=0; # Close handler
  35. }
  36. $|= 1; # Autoflush
  37. ####
  38. #### Start the tests
  39. ####
  40. test_insert() if (($pid=fork()) == 0); $work{$pid}="insert";
  41. test_delete() if (($pid=fork()) == 0); $work{$pid}="delete";
  42. test_select() if (($pid=fork()) == 0); $work{$pid}="select1";
  43. $errors=0;
  44. while (($pid=wait()) != -1)
  45. {
  46.   $ret=$?/256;
  47.   print "thread '" . $work{$pid} . "' finnished with exit code $retn";
  48.   $errors++ if ($ret != 0);
  49. }
  50. if (!$opt_skip_delete && !$errors)
  51. {
  52.   $dbh = DBI->connect("DBI:mysql:$opt_db:$opt_host",
  53.       $opt_user, $opt_password,
  54.     { PrintError => 0}) || die $DBI::errstr;
  55.   $dbh->do("drop table $firsttable");
  56.   $dbh->disconnect; $dbh=0; # Close handler
  57. }
  58. print ($errors ? "Test failedn" :"Test okn");
  59. $end_time=new Benchmark;
  60. print "Total time: " .
  61.   timestr(timediff($end_time, $start_time),"noc") . "n";
  62. exit(0);
  63. #
  64. # Insert records in the table
  65. sub test_insert
  66. {
  67.   my ($dbh,$i,$sth);
  68.   $dbh = DBI->connect("DBI:mysql:$opt_db:$opt_host",
  69.       $opt_user, $opt_password,
  70.     { PrintError => 0}) || die $DBI::errstr;
  71.   for ($i=0 ; $i < $opt_loop_count; $i++)
  72.   {
  73.     $sth=$dbh->do("insert into $firsttable values ($i,'This is entry $i','')") || die "Got error on insert: $Mysql::db_errstrn";
  74.     $sth=0;
  75.   }
  76.   $dbh->disconnect; $dbh=0;
  77.   print "Test_insert: Inserted $i rowsn";
  78.   exit(0);
  79. }
  80. sub test_delete
  81. {
  82.   my ($dbh,$i,$sth,@row);
  83.   $dbh = DBI->connect("DBI:mysql:$opt_db:$opt_host",
  84.       $opt_user, $opt_password,
  85.     { PrintError => 0}) || die $DBI::errstr;
  86.   for ($i=0 ; $i < $opt_loop_count ; $i++)
  87.   {
  88.     sleep(5);
  89.     if ($opt_lock_tables)
  90.     {
  91.       $sth=$dbh->do("lock tables $firsttable WRITE") || die "Got error on lock tables $firsttable: $Mysql::db_errstrn";
  92.     }
  93.     $sth=$dbh->prepare("select count(*) from $firsttable") || die "Got error on select from $firsttable: $dbh->errstrn";
  94.     $sth->execute || die $dbh->errstr;
  95.     if ((@row = $sth->fetchrow_array()))
  96.     {
  97.       last if (!$row[0]); # Insert thread is probably ready
  98.     }
  99.     $sth=$dbh->do("delete from $firsttable") || die "Got error on delete from $firsttable: $dbh->errstr;n";
  100.   }
  101.   $sth=0;
  102.   $dbh->disconnect; $dbh=0;
  103.   print "Test_delete: Deleted all rows $i timesn";
  104.   exit(0);
  105. }
  106. #
  107. # select records
  108. #
  109. sub test_select
  110. {
  111.   my ($dbh,$i,$sth,@row);
  112.   $dbh = DBI->connect("DBI:mysql:$opt_db:$opt_host",
  113.       $opt_user, $opt_password,
  114.     { PrintError => 0}) || die $DBI::errstr;
  115.   for ($i=0 ; $i < $opt_loop_count ; $i++)
  116.   {
  117.     $sth=$dbh->prepare("select count(*) from $firsttable") || die "Got error on select from $firsttable: $dbh->errstr;n";
  118.     $sth->execute || die $dbh->errstr;
  119.     @row = $sth->fetchrow_array();
  120.     $sth=0;
  121.   }
  122.   $dbh->disconnect; $dbh=0;
  123.   print "Test_select: okn";
  124.   exit(0);
  125. }