mirror of
https://github.com/MariaDB/server.git
synced 2025-01-23 15:24:16 +01:00
8d9cf89e96
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. mysql-test/extra/binlog_tests/blackhole.test: Blackhole now handles row-based replication. mysql-test/extra/rpl_tests/rpl_blackhole.test: Test helper file for testing that blackhole actually writes something to the binary log on the slave. mysql-test/suite/binlog/t/binlog_multi_engine.test: Replication now handles row-based replcation. mysql-test/suite/rpl/t/rpl_blackhole.test: Test that Blackhole works with primary key, index, or none. sql/log_event.cc: Correcting code to only touch filler bits and leave all other bits alone. It is necessary since there is no guarantee that the engine will be able to fill in the bits correctly (e.g., the blackhole engine). storage/blackhole/ha_blackhole.cc: Adding definitions for update_row() and delete_row() to return OK when executed from the slave SQL thread with thd->query == NULL (indicating that row-based replication events are being processed). Changing rnd_next(), index_read(), index_read_idx(), and index_read_last() to return OK when executed from the slave SQL thread (faking that the row has been found so that processing proceeds to update/delete the row). storage/blackhole/ha_blackhole.h: Enabling row capabilities for engine. Defining write_row(), update_row(), and delete_row(). Making write_row() private (as it should be).
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 <<<
|