diff options
Diffstat (limited to 'mysql-test/suite/multi_source/gtid_ignore_duplicates.result')
| -rw-r--r-- | mysql-test/suite/multi_source/gtid_ignore_duplicates.result | 56 |
1 files changed, 56 insertions, 0 deletions
diff --git a/mysql-test/suite/multi_source/gtid_ignore_duplicates.result b/mysql-test/suite/multi_source/gtid_ignore_duplicates.result index 2e15f11a7c7..92d096245c7 100644 --- a/mysql-test/suite/multi_source/gtid_ignore_duplicates.result +++ b/mysql-test/suite/multi_source/gtid_ignore_duplicates.result @@ -1,4 +1,9 @@ *** Test all-to-all replication with --gtid-ignore-duplicates *** +connect server_1,127.0.0.1,root,,,$SERVER_MYPORT_1; +connect server_2,127.0.0.1,root,,,$SERVER_MYPORT_2; +connect server_3,127.0.0.1,root,,,$SERVER_MYPORT_3; +connect server_4,127.0.0.1,root,,,$SERVER_MYPORT_4; +connection server_1; SET @old_parallel= @@GLOBAL.slave_parallel_threads; SET GLOBAL slave_parallel_threads=5; SET @old_ignore_duplicates= @@GLOBAL.gtid_ignore_duplicates; @@ -14,6 +19,7 @@ set default_master_connection = 'c2a'; START SLAVE; include/wait_for_slave_to_start.inc set default_master_connection = ''; +connection server_2; SET @old_parallel= @@GLOBAL.slave_parallel_threads; SET GLOBAL slave_parallel_threads=5; SET @old_ignore_duplicates= @@GLOBAL.gtid_ignore_duplicates; @@ -29,6 +35,7 @@ set default_master_connection = 'c2b'; START SLAVE; include/wait_for_slave_to_start.inc set default_master_connection = ''; +connection server_3; SET @old_parallel= @@GLOBAL.slave_parallel_threads; SET GLOBAL slave_parallel_threads=5; SET @old_ignore_duplicates= @@GLOBAL.gtid_ignore_duplicates; @@ -44,6 +51,7 @@ set default_master_connection = 'b2c'; START SLAVE; include/wait_for_slave_to_start.inc set default_master_connection = ''; +connection server_4; SET @old_parallel= @@GLOBAL.slave_parallel_threads; SET GLOBAL slave_parallel_threads=5; SET @old_ignore_duplicates= @@GLOBAL.gtid_ignore_duplicates; @@ -55,6 +63,7 @@ set default_master_connection = 'a2d'; START SLAVE; include/wait_for_slave_to_start.inc set default_master_connection = ''; +connection server_1; ALTER TABLE mysql.gtid_slave_pos ENGINE=InnoDB; CREATE TABLE t1 (a INT PRIMARY KEY) ENGINE=InnoDB; INSERT INTO t1 VALUES (1); @@ -65,6 +74,7 @@ COMMIT; INSERT INTO t1 VALUES (4), (5); INSERT INTO t1 VALUES (6); include/save_master_gtid.inc +connection server_2; include/sync_with_master_gtid.inc SELECT * FROM t1 ORDER BY a; a @@ -74,6 +84,7 @@ a 4 5 6 +connection server_3; include/sync_with_master_gtid.inc SELECT * FROM t1 ORDER BY a; a @@ -83,6 +94,7 @@ a 4 5 6 +connection server_4; include/sync_with_master_gtid.inc SELECT * FROM t1 ORDER BY a; a @@ -92,6 +104,7 @@ a 4 5 6 +connection server_1; include/sync_with_master_gtid.inc SELECT * FROM t1 ORDER BY a; a @@ -101,8 +114,10 @@ a 4 5 6 +connection server_3; INSERT INTO t1 VALUES (10); include/save_master_gtid.inc +connection server_2; include/sync_with_master_gtid.inc SELECT * FROM t1 WHERE a >= 10 ORDER BY a; a @@ -113,8 +128,10 @@ include/wait_for_slave_to_stop.inc STOP SLAVE "a2b"; SET default_master_connection = "a2b"; include/wait_for_slave_to_stop.inc +connection server_3; INSERT INTO t1 VALUES (11); include/save_master_gtid.inc +connection server_1; include/sync_with_master_gtid.inc SELECT * FROM t1 WHERE a >= 10 ORDER BY a; a @@ -123,12 +140,14 @@ a SET default_master_connection = "b2a"; STOP SLAVE; include/wait_for_slave_to_stop.inc +connection server_2; INSERT INTO t1 VALUES (12); SELECT * FROM t1 WHERE a >= 10 ORDER BY a; a 10 12 include/save_master_gtid.inc +connection server_1; START SLAVE "b2a"; SET default_master_connection = "b2a"; include/wait_for_slave_to_start.inc @@ -138,13 +157,16 @@ a 10 11 12 +connection server_2; START SLAVE "c2b"; SET default_master_connection = "c2b"; include/wait_for_slave_to_start.inc START SLAVE "a2b"; SET default_master_connection = "a2b"; include/wait_for_slave_to_start.inc +connection server_1; include/save_master_gtid.inc +connection server_2; include/sync_with_master_gtid.inc SELECT * FROM t1 WHERE a >= 10 ORDER BY a; a @@ -152,6 +174,7 @@ a 11 12 *** Test also with not using parallel replication. +connection server_1; SET default_master_connection = "b2a"; STOP SLAVE; include/wait_for_slave_to_stop.inc @@ -165,6 +188,7 @@ include/wait_for_slave_to_start.inc SET default_master_connection = "c2a"; START SLAVE; include/wait_for_slave_to_start.inc +connection server_2; SET default_master_connection = "a2b"; STOP SLAVE; include/wait_for_slave_to_stop.inc @@ -178,6 +202,7 @@ include/wait_for_slave_to_start.inc SET default_master_connection = "c2b"; START SLAVE; include/wait_for_slave_to_start.inc +connection server_3; SET default_master_connection = "a2c"; STOP SLAVE; include/wait_for_slave_to_stop.inc @@ -191,6 +216,7 @@ include/wait_for_slave_to_start.inc SET default_master_connection = "b2c"; START SLAVE; include/wait_for_slave_to_start.inc +connection server_4; SET default_master_connection = "a2d"; STOP SLAVE; include/wait_for_slave_to_stop.inc @@ -198,6 +224,7 @@ SET GLOBAL slave_parallel_threads=0; SET default_master_connection = "a2d"; START SLAVE; include/wait_for_slave_to_start.inc +connection server_2; INSERT INTO t1 VALUES (21); BEGIN; INSERT INTO t1 VALUES (22); @@ -206,6 +233,7 @@ COMMIT; INSERT INTO t1 VALUES (24), (25); INSERT INTO t1 VALUES (26); include/save_master_gtid.inc +connection server_1; include/sync_with_master_gtid.inc SELECT * FROM t1 WHERE a >= 20 ORDER BY a; a @@ -215,6 +243,7 @@ a 24 25 26 +connection server_3; include/sync_with_master_gtid.inc SELECT * FROM t1 WHERE a >= 20 ORDER BY a; a @@ -224,6 +253,7 @@ a 24 25 26 +connection server_4; include/sync_with_master_gtid.inc SELECT * FROM t1 WHERE a >= 20 ORDER BY a; a @@ -233,6 +263,7 @@ a 24 25 26 +connection server_2; include/sync_with_master_gtid.inc SELECT * FROM t1 WHERE a >= 20 ORDER BY a; a @@ -243,15 +274,18 @@ a 25 26 *** MDEV-8354: out-of-order error with --gtid-ignore-duplicates and row-based replication *** +connection server_1; SET default_master_connection = "b2a"; STOP SLAVE; include/wait_for_slave_to_stop.inc SET default_master_connection = "c2a"; STOP SLAVE; include/wait_for_slave_to_stop.inc +connection server_2; SET default_master_connection = "c2b"; STOP SLAVE; include/wait_for_slave_to_stop.inc +connection server_3; SET default_master_connection = "b2c"; STOP SLAVE; include/wait_for_slave_to_stop.inc @@ -261,6 +295,7 @@ SET @old_strict=@@GLOBAL.gtid_strict_mode; SET GLOBAL gtid_strict_mode=1; SET @old_dbug=@@GLOBAL.debug_dbug; SET GLOBAL debug_dbug="+d,inject_sleep_gtid_100_x_x"; +connection server_1; SET @old_domain=@@SESSION.gtid_domain_id; SET @old_format=@@SESSION.binlog_format; SET SESSION gtid_domain_id=100; @@ -288,15 +323,18 @@ INSERT INTO t1 VALUES (49); SET SESSION gtid_domain_id=@old_domain; SET SESSION binlog_format=@old_format; include/save_master_gtid.inc +connection server_2; include/sync_with_master_gtid.inc INSERT INTO t1 VALUES (50); include/save_master_gtid.inc +connection server_3; SET default_master_connection = "b2c"; START SLAVE; include/wait_for_slave_to_start.inc SELECT MASTER_GTID_WAIT("GTID", 30); MASTER_GTID_WAIT("GTID", 30) 0 +connection server_1; SET default_master_connection = "b2a"; START SLAVE; include/wait_for_slave_to_start.inc @@ -327,6 +365,7 @@ a 48 49 50 +connection server_2; SET default_master_connection = "c2b"; START SLAVE; include/wait_for_slave_to_start.inc @@ -354,6 +393,7 @@ a 48 49 50 +connection server_3; include/sync_with_master_gtid.inc SET GLOBAL debug_dbug=@old_dbug; SELECT * FROM t1 WHERE a >= 30 ORDER BY a; @@ -382,6 +422,7 @@ a SET GLOBAL slave_exec_mode=@old_slave_mode; SET GLOBAL gtid_strict_mode=@old_strict; *** MDEV-8496: gtid_ignore_duplicates treats gtid_seq_no as 32-bit *** +connection server_1; SET @old_domain= @@SESSION.gtid_domain_id; SET SESSION gtid_domain_id=102; SET SESSION gtid_seq_no=4294967294; @@ -390,12 +431,14 @@ INSERT INTO t1 VALUES (61); INSERT INTO t1 VALUES (62); SET SESSION gtid_domain_id= @old_domain; include/save_master_gtid.inc +connection server_4; include/sync_with_master_gtid.inc SELECT * FROM t1 WHERE a >= 60 ORDER BY a; a 60 61 62 +connection server_2; SET default_master_connection = "c2b"; include/sync_with_master_gtid.inc SET default_master_connection = "a2b"; @@ -405,6 +448,7 @@ a 60 61 62 +connection server_3; SET default_master_connection = "b2c"; include/sync_with_master_gtid.inc SET default_master_connection = "a2c"; @@ -414,6 +458,7 @@ a 60 61 62 +connection server_1; SET GLOBAL gtid_domain_id=0; STOP ALL SLAVES; Warnings: @@ -421,6 +466,7 @@ Note 1938 SLAVE 'b2a' stopped Note 1938 SLAVE 'c2a' stopped SET GLOBAL slave_parallel_threads= @old_parallel; SET GLOBAL gtid_ignore_duplicates= @old_ignore_duplicates; +connection server_2; SET GLOBAL gtid_domain_id=0; STOP ALL SLAVES; Warnings: @@ -428,6 +474,7 @@ Note 1938 SLAVE 'a2b' stopped Note 1938 SLAVE 'c2b' stopped SET GLOBAL slave_parallel_threads= @old_parallel; SET GLOBAL gtid_ignore_duplicates= @old_ignore_duplicates; +connection server_3; SET GLOBAL gtid_domain_id=0; STOP ALL SLAVES; Warnings: @@ -435,17 +482,26 @@ Note 1938 SLAVE 'a2c' stopped Note 1938 SLAVE 'b2c' stopped SET GLOBAL slave_parallel_threads= @old_parallel; SET GLOBAL gtid_ignore_duplicates= @old_ignore_duplicates; +connection server_4; SET GLOBAL gtid_domain_id=0; STOP ALL SLAVES; Warnings: Note 1938 SLAVE 'a2d' stopped SET GLOBAL slave_parallel_threads= @old_parallel; SET GLOBAL gtid_ignore_duplicates= @old_ignore_duplicates; +connection server_1; DROP TABLE t1; include/reset_master_slave.inc +disconnect server_1; +connection server_2; DROP TABLE t1; include/reset_master_slave.inc +disconnect server_2; +connection server_3; DROP TABLE t1; include/reset_master_slave.inc +disconnect server_3; +connection server_4; DROP TABLE t1; include/reset_master_slave.inc +disconnect server_4; |