1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
|
# ==== 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 replica coordinator and worker threads are stopped");
call mtr.add_suppression("Replica 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,replica_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.replica_parallel_workers = 0`)
{
--let $assert_cond=`SELECT Master_log_pos = $binlog_pos FROM mysql.slave_relay_log_info`
}
if (`select @@global.replica_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
|
