mirror of
https://github.com/MariaDB/server.git
synced 2025-01-22 06:44:16 +01:00
d8d6db6f78
without PK Bug#31609 Not all RBR slave errors reported as errors bug#32468 delete rows event on a table with foreign key constraint fails The first two bugs comprise idempotency issues. First, there was no error code reported under conditions of the bug description although the slave sql thread halted. Second, executions were different with and without presence of prim key in the table. Third, there was no way to instruct the slave whether to ignore an error and skip to the following event or to halt. Fourth, there are handler errors which might happen due to idempotent applying of binlog but those were not listed among the "idempotent" error list. All the named issues are addressed. Wrt to the 3rd, there is the new global system variable, changeble at run time, which controls the slave sql thread behaviour. The new variable allows further extensions to mimic the sql_mode session/global variable. To address the 4th, the new bug#32468 had to be fixed as it was staying in the way.
411 lines
10 KiB
Text
411 lines
10 KiB
Text
# Testing various forms of idempotency for replication that should
|
|
# work the same way under statement based as under row based.
|
|
|
|
source include/master-slave.inc;
|
|
|
|
connection master;
|
|
CREATE TABLE t1 (a INT PRIMARY KEY);
|
|
CREATE TABLE t2 (a INT);
|
|
INSERT INTO t1 VALUES (-1),(-2),(-3);
|
|
INSERT INTO t2 VALUES (-1),(-2),(-3);
|
|
sync_slave_with_master;
|
|
|
|
# A delete for a row that does not exist, the statement is
|
|
# deliberately written to be idempotent for statement-based
|
|
# replication as well. We test this towards both a table with a
|
|
# primary key and without a primary key.
|
|
|
|
connection slave;
|
|
DELETE FROM t1 WHERE a = -2;
|
|
DELETE FROM t2 WHERE a = -2;
|
|
connection master;
|
|
DELETE FROM t1 WHERE a = -2;
|
|
DELETE FROM t2 WHERE a = -2;
|
|
SELECT * FROM t1 ORDER BY a;
|
|
SELECT * FROM t2 ORDER BY a;
|
|
sync_slave_with_master;
|
|
SELECT * FROM t1 ORDER BY a;
|
|
SELECT * FROM t2 ORDER BY a;
|
|
let $last_error = query_get_value("SHOW SLAVE STATUS", Last_SQL_Errno, 1);
|
|
disable_query_log;
|
|
eval SELECT "$last_error" AS Last_SQL_Error;
|
|
enable_query_log;
|
|
|
|
# An insert of a row that already exists. Since we are replacing the
|
|
# row if it already exists, the most apropriate representation is
|
|
# INSERT IGNORE. We only test this towards a table with a primary key,
|
|
# since the other case does not make sense.
|
|
|
|
INSERT IGNORE INTO t1 VALUES (-2);
|
|
connection master;
|
|
INSERT IGNORE INTO t1 VALUES (-2);
|
|
SELECT * FROM t1 ORDER BY a;
|
|
sync_slave_with_master;
|
|
SELECT * FROM t1 ORDER BY a;
|
|
let $last_error = query_get_value("SHOW SLAVE STATUS", Last_SQL_Errno, 1);
|
|
disable_query_log;
|
|
eval SELECT "$last_error" AS Last_SQL_Error;
|
|
enable_query_log;
|
|
|
|
# BUG#19958: RBR idempotency issue for UPDATE and DELETE
|
|
|
|
# Statement-based and row-based replication have different behaviour
|
|
# when updating a row with an explicit WHERE-clause that matches
|
|
# exactly one row (or no row at all). For statement-based replication,
|
|
# the statement is idempotent since the first time it is executed, it
|
|
# will update exactly one row, and the second time it will not update
|
|
# any row at all. This was not the case for row-based replication, so
|
|
# we test under both row-based and statement-based replication both
|
|
# for tables with and without primary keys.
|
|
|
|
connection slave;
|
|
UPDATE t1 SET a = 1 WHERE a = -1;
|
|
UPDATE t2 SET a = 1 WHERE a = -1;
|
|
connection master;
|
|
UPDATE t1 SET a = 1 WHERE a = -1;
|
|
UPDATE t2 SET a = 1 WHERE a = -1;
|
|
SELECT * FROM t1 ORDER BY a;
|
|
SELECT * FROM t2 ORDER BY a;
|
|
sync_slave_with_master;
|
|
SELECT * FROM t1 ORDER BY a;
|
|
SELECT * FROM t2 ORDER BY a;
|
|
let $last_error = query_get_value("SHOW SLAVE STATUS", Last_SQL_Errno, 1);
|
|
disable_query_log;
|
|
eval SELECT "$last_error" AS Last_SQL_Error;
|
|
enable_query_log;
|
|
|
|
connection master;
|
|
DROP TABLE t1, t2;
|
|
sync_slave_with_master;
|
|
|
|
# bug#31609 Not all RBR slave errors reported as errors
|
|
# bug#31552 Replication breaks when deleting rows from out-of-sync table
|
|
# without PK
|
|
|
|
#
|
|
# Idempotent applying is not default any longer.
|
|
# The default for slave-exec-mode option and server
|
|
# variable slave_exec_mode is 'STRICT'.
|
|
# When 'STRICT' mode is set, the slave SQL thread will stop whenever
|
|
# the row to change is not found. In 'IDEMPOTENT' mode, the SQL thread
|
|
# will continue running and apply the row - replace if it's Write_rows event -
|
|
# or skip to the next event.
|
|
|
|
# the previous part of the tests was with IDEMPOTENT slave's mode.
|
|
|
|
|
|
#
|
|
# Other than above idempotent errors dealing with foreign keys constraint
|
|
#
|
|
|
|
select @@global.slave_exec_mode /* must be IDEMPOTENT */;
|
|
|
|
connection master;
|
|
|
|
create table ti1 (b int primary key) engine = innodb;
|
|
create table ti2 (a int primary key, b int, foreign key (b) references ti1(b))
|
|
engine = innodb;
|
|
set foreign_key_checks=1 /* ensure the check */;
|
|
|
|
insert into ti1 values (1),(2),(3);
|
|
insert into ti2 set a=2, b=2;
|
|
|
|
sync_slave_with_master;
|
|
|
|
#connection slave;
|
|
select * from ti1 order by b /* must be (1),(2),(3) */;
|
|
insert into ti2 set a=1, b=1;
|
|
select * from ti2 order by b /* must be (1,1) (2,2) */;
|
|
|
|
connection master;
|
|
|
|
# from now on checking rbr specific idempotent errors
|
|
set @save_binlog_format= @@session.binlog_format;
|
|
set @@session.binlog_format= row;
|
|
delete from ti1 where b=1;
|
|
|
|
select * from ti1 order by b /* must be (2),(3) */;
|
|
|
|
# slave must catch up (expect some warnings in error.log)
|
|
sync_slave_with_master;
|
|
|
|
#connection slave;
|
|
select * from ti1 order by b /* must stays as were on master (1),(2),(3) */;
|
|
|
|
delete from ti1 where b=3;
|
|
|
|
connection master;
|
|
insert into ti2 set a=3, b=3;
|
|
|
|
# slave must catch up (expect some warnings in error.log)
|
|
sync_slave_with_master;
|
|
|
|
#connection slave;
|
|
select * from ti2 order by b /* must be (1,1),(2,2) - not inserted */;
|
|
|
|
|
|
#
|
|
# Checking the new global sys variable
|
|
#
|
|
|
|
connection slave;
|
|
|
|
set global slave_exec_mode='IDEMPOTENT';
|
|
set global slave_exec_mode='STRICT';
|
|
|
|
# checking mutual exclusion for the options
|
|
--error ER_SLAVE_AMBIGOUS_EXEC_MODE
|
|
set global slave_exec_mode='IDEMPOTENT,STRICT';
|
|
|
|
select @@global.slave_exec_mode /* must be STRICT */;
|
|
|
|
#
|
|
# Checking stops.
|
|
# In the following sections strict slave sql thread is going to
|
|
# stop when faces an idempotent error. In order to proceed
|
|
# the mode is temporarily switched to indempotent.
|
|
#
|
|
|
|
#
|
|
--echo *** foreign keys errors as above now forces to stop
|
|
#
|
|
|
|
connection master;
|
|
|
|
set foreign_key_checks=0;
|
|
drop table ti2, ti1;
|
|
|
|
create table ti1 (b int primary key) engine = innodb;
|
|
create table ti2 (a int primary key, b int, foreign key (b) references ti1(b))
|
|
engine = innodb;
|
|
set foreign_key_checks=1 /* ensure the check */;
|
|
|
|
insert into ti1 values (1),(2),(3);
|
|
insert into ti2 set a=2, b=2;
|
|
|
|
sync_slave_with_master;
|
|
|
|
#connection slave;
|
|
select * from ti1 order by b /* must be (1),(2),(3) */;
|
|
--echo *** conspire future problem
|
|
insert into ti2 set a=1, b=1;
|
|
select * from ti2 order by b /* must be (1,1) (2,2) */;
|
|
|
|
connection master;
|
|
|
|
delete from ti1 where b=1 /* offending delete event */;
|
|
select * from ti1 order by b /* must be (2),(3) */;
|
|
|
|
# foreign key: row is referenced
|
|
|
|
--echo *** slave must stop
|
|
source include/wait_for_slave_sql_to_stop.inc;
|
|
|
|
connection slave;
|
|
|
|
let $last_error = query_get_value("SHOW SLAVE STATUS", Last_SQL_Errno, 1);
|
|
disable_query_log;
|
|
eval SELECT "$last_error" AS Last_SQL_Error;
|
|
enable_query_log;
|
|
|
|
select * from ti1 order by b /* must be (1),(2),(3) - not deleted */;
|
|
set foreign_key_checks= 0;
|
|
delete from ti2 where b=1;
|
|
set foreign_key_checks= 1;
|
|
set global slave_exec_mode='IDEMPOTENT';
|
|
start slave sql_thread;
|
|
connection master;
|
|
sync_slave_with_master;
|
|
#connection slave;
|
|
set global slave_exec_mode='STRICT';
|
|
|
|
connection master;
|
|
|
|
sync_slave_with_master;
|
|
|
|
#connection slave;
|
|
--echo *** conspire the following insert failure
|
|
# foreign key: no referenced row
|
|
|
|
--echo *** conspire future problem
|
|
delete from ti1 where b=3;
|
|
|
|
connection master;
|
|
insert into ti2 set a=3, b=3 /* offending write event */;
|
|
--echo *** slave must stop
|
|
|
|
source include/wait_for_slave_sql_to_stop.inc;
|
|
|
|
connection slave;
|
|
|
|
let $last_error = query_get_value("SHOW SLAVE STATUS", Last_SQL_Errno, 1);
|
|
disable_query_log;
|
|
eval SELECT "$last_error" AS Last_SQL_Error;
|
|
enable_query_log;
|
|
|
|
select * from ti2 order by b /* must be (2,2) */;
|
|
set foreign_key_checks= 0;
|
|
insert into ti1 set b=3;
|
|
set foreign_key_checks= 1;
|
|
set global slave_exec_mode='IDEMPOTENT';
|
|
start slave sql_thread;
|
|
connection master;
|
|
sync_slave_with_master;
|
|
#connection slave;
|
|
set global slave_exec_mode='STRICT';
|
|
|
|
connection master;
|
|
|
|
sync_slave_with_master;
|
|
|
|
select * from ti2 order by b /* must be (2,2),(3,3) */;
|
|
|
|
#
|
|
--echo *** other errors
|
|
#
|
|
|
|
# dup key insert
|
|
|
|
#connection slave;
|
|
--echo *** conspiring query
|
|
insert into ti1 set b=1;
|
|
|
|
connection master;
|
|
insert into ti1 set b=1 /* offending write event */;
|
|
|
|
--echo *** slave must stop
|
|
source include/wait_for_slave_sql_to_stop.inc;
|
|
|
|
connection slave;
|
|
|
|
let $last_error = query_get_value("SHOW SLAVE STATUS", Last_SQL_Errno, 1);
|
|
disable_query_log;
|
|
eval SELECT "$last_error" AS Last_SQL_Error;
|
|
enable_query_log;
|
|
|
|
set foreign_key_checks= 0;
|
|
delete from ti1 where b=1;
|
|
set foreign_key_checks= 1;
|
|
set global slave_exec_mode='IDEMPOTENT';
|
|
start slave sql_thread;
|
|
connection master;
|
|
sync_slave_with_master;
|
|
#connection slave;
|
|
set global slave_exec_mode='STRICT';
|
|
|
|
# key not found
|
|
|
|
connection master;
|
|
|
|
CREATE TABLE t1 (a INT PRIMARY KEY);
|
|
CREATE TABLE t2 (a INT);
|
|
INSERT INTO t1 VALUES (-1),(-2),(-3);
|
|
INSERT INTO t2 VALUES (-1),(-2),(-3);
|
|
sync_slave_with_master;
|
|
|
|
#connection slave;
|
|
DELETE FROM t1 WHERE a = -2;
|
|
DELETE FROM t2 WHERE a = -2;
|
|
connection master;
|
|
DELETE FROM t1 WHERE a = -2;
|
|
|
|
--echo *** slave must stop
|
|
source include/wait_for_slave_sql_to_stop.inc;
|
|
|
|
connection slave;
|
|
|
|
let $last_error = query_get_value("SHOW SLAVE STATUS", Last_SQL_Errno, 1);
|
|
disable_query_log;
|
|
eval SELECT "$last_error" AS Last_SQL_Error;
|
|
enable_query_log;
|
|
|
|
set global slave_exec_mode='IDEMPOTENT';
|
|
start slave sql_thread;
|
|
connection master;
|
|
sync_slave_with_master;
|
|
#connection slave;
|
|
set global slave_exec_mode='STRICT';
|
|
|
|
connection master;
|
|
DELETE FROM t2 WHERE a = -2;
|
|
--echo *** slave must stop
|
|
source include/wait_for_slave_sql_to_stop.inc;
|
|
|
|
connection slave;
|
|
|
|
let $last_error = query_get_value("SHOW SLAVE STATUS", Last_SQL_Errno, 1);
|
|
disable_query_log;
|
|
eval SELECT "$last_error" AS Last_SQL_Error;
|
|
enable_query_log;
|
|
|
|
set global slave_exec_mode='IDEMPOTENT';
|
|
start slave sql_thread;
|
|
connection master;
|
|
sync_slave_with_master;
|
|
#connection slave;
|
|
set global slave_exec_mode='STRICT';
|
|
|
|
UPDATE t1 SET a = 1 WHERE a = -1;
|
|
UPDATE t2 SET a = 1 WHERE a = -1;
|
|
|
|
connection master;
|
|
UPDATE t1 SET a = 1 WHERE a = -1;
|
|
|
|
--echo *** slave must stop
|
|
source include/wait_for_slave_sql_to_stop.inc;
|
|
|
|
connection slave;
|
|
|
|
let $last_error = query_get_value("SHOW SLAVE STATUS", Last_SQL_Errno, 1);
|
|
disable_query_log;
|
|
eval SELECT "$last_error" AS Last_SQL_Error;
|
|
enable_query_log;
|
|
|
|
set global slave_exec_mode='IDEMPOTENT';
|
|
start slave sql_thread;
|
|
connection master;
|
|
sync_slave_with_master;
|
|
#connection slave;
|
|
set global slave_exec_mode='STRICT';
|
|
|
|
|
|
connection master;
|
|
UPDATE t2 SET a = 1 WHERE a = -1;
|
|
|
|
--echo *** slave must stop
|
|
source include/wait_for_slave_sql_to_stop.inc;
|
|
|
|
connection slave;
|
|
|
|
let $last_error = query_get_value("SHOW SLAVE STATUS", Last_SQL_Errno, 1);
|
|
disable_query_log;
|
|
eval SELECT "$last_error" AS Last_SQL_Error;
|
|
enable_query_log;
|
|
|
|
set global slave_exec_mode='IDEMPOTENT';
|
|
start slave sql_thread;
|
|
connection master;
|
|
sync_slave_with_master;
|
|
#connection slave;
|
|
set global slave_exec_mode='STRICT';
|
|
|
|
|
|
# cleanup for bug#31609 tests
|
|
|
|
connection master;
|
|
set @@session.binlog_format= @save_binlog_format;
|
|
drop table t1,t2,ti2,ti1;
|
|
|
|
sync_slave_with_master;
|
|
|
|
|
|
--echo *** end of tests
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|