124 lines
4.1 KiB
Plaintext
124 lines
4.1 KiB
Plaintext
# ==== Purpose ====
|
|
#
|
|
# The test verifies the slave applier recovery after non-atomic DDL
|
|
# crashes the server.
|
|
# The test specifies slave_relay_log_info as of TABLE type.
|
|
# At post-crash the slave service must recover and the applier resumes
|
|
# from a correct binlog position.
|
|
# The subject is not trivial as it may look because even with the slave binlogging
|
|
# turned ON the post-crash recovering slave can't make use of its binlog as
|
|
# the non-atomic DDL is not xided.
|
|
#
|
|
# ==== Implementation ====
|
|
#
|
|
# Simulate the crash once a non-atomic DDL completes on the slave
|
|
# server including the final phase of the slave applier committing an
|
|
# update into the info table.
|
|
# At restart the slave server recovery must always find the slave info table updated
|
|
# so never attempt binlog-based recovery for it which otherwise would
|
|
# be in vain thanks to missed XID info.
|
|
#
|
|
# ==== References ====
|
|
# WL#9175 Correct recovery of DDL statements/transactions by binary log
|
|
#
|
|
# See other tests like rpl_atomic_ddl, rpl_half_atomic_ddl verifying
|
|
# the atomic DDL classes.
|
|
#
|
|
|
|
--source include/force_myisam_default.inc
|
|
--source include/have_myisam.inc
|
|
--source include/not_crashrep.inc
|
|
--source include/not_valgrind.inc
|
|
--source include/have_log_bin.inc
|
|
--source include/have_binlog_format_mixed.inc
|
|
--source include/have_debug.inc
|
|
--let $rpl_gtid_utils= 1
|
|
--source include/master-slave.inc
|
|
|
|
##
|
|
## Initialization
|
|
##
|
|
--source include/rpl_connection_slave.inc
|
|
call mtr.add_suppression("The slave coordinator and worker threads are stopped");
|
|
call mtr.add_suppression("Slave worker thread has failed to apply an event");
|
|
call mtr.add_suppression("Error writing relay log configuration");
|
|
|
|
--source include/rpl_connection_master.inc
|
|
# instructing gtid_step_assert that is called by a sourced file
|
|
# to satisfy to gtid-mode OFF as well.
|
|
--let $gtid_mode_on= `SELECT @@GLOBAL.GTID_MODE = 'ON'`
|
|
--let $gtid_mode= `SELECT @@GLOBAL.GTID_MODE`
|
|
--let $gtid_step_gtid_mode_agnostic=`SELECT '$gtid_mode' != 'ON'`
|
|
|
|
# Leave slave applier stopped
|
|
--source include/sync_slave_sql_with_master.inc
|
|
--source include/stop_slave_sql.inc
|
|
|
|
if (!$crash_commit)
|
|
{
|
|
--let $commit_message=Crash right after the non-atomic DDL's event has updated slave relay log info
|
|
--let $crash_commit="+d,slave_crash_after_commit_no_atomic_ddl"
|
|
}
|
|
|
|
##
|
|
## Execution
|
|
##
|
|
|
|
--let $table_name=tm
|
|
--let $current_query=CREATE TABLE $table_name (a int) ENGINE=MYISAM
|
|
|
|
--source include/rpl_connection_master.inc
|
|
--eval $current_query
|
|
--let $binlog_pos= query_get_value("SHOW MASTER STATUS", Position, 1)
|
|
|
|
--source include/sync_slave_io_with_master.inc
|
|
|
|
# The receiver thread must be stopped now which
|
|
# crash-safely memorizes the last received event coordinates.
|
|
--source include/rpl_connection_slave.inc
|
|
--source include/stop_slave_io.inc
|
|
|
|
# Set up post-commit crash
|
|
--source include/expect_crash.inc
|
|
--echo *** Query: '$current_query'. $commit_message. ***
|
|
--eval SET @@GLOBAL.debug=$crash_commit
|
|
|
|
--error 0,2013
|
|
START SLAVE SQL_THREAD;
|
|
|
|
# Server wait for stop and restart
|
|
--enable_reconnect
|
|
--source include/wait_until_disconnected.inc
|
|
--let $rpl_server_number= 2
|
|
--source include/rpl_start_server.inc
|
|
--disable_reconnect
|
|
|
|
--source include/rpl_connection_slave.inc
|
|
--let $assert_text=The table $table_name must be present
|
|
--let $assert_cond=`SELECT count(*) = 0 FROM $table_name`
|
|
--source include/assert.inc
|
|
|
|
# The last executed position post crash recovery is extraneous.
|
|
# Eventual 'START SLAVE' must succeed and would not when the last execution
|
|
# coordiate remained as before the crash as the table could not be
|
|
# re-CREATE-ed.
|
|
--let $assert_text=The executed coordinates must be as after the crashing '$current_query'
|
|
if (`select @@global.slave_parallel_workers = 0`)
|
|
{
|
|
--let $assert_cond=`SELECT Master_log_pos = $binlog_pos FROM mysql.slave_relay_log_info`
|
|
}
|
|
if (`select @@global.slave_parallel_workers > 0`)
|
|
{
|
|
--let $assert_cond=`SELECT max(Master_log_pos) = $binlog_pos FROM mysql.slave_worker_info`
|
|
}
|
|
--source include/assert.inc
|
|
|
|
--source include/start_slave.inc
|
|
|
|
--source include/rpl_connection_master.inc
|
|
--eval DROP TABLE $table_name
|
|
|
|
--source include/sync_slave_sql_with_master.inc
|
|
|
|
--source include/rpl_end.inc
|