mirror/mariadb
1
0
Fork 0
mirror of https://github.com/MariaDB/server.git synced 2025-01-21 06:22:28 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions

[t:3453] skeleton code generation down, working on point row locks, may

Browse source 
have uncovered a bug already


git-svn-id: file:///svn/mysql/tests/mysql-test@34998 c7de825b-a66e-492c-adef-691d508d4ae1
This commit is contained in:
John Esmet 2011-09-23 21:17:50 +00:00
parent 7467ee976c
commit 84b4b0feaf
1 changed files with 14 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

19
mysql-test/suite/tokudb.locks/blocking-row-locks-testgen.py
View file

@ -2,12 +2,14 @@
import datetime
# generate sql write queries
def mysqlgen_select_for_update(k, kv):
def mysqlgen_select_for_update(k, kv, c, cv):
print "select * from t where %s=%s for update;" % (k, kv)
def mysqlgen_update(k, kv, c, cv):
print "update t where %s=%s set %s=%s+1;" % (k, kv, kv, kv);
print "update t where %s=%s set %s=%s+1;" % (k, kv, c, c);
def mysqlgen_insert(k, kv, c, cv):
print "insert t values(%s, %s);" % (kv, cv)
def mysqlgen_insert_on_dup_update(k, kv, c, cv):
print "insert t values(%s, %s) on duplicate key update %s=%s+1;" % (kv, cv, c, c)
def mysqlgen_replace(k, kv, c, cv):
print "replace t values(%s, %s);" % (kv, cv)
@ -22,8 +24,6 @@ def mysqlgen_prepare():
print "# prepare with some common parameters"
print "set storage_engine=tokudb;"
print "connect(conn1, localhost, root);"
# ONLY connection 1 should have autocommit off.
print "set autocommit=off;"
print "connect(conn2, localhost, root);"
print "connection conn1;"
print ""
@ -42,6 +42,9 @@ def mysqlgen_cleanup():
print "set global tokudb_lock_timeout=30000000;"
print ""
def expect_lock_timeout():
print "--error ER_LOCK_WAIT_TIMEOUT"
# Here's where all the magic happens
print "# Tokutek"
print "# Blocking row lock tests;"
@ -67,12 +70,18 @@ for timeout in ["0", "1000000"]:
for tb, qb in write_queries:
print "# testing conflict \"%s\" vs. \"%s\"" % (ta, tb)
print "connection conn1;"
print "set autocommit=off;"
print "begin;"
print ""
# point lock
print "#TODO: Test point lock"
print ""
qa("a", 1, "b", 100)
print "connection conn2;"
for k in range(1, 5):
if k == 1:
print "--error ER_LOCK_WAIT_TIMEOUT"
qb("a", k, "b", 100)
# range lock
print "#TODO: Test range lock"