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
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
|
###############################################################################
#
# When switching to a primary server or changing mode to single primary
# with an appointed primary, P, if P leaves or fails under a majority,
# after the election finalizes, change terminates and the
# group elects a new primary. A warning is thrown to the user.
#
# Test:
# 0. This test needs three servers
# 1. Members in Multi Primary Mode, create two tables and rpl_sync
# 2. On a member server2 that will be secondary lock a table t1
# 3. On other member insert value on table locked on server2
# 4. Execute action to change to single primary with server1 as primary
# 5. Check that the other members are waiting for members to be in read
# mode. Stages should be
# - Primary Election: waiting for members to enable super_read_only
# - Single-primary Switch: executing Primary election - completed work 0
# 6. Lock a table t2 on the primary server1
# 7. Insert something on t2 on server2, the locked secondary
# 8. Unlock table t1 on server2, the locked secondary
# 9. Stage should be
# - Single-primary Switch: executing Primary election - completed work 1
# 10. Kill the new primary server1
# 11. Check that the action finishes
# 12. Check server2 was able to insert value
# 13. Using weights one can assert here that primary is now server3
# 14. Cleanup
#
###############################################################################
--source include/have_group_replication_plugin.inc
--source include/not_valgrind.inc
--let $rpl_server_count= 3
--source include/group_replication.inc
--echo
--echo # 1. Members in Multi Primary Mode, create two tables and rpl_sync
--let $server1_uuid= query_get_value(SELECT @@SERVER_UUID, @@SERVER_UUID, 1)
CREATE TABLE test.t1 (a INT PRIMARY KEY);
CREATE TABLE test.t2 (a INT PRIMARY KEY);
--source include/rpl_sync.inc
--echo
--echo # 2. On a member server2 that will be secondary lock a table t1
--let $rpl_connection_name= server2
--source include/rpl_connection.inc
LOCK TABLE t1 READ;
--echo
--echo # 3. On other member insert value on table locked on server2
--let $rpl_connection_name= server_3
--source include/rpl_connection.inc
--let $server3_uuid= query_get_value(SELECT @@SERVER_UUID, @@SERVER_UUID, 1)
SET @@GLOBAL.group_replication_member_weight= 90;
INSERT INTO t1 VALUES (1);
--let $rpl_connection_name= server_2
--source include/rpl_connection.inc
--let $wait_condition=SELECT COUNT(*)=1 FROM performance_schema.events_stages_current WHERE event_name LIKE "%Waiting for table metadata lock%"
--source include/wait_condition.inc
--echo
--echo # 4. Execute action to change to single primary with server1 as primary
--let $rpl_connection_name= server3
--source include/rpl_connection.inc
--replace_result $server1_uuid MEMBER1_UUID
--send_eval SELECT group_replication_switch_to_single_primary_mode("$server1_uuid")
--let $rpl_connection_name= server_3
--source include/rpl_connection.inc
--echo
--echo # 5. Check that the other members are waiting for members to be in read
--echo # mode. Stages should be
--echo # - Primary Election: waiting for members to enable super_read_only
--echo # - Single-primary Switch: executing Primary election - completed work 0
--let $wait_condition=SELECT COUNT(*)=1 FROM performance_schema.events_stages_current WHERE event_name LIKE "%super_read_only%"
--source include/wait_condition.inc
--let $stage_name= `SELECT event_name FROM performance_schema.events_stages_current WHERE event_name LIKE "%Single-primary Switch%" AND work_completed=0;`
--let $assert_text= The stage should be "Single-primary Switch: executing Primary election"
--let $assert_cond= "$stage_name" = "stage/group_rpl/Single-primary Switch: executing Primary election"
--source include/assert.inc
--let $stage_name= `SELECT event_name FROM performance_schema.events_stages_current WHERE event_name LIKE "%super_read_only%";`
--let $assert_text= The stage should be "Primary Election: waiting for members to enable super_read_only"
--let $assert_cond= "$stage_name" = "stage/group_rpl/Primary Election: waiting for members to enable super_read_only"
--source include/assert.inc
--echo
--echo # 6. Lock a table t2 on the primary server1
--let $rpl_connection_name= server1
--source include/rpl_connection.inc
LOCK TABLE t2 READ;
--echo
--echo # 7. Insert something on t2 on server2, the locked secondary
--let $rpl_connection_name= server_2_1
--source include/rpl_connection.inc
--send INSERT INTO t2 VALUES (1)
--echo
--echo # 8. Unlock table t1 on server2, the locked secondary
--let $rpl_connection_name= server2
--source include/rpl_connection.inc
# Insert might not have started, UNLOCK will unblock internal SET READ_ONLY
--let $wait_condition=SELECT COUNT(*)=1 FROM information_schema.processlist WHERE state LIKE "%Waiting for global read lock%" AND info lIKE "%INSERT INTO t2%" AND USER="root"
--source include/wait_condition.inc
UNLOCK TABLES;
--echo
--echo # 9. Stage should be
--echo # - Single-primary Switch: executing Primary election - completed work 1
--let $wait_condition=SELECT COUNT(*)=1 FROM performance_schema.events_stages_current WHERE event_name LIKE "%Single-primary Switch: executing Primary election%" AND work_completed=1
--source include/wait_condition.inc
--echo
--echo # 10. Kill the new primary server1
--let $rpl_connection_name= server1
--source include/rpl_connection.inc
--let $_group_replication_local_address= `SELECT @@GLOBAL.group_replication_local_address`
--let $_group_replication_group_seeds= `SELECT @@GLOBAL.group_replication_group_seeds`
--replace_result $group_replication_group_name GROUP_REPLICATION_GROUP_NAME $_group_replication_local_address GROUP_REPLICATION_LOCAL_ADDRESS $_group_replication_group_seeds GROUP_REPLICATION_GROUP_SEEDS
--let $restart_parameters=restart:--group-replication-start-on-boot=0 --group-replication-group-name=$group_replication_group_name --group_replication_local_address=$_group_replication_local_address --group_replication_group_seeds=$_group_replication_group_seeds --group_replication_single_primary_mode=TRUE --group_replication_enforce_update_everywhere_checks=FALSE
--source include/kill_and_restart_mysqld.inc
--let $rpl_server_number= 1
--source include/rpl_reconnect.inc
--echo
--echo # 11. Check that the action finishes
--let $rpl_connection_name= server2
--source include/rpl_connection.inc
--let $group_replication_number_of_members= 2
--source include/gr_wait_for_number_of_members.inc
--echo
--echo # 12. Check server2 was able to insert value
--let $rpl_connection_name= server_2_1
--source include/rpl_connection.inc
--reap
--echo
--echo # 13. Using weights one can assert here that primary is now server3
--let $rpl_connection_name= server3
--source include/rpl_connection.inc
--replace_result $server1_uuid MEMBER1_UUID
--reap
--source include/gr_assert_primary_member.inc
--echo
--echo # 14. Cleanup
--let $rpl_connection_name= server1
--source include/rpl_connection.inc
--source include/start_group_replication.inc
--let $rpl_connection_name= server3
--source include/rpl_connection.inc
SET @@GLOBAL.group_replication_member_weight= DEFAULT;
DROP TABLE t1;
DROP TABLE t2;
--let $rpl_group_replication_single_primary_mode=1
--let $rpl_group_replication_reset_persistent_vars=1
--source include/group_replication_end.inc
|
