include/master-slave.inc
Warnings:
Note	####	Sending passwords in plain text without SSL/TLS is extremely insecure.
Note	####	Storing MySQL user name or password information in the master info repository is not secure and is therefore not recommended. Please consider using the USER and PASSWORD connection options for START SLAVE; see the 'START SLAVE Syntax' in the MySQL Manual for more information.
[connection master]
SET DEBUG = "d,set_commit_parent_100";
#
# Initialization the test
#
CREATE DATABASE db1;
CREATE DATABASE db2;
CREATE TABLE db1.t1(c1 INT PRIMARY KEY, c2 VARCHAR(4096)) ENGINE=InnoDB;
CREATE TABLE db1.t2(c1 INT PRIMARY KEY, c2 VARCHAR(4096)) ENGINE=InnoDB;
CREATE TABLE db2.t1(c1 INT PRIMARY KEY, c2 VARCHAR(4096)) ENGINE=InnoDB;
INSERT INTO db1.t1 VALUES(1, NULL), (10, NULL), (100, NULL);
INSERT INTO db1.t2 VALUES(1, NULL), (10, NULL), (100, NULL);
INSERT INTO db2.t1 VALUES(1, NULL), (10, NULL), (100, NULL);
include/sync_slave_sql_with_master.inc
CALL mtr.add_suppression("Slave SQL for channel '':.*Lock wait timeout exceeded.*");
CALL mtr.add_suppression("Slave SQL for channel '': Worker . failed executing transaction.*");
CALL mtr.add_suppression("Slave SQL for channel '': .*Error_code: 1756");
CALL mtr.add_suppression("Slave SQL for channel '': worker thread retried transaction.*");
SET @saved_innodb_lock_wait_timeout = @@GLOBAL.innodb_lock_wait_timeout;
SET @saved_slave_parallel_workers = @@GLOBAL.slave_parallel_workers;
SET @saved_slave_parallel_type = @@GLOBAL.slave_parallel_type;
SET @saved_max_relay_log_size = @@GLOBAL.max_relay_log_size;
SET @saved_slave_transaction_retries = @@GLOBAL.slave_transaction_retries;
SET GLOBAL innodb_lock_wait_timeout = 1;
SET GLOBAL slave_parallel_workers = 2;
SET GLOBAL max_relay_log_size = 4096;
include/stop_slave_sql.inc
SET GLOBAL slave_parallel_type = "LOGICAL_CLOCK";
include/start_slave_sql.inc
#
# Case 1: slave will stop if slave_transaction_retries is 0
#
SET GLOBAL slave_transaction_retries = 0;
BEGIN;
SELECT c1 FROM db1.t1 FOR UPDATE;
c1
1
10
100
[connection master]
INSERT INTO db1.t1 VALUES(2, NULL);
INSERT INTO db2.t1 VALUES(2, NULL);
include/save_master_pos.inc
[connection slave]
include/wait_for_slave_sql_error.inc [errno=1205]
include/assert.inc [Value 2 is not in db1.t1.]
ROLLBACK;
#
# Case 2: Slave will stop after retrying a transaction
#         slave_transaction_retries times.
#
SET GLOBAL slave_transaction_retries = 2;
include/start_slave_sql.inc
include/sync_slave_sql.inc
BEGIN;
SELECT c1 FROM db1.t2 FOR UPDATE;
c1
1
10
100
[connection master]
BEGIN;
INSERT INTO db1.t1 VALUES(20, NULL);
INSERT INTO db1.t2 VALUES(20, NULL);
COMMIT;
INSERT INTO db2.t1 VALUES(20, NULL);
include/save_master_pos.inc
[connection slave]
include/wait_for_slave_sql_error.inc [errno=1205]
include/assert.inc [Value 20 is not in db1.t1.]
ROLLBACK;
#
# Case 3: Slave worker will not stop after retring a transaction
#         sucessfully.
#
SET GLOBAL slave_transaction_retries = 10;
include/start_slave_sql.inc
include/sync_slave_sql.inc
include/check_slave_no_error.inc
BEGIN;
SELECT c1 FROM db1.t2 FOR UPDATE;
c1
1
10
20
100
[connection master]
BEGIN;
# INSERT INTO db1.t1 VALUES(30, 4096'a')
# INSERT INTO db1.t1 VALUES(31, 4096'a')
SET @str= 'abc';
INSERT INTO db1.t2 VALUES(30, @str);
COMMIT;
INSERT INTO db2.t1 VALUES(30, NULL);
include/save_master_pos.inc
[connection slave]
include/check_slave_no_error.inc
ROLLBACK;
include/sync_slave_sql.inc
include/check_slave_no_error.inc
include/rpl_diff.inc
include/rpl_diff.inc
include/rpl_diff.inc
[connection master]
INSERT INTO db1.t1 VALUES(40, NULL);
INSERT INTO db2.t1 VALUES(40, NULL);
include/sync_slave_sql_with_master.inc
#
# Case 4: Non-temporary error will stop slave workers without retrying
#
INSERT INTO db1.t1 VALUES(50, NULL);
[connection master]
INSERT INTO db1.t1 VALUES(50, NULL);
include/save_master_pos.inc
[connection slave]
include/wait_for_slave_sql_error.inc [errno=1062]
include/assert.inc [slave_retried_transactions should not increase]
DELETE FROM db1.t1 WHERE c1 = 50;
include/start_slave_sql.inc
include/sync_slave_sql.inc
#
# Cleanup
#
SET GLOBAL innodb_lock_wait_timeout = @saved_innodb_lock_wait_timeout;
SET GLOBAL slave_parallel_workers = @saved_slave_parallel_workers;
SET GLOBAL max_relay_log_size = @saved_max_relay_log_size;
SET GLOBAL slave_transaction_retries = @saved_slave_transaction_retries;
include/stop_slave_sql.inc
SET GLOBAL slave_parallel_type= @saved_slave_parallel_type;
include/start_slave_sql.inc
[connection master]
DROP DATABASE db1;
DROP DATABASE db2;
include/rpl_end.inc