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
|
################################################################################
# This test verifies that during recovery the user cannot execute transactions
#
# We test:
# 1. Single node recovery.
# Block recovery with a debug sync point and check no queries can be applied.
# 2. General replication.
# Block recovery state transfer and check no queries can be applied.
#
# Test:
# 0. The test requires two servers: M1 and M2.
# Test local recovery:
# 1. Bootstrap GR on the first node M1 after setting the debug point to block
# recovery. Check transactions cannot be executed.
# 2. Signal to unblock recovery. Check M1 is ONLINE. Table creation should pass
# as M1 is ONLINE now.
# Test for a joining member:
# 3. Block state transfer by stoping applier thread on M1. Start GR on M2.
# M2 should be in RECOVERING state. Check transactions cannot be executed.
# 4. Unblock recovery on M2 by starting applier thread on M1. Table creation
# should pass as this M2 has now recovered and in ONLINE state.
# 5. Clean up.
################################################################################
--source include/have_debug.inc
--source include/have_debug_sync.inc
--source include/have_group_replication_plugin.inc
--let $rpl_skip_group_replication_start= 1
--source include/group_replication.inc
--echo #
--echo # 1. Test local recovery
--echo # Start group_replication on the first node after setting the debug
--echo # point to block recovery. Check whether transactions can be executed.
--echo #
--connection server1
SET @debug_save= @@GLOBAL.DEBUG;
--echo # Set the debug flag to block recovery at different stages.
SET @@GLOBAL.DEBUG='+d,recovery_thread_start_wait';
--source include/gr_set_bootstrap_group.inc
--let $group_replication_start_member_state= RECOVERING
--source include/start_group_replication.inc
# Check we cannot execute transactions
--connection server_1
--error ER_OPTION_PREVENTS_STATEMENT
CREATE TABLE t1 (i INT NOT NULL PRIMARY KEY);
#Unblock recovery
SET DEBUG_SYNC= "now SIGNAL signal.recovery_continue";
--echo # Now wait for the node to be online
--let $group_replication_member_state= ONLINE
--source include/gr_wait_for_member_state.inc
--echo # Table creation should pass as the single member is now recovered.
CREATE TABLE t1 (i INT NOT NULL PRIMARY KEY);
SET @@GLOBAL.DEBUG= @debug_save;
--echo #
--echo # 2. Test for a joining member
--echo # Start group_replication on the second member and block state transfer
--echo # Query execution should not be allowed
--echo #
--connection server1
SET @@GLOBAL.DEBUG='+d,block_applier_updates';
--connection server2
--let $group_replication_start_member_state= RECOVERING
--source include/start_group_replication.inc
--error ER_OPTION_PREVENTS_STATEMENT
CREATE TABLE t2 (i INT NOT NULL PRIMARY KEY);
# Unblock recovery and verify all is now normal
--connection server1
SET DEBUG_SYNC = "now WAIT_FOR applier_read_blocked";
SET @@GLOBAL.DEBUG='-d,block_applier_updates';
SET DEBUG_SYNC = "now SIGNAL resume_applier_read";
--connection server2
--let $group_replication_member_state= ONLINE
--source include/gr_wait_for_member_state.inc
--echo # Table creation should pass as this node has now recovered.
CREATE TABLE t2 (i INT NOT NULL PRIMARY KEY);
--echo #
--echo # Cleanup
--echo #
DROP TABLE t1;
DROP TABLE t2;
--connection server1
SET DEBUG_SYNC= 'RESET';
--source include/group_replication_end.inc
|
