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
|
# ==== Purpose ====
#
# Wait for SQL error and restart slave.
#
# This script is normally used to wait for slave to error out with given SQL
# error code and restart slave. It also asserts last SQL error code and error
# message in performance_schema.replication_applier_status_by_worker.
# And before restarting slave, if gtid to skip is provided it will skip the
# given transaction with injecting empty transaction so slave can be started.
#
# ==== Usage ====
#
# --let $slave_sql_errno= NUMBER
# --let $slave_sql_error= TEXT
# --let $rpl_channel_name= 'NAME'
# [--let $rpl_skip_gtid= UUID:ID]
# --source include/wait_for_slave_sql_error_and_restart.inc
#
# Parameters:
#
# $slave_sql_errno
# The expected SQL error number.
#
# $slave_sql_error
# The expected SQL error message.
#
# $rpl_channel_name
# Set this to channel you want this script to operate,
# otherwise it will use the empty channel (channel name '').
#
# $rpl_skip_gtid
# The gtid to be skipped with empty transaction.
#
# $rpl_debug
# See include/rpl_init.inc
#
--let $include_filename= wait_for_slave_sql_error_and_restart.inc [errno=$slave_sql_errno]
if ($rpl_channel_name)
{
--let $include_filename= wait_for_slave_sql_error_and_restart.inc [errno=$slave_sql_errno FOR CHANNEL $rpl_channel_name]
}
--source include/begin_include_file.inc
if (!$slave_sql_errno)
{
--die ERROR IN TEST: You must set $slave_sql_errno before sourcing wait_for_slave_sql_error_and_restart.inc
}
if (!$slave_sql_error)
{
--die ERROR IN TEST: You must set $slave_sql_error before sourcing wait_for_slave_sql_error_and_restart.inc
}
if (!$rpl_channel_name)
{
--let $rpl_channel_name= ''
}
--replace_regex /[0-9][0-9][0-9][0-9]-[0-9][0-9]-[0-9][0-9]T[0-9][0-9]:[0-9][0-9]:[0-9][0-9]\.[0-9][0-9][0-9][0-9][0-9][0-9][-+Z][0-9:]* *[0-9]* *\[/DATE_TIME [/
--let $show_slave_sql_error= 0
--let $slave_sql_error_replace= / at [0-9]*/ at XXX/
--source include/wait_for_slave_sql_error.inc
# Wait for slave sql channel last error number
--let $wait_condition= SELECT COUNT(*)=1 FROM performance_schema.replication_applier_status_by_worker WHERE channel_name=$rpl_channel_name AND LAST_ERROR_NUMBER=$slave_sql_errno
--source include/wait_condition.inc
# Wait for slave sql channel last error message
--let $wait_condition= SELECT COUNT(*)=1 LAST_ERROR_MESSAGE_COUNT FROM performance_schema.replication_applier_status_by_worker WHERE channel_name=$rpl_channel_name AND LAST_ERROR_MESSAGE REGEXP '.*$slave_sql_error.*'
--source include/wait_condition.inc
# Wait for slave sql channel state to be OFF
--let $wait_condition= SELECT COUNT(*)=1 FROM performance_schema.replication_applier_status WHERE channel_name=$rpl_channel_name AND SERVICE_STATE="OFF"
--source include/wait_condition.inc
--source include/stop_slave.inc
--disable_query_log
--eval RESET REPLICA FOR CHANNEL $rpl_channel_name
# skip $rpl_skip_gtid transaction
if ($rpl_skip_gtid)
{
--eval SET GTID_NEXT= $rpl_skip_gtid
BEGIN; COMMIT;
SET GTID_NEXT= AUTOMATIC;
}
--enable_query_log
--source include/start_slave.inc
--let $include_filename= wait_for_slave_sql_error_and_restart.inc [errno=$slave_sql_errno]
--source include/end_include_file.inc
|
