WL#10655 - Global notification for GR membership changes

The purpose of this worklog is to supply to the client an information about
group replication view changes without pulling the system by the client.
On X Protocol level, client can enable following group-replication notices:
quorum loss, view change, role change, state change.

Approved-by: Mohit Joshi <[email protected]>

Author: lkotula

mysql-test/include/xplugin_create_user.inc

@@ -1,4 +1,22 @@
+#==== Usage ====
+#
+#[--let $create_user_disable_binlog = 1]
+#-- source include/xplugin_create_user.inc
+#
+
 --disable_query_log
-CREATE USER 'x_root'@'localhost' IDENTIFIED WITH 'mysql_native_password';
-GRANT ALL ON *.* TO 'x_root'@'localhost' WITH GRANT OPTION;
+
+if ($create_user_disable_binlog)
+{
+  SET SESSION sql_log_bin = 0;
+}
+
+CREATE USER 'x_root' @'localhost' IDENTIFIED WITH 'mysql_native_password';
+GRANT ALL ON *.*TO 'x_root' @'localhost' WITH GRANT OPTION;
+
+if ($create_user_disable_binlog)
+{
+  SET SESSION sql_log_bin = 1;
+}
+
 --enable_query_log

mysql-test/suite/x/r/mysqlxtest_help.result

@@ -135,6 +135,10 @@ The following commands may appear in the input script:
   Stops reading commands, disconnects and exits (same as <eof>/^D)
 -->abort
   Exit immediately, without performing cleanup
+-->shutdown_server [timeout]
+  Shutdown the server associated with current session,
+  in case when the 'timeout' argument was set to '0'(for now it only supported
+  option), the command kills the server.
 -->nowarnings/-->yeswarnings
   Whether to print warnings generated by the statement (default no)
 -->recvuntildisc [show-received]
@@ -149,10 +153,18 @@ The following commands may appear in the input script:
 -->loginerror <errno>	<user>	<pass>	<db>
   Performs authentication steps expecting an error (use with --no-auth)
 -->fatalerrors/nofatalerrors
-  Whether to immediately exit on MySQL errors
--->expecterror <errno>
-  Expect a specific error for the next command and fail if something else occurs
-  Works for: newsession, closesession, recvresult, recvok
+  Whether to immediately exit on MySQL errors.
+  All expected errors are ignored.
+-->fatalwarnings [yes|no|true|false|1|0]
+  Whether to immediately exit on MySQL warnings.
+  All expected warnings are ignored.
+-->expectwarnings <errno>[,<errno>[,<errno>...]]
+  Expect a specific warning for the next command. Fails if warning other than specified occurred.
+  When this command was not used then all warnings are expected.
+  Works for: recvresult, SQL
+-->expecterror <errno>[,<errno>[,<errno>...]]
+  Expect a specific error for the next command. Fails if error other than specified occurred
+  Works for: newsession, closesession, recvresult, recvok, SQL
 -->newsession <name>	<user>	<pass>	<db>
   Create a new connection which is going to be authenticate using sequence of mechanisms (AUTO). Use '-' in place of the user for raw connection.
 -->newsession_mysql41 <name>	<user>	<pass>	<db>
@@ -161,6 +173,8 @@ The following commands may appear in the input script:
   Create a new connection which is going to be authenticate using SHA256_MEMORY mechanism.
 -->newsession_plain <name>	<user>	<pass>	<db>
   Create a new connection which is going to be authenticate using PLAIN mechanism.
+-->reconnect
+  Try to restore the connection/session. Default connection  is restored or session established by '-->newsession*'.
 -->setsession <name>
   Activate the named session
 -->closesession [abort]

mysql-test/suite/x/r/notice_warning.result

@@ -340,6 +340,26 @@ Mysqlx.Resultset.Row {
   field: "\002"
 }
 
