mirror of
https://github.com/MariaDB/server.git
synced 2025-01-22 14:54:20 +01:00
43fb8633b0
The Blackhole engine did not support row-based replication since the delete_row(), update_row(), and the index and range searching functions were not implemented. This patch adds row-based replication support for the Blackhole engine by implementing the two functions mentioned above, and making the engine pretend that it has found the correct row to delete or update when executed from the slave SQL thread by implementing index and range searching functions. It is necessary to only pretend this for the SQL thread, since a SELECT executed on the Blackhole engine will otherwise never return EOF, causing a livelock.
100 lines
2.1 KiB
Text
100 lines
2.1 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;
|
|
CREATE TABLE t1 (a INT, b INT, c INT);
|
|
CREATE TABLE t2 (a INT, b INT, c INT);
|
|
ALTER TABLE t1 ENGINE=BLACKHOLE;
|
|
INSERT INTO t2 VALUES (1,9,1), (2,9,2), (3,9,3), (4,9,4);
|
|
[on master]
|
|
INSERT INTO t1 VALUES (1,1,1),(2,1,2),(3,1,3),(4,1,4);
|
|
[on slave]
|
|
# Expect 0
|
|
SELECT COUNT(*) FROM t1;
|
|
COUNT(*)
|
|
0
|
|
>>> Something was written to binary log <<<
|
|
[on master]
|
|
UPDATE t1 SET c = 2*c WHERE a % 2 = 0 AND b = 1;
|
|
[on slave]
|
|
# Expect 0
|
|
SELECT COUNT(*) FROM t1;
|
|
COUNT(*)
|
|
0
|
|
>>> Something was written to binary log <<<
|
|
[on master]
|
|
DELETE FROM t1 WHERE a % 2 = 0 AND b = 1;
|
|
[on slave]
|
|
# Expect 0
|
|
SELECT COUNT(*) FROM t1;
|
|
COUNT(*)
|
|
0
|
|
>>> Something was written to binary log <<<
|
|
[on master]
|
|
INSERT INTO t1 SELECT * FROM t2;
|
|
[on slave]
|
|
# Expect 0
|
|
SELECT COUNT(*) FROM t1;
|
|
COUNT(*)
|
|
0
|
|
>>> Something was written to binary log <<<
|
|
[on master]
|
|
INSERT INTO t2 SELECT * FROM t1;
|
|
[on slave]
|
|
# Expect 0
|
|
SELECT COUNT(*) FROM t1;
|
|
COUNT(*)
|
|
0
|
|
>>> Something was written to binary log <<<
|
|
ALTER TABLE t1 ADD PRIMARY KEY pk_t1 (a,b);
|
|
[on master]
|
|
INSERT INTO t1 VALUES (1,2,1),(2,2,2),(3,2,3),(4,2,4);
|
|
[on slave]
|
|
# Expect 0
|
|
SELECT COUNT(*) FROM t1;
|
|
COUNT(*)
|
|
0
|
|
>>> Something was written to binary log <<<
|
|
[on master]
|
|
UPDATE t1 SET c = 2*c WHERE a % 2 = 0 AND b = 2;
|
|
[on slave]
|
|
# Expect 0
|
|
SELECT COUNT(*) FROM t1;
|
|
COUNT(*)
|
|
0
|
|
>>> Something was written to binary log <<<
|
|
[on master]
|
|
DELETE FROM t1 WHERE a % 2 = 0 AND b = 2;
|
|
[on slave]
|
|
# Expect 0
|
|
SELECT COUNT(*) FROM t1;
|
|
COUNT(*)
|
|
0
|
|
>>> Something was written to binary log <<<
|
|
ALTER TABLE t1 DROP PRIMARY KEY, ADD KEY key_t1 (a);
|
|
[on master]
|
|
INSERT INTO t1 VALUES (1,3,1),(2,3,2),(3,3,3),(4,3,4);
|
|
[on slave]
|
|
# Expect 0
|
|
SELECT COUNT(*) FROM t1;
|
|
COUNT(*)
|
|
0
|
|
>>> Something was written to binary log <<<
|
|
[on master]
|
|
UPDATE t1 SET c = 2*c WHERE a % 2 = 0 AND b = 3;
|
|
[on slave]
|
|
# Expect 0
|
|
SELECT COUNT(*) FROM t1;
|
|
COUNT(*)
|
|
0
|
|
>>> Something was written to binary log <<<
|
|
[on master]
|
|
DELETE FROM t1 WHERE a % 2 = 0 AND b = 3;
|
|
[on slave]
|
|
# Expect 0
|
|
SELECT COUNT(*) FROM t1;
|
|
COUNT(*)
|
|
0
|
|
>>> Something was written to binary log <<<
|