5cab979e7d
Multiple connections per thread were made possible as a part of the SQL API refactoring. The feature is a pre-requisite for fixing issue #73. This commit just adds a regression test.
132 lines
3.2 KiB
Perl
132 lines
3.2 KiB
Perl
########################################################################
|
|
SQL Lua API tests
|
|
########################################################################
|
|
|
|
$ if [ -z "${SBTEST_MYSQL_ARGS:-}" ]
|
|
> then
|
|
> exit 80
|
|
> fi
|
|
|
|
$ SB_ARGS="--verbosity=1 --test=$CRAMTMP/api_sql.lua --max-requests=1 --num-threads=1 --db-driver=mysql $SBTEST_MYSQL_ARGS"
|
|
$ cat >$CRAMTMP/api_sql.lua <<EOF
|
|
> function thread_init()
|
|
> drv = sysbench.sql.driver()
|
|
> con = drv:connect()
|
|
> end
|
|
>
|
|
> function event()
|
|
> print("drv:name() = " .. drv:name())
|
|
> for k,v in pairs(sysbench.sql.type) do print(k .. " = " .. v) end
|
|
> print()
|
|
>
|
|
> con:query("DROP TABLE IF EXISTS t")
|
|
> con:query("CREATE TABLE t(a INT)")
|
|
> con:bulk_insert_init("INSERT INTO t VALUES")
|
|
> for i = 1,100 do
|
|
> con:bulk_insert_next(string.format("(%d)", i))
|
|
> end
|
|
> con:bulk_insert_done()
|
|
>
|
|
> con2 = drv:connect()
|
|
> con:query("SELECT CONNECTION_ID()")
|
|
> con2:query("SELECT CONNECTION_ID()")
|
|
> con2:disconnect()
|
|
>
|
|
> con:query("SELECT 1")
|
|
> con:disconnect()
|
|
> con:query("SELECT 1")
|
|
>
|
|
> con = drv:connect()
|
|
>
|
|
> con:query("ALTER TABLE t ADD COLUMN b CHAR(10)")
|
|
>
|
|
> local stmt = con:prepare("UPDATE t SET a = a + ?, b = ?")
|
|
> local a = stmt:bind_create(sysbench.sql.type.INT)
|
|
> local b = stmt:bind_create(sysbench.sql.type.CHAR, 10)
|
|
> stmt:bind_param(a, b)
|
|
> a:set(100)
|
|
> rs = stmt:execute()
|
|
> a:set(200)
|
|
> b:set("01234567890")
|
|
> rs = stmt:execute()
|
|
> rs:free()
|
|
> stmt:close()
|
|
> end
|
|
> EOF
|
|
|
|
$ mysql -uroot sbtest -Nse "DROP TABLE IF EXISTS t"
|
|
|
|
$ sysbench $SB_ARGS run
|
|
drv:name() = mysql
|
|
NONE = 0
|
|
INT = 3
|
|
CHAR = 11
|
|
VARCHAR = 12
|
|
TIMESTAMP = 10
|
|
TIME = 7
|
|
FLOAT = 5
|
|
TINYINT = 1
|
|
BIGINT = 4
|
|
SMALLINT = 2
|
|
DATE = 8
|
|
DATETIME = 9
|
|
DOUBLE = 6
|
|
|
|
ALERT: attempt to use an already closed connection
|
|
|
|
$ mysql -uroot sbtest -Nse "SHOW CREATE TABLE t\G"
|
|
*************************** 1. row ***************************
|
|
t
|
|
CREATE TABLE `t` (
|
|
`a` int(11) DEFAULT NULL,
|
|
`b` char(10)* DEFAULT NULL (glob)
|
|
) * (glob)
|
|
|
|
$ mysql -uroot sbtest -Nse "SELECT COUNT(DISTINCT a) FROM t"
|
|
100
|
|
|
|
$ mysql -uroot sbtest -Nse "SELECT MIN(a), MAX(a), MIN(b), MAX(b) FROM t\G"
|
|
*************************** 1. row ***************************
|
|
301
|
|
400
|
|
0123456789
|
|
0123456789
|
|
|
|
$ mysql -uroot sbtest -Nse "DROP TABLE t"
|
|
|
|
########################################################################
|
|
Multiple connections test
|
|
########################################################################
|
|
$ SB_ARGS="--verbosity=1 --test=$CRAMTMP/api_sql.lua --max-requests=1 --num-threads=1 --db-driver=mysql $SBTEST_MYSQL_ARGS"
|
|
$ cat >$CRAMTMP/api_sql.lua <<EOF
|
|
> function thread_init()
|
|
> drv = sysbench.sql.driver()
|
|
> con = {}
|
|
> for i=1,10 do
|
|
> con[i] = drv:connect()
|
|
> end
|
|
> end
|
|
>
|
|
> function event()
|
|
> con[1]:query("DROP TABLE IF EXISTS t")
|
|
> con[2]:query("CREATE TABLE t(a INT)")
|
|
> for i=1,10 do
|
|
> con[i]:query("INSERT INTO t VALUES (" .. i .. ")")
|
|
> end
|
|
> end
|
|
> EOF
|
|
|
|
$ sysbench $SB_ARGS run
|
|
$ mysql -uroot sbtest -Nse "SELECT * FROM t"
|
|
1
|
|
2
|
|
3
|
|
4
|
|
5
|
|
6
|
|
7
|
|
8
|
|
9
|
|
10
|
|
$ mysql -uroot sbtest -Nse "DROP TABLE t"
|