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
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
|
# Test with AUTO_INCREMENT
CREATE TABLE tp
(a INT NOT NULL AUTO_INCREMENT PRIMARY KEY,
b varchar(24))
ENGINE = 'Memory'
PARTITION BY HASH (a) PARTITIONS 4;
CREATE TABLE t LIKE tp;
ALTER TABLE t REMOVE PARTITIONING;
SHOW CREATE TABLE tp;
Table Create Table
tp CREATE TABLE `tp` (
`a` int(11) NOT NULL AUTO_INCREMENT,
`b` varchar(24) DEFAULT NULL,
PRIMARY KEY (`a`)
) ENGINE=MEMORY DEFAULT CHARSET=latin1
/*!50100 PARTITION BY HASH (a)
PARTITIONS 4 */
SHOW CREATE TABLE t;
Table Create Table
t CREATE TABLE `t` (
`a` int(11) NOT NULL AUTO_INCREMENT,
`b` varchar(24) DEFAULT NULL,
PRIMARY KEY (`a`)
) ENGINE=MEMORY DEFAULT CHARSET=latin1
INSERT INTO tp (b) VALUES ("One"), ("Two"), ("Three"), ("Four"), ("Five"),
("Six"), ("Seven"), ("Eight"), ("Nine"), ("Ten"), ("Eleven"), ("Twelwe");
INSERT INTO tp VALUES (97, "Ninety seven");
INSERT INTO tp VALUES (111, "One hundred eleven");
INSERT INTO tp VALUES (101, "One hundred one");
SET INSERT_ID = 13;
INSERT INTO t (b) VALUES ("Thirteen");
SET INSERT_ID = 21;
INSERT INTO t (b) VALUES ("Twenty one");
SET INSERT_ID = 25;
INSERT INTO t (b) VALUES ("Twenty five");
SET INSERT_ID = 55;
INSERT INTO t (b) VALUES ("Fifty five");
DELETE FROM tp WHERE a = 111;
DELETE FROM t WHERE a = 55;
UPDATE tp SET a = 41 WHERE a = 101;
UPDATE t SET a = 17 WHERE a = 25;
SELECT PARTITION_NAME, IF(TABLE_ROWS, 'YES', 'NO') AS HAVE_ROWS FROM INFORMATION_SCHEMA.PARTITIONS WHERE TABLE_SCHEMA ='test' AND TABLE_NAME = 'tp';
PARTITION_NAME HAVE_ROWS
p0 YES
p1 YES
p2 YES
p3 YES
SELECT IF(TABLE_ROWS, 'YES', 'NO') AS HAVE_ROWS FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_SCHEMA ='test' AND TABLE_NAME = 't';
HAVE_ROWS
YES
ALTER TABLE tp EXCHANGE PARTITION p1 WITH TABLE t;
SELECT PARTITION_NAME, IF(TABLE_ROWS, 'YES', 'NO') AS HAVE_ROWS FROM INFORMATION_SCHEMA.PARTITIONS WHERE TABLE_SCHEMA ='test' AND TABLE_NAME = 'tp';
PARTITION_NAME HAVE_ROWS
p0 YES
p1 YES
p2 YES
p3 YES
SELECT IF(TABLE_ROWS, 'YES', 'NO') AS HAVE_ROWS FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_SCHEMA ='test' AND TABLE_NAME = 't';
HAVE_ROWS
YES
SELECT * FROM tp ORDER BY a;
a b
2 Two
3 Three
4 Four
6 Six
7 Seven
8 Eight
10 Ten
11 Eleven
12 Twelwe
13 Thirteen
17 Twenty five
21 Twenty one
SELECT * FROM t ORDER BY a;
a b
1 One
5 Five
9 Nine
41 One hundred one
97 Ninety seven
SHOW CREATE TABLE tp;
Table Create Table
tp CREATE TABLE `tp` (
`a` int(11) NOT NULL AUTO_INCREMENT,
`b` varchar(24) DEFAULT NULL,
PRIMARY KEY (`a`)
) ENGINE=MEMORY AUTO_INCREMENT=112 DEFAULT CHARSET=latin1
/*!50100 PARTITION BY HASH (a)
PARTITIONS 4 */
SHOW CREATE TABLE t;
Table Create Table
t CREATE TABLE `t` (
`a` int(11) NOT NULL AUTO_INCREMENT,
`b` varchar(24) DEFAULT NULL,
PRIMARY KEY (`a`)
) ENGINE=MEMORY AUTO_INCREMENT=102 DEFAULT CHARSET=latin1
DROP TABLE tp, t;
CREATE TABLE t
(a INT,
b VARCHAR(55),
PRIMARY KEY (a))
ENGINE = 'Memory';
CREATE TABLE tp
(a INT,
b VARCHAR(55),
PRIMARY KEY (a))
ENGINE = 'Memory'
PARTITION BY RANGE (a)
(PARTITION p0 VALUES LESS THAN (100),
PARTITION p1 VALUES LESS THAN MAXVALUE);
CREATE TABLE tsp
(a INT,
b VARCHAR(55),
PRIMARY KEY (a))
ENGINE = 'Memory'
PARTITION BY RANGE (a)
SUBPARTITION BY HASH(a)
(PARTITION p0 VALUES LESS THAN (100)
(SUBPARTITION sp0,
SUBPARTITION sp1),
PARTITION p1 VALUES LESS THAN MAXVALUE
(SUBPARTITION sp2,
SUBPARTITION sp3));
INSERT INTO t VALUES (1, "First value"), (3, "Three"), (5, "Five"), (99, "End of values");
INSERT INTO tp VALUES (2, "First value"), (10, "Ten"), (50, "Fifty"), (200, "Two hundred, end of values"), (61, "Sixty one"), (62, "Sixty two"), (63, "Sixty three"), (64, "Sixty four"), (161, "161"), (162, "162"), (163, "163"), (164, "164");
INSERT INTO tsp VALUES (2, "First value"), (10, "Ten"), (50, "Fifty"), (200, "Two hundred, end of values"), (61, "Sixty one"), (62, "Sixty two"), (63, "Sixty three"), (64, "Sixty four"), (161, "161"), (162, "162"), (163, "163"), (164, "164");
SELECT * FROM t;
a b
1 First value
3 Three
5 Five
99 End of values
SELECT * FROM tp;
a b
10 Ten
161 161
162 162
163 163
164 164
2 First value
200 Two hundred, end of values
50 Fifty
61 Sixty one
62 Sixty two
63 Sixty three
64 Sixty four
# Start by testing read/write locking
SET AUTOCOMMIT = 1;
connect con1, localhost, root,,;
SET DEBUG_SYNC= 'swap_partition_after_compare_tables SIGNAL swap_in_progress WAIT_FOR goto_verification';
SET DEBUG_SYNC= 'swap_partition_first_row_read SIGNAL swap_in_progress WAIT_FOR goto_wait';
SET DEBUG_SYNC= 'swap_partition_after_wait SIGNAL swap_in_progress WAIT_FOR goto_rename';
SET DEBUG_SYNC= 'swap_partition_before_rename SIGNAL swap_in_progress WAIT_FOR test_done';
ALTER TABLE tp EXCHANGE PARTITION p0 WITH TABLE t;
connection default;
SET DEBUG_SYNC= 'now WAIT_FOR swap_in_progress';
# select from t and select/update/delete/insert from tp should work
SELECT * FROM t WHERE a = 99;
a b
99 End of values
SELECT * FROM tp WHERE a = 61;
a b
61 Sixty one
# any write (update/delete/insert) into t or tp should fail
SET SESSION lock_wait_timeout=1;
UPDATE tp SET a = 53, b = concat("Fifty three, was ", b) WHERE a = 63;
ERROR HY000: Lock wait timeout exceeded; try restarting transaction
INSERT INTO tp VALUES (63, "Sixty three, new"), (59, "To be deleted");
ERROR HY000: Lock wait timeout exceeded; try restarting transaction
DELETE FROM tp WHERE a = 59;
ERROR HY000: Lock wait timeout exceeded; try restarting transaction
UPDATE t SET a = 53, b = "Fifty three, was three" WHERE a = 3;
ERROR HY000: Lock wait timeout exceeded; try restarting transaction
INSERT INTO t VALUES (63, "Sixty three, new"), (59, "To be deleted");
ERROR HY000: Lock wait timeout exceeded; try restarting transaction
DELETE FROM t WHERE a = 3;
ERROR HY000: Lock wait timeout exceeded; try restarting transaction
ALTER TABLE t ENGINE = 'Memory';
ERROR HY000: Lock wait timeout exceeded; try restarting transaction
ALTER TABLE tp ENGINE = 'Memory';
ERROR HY000: Lock wait timeout exceeded; try restarting transaction
SHOW CREATE TABLE t;
Table Create Table
t CREATE TABLE `t` (
`a` int(11) NOT NULL,
`b` varchar(55) DEFAULT NULL,
PRIMARY KEY (`a`)
) ENGINE=MEMORY DEFAULT CHARSET=latin1
SHOW CREATE TABLE tp;
Table Create Table
tp CREATE TABLE `tp` (
`a` int(11) NOT NULL,
`b` varchar(55) DEFAULT NULL,
PRIMARY KEY (`a`)
) ENGINE=MEMORY DEFAULT CHARSET=latin1
/*!50100 PARTITION BY RANGE (a)
(PARTITION p0 VALUES LESS THAN (100) ENGINE = MEMORY,
PARTITION p1 VALUES LESS THAN MAXVALUE ENGINE = MEMORY) */
SET DEBUG_SYNC= 'now SIGNAL goto_verification';
SET DEBUG_SYNC= 'now WAIT_FOR swap_in_progress';
# select from t and select/update/delete/insert from tp should work
SELECT * FROM t WHERE a = 99;
a b
99 End of values
SELECT * FROM tp WHERE a = 61;
a b
61 Sixty one
UPDATE tp SET a = 43, b = concat("Fifty three, was ", b) WHERE a = 63;
ERROR HY000: Lock wait timeout exceeded; try restarting transaction
INSERT INTO tp VALUES (63, "Sixty three, new 2"), (59, "To be deleted");
ERROR HY000: Lock wait timeout exceeded; try restarting transaction
DELETE FROM tp WHERE a = 59;
ERROR HY000: Lock wait timeout exceeded; try restarting transaction
# any write (update/delete/insert) into t should fail
UPDATE t SET a = 53, b = "Fifty three, was three" WHERE a = 3;
ERROR HY000: Lock wait timeout exceeded; try restarting transaction
INSERT INTO t VALUES (63, "Sixty three, new"), (59, "To be deleted");
ERROR HY000: Lock wait timeout exceeded; try restarting transaction
DELETE FROM t WHERE a = 3;
ERROR HY000: Lock wait timeout exceeded; try restarting transaction
ALTER TABLE t ENGINE = 'Memory';
ERROR HY000: Lock wait timeout exceeded; try restarting transaction
ALTER TABLE tp ENGINE = 'Memory';
ERROR HY000: Lock wait timeout exceeded; try restarting transaction
SHOW CREATE TABLE t;
Table Create Table
t CREATE TABLE `t` (
`a` int(11) NOT NULL,
`b` varchar(55) DEFAULT NULL,
PRIMARY KEY (`a`)
) ENGINE=MEMORY DEFAULT CHARSET=latin1
SHOW CREATE TABLE tp;
Table Create Table
tp CREATE TABLE `tp` (
`a` int(11) NOT NULL,
`b` varchar(55) DEFAULT NULL,
PRIMARY KEY (`a`)
) ENGINE=MEMORY DEFAULT CHARSET=latin1
/*!50100 PARTITION BY RANGE (a)
(PARTITION p0 VALUES LESS THAN (100) ENGINE = MEMORY,
PARTITION p1 VALUES LESS THAN MAXVALUE ENGINE = MEMORY) */
SET DEBUG_SYNC= 'now SIGNAL goto_wait';
SET DEBUG_SYNC= 'now WAIT_FOR swap_in_progress';
# Both tables should now be under exclusive lock, even SHOW should fail
SELECT * FROM t WHERE a = 99;
ERROR HY000: Lock wait timeout exceeded; try restarting transaction
SELECT * FROM tp WHERE a = 61;
ERROR HY000: Lock wait timeout exceeded; try restarting transaction
UPDATE tp SET a = 53, b = concat("Fifty three, was ", b) WHERE a = 63;
ERROR HY000: Lock wait timeout exceeded; try restarting transaction
INSERT INTO tp VALUES (63, "Sixty three, new 2"), (59, "To be deleted");
ERROR HY000: Lock wait timeout exceeded; try restarting transaction
DELETE FROM tp WHERE a = 59;
ERROR HY000: Lock wait timeout exceeded; try restarting transaction
UPDATE t SET a = 53, b = "Fifty three, was three" WHERE a = 3;
ERROR HY000: Lock wait timeout exceeded; try restarting transaction
INSERT INTO t VALUES (63, "Sixty three, new"), (59, "To be deleted");
ERROR HY000: Lock wait timeout exceeded; try restarting transaction
DELETE FROM t WHERE a = 3;
ERROR HY000: Lock wait timeout exceeded; try restarting transaction
SHOW CREATE TABLE t;
ERROR HY000: Lock wait timeout exceeded; try restarting transaction
SHOW CREATE TABLE tp;
ERROR HY000: Lock wait timeout exceeded; try restarting transaction
ALTER TABLE t ENGINE = 'Memory';
ERROR HY000: Lock wait timeout exceeded; try restarting transaction
ALTER TABLE tp ENGINE = 'Memory';
ERROR HY000: Lock wait timeout exceeded; try restarting transaction
SET DEBUG_SYNC= 'now SIGNAL goto_rename';
SET DEBUG_SYNC= 'now WAIT_FOR swap_in_progress';
# Both tables should now be under exclusive lock
SELECT * FROM t WHERE a = 99;
ERROR HY000: Lock wait timeout exceeded; try restarting transaction
SELECT * FROM tp WHERE a = 61;
ERROR HY000: Lock wait timeout exceeded; try restarting transaction
UPDATE tp SET a = 53, b = concat("Fifty three, was ", b) WHERE a = 63;
ERROR HY000: Lock wait timeout exceeded; try restarting transaction
INSERT INTO tp VALUES (63, "Sixty three, new 2"), (59, "To be deleted");
ERROR HY000: Lock wait timeout exceeded; try restarting transaction
DELETE FROM tp WHERE a = 59;
ERROR HY000: Lock wait timeout exceeded; try restarting transaction
UPDATE t SET a = 53, b = "Fifty three, was three" WHERE a = 3;
ERROR HY000: Lock wait timeout exceeded; try restarting transaction
INSERT INTO t VALUES (63, "Sixty three, new"), (59, "To be deleted");
ERROR HY000: Lock wait timeout exceeded; try restarting transaction
DELETE FROM t WHERE a = 3;
ERROR HY000: Lock wait timeout exceeded; try restarting transaction
ALTER TABLE t ENGINE = 'Memory';
ERROR HY000: Lock wait timeout exceeded; try restarting transaction
ALTER TABLE tp ENGINE = 'Memory';
ERROR HY000: Lock wait timeout exceeded; try restarting transaction
SHOW CREATE TABLE t;
ERROR HY000: Lock wait timeout exceeded; try restarting transaction
SHOW CREATE TABLE tp;
ERROR HY000: Lock wait timeout exceeded; try restarting transaction
SET DEBUG_SYNC= 'now SIGNAL test_done';
connection con1;
connection default;
# Tables should now be as normal
SHOW CREATE TABLE t;
Table Create Table
t CREATE TABLE `t` (
`a` int(11) NOT NULL,
`b` varchar(55) DEFAULT NULL,
PRIMARY KEY (`a`)
) ENGINE=MEMORY DEFAULT CHARSET=latin1
SHOW CREATE TABLE tp;
Table Create Table
tp CREATE TABLE `tp` (
`a` int(11) NOT NULL,
`b` varchar(55) DEFAULT NULL,
PRIMARY KEY (`a`)
) ENGINE=MEMORY DEFAULT CHARSET=latin1
/*!50100 PARTITION BY RANGE (a)
(PARTITION p0 VALUES LESS THAN (100) ENGINE = MEMORY,
PARTITION p1 VALUES LESS THAN MAXVALUE ENGINE = MEMORY) */
SELECT * FROM tp WHERE a = 99;
a b
99 End of values
SELECT * FROM t WHERE a = 61;
a b
61 Sixty one
UPDATE t SET a = 53, b = "Fifty three, was sixty three" WHERE a = 63;
INSERT INTO t VALUES (63, "Sixty three, new"), (59, "To be deleted");
DELETE FROM t WHERE a = 59;
UPDATE tp SET a = 53, b = "Fifty three, was three" WHERE a = 3;
INSERT INTO tp VALUES (63, "Sixty three, new"), (59, "To be deleted");
DELETE FROM tp WHERE a = 3;
ALTER TABLE t ENGINE = 'Memory';
ALTER TABLE tp ENGINE = 'Memory';
disconnect con1;
connection default;
SET DEBUG_SYNC= 'RESET';
SHOW CREATE TABLE t;
Table Create Table
t CREATE TABLE `t` (
`a` int(11) NOT NULL,
`b` varchar(55) DEFAULT NULL,
PRIMARY KEY (`a`)
) ENGINE=MEMORY DEFAULT CHARSET=latin1
SHOW CREATE TABLE tp;
Table Create Table
tp CREATE TABLE `tp` (
`a` int(11) NOT NULL,
`b` varchar(55) DEFAULT NULL,
PRIMARY KEY (`a`)
) ENGINE=MEMORY DEFAULT CHARSET=latin1
/*!50100 PARTITION BY RANGE (a)
(PARTITION p0 VALUES LESS THAN (100) ENGINE = MEMORY,
PARTITION p1 VALUES LESS THAN MAXVALUE ENGINE = MEMORY) */
SELECT * FROM t;
a b
10 Ten
2 First value
50 Fifty
53 Fifty three, was sixty three
61 Sixty one
62 Sixty two
63 Sixty three, new
64 Sixty four
SELECT * FROM tp;
a b
1 First value
161 161
162 162
163 163
164 164
200 Two hundred, end of values
5 Five
53 Fifty three, was three
59 To be deleted
63 Sixty three, new
99 End of values
DROP TABLE t, tp, tsp;
|
