mirror of
https://github.com/MariaDB/server.git
synced 2026-03-01 05:58:40 +01:00
- use shared key for sequence update certification - employ native replication's code to apply changes for sequences which handles all corner cases properly - fix the tests to allow more transactions using sequences to be accepted That way the sequence is always updated to the maximum value independent of the order of updates, and shared certification keys allow to improve acceptance ratio of concurrent transactions that use sequences. It's reflected in the test changes.
368 lines
6.3 KiB
Text
368 lines
6.3 KiB
Text
connection node_2;
|
|
connection node_1;
|
|
connection node_1;
|
|
CREATE SEQUENCE s INCREMENT=0 CACHE=5 ENGINE=InnoDB;
|
|
CREATE TABLE t1 (f1 INT PRIMARY KEY DEFAULT NEXTVAL(s), f2 INT) ENGINE=InnoDB;
|
|
connect node_1a, 127.0.0.1, root, , test, $NODE_MYPORT_1;
|
|
connect node_2a, 127.0.0.1, root, , test, $NODE_MYPORT_2;
|
|
connection node_1;
|
|
BEGIN;
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
COMMIT;
|
|
connection node_2;
|
|
BEGIN;
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
COMMIT;
|
|
connection node_2a;
|
|
BEGIN;
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
COMMIT;
|
|
connection node_1a;
|
|
BEGIN;
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
COMMIT;
|
|
connection node_2;
|
|
SELECT LASTVAL(s);
|
|
LASTVAL(s)
|
|
40
|
|
connection node_1;
|
|
SELECT LASTVAL(s);
|
|
LASTVAL(s)
|
|
19
|
|
connection node_2a;
|
|
SELECT LASTVAL(s);
|
|
LASTVAL(s)
|
|
60
|
|
connection node_1a;
|
|
SELECT LASTVAL(s);
|
|
LASTVAL(s)
|
|
81
|
|
connection node_1;
|
|
SELECT * FROM t1;
|
|
f1 f2
|
|
1 1
|
|
3 1
|
|
5 1
|
|
7 1
|
|
9 1
|
|
11 1
|
|
13 1
|
|
15 1
|
|
17 1
|
|
19 1
|
|
22 1
|
|
24 1
|
|
26 1
|
|
28 1
|
|
30 1
|
|
32 1
|
|
34 1
|
|
36 1
|
|
38 1
|
|
40 1
|
|
42 1
|
|
44 1
|
|
46 1
|
|
48 1
|
|
50 1
|
|
52 1
|
|
54 1
|
|
56 1
|
|
58 1
|
|
60 1
|
|
63 1
|
|
65 1
|
|
67 1
|
|
69 1
|
|
71 1
|
|
73 1
|
|
75 1
|
|
77 1
|
|
79 1
|
|
81 1
|
|
connection node_2;
|
|
SELECT * FROM t1;
|
|
f1 f2
|
|
1 1
|
|
3 1
|
|
5 1
|
|
7 1
|
|
9 1
|
|
11 1
|
|
13 1
|
|
15 1
|
|
17 1
|
|
19 1
|
|
22 1
|
|
24 1
|
|
26 1
|
|
28 1
|
|
30 1
|
|
32 1
|
|
34 1
|
|
36 1
|
|
38 1
|
|
40 1
|
|
42 1
|
|
44 1
|
|
46 1
|
|
48 1
|
|
50 1
|
|
52 1
|
|
54 1
|
|
56 1
|
|
58 1
|
|
60 1
|
|
63 1
|
|
65 1
|
|
67 1
|
|
69 1
|
|
71 1
|
|
73 1
|
|
75 1
|
|
77 1
|
|
79 1
|
|
81 1
|
|
connection node_1;
|
|
DROP TABLE t1;
|
|
DROP SEQUENCE s;
|
|
connection node_1;
|
|
CREATE SEQUENCE s INCREMENT=0 CACHE=5 ENGINE=InnoDB;
|
|
CREATE TABLE t1 (f1 INT PRIMARY KEY DEFAULT NEXTVAL(s), f2 INT) ENGINE=InnoDB;
|
|
connection node_1;
|
|
BEGIN;
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
ROLLBACK;
|
|
connection node_2;
|
|
BEGIN;
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
ROLLBACK;
|
|
connection node_2a;
|
|
BEGIN;
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
ROLLBACK;
|
|
connection node_1a;
|
|
BEGIN;
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
ROLLBACK;
|
|
connection node_2;
|
|
SELECT LASTVAL(s);
|
|
LASTVAL(s)
|
|
20
|
|
connection node_1;
|
|
SELECT LASTVAL(s);
|
|
LASTVAL(s)
|
|
19
|
|
connection node_2a;
|
|
SELECT LASTVAL(s);
|
|
LASTVAL(s)
|
|
40
|
|
connection node_1a;
|
|
SELECT LASTVAL(s);
|
|
LASTVAL(s)
|
|
39
|
|
connection node_1;
|
|
SELECT * FROM t1;
|
|
f1 f2
|
|
connection node_2;
|
|
SELECT * FROM t1;
|
|
f1 f2
|
|
connection node_1;
|
|
DROP TABLE t1;
|
|
DROP SEQUENCE s;
|
|
connection node_1;
|
|
CREATE SEQUENCE s INCREMENT=0 CACHE=5 ENGINE=InnoDB;
|
|
CREATE TABLE t1 (f1 INT PRIMARY KEY DEFAULT NEXTVAL(s), f2 INT) ENGINE=InnoDB;
|
|
connection node_1;
|
|
BEGIN;
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
connection node_1a;
|
|
BEGIN;
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
connection node_2a;
|
|
BEGIN;
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
connection node_2;
|
|
BEGIN;
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
INSERT INTO t1(f2) values (1);
|
|
connection node_1;
|
|
COMMIT;
|
|
connection node_1a;
|
|
ROLLBACK;
|
|
connection node_2;
|
|
COMMIT;
|
|
connection node_2a;
|
|
ROLLBACK;
|
|
connection node_2;
|
|
SELECT LASTVAL(s);
|
|
LASTVAL(s)
|
|
40
|
|
connection node_1;
|
|
SELECT LASTVAL(s);
|
|
LASTVAL(s)
|
|
19
|
|
connection node_2a;
|
|
SELECT LASTVAL(s);
|
|
LASTVAL(s)
|
|
20
|
|
connection node_1a;
|
|
SELECT LASTVAL(s);
|
|
LASTVAL(s)
|
|
39
|
|
connection node_1;
|
|
SELECT * FROM t1;
|
|
f1 f2
|
|
1 1
|
|
3 1
|
|
5 1
|
|
7 1
|
|
9 1
|
|
11 1
|
|
13 1
|
|
15 1
|
|
17 1
|
|
19 1
|
|
22 1
|
|
24 1
|
|
26 1
|
|
28 1
|
|
30 1
|
|
32 1
|
|
34 1
|
|
36 1
|
|
38 1
|
|
40 1
|
|
connection node_2;
|
|
SELECT * FROM t1;
|
|
f1 f2
|
|
1 1
|
|
3 1
|
|
5 1
|
|
7 1
|
|
9 1
|
|
11 1
|
|
13 1
|
|
15 1
|
|
17 1
|
|
19 1
|
|
22 1
|
|
24 1
|
|
26 1
|
|
28 1
|
|
30 1
|
|
32 1
|
|
34 1
|
|
36 1
|
|
38 1
|
|
40 1
|
|
connection node_1;
|
|
DROP TABLE t1;
|
|
DROP SEQUENCE s;
|