1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
|
--source include/have_rocksdb.inc
#
# MyRocks-specific tests for locking
#
--source include/have_debug.inc
--enable_connect_log
create table t1 (pk int not null primary key) engine=rocksdb;
insert into t1 values (1),(2),(3);
set autocommit=0;
begin;
select * from t1 where pk=1 for update;
--connect (con1,localhost,root,,)
--connection con1
--echo ### Connection con1
let $ID= `select connection_id()`;
set @@rocksdb_lock_wait_timeout=500;
set autocommit=0;
begin;
--send select * from t1 where pk=1 for update;
--connection default
--echo ### Connection default
let $wait_condition= select 1 from INFORMATION_SCHEMA.PROCESSLIST
where ID = $ID and STATE = "Waiting for row lock";
--source include/wait_condition.inc
## Waiting for row lock
## select connection_id();
## select state='Waiting for row lock' from information_schema.processlist where id=2;
rollback;
connection con1;
reap;
rollback;
connection default;
##
## Now, repeat the same test but let the wait time out.
##
begin;
select * from t1 where pk=1 for update;
--connection con1
--echo ### Connection con1
set @@rocksdb_lock_wait_timeout=2;
set autocommit=0;
begin;
--error ER_LOCK_WAIT_TIMEOUT
select * from t1 where pk=1 for update;
--connection default
rollback;
set autocommit=1;
--connection con1
drop table t1;
--connection default
--echo #
--echo # Now, test what happens if another transaction modified the record and committed
--echo #
CREATE TABLE t1 (
id int primary key,
value int
) engine=rocksdb collate latin1_bin;
insert into t1 values (1,1),(2,2),(3,3),(4,4),(5,5),(6,6),(7,7),(8,8),(9,9),(10,10);
--connection con1
BEGIN;
SELECT * FROM t1 WHERE id=3;
--connection default
BEGIN;
UPDATE t1 SET value=30 WHERE id=3;
COMMIT;
--connection con1
--error ER_LOCK_DEADLOCK
SELECT * FROM t1 WHERE id=3 FOR UPDATE;
ROLLBACK;
--disconnect con1
--connection default
drop table t1;
|
