2008-10-02 21:13:15 +02:00
|
|
|
# PURPOSE. Test that blackhole works with replication in all three
|
|
|
|
# modes: STATEMENT, MIXED, and ROW.
|
|
|
|
#
|
|
|
|
# METHOD. We start by creating a table on the master and then change
|
Bug #38360: BLACKHOLE replication with RBR is broken
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).
2008-10-02 11:02:38 +02:00
|
|
|
# the engine to use blackhole on the slave.
|
2008-10-02 21:13:15 +02:00
|
|
|
#
|
|
|
|
# After insert/update/delete of one or more rows, the test the
|
|
|
|
# proceeds to check that replication is running after replicating an
|
|
|
|
# change, that the blackhole engine does not contain anything (which
|
|
|
|
# is just a check that the correct engine is used), and that something
|
|
|
|
# is written to the binary log.
|
|
|
|
#
|
|
|
|
# Whe check INSERT, UPDATE, and DELETE statement for tables with no
|
|
|
|
# key (forcing a range search on the slave), primary keys (using a
|
|
|
|
# primary key lookup), and index/key with multiple matches (forcing an
|
|
|
|
# index search).
|
Bug #38360: BLACKHOLE replication with RBR is broken
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).
2008-10-02 11:02:38 +02:00
|
|
|
|
2008-10-03 12:52:01 +02:00
|
|
|
source include/master-slave.inc;
|
|
|
|
source include/have_blackhole.inc;
|
|
|
|
|
Bug #38360: BLACKHOLE replication with RBR is broken
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).
2008-10-02 11:02:38 +02:00
|
|
|
# We start with no primary key
|
|
|
|
CREATE TABLE t1 (a INT, b INT, c INT);
|
|
|
|
CREATE TABLE t2 (a INT, b INT, c INT);
|
|
|
|
|
|
|
|
sync_slave_with_master;
|
|
|
|
ALTER TABLE t1 ENGINE=BLACKHOLE;
|
|
|
|
|
|
|
|
connection master;
|
|
|
|
INSERT INTO t2 VALUES (1,9,1), (2,9,2), (3,9,3), (4,9,4);
|
|
|
|
sync_slave_with_master;
|
|
|
|
|
|
|
|
# Test insert, no primary key
|
|
|
|
let $statement = INSERT INTO t1 VALUES (1,1,1),(2,1,2),(3,1,3),(4,1,4);
|
|
|
|
source extra/rpl_tests/rpl_blackhole.test;
|
|
|
|
|
|
|
|
# Test update, no primary key
|
|
|
|
let $statement = UPDATE t1 SET c = 2*c WHERE a % 2 = 0 AND b = 1;
|
|
|
|
source extra/rpl_tests/rpl_blackhole.test;
|
|
|
|
|
|
|
|
# Test delete, no primary key
|
|
|
|
let $statement = DELETE FROM t1 WHERE a % 2 = 0 AND b = 1;
|
|
|
|
source extra/rpl_tests/rpl_blackhole.test;
|
|
|
|
|
|
|
|
# Test INSERT-SELECT into Blackhole, no primary key
|
|
|
|
let $statement = INSERT INTO t1 SELECT * FROM t2;
|
|
|
|
source extra/rpl_tests/rpl_blackhole.test;
|
|
|
|
|
|
|
|
# Test INSERT-SELECT from Blackhole, no primary key
|
|
|
|
let $statement = INSERT INTO t2 SELECT * FROM t1;
|
|
|
|
source extra/rpl_tests/rpl_blackhole.test;
|
|
|
|
|
|
|
|
connection master;
|
|
|
|
ALTER TABLE t1 ADD PRIMARY KEY pk_t1 (a,b);
|
|
|
|
|
|
|
|
# Test insert, primary key
|
|
|
|
let $statement = INSERT INTO t1 VALUES (1,2,1),(2,2,2),(3,2,3),(4,2,4);
|
|
|
|
source extra/rpl_tests/rpl_blackhole.test;
|
|
|
|
|
|
|
|
# Test update, primary key
|
|
|
|
let $statement = UPDATE t1 SET c = 2*c WHERE a % 2 = 0 AND b = 2;
|
|
|
|
source extra/rpl_tests/rpl_blackhole.test;
|
|
|
|
|
|
|
|
# Test delete, primary key
|
|
|
|
let $statement = DELETE FROM t1 WHERE a % 2 = 0 AND b = 2;
|
|
|
|
source extra/rpl_tests/rpl_blackhole.test;
|
|
|
|
|
|
|
|
connection master;
|
|
|
|
ALTER TABLE t1 DROP PRIMARY KEY, ADD KEY key_t1 (a);
|
|
|
|
|
|
|
|
# Test insert, key
|
|
|
|
let $statement = INSERT INTO t1 VALUES (1,3,1),(2,3,2),(3,3,3),(4,3,4);
|
|
|
|
source extra/rpl_tests/rpl_blackhole.test;
|
|
|
|
|
|
|
|
# Test update, key
|
|
|
|
let $statement = UPDATE t1 SET c = 2*c WHERE a % 2 = 0 AND b = 3;
|
|
|
|
source extra/rpl_tests/rpl_blackhole.test;
|
|
|
|
|
|
|
|
# Test delete, key
|
|
|
|
let $statement = DELETE FROM t1 WHERE a % 2 = 0 AND b = 3;
|
|
|
|
source extra/rpl_tests/rpl_blackhole.test;
|