1SET SESSION TRANSACTION ISOLATION LEVEL READ COMMITTED; 2connect con1, localhost, root,,; 3SET SESSION TRANSACTION ISOLATION LEVEL READ COMMITTED; 4connection default; 5CREATE TABLE t1(c1 VARCHAR(10) NOT NULL, c2 VARCHAR(10) NOT NULL, c3 VARCHAR(10) NOT NULL); 6INSERT INTO t1(c1, c2, c3) VALUES('A1','B1','IT1'), ('A2','B2','IT1'), ('A3','B3','IT1'), ('A4','B4','IT1'), ('A5','B5','IT1'), ('A6','B6','IT1'), ('A7','B7','IT1'); 7CREATE TABLE t2(c1 VARCHAR(10) NOT NULL, c2 VARCHAR(10) NOT NULL, c3 VARCHAR(10) NOT NULL); 8INSERT INTO t2(c1, c2, c3) VALUES ('A3','B3','IT2'), ('A2','B2','IT2'), ('A4','B4','IT2'), ('A5','B5','II2'); 9CREATE TABLE result(id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT, c1 VARCHAR(10) NOT NULL, c2 VARCHAR(10), 10c3 VARCHAR(10), update_count INT DEFAULT 0, UNIQUE KEY uniq_idx (c1,c2), PRIMARY KEY (id)) ENGINE = innodb; 11SET DEBUG_SYNC = "ha_write_row_end WAIT_FOR flushed EXECUTE 1"; 12INSERT INTO result(c1, c2, c3) SELECT * FROM t1 ON DUPLICATE KEY UPDATE c2=t1.c2, c3='UT1', update_count=update_count+1; 13connection con1; 14INSERT INTO result(c1, c2, c3) SELECT * FROM t2 ON DUPLICATE KEY UPDATE c2=t2.c2, c3='UT2', update_count=update_count+1; 15SET DEBUG_SYNC = "now SIGNAL flushed"; 16connection default; 17SELECT * FROM result; 18id c1 c2 c3 update_count 191 A1 B1 IT1 0 202 A3 B3 UT1 1 213 A2 B2 UT1 1 224 A4 B4 UT1 1 235 A5 B5 UT1 1 249 A6 B6 IT1 0 2510 A7 B7 IT1 0 26DROP TABLE t1; 27DROP TABLE t2; 28DROP TABLE result; 29SET DEBUG_SYNC = "RESET"; 30