WL#12819:GTIDs: Replicate from GTID disabled source to GTID enabled replica directly

This worklog implements a new option ASSIGN_GTIDS_TO_ANONYMOUS_TRANSACTIONS = [OFF|LOCAL|uuid]
which will be a per channel property to be specified with
CHANGE MASTER that allows direct data flows between a non-GTID
replication setup and a GTID replication setup.
After this worklog, a user shall be able to replicate from a
GTID disabled source to a GTID enabled replica without any other
middleware or any upgrade procedure.

RB: 24033

Author: Neha Kumari

mysql-test/extra/rpl_tests/restart_slave_with_custom_relaylog_repo_file.inc

@@ -146,6 +146,123 @@ localhost
 EOF
 END_OF_PROCEDURE
 
+--write_file $MYSQL_TMP_DIR/create_file_repo_with_no_assign_gtids_to_anonymous_transactions.inc END_OF_PROCEDURE
+  --write_file $MYSQLD_DATADIR/$filename
+12
+./slave-relay-bin.000001
+4
+
+0
+0
+0
+1
+
+root
+localhost
+0
+1
+EOF
+END_OF_PROCEDURE
+
+--write_file $MYSQL_TMP_DIR/create_file_repo_with_invalid_type_assign_gtids_to_anonymous_transactions.inc END_OF_PROCEDURE
+  --write_file $MYSQLD_DATADIR/$filename
+14
+./slave-relay-bin.000001
+4
+
+0
+0
+0
+1
+
+root
+localhost
+0
+1
+6
+
+EOF
+END_OF_PROCEDURE
+
+--write_file $MYSQL_TMP_DIR/create_file_repo_with_invalid_default_value_for_type_off_assign_gtids_to_anonymous_transactions.inc END_OF_PROCEDURE
+  --write_file $MYSQLD_DATADIR/$filename
+14
+./slave-relay-bin.000001
+4
+
+0
+0
+0
+1
+
+root
+localhost
+0
+1
+1
+aaaaaaaa-aaaa-aaaa-aaaa-aaaaaaaaaaaaa
+EOF
+END_OF_PROCEDURE
+
+--write_file $MYSQL_TMP_DIR/create_file_repo_with_invalid_value_for_type_not_off_assign_gtids_to_anonymous_transactions.inc END_OF_PROCEDURE
+  --write_file $MYSQLD_DATADIR/$filename
+14
+./slave-relay-bin.000001
+4
+
+0
+0
+0
+1
+
+root
+localhost
+0
+1
+3
+
+EOF
+END_OF_PROCEDURE
+
+--write_file $MYSQL_TMP_DIR/create_file_repo_with_invalid_value_assign_gtids_to_anonymous_transactions.inc END_OF_PROCEDURE
+  --write_file $MYSQLD_DATADIR/$filename
+14
+./slave-relay-bin.000001
+4
+
+0
+0
+0
+1
+
+root
+localhost
+0
+1
+3
+aaaaaaaa-aaaa-aaaa-aaaa-aaaaaaaaaaa
+EOF
+END_OF_PROCEDURE
+
+--write_file $MYSQL_TMP_DIR/create_file_repo_with_no_value_assign_gtids_to_anonymous_transactions.inc END_OF_PROCEDURE
+  --write_file $MYSQLD_DATADIR/$filename
+13
+./slave-relay-bin.000001
+4
+
+0
+0
+0
+1
+
+root
+localhost
+0
+1
+3
+EOF
+END_OF_PROCEDURE
+
 --let $MYSQLD_DATADIR= `select @@datadir`
 --let $filename = `SELECT @@relay_log_info_file`
 
