mirror of
https://github.com/MariaDB/server.git
synced 2025-02-01 19:41:47 +01:00
21cc7d5a25
Bug#319 if while a non-transactional slave is replicating a transaction possible problem
It is impossible to roll back a mixed engines transaction when one of the engine is
non-transaction. In replication that fact is crucial because the slave can not safely
re-apply a transction that was interrupted with STOP SLAVE.
Fixed with making STOP SLAVE not be effective immediately in the case the current
group of replication events has modified a non-transaction table. In order for slave to leave
either the group needs finishing or the user issues KILL QUERY|CONNECTION slave_thread_id.
mysql-test/suite/bugs/r/rpl_bug38205.result:
bug#38205 non-deterministic part of tests results.
mysql-test/suite/bugs/t/rpl_bug38205.test:
bug#38205 non-deterministic part of tests.
mysql-test/suite/rpl/r/rpl_start_stop_slave.result:
bug#38205 deterministic part of tests results.
mysql-test/suite/rpl/t/rpl_start_stop_slave-slave.opt:
increasing `innodb_lock_wait_timeout' to make the test pass on slow env w/o
timeout expired issue.
mysql-test/suite/rpl/t/rpl_start_stop_slave.test:
bug#38205 deterministic part of tests.
sql/log_event.cc:
Augmenting row-based events applying with the notion of
thd->transaction.{all,stmt}.modified_non_trans_table.
The pair is set and reset according to its specification
for the mixed transaction processing.
Particualry, once `modified_non_trans_table' is set in the row-events
processing loop, it will remain till the commit of the transaction.
sql/slave.cc:
Consulting `thd->transaction.all.modified_non_trans_table' to decide
whether to terminate by the sql thread or to continue even though
the sql thread might have been STOP-ed (rli->abort_slave).
123 lines
2.9 KiB
Text
123 lines
2.9 KiB
Text
source include/master-slave.inc;
|
|
source include/have_innodb.inc;
|
|
|
|
#
|
|
# Bug#6148 ()
|
|
#
|
|
# Let the master do lots of insertions
|
|
connection master;
|
|
create table t1(n int);
|
|
sync_slave_with_master;
|
|
stop slave;
|
|
connection master;
|
|
let $1=5000;
|
|
disable_query_log;
|
|
while ($1)
|
|
{
|
|
eval insert into t1 values($1);
|
|
dec $1;
|
|
}
|
|
enable_query_log;
|
|
save_master_pos;
|
|
|
|
connection slave;
|
|
start slave;
|
|
let $wait_condition= SELECT COUNT(*) > 0 FROM t1;
|
|
source include/wait_condition.inc;
|
|
stop slave io_thread;
|
|
start slave io_thread;
|
|
source include/wait_for_slave_to_start.inc;
|
|
sync_with_master;
|
|
|
|
connection master;
|
|
drop table t1;
|
|
save_master_pos;
|
|
|
|
connection slave;
|
|
sync_with_master;
|
|
|
|
|
|
#
|
|
# Bug #38205 Row-based Replication (RBR) causes inconsistencies...
|
|
#
|
|
# Verifying that STOP SLAVE does not interrupt excution of a group
|
|
# execution of events if the group can not roll back.
|
|
# Killing the sql thread continues to provide a "hard" stop (the
|
|
# part II, moved to the bugs suite as it's hard to make it
|
|
# deterministic with KILL).
|
|
#
|
|
|
|
#
|
|
# Part I. The being stopped sql thread finishes first the current group of
|
|
# events if the group contains an event on a non-transaction table.
|
|
|
|
connection master;
|
|
create table t1i(n int primary key) engine=innodb;
|
|
create table t2m(n int primary key) engine=myisam;
|
|
begin;
|
|
insert into t1i values (1);
|
|
insert into t1i values (2);
|
|
insert into t1i values (3);
|
|
commit;
|
|
|
|
sync_slave_with_master;
|
|
connection slave;
|
|
begin;
|
|
insert into t1i values (5);
|
|
|
|
connection master;
|
|
let $pos0_master= query_get_value(SHOW MASTER STATUS, Position, 1);
|
|
begin;
|
|
insert into t1i values (4);
|
|
insert into t2m values (1); # non-ta update to process
|
|
insert into t1i values (5); # to block at. to be played with stopped
|
|
commit;
|
|
|
|
connection slave;
|
|
# slave sql thread must be locked out by the conn `slave' explicit lock
|
|
let $pos0_slave= query_get_value(SHOW SLAVE STATUS, Exec_Master_Log_Pos, 1);
|
|
--disable_query_log
|
|
eval select $pos0_master - $pos0_slave as zero;
|
|
--enable_query_log
|
|
|
|
connection slave1;
|
|
let $count= 1;
|
|
let $table= t2m;
|
|
source include/wait_until_rows_count.inc;
|
|
send stop slave;
|
|
|
|
connection slave;
|
|
rollback; # release the sql thread
|
|
|
|
connection slave1;
|
|
reap;
|
|
source include/wait_for_slave_to_stop.inc;
|
|
let $sql_status= query_get_value(SHOW SLAVE STATUS, Slave_SQL_Running, 1);
|
|
--echo *** sql thread is running: $sql_status ***
|
|
|
|
|
|
connection master;
|
|
let $pos1_master= query_get_value(SHOW MASTER STATUS, Position, 1);
|
|
|
|
connection slave;
|
|
source include/wait_for_slave_sql_to_stop.inc;
|
|
|
|
let $pos1_slave= query_get_value(SHOW SLAVE STATUS, Exec_Master_Log_Pos, 1);
|
|
|
|
--echo *** the prove: the stopped slave has finished the current transaction ***
|
|
|
|
--disable_query_log
|
|
select count(*) as five from t1i;
|
|
eval select $pos1_master - $pos1_slave as zero;
|
|
eval select $pos1_slave > $pos0_slave as one;
|
|
--enable_query_log
|
|
|
|
start slave;
|
|
|
|
# clean-up
|
|
connection master;
|
|
drop table t1i, t2m;
|
|
|
|
sync_slave_with_master;
|
|
|
|
# End of tests
|