mirror of
https://github.com/MariaDB/server.git
synced 2025-01-17 20:42:30 +01:00
150590a0bc
Complementary patch since LOAD DATA INFILE was not covered in the previous patch. This patch adds a check so that the slave skip counter is not decreased to zero if seeing a BEGIN_LOAD_QUERY_EVENT, APPEND_BLOCK_EVENT, or CREATE_FILE_EVENT since these cannot end a group. The group is terminated by an EXECUTE_LOAD_QUERY_ EVENT or DELETE_FILE_EVENT. mysql-test/r/rpl_slave_skip.result: Result change. mysql-test/t/rpl_slave_skip.test: Adding tests to test that the first event of a LOAD DATA INFILE can be skipped safely for both transactional and non-transactional tables. Also include a case that will generate a DELETE_FILE event last in the group, and this should be properly skipped as well. sql/slave.cc: Not decrementing slave skip counter to zero when seeing a BEGIN_LOAD_QUERY_EVENT, APPEND_BLOCK_EVENT, or CREATE_FILE_EVENT since these cannot end a group.
242 lines
6 KiB
Text
242 lines
6 KiB
Text
stop slave;
|
|
drop table if exists t1,t2,t3,t4,t5,t6,t7,t8,t9;
|
|
reset master;
|
|
reset slave;
|
|
drop table if exists t1,t2,t3,t4,t5,t6,t7,t8,t9;
|
|
start slave;
|
|
**** On Master ****
|
|
CREATE TABLE t1 (a INT, b SET('master','slave')) ENGINE=InnoDB;
|
|
CREATE TABLE t2 (a INT, b SET('master','slave')) ENGINE=MyISAM;
|
|
CREATE TABLE t3 (a CHAR(20), b SET('master','slave')) ENGINE=InnoDB;
|
|
CREATE TABLE t4 (a CHAR(20), b SET('master','slave')) ENGINE=MyISAM;
|
|
==== Skipping normal transactions ====
|
|
**** On Slave ****
|
|
STOP SLAVE;
|
|
**** On Master ****
|
|
BEGIN;
|
|
INSERT INTO t1 VALUES (1, 'master');
|
|
INSERT INTO t1 VALUES (2, 'master');
|
|
INSERT INTO t1 VALUES (3, 'master');
|
|
COMMIT;
|
|
BEGIN;
|
|
INSERT INTO t1 VALUES (4, 'master,slave');
|
|
INSERT INTO t1 VALUES (5, 'master,slave');
|
|
INSERT INTO t1 VALUES (6, 'master,slave');
|
|
COMMIT;
|
|
SELECT * FROM t1 ORDER BY a;
|
|
a b
|
|
1 master
|
|
2 master
|
|
3 master
|
|
4 master,slave
|
|
5 master,slave
|
|
6 master,slave
|
|
**** On Slave ****
|
|
SET GLOBAL SQL_SLAVE_SKIP_COUNTER=2;
|
|
START SLAVE;
|
|
SELECT * FROM t1 ORDER BY a;
|
|
a b
|
|
4 master,slave
|
|
5 master,slave
|
|
6 master,slave
|
|
**** On Master ****
|
|
DELETE FROM t1;
|
|
==== Skipping two normal transactions ====
|
|
**** On Slave ****
|
|
STOP SLAVE;
|
|
**** On Master ****
|
|
BEGIN;
|
|
INSERT INTO t1 VALUES (1, 'master');
|
|
INSERT INTO t1 VALUES (2, 'master');
|
|
INSERT INTO t1 VALUES (3, 'master');
|
|
COMMIT;
|
|
BEGIN;
|
|
INSERT INTO t1 VALUES (4, 'master');
|
|
INSERT INTO t1 VALUES (5, 'master');
|
|
INSERT INTO t1 VALUES (6, 'master');
|
|
COMMIT;
|
|
BEGIN;
|
|
INSERT INTO t1 VALUES (7, 'master,slave');
|
|
INSERT INTO t1 VALUES (8, 'master,slave');
|
|
INSERT INTO t1 VALUES (9, 'master,slave');
|
|
COMMIT;
|
|
SELECT * FROM t1 ORDER BY a;
|
|
a b
|
|
1 master
|
|
2 master
|
|
3 master
|
|
4 master
|
|
5 master
|
|
6 master
|
|
7 master,slave
|
|
8 master,slave
|
|
9 master,slave
|
|
**** On Slave ****
|
|
SET GLOBAL SQL_SLAVE_SKIP_COUNTER=8;
|
|
START SLAVE;
|
|
SELECT * FROM t1 ORDER BY a;
|
|
a b
|
|
7 master,slave
|
|
8 master,slave
|
|
9 master,slave
|
|
**** On Master ****
|
|
DELETE FROM t1;
|
|
==== Skipping without autocommit ====
|
|
**** On Slave ****
|
|
STOP SLAVE;
|
|
**** On Master ****
|
|
SET AUTOCOMMIT=0;
|
|
INSERT INTO t1 VALUES (1, 'master');
|
|
INSERT INTO t1 VALUES (2, 'master');
|
|
INSERT INTO t1 VALUES (3, 'master');
|
|
COMMIT;
|
|
INSERT INTO t1 VALUES (4, 'master,slave');
|
|
INSERT INTO t1 VALUES (5, 'master,slave');
|
|
INSERT INTO t1 VALUES (6, 'master,slave');
|
|
COMMIT;
|
|
SELECT * FROM t1 ORDER BY a;
|
|
a b
|
|
1 master
|
|
2 master
|
|
3 master
|
|
4 master,slave
|
|
5 master,slave
|
|
6 master,slave
|
|
**** On Slave ****
|
|
SET GLOBAL SQL_SLAVE_SKIP_COUNTER=2;
|
|
START SLAVE;
|
|
SELECT * FROM t1 ORDER BY a;
|
|
a b
|
|
4 master,slave
|
|
5 master,slave
|
|
6 master,slave
|
|
==== Rollback of transaction with non-transactional change ====
|
|
**** On Master ****
|
|
DELETE FROM t1;
|
|
SET AUTOCOMMIT=1;
|
|
**** On Slave ****
|
|
STOP SLAVE;
|
|
**** On Master ****
|
|
BEGIN;
|
|
INSERT INTO t1 VALUES (1, '');
|
|
INSERT INTO t2 VALUES (2, 'master');
|
|
INSERT INTO t1 VALUES (3, '');
|
|
ROLLBACK;
|
|
BEGIN;
|
|
INSERT INTO t1 VALUES (4, '');
|
|
INSERT INTO t2 VALUES (5, 'master,slave');
|
|
INSERT INTO t1 VALUES (6, '');
|
|
ROLLBACK;
|
|
SELECT * FROM t1 ORDER BY a;
|
|
a b
|
|
SELECT * FROM t2 ORDER BY a;
|
|
a b
|
|
2 master
|
|
5 master,slave
|
|
**** On Slave ****
|
|
SET GLOBAL SQL_SLAVE_SKIP_COUNTER=2;
|
|
START SLAVE;
|
|
SELECT * FROM t1 ORDER BY a;
|
|
a b
|
|
SELECT * FROM t2 ORDER BY a;
|
|
a b
|
|
5 master,slave
|
|
==== Skipping first event of a LOAD DATA for a transactional table ====
|
|
**** On Slave ****
|
|
STOP SLAVE;
|
|
**** On Master ****
|
|
SET AUTOCOMMIT=1;
|
|
LOAD DATA INFILE '../std_data_ln/words.dat' INTO TABLE t3(a) SET b = 'master';
|
|
INSERT INTO t3 VALUES ('Go Rin No Sho', 'master,slave');
|
|
SELECT COUNT(*) FROM t3;
|
|
COUNT(*)
|
|
71
|
|
**** On Slave ****
|
|
SET GLOBAL SQL_SLAVE_SKIP_COUNTER=1;
|
|
START SLAVE;
|
|
-- Should only contain records marked 'master,slave'
|
|
SELECT * FROM t3 ORDER BY a;
|
|
a b
|
|
Go Rin No Sho master,slave
|
|
**** On Master ****
|
|
DELETE FROM t3;
|
|
==== Skipping first event of a LOAD DATA for a non-transactional table ====
|
|
**** On Slave ****
|
|
STOP SLAVE;
|
|
**** On Master ****
|
|
SET AUTOCOMMIT=1;
|
|
LOAD DATA INFILE '../std_data_ln/words.dat' INTO TABLE t4(a) SET b = 'master';
|
|
INSERT INTO t4 VALUES ('Go Rin No Sho', 'master,slave');
|
|
SELECT COUNT(*) FROM t4;
|
|
COUNT(*)
|
|
71
|
|
**** On Slave ****
|
|
SET GLOBAL SQL_SLAVE_SKIP_COUNTER=1;
|
|
START SLAVE;
|
|
-- Should only contain records marked 'master,slave'
|
|
SELECT * FROM t4 ORDER BY a;
|
|
a b
|
|
Go Rin No Sho master,slave
|
|
**** On Master ****
|
|
DELETE FROM t4;
|
|
==== Try with a big file so that we get an append_block event as well
|
|
**** On Slave ****
|
|
STOP SLAVE;
|
|
**** On Master ****
|
|
SET AUTOCOMMIT=1;
|
|
SET SQL_LOG_BIN=0;
|
|
LOAD DATA INFILE '../std_data_ln/words.dat' INTO TABLE t4(a) SET b = 'master';
|
|
INSERT INTO t4 SELECT * FROM t4;
|
|
INSERT INTO t4 SELECT * FROM t4;
|
|
INSERT INTO t4 SELECT * FROM t4;
|
|
INSERT INTO t4 SELECT * FROM t4;
|
|
INSERT INTO t4 SELECT * FROM t4;
|
|
INSERT INTO t4 SELECT * FROM t4;
|
|
INSERT INTO t4 SELECT * FROM t4;
|
|
INSERT INTO t4 SELECT * FROM t4;
|
|
INSERT INTO t4 SELECT * FROM t4;
|
|
INSERT INTO t4 SELECT * FROM t4;
|
|
INSERT INTO t4 SELECT * FROM t4;
|
|
SELECT a FROM t4 INTO OUTFILE 'rpl_slave_skip_words.dat';
|
|
SET SQL_LOG_BIN=1;
|
|
LOAD DATA INFILE 'rpl_slave_skip_words.dat' INTO TABLE t4(a) SET b = 'master';
|
|
INSERT INTO t4 VALUES ('Go Rin No Sho', 'master,slave');
|
|
SELECT COUNT(*) FROM t4;
|
|
COUNT(*)
|
|
286721
|
|
**** On Slave ****
|
|
SET GLOBAL SQL_SLAVE_SKIP_COUNTER=1;
|
|
START SLAVE;
|
|
-- Should only contain records marked 'master,slave'
|
|
SELECT * FROM t4 ORDER BY a;
|
|
a b
|
|
Go Rin No Sho master,slave
|
|
**** On Master ****
|
|
DELETE FROM t4;
|
|
**** On Master ****
|
|
CREATE TABLE t5 (a int, b int, c SET('master','slave'), PRIMARY KEY (a,b)) ENGINE=MyISAM;
|
|
LOAD DATA INFILE '../std_data_ln/loaddata5.dat' INTO TABLE t5 FIELDS TERMINATED BY '' ENCLOSED BY '' (a,b) SET c='master,slave';
|
|
**** On Slave ****
|
|
STOP SLAVE;
|
|
**** On Master ****
|
|
LOAD DATA INFILE '../std_data_ln/loaddata5.dat' INTO TABLE t5 FIELDS TERMINATED BY '' ENCLOSED BY '' (a,b) SET c='';
|
|
ERROR 23000: Duplicate entry '1-2' for key 1
|
|
INSERT INTO t5 VALUES (42, 42, 'master,slave');
|
|
SELECT * FROM t5;
|
|
a b c
|
|
1 2 master,slave
|
|
3 4 master,slave
|
|
5 6 master,slave
|
|
42 42 master,slave
|
|
**** On Slave ****
|
|
SET GLOBAL SQL_SLAVE_SKIP_COUNTER=1;
|
|
START SLAVE;
|
|
SELECT * FROM t5;
|
|
a b c
|
|
1 2 master,slave
|
|
3 4 master,slave
|
|
5 6 master,slave
|
|
42 42 master,slave
|
|
==== Cleanup ====
|
|
**** On Master ****
|
|
DROP TABLE t1, t2, t3, t4, t5;
|