mirror of
https://github.com/MariaDB/server.git
synced 2025-08-07 00:04:31 +03:00
This reverts commit c37b2087b4
.
In c37b20887, when re-binlogging a GTID event on a replica,
it will overwrite the thread_id from the primary to be the
value of the slave applier (SQL thread or parallel worker).
This should be the value of the original thread_id on the
master connection though, to both help track temporary
tables, and be consistent with Query_log_event.
Reverting the commit to re-target 11.5, so we can re-test
with the corrected thread_id.
109 lines
5.2 KiB
Plaintext
109 lines
5.2 KiB
Plaintext
RESET MASTER;
|
|
CREATE TABLE t1 (a INT PRIMARY KEY, b INT) ENGINE=InnoDB;
|
|
/* GTID */ INSERT INTO t1 VALUES (1,0);
|
|
/* GTID */ BEGIN;
|
|
/* GTID */ INSERT INTO t1 VALUES (2,0);
|
|
/* GTID */ ALTER TABLE t1 ADD c INT;
|
|
/* GTID */ INSERT INTO t1 VALUES (3,0,0);
|
|
/* GTID */ COMMIT;
|
|
/* GTID */ BEGIN;
|
|
/* GTID */ UPDATE t1 SET b=1, c=1 WHERE a=2;
|
|
/* GTID */ CREATE TEMPORARY TABLE t2 (a INT PRIMARY KEY, b INT) ENGINE=InnoDB;
|
|
/* GTID */ INSERT INTO t2 VALUES (4,10), (5,20);
|
|
/* GTID */ INSERT INTO t1 SELECT a, 2, b FROM t2;
|
|
/* GTID */ DROP TEMPORARY TABLE t2;
|
|
/* GTID */ INSERT INTO t1 VALUES (6, 3, 0);
|
|
/* GTID */ COMMIT;
|
|
/* GTID */ CREATE TEMPORARY TABLE t3 (a INT PRIMARY KEY) ENGINE=InnoDB;
|
|
/* GTID */ BEGIN;
|
|
/* GTID */ DELETE FROM t1 WHERE a=5;
|
|
/* GTID */ INSERT INTO t3 VALUES (7);
|
|
/* GTID */ INSERT INTO t1 SELECT a, 4, 0 FROM t3;
|
|
/* GTID */ UPDATE t1 SET c=1 WHERE a=7;
|
|
/* GTID */ DROP TEMPORARY TABLE t3;
|
|
/* GTID */ COMMIT;
|
|
/* GTID */ CREATE TEMPORARY TABLE t4 (a INT PRIMARY KEY) ENGINE=InnoDB;
|
|
/* GTID */ BEGIN;
|
|
/* GTID */ INSERT INTO t1 VALUES (8, 5, 0);
|
|
/* GTID */ ALTER TABLE t4 ADD b INT;
|
|
/* GTID */ INSERT INTO t1 VALUES (9, 5, 1);
|
|
/* GTID */ COMMIT;
|
|
connect tmp_con,localhost,root,,;
|
|
/* GTID */ INSERT INTO t1 VALUES (10, 6, 0);
|
|
/* GTID */ BEGIN;
|
|
/* GTID */ CREATE TEMPORARY TABLE t5 (a INT PRIMARY KEY) ENGINE=InnoDB;
|
|
/* GTID */ INSERT INTO t1 VALUES (11, 7, 0);
|
|
/* GTID */ COMMIT;
|
|
disconnect tmp_con;
|
|
connection default;
|
|
FLUSH LOGS;
|
|
# server id 1 end_log_pos # CRC32 0x######## GTID #-#-# trans
|
|
START TRANSACTION
|
|
#Q> /* GTID */ INSERT INTO t1 VALUES (1,0)
|
|
# server id 1 end_log_pos # CRC32 0x######## Table_map: `test`.`t1` mapped to number #
|
|
# server id 1 end_log_pos # CRC32 0x######## Write_rows: table id # flags: STMT_END_F
|
|
COMMIT/*!*/;
|
|
# server id 1 end_log_pos # CRC32 0x######## GTID #-#-# trans
|
|
START TRANSACTION
|
|
#Q> /* GTID */ INSERT INTO t1 VALUES (2,0)
|
|
# server id 1 end_log_pos # CRC32 0x######## Table_map: `test`.`t1` mapped to number #
|
|
# server id 1 end_log_pos # CRC32 0x######## Write_rows: table id # flags: STMT_END_F
|
|
COMMIT/*!*/;
|
|
# server id 1 end_log_pos # CRC32 0x######## GTID #-#-# ddl
|
|
/* GTID */ ALTER TABLE t1 ADD c INT
|
|
# server id 1 end_log_pos # CRC32 0x######## GTID #-#-# trans
|
|
START TRANSACTION
|
|
#Q> /* GTID */ INSERT INTO t1 VALUES (3,0,0)
|
|
# server id 1 end_log_pos # CRC32 0x######## Table_map: `test`.`t1` mapped to number #
|
|
# server id 1 end_log_pos # CRC32 0x######## Write_rows: table id # flags: STMT_END_F
|
|
COMMIT/*!*/;
|
|
# server id 1 end_log_pos # CRC32 0x######## GTID #-#-# trans
|
|
START TRANSACTION
|
|
#Q> /* GTID */ UPDATE t1 SET b=1, c=1 WHERE a=2
|
|
# server id 1 end_log_pos # CRC32 0x######## Table_map: `test`.`t1` mapped to number #
|
|
# server id 1 end_log_pos # CRC32 0x######## Update_rows: table id # flags: STMT_END_F
|
|
#Q> /* GTID */ INSERT INTO t1 SELECT a, 2, b FROM t2
|
|
# server id 1 end_log_pos # CRC32 0x######## Table_map: `test`.`t1` mapped to number #
|
|
# server id 1 end_log_pos # CRC32 0x######## Write_rows: table id # flags: STMT_END_F
|
|
#Q> /* GTID */ INSERT INTO t1 VALUES (6, 3, 0)
|
|
# server id 1 end_log_pos # CRC32 0x######## Table_map: `test`.`t1` mapped to number #
|
|
# server id 1 end_log_pos # CRC32 0x######## Write_rows: table id # flags: STMT_END_F
|
|
COMMIT/*!*/;
|
|
# server id 1 end_log_pos # CRC32 0x######## GTID #-#-# trans
|
|
START TRANSACTION
|
|
#Q> /* GTID */ DELETE FROM t1 WHERE a=5
|
|
# server id 1 end_log_pos # CRC32 0x######## Table_map: `test`.`t1` mapped to number #
|
|
# server id 1 end_log_pos # CRC32 0x######## Delete_rows: table id # flags: STMT_END_F
|
|
#Q> /* GTID */ INSERT INTO t1 SELECT a, 4, 0 FROM t3
|
|
# server id 1 end_log_pos # CRC32 0x######## Table_map: `test`.`t1` mapped to number #
|
|
# server id 1 end_log_pos # CRC32 0x######## Write_rows: table id # flags: STMT_END_F
|
|
#Q> /* GTID */ UPDATE t1 SET c=1 WHERE a=7
|
|
# server id 1 end_log_pos # CRC32 0x######## Table_map: `test`.`t1` mapped to number #
|
|
# server id 1 end_log_pos # CRC32 0x######## Update_rows: table id # flags: STMT_END_F
|
|
COMMIT/*!*/;
|
|
# server id 1 end_log_pos # CRC32 0x######## GTID #-#-# trans
|
|
START TRANSACTION
|
|
#Q> /* GTID */ INSERT INTO t1 VALUES (8, 5, 0)
|
|
# server id 1 end_log_pos # CRC32 0x######## Table_map: `test`.`t1` mapped to number #
|
|
# server id 1 end_log_pos # CRC32 0x######## Write_rows: table id # flags: STMT_END_F
|
|
COMMIT/*!*/;
|
|
# server id 1 end_log_pos # CRC32 0x######## GTID #-#-# trans
|
|
START TRANSACTION
|
|
#Q> /* GTID */ INSERT INTO t1 VALUES (9, 5, 1)
|
|
# server id 1 end_log_pos # CRC32 0x######## Table_map: `test`.`t1` mapped to number #
|
|
# server id 1 end_log_pos # CRC32 0x######## Write_rows: table id # flags: STMT_END_F
|
|
COMMIT/*!*/;
|
|
# server id 1 end_log_pos # CRC32 0x######## GTID #-#-# trans
|
|
START TRANSACTION
|
|
#Q> /* GTID */ INSERT INTO t1 VALUES (10, 6, 0)
|
|
# server id 1 end_log_pos # CRC32 0x######## Table_map: `test`.`t1` mapped to number #
|
|
# server id 1 end_log_pos # CRC32 0x######## Write_rows: table id # flags: STMT_END_F
|
|
COMMIT/*!*/;
|
|
# server id 1 end_log_pos # CRC32 0x######## GTID #-#-# trans
|
|
START TRANSACTION
|
|
#Q> /* GTID */ INSERT INTO t1 VALUES (11, 7, 0)
|
|
# server id 1 end_log_pos # CRC32 0x######## Table_map: `test`.`t1` mapped to number #
|
|
# server id 1 end_log_pos # CRC32 0x######## Write_rows: table id # flags: STMT_END_F
|
|
COMMIT/*!*/;
|
|
DROP TABLE t1;
|