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
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
|
--source include/have_rocksdb.inc
--source include/have_debug_sync.inc
# For GitHub issue#167 -- Unique key check doesn't work
connect (con1, localhost, root,,);
connect (con2, localhost, root,,);
connect (con3, localhost, root,,);
connection default;
--disable_warnings
set debug_sync='RESET';
drop table if exists t1;
--enable_warnings
create table t1 (id int, value int, primary key (id)) engine=rocksdb;
create table t2 (id int, id2 int, value int, primary key (id), unique key (id2)) engine=rocksdb;
# 1) second insert should be blocked at GetForUpdate(), then returning duplicate key error
# after con1's commit
connection con1;
begin;
insert into t1 values (1,1);
connection con2;
let $ID= `select connection_id()`;
set session rocksdb_lock_wait_timeout=50;
begin;
send insert into t1 values (1,2);
connection con1;
let $wait_condition= select 1 from INFORMATION_SCHEMA.PROCESSLIST
where ID = $ID and STATE = "Waiting for row lock";
--source include/wait_condition.inc
commit;
connection con2;
--error ER_DUP_ENTRY
reap;
commit;
select * from t1;
truncate table t1;
# 2) same as 1) but using secondary unique key constraint
connection con1;
begin;
insert into t2 values (1,1,1);
connection con2;
begin;
send insert into t2 values (2,1,2);
connection con1;
--source include/wait_condition.inc
commit;
connection con2;
--error ER_DUP_ENTRY
reap;
commit;
select * from t2;
truncate table t2;
# 3) similar to 1),2) but rolled back
connection con1;
begin;
insert into t1 values (1,1);
connection con2;
begin;
send insert into t1 values (1,2);
connection con1;
--source include/wait_condition.inc
rollback;
connection con2;
reap;
commit;
select * from t1;
truncate table t1;
connection con1;
begin;
insert into t2 values (1,1,1);
connection con2;
begin;
send insert into t2 values (2,1,2);
connection con1;
--source include/wait_condition.inc
rollback;
connection con2;
reap;
commit;
select * from t2;
truncate table t2;
# 4) simulating T1 GetForUpdate() -> T2 GetForUpdate(). T2 should fail with lock wait timeout.
connection con1;
set debug_sync='rocksdb.update_write_row_after_unique_check SIGNAL parked1 WAIT_FOR go1';
send insert into t1 values (1,1);
connection con2;
set debug_sync='rocksdb.update_write_row_after_unique_check SIGNAL parked2 WAIT_FOR go2';
send insert into t2 values (1,1,1);
connection default;
set debug_sync='now WAIT_FOR parked1';
set debug_sync='now WAIT_FOR parked2';
connection con3;
set session rocksdb_lock_wait_timeout=1;
--error ER_LOCK_WAIT_TIMEOUT
insert into t1 values (1,2);
--error ER_LOCK_WAIT_TIMEOUT
insert into t2 values (2,1,2);
connection default;
set debug_sync='now SIGNAL go1';
set debug_sync='now SIGNAL go2';
connection con1;
reap;
connection con2;
reap;
connection default;
--error ER_DUP_ENTRY
insert into t1 values (1,2);
--error ER_DUP_ENTRY
insert into t2 values (2,1,2);
select * from t1;
select * from t2;
# Cleanup
connection default;
set debug_sync='RESET';
disconnect con1;
disconnect con2;
disconnect con3;
drop table t1, t2;
# skip_unique checks should skip checks only for tables that don't have
# secondary indexes
connection default;
--disable_warnings
drop table if exists t1,t2,t3;
--enable_warnings
# table with PK only
create table t1 (id int, value int, primary key (id)) engine=rocksdb;
# table with PK and SK
create table t2 (id int, id2 int, value int, primary key (id), unique key (id2)) engine=rocksdb;
# table with hidden PK
create table t3 (id int, value int) engine=rocksdb;
SET @old_val = @@session.unique_checks;
set @@session.unique_checks = FALSE;
insert into t1 values (1, 1), (1, 2);
--error ER_DUP_ENTRY
insert into t2 values (1, 1, 1), (1, 2, 1);
insert into t3 values (1, 1), (1, 1);
set @@session.unique_checks = @old_val;
# cleanup
drop table t1, t2, t3;
|