+Mysqlx.Resultset.Row {
+  field: "group_replication/membership/quorum_loss\000"
+  field: "\000"
+}
+
+Mysqlx.Resultset.Row {
+  field: "group_replication/membership/view\000"
+  field: "\000"
+}
+
+Mysqlx.Resultset.Row {
+  field: "group_replication/status/role_change\000"
+  field: "\000"
+}
+
+Mysqlx.Resultset.Row {
+  field: "group_replication/status/state_change\000"
+  field: "\000"
+}
+
 Mysqlx.Resultset.Row {
   field: "account_expired\000"
   field: "\002"

mysql-test/suite/x/r/notice_warning_mysqlx.result

@@ -39,6 +39,10 @@ Warnings generated:
 WARNING | 1265 | Data truncated for column 'd' at row 1
 notice	enabled
 warnings	1
+group_replication/membership/quorum_loss	0
+group_replication/membership/view	0
+group_replication/status/role_change	0
+group_replication/status/state_change	0
 account_expired	1
 generated_insert_id	1
 rows_affected	1

mysql-test/suite/x/r/notices_disable.result

@@ -2713,6 +2713,7 @@ Mysqlx.Error {
 expect Mysqlx_stmt_disable_notices=5 and remaining are 0
 RUN show status like 'Mysqlx%notice%'
 Variable_name	Value
+Mysqlx_notice_global_sent	0
 Mysqlx_notice_other_sent	2
 Mysqlx_notice_warning_sent	0
 Mysqlx_stmt_disable_notices	5
@@ -2833,6 +2834,7 @@ Mysqlx.Error {
 expect Mysqlx_stmt_disable_notices=5 and remaining are 0
 RUN show status like 'Mysqlx%notice%'
 Variable_name	Value
+Mysqlx_notice_global_sent	0
 Mysqlx_notice_other_sent	2
 Mysqlx_notice_warning_sent	0
 Mysqlx_stmt_disable_notices	5
@@ -3167,6 +3169,26 @@ Mysqlx.Resultset.Row {
   field: "\002"
 }
 
+Mysqlx.Resultset.Row {
+  field: "group_replication/membership/quorum_loss\000"
+  field: "\000"
+}
+
+Mysqlx.Resultset.Row {
+  field: "group_replication/membership/view\000"
+  field: "\000"
+}
+
+Mysqlx.Resultset.Row {
+  field: "group_replication/status/role_change\000"
+  field: "\000"
+}
+
+Mysqlx.Resultset.Row {
+  field: "group_replication/status/state_change\000"
+  field: "\000"
+}
+
 Mysqlx.Resultset.Row {
   field: "account_expired\000"
   field: "\002"
@@ -3281,6 +3303,26 @@ Mysqlx.Resultset.Row {
   field: "\002"
 }
 
+Mysqlx.Resultset.Row {
+  field: "group_replication/membership/quorum_loss\000"
+  field: "\000"
+}
+
+Mysqlx.Resultset.Row {
+  field: "group_replication/membership/view\000"
+  field: "\000"
+}
+
+Mysqlx.Resultset.Row {
+  field: "group_replication/status/role_change\000"
+  field: "\000"
+}
+
+Mysqlx.Resultset.Row {
+  field: "group_replication/status/state_change\000"
+  field: "\000"
+}
+
 Mysqlx.Resultset.Row {
   field: "account_expired\000"
   field: "\002"

mysql-test/suite/x/r/notices_disable_mysqlx.result

@@ -409,6 +409,7 @@ Try Disable produced_message
 Got expected error: Cannot disable notice produced_message (code 5164)
 expect Mysqlx_stmt_disable_notices=5 and remaining are 0
 Variable_name	Value
+Mysqlx_notice_global_sent	0
 Mysqlx_notice_other_sent	1
 Mysqlx_notice_warning_sent	0
 Mysqlx_stmt_disable_notices	5
@@ -433,6 +434,7 @@ Try Disable produced_message
 Got expected error: Cannot disable notice produced_message (code 5164)
 expect Mysqlx_stmt_disable_notices=5 and remaining are 0
 Variable_name	Value
+Mysqlx_notice_global_sent	0
 Mysqlx_notice_other_sent	1
 Mysqlx_notice_warning_sent	0
 Mysqlx_stmt_disable_notices	5
@@ -542,6 +544,10 @@ expect error from account_expired onwards as it is read-only though warnings ret
 Got expected error: Cannot disable notice account_expired (code 5164)
 notice	enabled
 warnings	1
+group_replication/membership/quorum_loss	0
+group_replication/membership/view	0
+group_replication/status/role_change	0
+group_replication/status/state_change	0
 account_expired	1
 generated_insert_id	1
 rows_affected	1
@@ -551,6 +557,10 @@ expect error as disabling account_expired returns error as expected since it is
 Got expected error: Cannot disable notice account_expired (code 5164)
 notice	enabled
 warnings	1
+group_replication/membership/quorum_loss	0
+group_replication/membership/view	0
+group_replication/status/role_change	0
+group_replication/status/state_change	0
 account_expired	1
 generated_insert_id	1
 rows_affected	1

mysql-test/suite/x/r/notices_enable.result

@@ -7810,8 +7810,9 @@ Mysqlx.Error {
 0 rows affected
 
 0 rows affected
-Verify [Status variable "Mysqlx_notice_other_sent" needs to have a value of 37]
+Verify [Status variable "Mysqlx_notice_global_sent" needs to have a value of 0]
 Verify [Status variable "Mysqlx_notice_warning_sent" needs to have a value of 32]
+Verify [Status variable "Mysqlx_notice_other_sent" needs to have a value of 39]
 Verify [Status variable "Mysqlx_stmt_disable_notices" needs to have a value of 0]
 Verify [Status variable "Mysqlx_stmt_enable_notices" needs to have a value of 0]
 Verify [Status variable "Mysqlx_stmt_list_notices" needs to have a value of 0]
@@ -7839,8 +7840,9 @@ Try enable produced_message
 Mysqlx.Sql.StmtExecuteOk {
 }
 
-Verify [Status variable "Mysqlx_notice_other_sent" needs to have a value of 2]
+Verify [Status variable "Mysqlx_notice_global_sent" needs to have a value of 0]
 Verify [Status variable "Mysqlx_notice_warning_sent" needs to have a value of 0]
+Verify [Status variable "Mysqlx_notice_other_sent" needs to have a value of 4]
 Verify [Status variable "Mysqlx_stmt_disable_notices" needs to have a value of 0]
 Verify [Status variable "Mysqlx_stmt_enable_notices" needs to have a value of 5]
 Verify [Status variable "Mysqlx_stmt_list_notices" needs to have a value of 0]
@@ -7869,8 +7871,9 @@ Try enable produced_message
 Mysqlx.Sql.StmtExecuteOk {
 }
 
-Verify [Status variable "Mysqlx_notice_other_sent" needs to have a value of 2]
+Verify [Status variable "Mysqlx_notice_global_sent" needs to have a value of 0]
 Verify [Status variable "Mysqlx_notice_warning_sent" needs to have a value of 0]
+Verify [Status variable "Mysqlx_notice_other_sent" needs to have a value of 4]
 Verify [Status variable "Mysqlx_stmt_disable_notices" needs to have a value of 0]
 Verify [Status variable "Mysqlx_stmt_enable_notices" needs to have a value of 5]
 Verify [Status variable "Mysqlx_stmt_list_notices" needs to have a value of 0]
@@ -7907,6 +7910,26 @@ Mysqlx.Resultset.Row {
   field: "\002"
 }
 
+Mysqlx.Resultset.Row {
+  field: "group_replication/membership/quorum_loss\000"
+  field: "\000"
+}
+
+Mysqlx.Resultset.Row {
+  field: "group_replication/membership/view\000"
+  field: "\000"
+}
+
+Mysqlx.Resultset.Row {
+  field: "group_replication/status/role_change\000"
+  field: "\000"
+}
+
+Mysqlx.Resultset.Row {
+  field: "group_replication/status/state_change\000"
+  field: "\000"
+}
+
 Mysqlx.Resultset.Row {
   field: "account_expired\000"
   field: "\002"
@@ -7933,8 +7956,9 @@ Mysqlx.Resultset.FetchDone {
 Mysqlx.Sql.StmtExecuteOk {
 }
 
-Verify [Status variable "Mysqlx_notice_other_sent" needs to have a value of 2]
+Verify [Status variable "Mysqlx_notice_global_sent" needs to have a value of 0]
 Verify [Status variable "Mysqlx_notice_warning_sent" needs to have a value of 0]
+Verify [Status variable "Mysqlx_notice_other_sent" needs to have a value of 4]
 Verify [Status variable "Mysqlx_stmt_disable_notices" needs to have a value of 0]
 Verify [Status variable "Mysqlx_stmt_enable_notices" needs to have a value of 1]
 Verify [Status variable "Mysqlx_stmt_list_notices" needs to have a value of 1]
@@ -7997,6 +8021,26 @@ Mysqlx.Resultset.Row {
   field: "\002"
 }
 
+Mysqlx.Resultset.Row {
+  field: "group_replication/membership/quorum_loss\000"
+  field: "\000"
+}
+
+Mysqlx.Resultset.Row {
+  field: "group_replication/membership/view\000"
+  field: "\000"
+}
+
+Mysqlx.Resultset.Row {
+  field: "group_replication/status/role_change\000"
+  field: "\000"
+}
+
+Mysqlx.Resultset.Row {
+  field: "group_replication/status/state_change\000"
+  field: "\000"
+}
+
 Mysqlx.Resultset.Row {
   field: "account_expired\000"
   field: "\002"
@@ -8049,6 +8093,26 @@ Mysqlx.Resultset.Row {
   field: "\002"
 }
 
+Mysqlx.Resultset.Row {
+  field: "group_replication/membership/quorum_loss\000"
+  field: "\000"
+}
+
+Mysqlx.Resultset.Row {
+  field: "group_replication/membership/view\000"
+  field: "\000"
+}
+
+Mysqlx.Resultset.Row {
+  field: "group_replication/status/role_change\000"
+  field: "\000"
+}
+
+Mysqlx.Resultset.Row {
+  field: "group_replication/status/state_change\000"
+  field: "\000"
+}
+
 Mysqlx.Resultset.Row {
   field: "account_expired\000"
   field: "\002"
@@ -8075,8 +8139,9 @@ Mysqlx.Resultset.FetchDone {
 Mysqlx.Sql.StmtExecuteOk {
 }
 
-Verify [Status variable "Mysqlx_notice_other_sent" needs to have a value of 4]
+Verify [Status variable "Mysqlx_notice_global_sent" needs to have a value of 0]
 Verify [Status variable "Mysqlx_notice_warning_sent" needs to have a value of 1]
+Verify [Status variable "Mysqlx_notice_other_sent" needs to have a value of 6]
 Verify [Status variable "Mysqlx_stmt_disable_notices" needs to have a value of 1]
 Verify [Status variable "Mysqlx_stmt_enable_notices" needs to have a value of 2]
 Verify [Status variable "Mysqlx_stmt_list_notices" needs to have a value of 2]
@@ -8102,8 +8167,9 @@ Mysqlx.Notice.Frame {
 Mysqlx.Sql.StmtExecuteOk {
 }
 
-Verify [Status variable "Mysqlx_notice_other_sent" needs to have a value of 3]
+Verify [Status variable "Mysqlx_notice_global_sent" needs to have a value of 0]
 Verify [Status variable "Mysqlx_notice_warning_sent" needs to have a value of 1]
+Verify [Status variable "Mysqlx_notice_other_sent" needs to have a value of 5]
 Verify [Status variable "Mysqlx_stmt_disable_notices" needs to have a value of 0]
 Verify [Status variable "Mysqlx_stmt_enable_notices" needs to have a value of 0]
 Verify [Status variable "Mysqlx_stmt_list_notices" needs to have a value of 0]
@@ -8122,8 +8188,9 @@ Mysqlx.Error {
   sql_state: "3D000"
 }
 
-Verify [Status variable "Mysqlx_notice_other_sent" needs to have a value of 1]
+Verify [Status variable "Mysqlx_notice_global_sent" needs to have a value of 0]
 Verify [Status variable "Mysqlx_notice_warning_sent" needs to have a value of 0]
+Verify [Status variable "Mysqlx_notice_other_sent" needs to have a value of 3]
 Verify [Status variable "Mysqlx_stmt_disable_notices" needs to have a value of 0]
 Verify [Status variable "Mysqlx_stmt_enable_notices" needs to have a value of 0]
 Verify [Status variable "Mysqlx_stmt_list_notices" needs to have a value of 0]