WL#11007: Remove group_replication_primary_member status variable

In this worklog the global status variable
group_replication_primary_member will be removed. It was deprecated in the
'WL#10958: Deprecate group_replication_primary_member status variable' in
MySQL 8.0.4. The MEMBER_ROLE column of
performance_schema.replication_group_members table can be used to identify
whether member has PRIMARY or SECONDARY role.

Change-Id: I5b8eec14dc44020e0c83cfd4114aefe031582c64

Author: Hemant Dangi

mysql-test/include/gr_count_primaries_secondaries.inc

@@ -41,15 +41,13 @@ while ($_i)
          WHERE MEMBER_ID = @@server_uuid AND
          MEMBER_STATE != "ERROR"`;
 
-  let $_is_primary= `SELECT COUNT(*)=1 FROM performance_schema.global_status
-                            WHERE VARIABLE_NAME = "group_replication_primary_member" AND
-                            VARIABLE_VALUE = @@server_uuid`;
-
-  let $_is_secondary= `SELECT COUNT(*)=1 FROM performance_schema.global_status
-                            WHERE VARIABLE_NAME = "group_replication_primary_member" AND
-                            VARIABLE_VALUE != @@server_uuid AND
-                            VARIABLE_VALUE != ""`;
+  let $_is_primary= `SELECT COUNT(*)=1 FROM performance_schema.replication_group_members
+                     WHERE MEMBER_ROLE="PRIMARY" AND
+                           MEMBER_ID=@@server_uuid`;
 
+  let $_is_secondary= `SELECT COUNT(*)=1 FROM performance_schema.replication_group_members
+                       WHERE MEMBER_ROLE="SECONDARY" AND
+                             MEMBER_ID=@@server_uuid`;
   if ($_has_no_errors)
   {
     if ($_is_primary)

mysql-test/include/gr_find_a_primary.inc

@@ -28,6 +28,11 @@
 --let $include_filename= gr_find_a_primary.inc
 --source include/begin_include_file.inc
 
+if (`SELECT @@GLOBAL.group_replication_single_primary_mode != 1`)
+{
+  --die "The group must be operating in single-primary mode."
+}
+
 # save the connection to reinstate it later
 --let $_saved_current_connection= $CURRENT_CONNECTION
 
@@ -45,9 +50,8 @@ while ($_retry_find_primary)
     --let $rpl_connection_name=server$_i_find_primary
     --source include/rpl_connection.inc
 
-    let $_is_primary= `SELECT COUNT(*)=1 FROM performance_schema.global_status
-                              WHERE VARIABLE_NAME = "group_replication_primary_member" AND
-                              VARIABLE_VALUE = @@server_uuid`;
+    let $_is_primary= `SELECT COUNT(*)=1 FROM performance_schema.replication_group_members
+                       WHERE MEMBER_ROLE="PRIMARY" AND MEMBER_ID=@@server_uuid`;
 
     if ($_is_primary)
     {

mysql-test/include/gr_wait_primary_member_uuid.inc

@@ -13,9 +13,19 @@
 --let $include_filename= gr_wait_primary_member_uuid.inc
 --source include/begin_include_file.inc
 
-let $wait_condition= SELECT COUNT(*) = 1 FROM performance_schema.global_status
-   WHERE VARIABLE_NAME = "group_replication_primary_member" AND
-         VARIABLE_VALUE = "$group_replication_expected_uuid";
+if (`SELECT @@GLOBAL.group_replication_single_primary_mode != 1`)
+{
+  --die "The group must be operating in single-primary mode."
+}
+
+if ($group_replication_expected_uuid == '')
+{
+  --die "Missing argument 'group_replication_expected_uuid'"
+}
+
+let $wait_condition= SELECT COUNT(*)=1 FROM performance_schema.replication_group_members
+                     WHERE MEMBER_ROLE="PRIMARY" AND
+                           MEMBER_ID="$group_replication_expected_uuid";
 --source include/wait_condition_or_abort.inc
 
 --let $include_filename= gr_wait_primary_member_uuid.inc

mysql-test/suite/group_replication/include/gr_single_primary_with_transaction_isolation.inc

@@ -32,7 +32,7 @@
 #     between server1 and server2
 #
 #   $test_parameter_primary_uuid
-#     Test verifies if the group_replication_primary_member has this uuid
+#     Test verifies if the primary member has this uuid
 #
 
 --let $include_filename= gr_single_primary_with_transaction_isolation.inc
@@ -49,8 +49,20 @@
 
 --source include/start_and_bootstrap_group_replication.inc
 
---let $group_replication_expected_uuid= $test_parameter_primary_uuid
---source include/gr_wait_primary_member_uuid.inc
+if ($test_parameter_single_primary_mode == TRUE)
+{
+  --let $group_replication_expected_uuid= $test_parameter_primary_uuid
+  --source include/gr_wait_primary_member_uuid.inc
+}
+
+if ($test_parameter_single_primary_mode == FALSE)
+{
+  #if multi-primary the members ONLINE in the group all should be primary
+  --let $_gr_wait_primary_member_uuid_online_count = query_get_value(SELECT COUNT(*) COUNT FROM performance_schema.replication_group_members WHERE member_state="ONLINE", COUNT, 1)
+  --let $wait_condition= SELECT COUNT(*)=$_gr_wait_primary_member_uuid_online_count FROM performance_schema.replication_group_members WHERE MEMBER_ROLE="PRIMARY"
+  --source include/wait_condition_or_abort.inc
+}
+
 
 --echo # CONFIGURE SERVER 2
 --let $rpl_connection_name= server2
@@ -60,8 +72,19 @@
 --eval SET SESSION transaction_isolation=$test_parameter_tx_isolation
 --source include/start_group_replication.inc
 
---let $group_replication_expected_uuid= $test_parameter_primary_uuid
---source include/gr_wait_primary_member_uuid.inc
+if ($test_parameter_single_primary_mode == TRUE)
+{
+  --let $group_replication_expected_uuid= $test_parameter_primary_uuid
+  --source include/gr_wait_primary_member_uuid.inc
+}
+
+if ($test_parameter_single_primary_mode == FALSE)
+{
+  #if multi-primary the members ONLINE in the group all should be primary
+  --let $_gr_wait_primary_member_uuid_online_count = query_get_value(SELECT COUNT(*) COUNT FROM performance_schema.replication_group_members WHERE member_state="ONLINE", COUNT, 1)
+  --let $wait_condition= SELECT COUNT(*)=$_gr_wait_primary_member_uuid_online_count FROM performance_schema.replication_group_members WHERE MEMBER_ROLE="PRIMARY"
+  --source include/wait_condition_or_abort.inc
+}
 
 --echo # WRITE DATA ON SERVER 1 (ISOLATION LEVEL $test_parameter_tx_isolation)
 --echo # AND VERIFY PRESENCE OF THE DATA ON SERVER 2

mysql-test/suite/group_replication/r/gr_acf_57_sources.result

@@ -12,7 +12,7 @@ include/start_and_bootstrap_group_replication.inc
 [connection server2]
 include/start_group_replication.inc
 
-include/assert.inc [Verify group_replication_primary_member is SERVER_UUID]
+include/assert.inc [Verify primary member has given SERVER_UUID]
 
 #-- On Server1
 [connection server1]

mysql-test/suite/group_replication/r/gr_random_password.result

@@ -47,7 +47,6 @@ Gr_transactions_consistency_after_termination_count	0
 Gr_transactions_consistency_after_termination_time_sum	0
 Gr_transactions_consistency_before_begin_count	0
 Gr_transactions_consistency_before_begin_time_sum	0
-group_replication_primary_member	
 SHOW GLOBAL STATUS LIKE 'Gr\_%';
 Variable_name	Value
 Gr_all_consensus_proposals_count	0

mysql-test/suite/group_replication/r/gr_show_status_on_start.result

@@ -49,7 +49,7 @@ include/gr_wait_for_member_state.inc
 #
 include/gr_wait_for_role_count.inc
 include/assert.inc ['Old primary server should be in ERROR state';]
-include/assert.inc ['group_replication_primary_member should be set to UNDEFINED when replication node is in error state';]
+include/assert.inc ['No primary defined when replication node is in error state';]
 #
 # Stage 4. Clean up.
 #

mysql-test/suite/group_replication/r/gr_single_primary_and_leader_election_on_error.result

@@ -60,19 +60,19 @@ include/assert.inc [Assert that server has group_replication_member_weight=97 af
 #    based on member weight.
 [connection server1]
 include/gr_wait_primary_member_uuid.inc
-include/assert.inc [Verify group_replication_primary_member is server1]
+include/assert.inc [Verify server1 is primary]
 include/stop_group_replication.inc
 [connection server4]
 include/gr_wait_primary_member_uuid.inc
-include/assert.inc [Verify group_replication_primary_member is server4]
+include/assert.inc [Verify server4 is primary]
 include/stop_group_replication.inc
 [connection server2]
 include/gr_wait_primary_member_uuid.inc
-include/assert.inc [Verify group_replication_primary_member is server2]
+include/assert.inc [Verify server2 is primary]
 include/stop_group_replication.inc
 [connection server3]
 include/gr_wait_primary_member_uuid.inc
-include/assert.inc [Verify group_replication_primary_member is server3]
+include/assert.inc [Verify server3 is primary]
 include/stop_group_replication.inc
 [connection server1]
 SET @@GLOBAL.group_replication_member_weight= DEFAULT;

mysql-test/suite/group_replication/r/gr_single_primary_and_leader_election_weight.result

@@ -42,7 +42,7 @@ INSERT INTO t1 VALUES(1,1);
 include/stop_group_replication.inc
 [connection server2]
 include/rpl_gr_wait_for_number_of_members.inc
-include/assert.inc [Verify group_replication_primary_member is SERVER_UUID]
+include/assert.inc [Verify server2 is primary]
 
 ###########################################################
 # 4. Configure server 1 with recovery credentials from server

mysql-test/suite/group_replication/r/gr_single_primary_double_change.result

@@ -11,7 +11,7 @@ Note	####	Storing MySQL user name or password information in the connection meta
 include/start_and_bootstrap_group_replication.inc
 [connection server2]
 include/start_group_replication.inc
-include/assert.inc [Verify group_replication_primary_member is SERVER_UUID]
+include/assert.inc [Verify server1 is primary]
 
 ############################################################
 # 2. Create two tables, one with a foreign key