lock_test.pl
上传用户:romrleung
上传日期:2022-05-23
资源大小:18897k
文件大小:3k
- #!/usr/bin/perl
- # This is a test with uses two processes to a database.
- # The other inserts records in two tables, the other does a lot of joins
- # on these.
- # Every time the read thread outputs info, it does a ALTER TABLE command
- # which should stop the insert thread until the ALTER TABLE command is ready.
- #
- # Warning, the output from this test will differ in 'found' from time to time,
- # but there should never be any errors
- #
- $host = shift || "";
- $test_db="test";
- $test_count=10000;
- srand 0; # Repeatable test
- use Mysql;
- $|= 1; # Autoflush
- $dbh = Mysql->Connect($host) || die "Can't connect: $Mysql::db_errstrn";
- $dbh->SelectDB($test_db) || die "Can't use database $test_db: $Mysql::db_errstrn";
- $firsttable = "test_lock_1";
- $secondtable = "test_lock_2";
- $dbh->Query("drop table $firsttable");
- $dbh->Query("drop table $secondtable");
- print "Creating tables $firsttable and $secondtable in database $test_dbn";
- $dbh->Query("create table $firsttable (id int(6) not null, info char(32), auto int(11) not null auto_increment, primary key(id),key(auto))") or die $Mysql::db_errstr;
- $dbh->Query("create table $secondtable (id int(6) not null, info varchar(32), key(id))") or die $Mysql::db_errstr;
- $dbh=0; # Close handler
- if (fork() == 0)
- { # Insert process
- $dbh = Mysql->Connect($host) || die "Can't connect: $Mysql::db_errstrn";
- $dbh->SelectDB($test_db) || die "Can't use database $test_db: $Mysql::db_errstrn";
- $first_id=1; $second_id=1;
- $first_count=$second_count=0;
- print "Writing startedn";
- for ($i=1 ; $i <= $test_count ; $i++)
- {
- if (rand(3) <= 1)
- {
- $sth=$dbh->Query("insert into $firsttable values ($first_id,'This is entry $i',NULL)") || die "Got error on insert: $Mysql::db_errstrn";
- die "Row not inserted, abortingn" if ($sth->affected_rows != 1);
- $first_id++;
- $first_count++;
- }
- else
- {
- $sth=$dbh->Query("insert into $secondtable values ($second_id,'This is entry $i')") || die "Got error on insert: $Mysql::db_errstrn";
- die "Row not inserted, abortingn" if ($sth->affected_rows != 1);
- $second_id++ if (rand(10) <= 1); # Don't always count it up
- $second_count++;
- }
- print "Write: $in" if ($i % 1000 == 0);
- }
- print "Writing done ($first_count $second_count)n";
- }
- else
- {
- $dbh = Mysql->Connect($host) || die "Can't connect: $Mysql::db_errstrn";
- $dbh->SelectDB($test_db) || die "Can't use database $test_db: $Mysql::db_errstrn";
- $locked=$found=0;
- print "Reading startedn";
- for ($i=1 ; $i <= $test_count ; $i++)
- {
- $id=int(rand($test_count)/3)+1;
- $sth=$dbh->Query("select count(*) from $firsttable,$secondtable where $firsttable.id = $secondtable.id and $firsttable.id=$id") || die "Got error on select: $Mysql::db_errstrn";
- $found++ if ($sth->numrows);
- if ($i % 1000 == 0)
- {
- print "Read: $i Found: $foundn";
- if ($found)
- {
- $locked=1-$locked;
- if ($locked)
- {
- $sth=$dbh->Query("lock tables $firsttable write,$secondtable write");
- }
- $sth=$dbh->Query("alter table $firsttable CHANGE id id int(6) not null") || die "Got error on ALTER TABLE: $Mysql::db_errstrn";
- $sth=$dbh->Query("alter table $secondtable CHANGE info info char(32) not null") || die "Got error on ALTER TABLE: $Mysql::db_errstrn";
- if ($locked)
- {
- $sth=$dbh->Query("unlock tables");
- }
- }
- }
- }
- print "Reading done Found: $foundn";
- }