@@ -178,7 +295,24 @@ if ($sub_testcase == no_require_table_primary_key_check) {
 if ($sub_testcase == invalid_require_table_primary_key_check) {
   --source $MYSQL_TMP_DIR/create_file_repo_with_invalid_require_table_primary_key_check.inc
 }
-
+if ($sub_testcase == no_assign_gtids_to_anonymous_transactions) {
+  --source $MYSQL_TMP_DIR/create_file_repo_with_no_assign_gtids_to_anonymous_transactions.inc
+}
+if ($sub_testcase == invalid_type_assign_gtids_to_anonymous_transactions) {
+  --source $MYSQL_TMP_DIR/create_file_repo_with_invalid_type_assign_gtids_to_anonymous_transactions.inc
+}
+if ($sub_testcase == invalid_default_value_for_type_off_assign_gtids_to_anonymous_transactions) {
+  --source $MYSQL_TMP_DIR/create_file_repo_with_invalid_default_value_for_type_off_assign_gtids_to_anonymous_transactions.inc
+}
+if ($sub_testcase == invalid_value_for_type_not_off_assign_gtids_to_anonymous_transactions) {
+  --source $MYSQL_TMP_DIR/create_file_repo_with_invalid_value_for_type_not_off_assign_gtids_to_anonymous_transactions.inc
+}
+if ($sub_testcase == invalid_value_assign_gtids_to_anonymous_transactions) {
+  --source $MYSQL_TMP_DIR/create_file_repo_with_invalid_value_assign_gtids_to_anonymous_transactions.inc
+}
+if ($sub_testcase == no_value_assign_gtids_to_anonymous_transactions) {
+  --source $MYSQL_TMP_DIR/create_file_repo_with_no_value_assign_gtids_to_anonymous_transactions.inc
+}
 --let $rpl_server_parameters= $rpl_server_restart_parameters
 
 --let $explicit_default_wait_counter = 15000
@@ -192,3 +326,9 @@ if ($sub_testcase == invalid_require_table_primary_key_check) {
 --remove_file $MYSQL_TMP_DIR/create_file_repo_with_nonexist_PCU.inc
 --remove_file $MYSQL_TMP_DIR/create_file_repo_with_no_require_table_primary_key_check.inc
 --remove_file $MYSQL_TMP_DIR/create_file_repo_with_invalid_require_table_primary_key_check.inc
+--remove_file $MYSQL_TMP_DIR/create_file_repo_with_no_assign_gtids_to_anonymous_transactions.inc
+--remove_file $MYSQL_TMP_DIR/create_file_repo_with_invalid_type_assign_gtids_to_anonymous_transactions.inc
+--remove_file $MYSQL_TMP_DIR/create_file_repo_with_invalid_default_value_for_type_off_assign_gtids_to_anonymous_transactions.inc
+--remove_file $MYSQL_TMP_DIR/create_file_repo_with_invalid_value_assign_gtids_to_anonymous_transactions.inc
+--remove_file $MYSQL_TMP_DIR/create_file_repo_with_invalid_value_for_type_not_off_assign_gtids_to_anonymous_transactions.inc
+--remove_file $MYSQL_TMP_DIR/create_file_repo_with_no_value_assign_gtids_to_anonymous_transactions.inc

mysql-test/include/rpl_end.inc

@@ -14,11 +14,14 @@
 #
 # ==== Usage ====
 #
-# [--let $rpl_only_running_threads= 1]
-# [--let $rpl_debug= 1]
-# [--let $rpl_group_replication= 1]
-# [--let $rpl_gtid_utils= 1]
-# [--let $rpl_assert_transaction_length= 1]
+# [--let $rpl_skip_sync = 1]
+# [--let $rpl_skip_delete_channels = 1]
+# [--let $rpl_skip_stop_slave = 1]
+# [--let $rpl_only_running_threads = 1]
+# [--let $rpl_debug = 1]
+# [--let $rpl_group_replication = 1]
+# [--let $rpl_gtid_utils = 1]
+# [--let $rpl_assert_transaction_length = 1]
 # --source include/rpl_end.inc
 #
 # Parameters:

mysql-test/r/information_schema_keywords.result

@@ -24,6 +24,7 @@ AS	1
 ASC	1
 ASCII	0
 ASENSITIVE	1
+ASSIGN_GTIDS_TO_ANONYMOUS_TRANSACTIONS	0
 AT	0
 ATTRIBUTE	0
 AUTOEXTEND_SIZE	0

mysql-test/r/mysqldump.result

@@ -5347,6 +5347,8 @@ CREATE TABLE IF NOT EXISTS `slave_relay_log_info` (
   `Privilege_checks_hostname` char(255) CHARACTER SET ascii COLLATE ascii_general_ci DEFAULT NULL COMMENT 'Hostname part of PRIVILEGE_CHECKS_USER.',
   `Require_row_format` tinyint(1) NOT NULL COMMENT 'Indicates whether the channel shall only accept row based events.',
   `Require_table_primary_key_check` enum('STREAM','ON','OFF') NOT NULL DEFAULT 'STREAM' COMMENT 'Indicates what is the channel policy regarding tables having primary keys on create and alter table queries',
+  `Assign_gtids_to_anonymous_transactions_type` enum('OFF','LOCAL','UUID') NOT NULL DEFAULT 'OFF' COMMENT 'Indicates whether the channel will generate a new GTID for anonymous transactions. OFF means that anonymous transactions will remain anonymous. LOCAL means that anonymous transactions will be assigned a newly generated GTID based on server_uuid. UUID indicates that anonymous transactions will be assigned a newly generated GTID based on Assign_gtids_to_anonymous_transactions_value',
+  `Assign_gtids_to_anonymous_transactions_value` text CHARACTER SET utf8 COLLATE utf8_bin COMMENT 'Indicates the UUID used while generating GTIDs for anonymous transactions',
   PRIMARY KEY (`Channel_name`)
 ) /*!50100 TABLESPACE `mysql` */ ENGINE=InnoDB DEFAULT CHARSET=utf8 STATS_PERSISTENT=0 ROW_FORMAT=DYNAMIC COMMENT='Relay Log Information';
 /*!40101 SET character_set_client = @saved_cs_client */;

mysql-test/suite/funcs_1/r/is_columns_mysql.result

@@ -188,6 +188,8 @@ def	mysql	slave_relay_log_info	Privilege_checks_username	10	NULL	YES	char	32	96
 def	mysql	slave_relay_log_info	Privilege_checks_hostname	11	NULL	YES	char	255	255	NULL	NULL	NULL	ascii	ascii_general_ci	char(255)			select,insert,update,references	Hostname part of PRIVILEGE_CHECKS_USER.		NULL
 def	mysql	slave_relay_log_info	Require_row_format	12	NULL	NO	tinyint	NULL	NULL	3	0	NULL	NULL	NULL	tinyint(1)			select,insert,update,references	Indicates whether the channel shall only accept row based events.		NULL
 def	mysql	slave_relay_log_info	Require_table_primary_key_check	13	STREAM	NO	enum	6	18	NULL	NULL	NULL	utf8	utf8_general_ci	enum('STREAM','ON','OFF')			select,insert,update,references	Indicates what is the channel policy regarding tables having primary keys on create and alter table queries		NULL
+def	mysql	slave_relay_log_info	Assign_gtids_to_anonymous_transactions_type	14	OFF	NO	enum	5	15	NULL	NULL	NULL	utf8	utf8_general_ci	enum('OFF','LOCAL','UUID')			select,insert,update,references	Indicates whether the channel will generate a new GTID for anonymous transactions. OFF means that anonymous transactions will remain anonymous. LOCAL means that anonymous transactions will be assigned a newly generated GTID based on server_uuid. UUID indicates that anonymous transactions will be assigned a newly generated GTID based on Assign_gtids_to_anonymous_transactions_value		NULL
+def	mysql	slave_relay_log_info	Assign_gtids_to_anonymous_transactions_value	15	NULL	YES	text	65535	65535	NULL	NULL	NULL	utf8	utf8_bin	text			select,insert,update,references	Indicates the UUID used while generating GTIDs for anonymous transactions		NULL
 def	mysql	slave_worker_info	Id	1	NULL	NO	int	NULL	NULL	10	0	NULL	NULL	NULL	int unsigned	PRI		select,insert,update,references			NULL
 def	mysql	slave_worker_info	Relay_log_name	2	NULL	NO	text	65535	65535	NULL	NULL	NULL	utf8	utf8_bin	text			select,insert,update,references			NULL
 def	mysql	slave_worker_info	Relay_log_pos	3	NULL	NO	bigint	NULL	NULL	20	0	NULL	NULL	NULL	bigint unsigned			select,insert,update,references			NULL
@@ -540,6 +542,8 @@ NULL	mysql	slave_relay_log_info	Id	int	NULL	NULL	NULL	NULL	int unsigned
 1.0000	mysql	slave_relay_log_info	Privilege_checks_hostname	char	255	255	ascii	ascii_general_ci	char(255)
 NULL	mysql	slave_relay_log_info	Require_row_format	tinyint	NULL	NULL	NULL	NULL	tinyint(1)
 3.0000	mysql	slave_relay_log_info	Require_table_primary_key_check	enum	6	18	utf8	utf8_general_ci	enum('STREAM','ON','OFF')
+3.0000	mysql	slave_relay_log_info	Assign_gtids_to_anonymous_transactions_type	enum	5	15	utf8	utf8_general_ci	enum('OFF','LOCAL','UUID')
+1.0000	mysql	slave_relay_log_info	Assign_gtids_to_anonymous_transactions_value	text	65535	65535	utf8	utf8_bin	text
 NULL	mysql	slave_worker_info	Id	int	NULL	NULL	NULL	NULL	int unsigned
 1.0000	mysql	slave_worker_info	Relay_log_name	text	65535	65535	utf8	utf8_bin	text
 NULL	mysql	slave_worker_info	Relay_log_pos	bigint	NULL	NULL	NULL	NULL	bigint unsigned