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
|
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 connection metadata repository is not secure and is therefore not recommended. Please consider using the USER and PASSWORD connection options for START REPLICA; see the 'START REPLICA Syntax' in the MySQL Manual for more information.
[connection master]
[connection slave]
TRUNCATE TABLE performance_schema.events_transactions_current;
---- Setup ----
[connection master]
CREATE TABLE t ( f INT) ENGINE=INNODB;
---- XA PREPARE ----
XA START 'xatest';
INSERT INTO t VALUES (10);
XA END 'xatest';
XA PREPARE 'xatest';
include/sync_slave_sql_with_master.inc
# Wait for XA_STATE to become PREPARED on slave
# Expecting one prepared transaction
XA RECOVER;
formatID gtrid_length bqual_length data
1 6 0 xatest
Waiting until gtid is MASTER_UUID:2
---- XA COMMIT ----
[connection master]
XA COMMIT 'xatest';
include/sync_slave_sql_with_master.inc
# Wait for XA_STATE to become COMMITTED on slave
# Expecting no prepared transactions
XA RECOVER;
formatID gtrid_length bqual_length data
Waiting until gtid is MASTER_UUID:3
include/diff_tables.inc [master:t,slave:t]
[connection master]
DROP TABLE t;
include/sync_slave_sql_with_master.inc
include/rpl_reset.inc
####################################################################
# Test Case 2: Enable Multithreaded Slave with replica_parallel_type as
# DATABASE. Verify that slave displays appropriate XA_STATE in
# performance schema table, post XA PREPARE AND XA COMMIT command
# execution.
####################################################################
[connection slave]
SET @save_replica_parallel_workers=@@global.replica_parallel_workers;
SET @replica_parallel_type=@@global.replica_parallel_type;
include/stop_slave.inc
SET GLOBAL replica_parallel_workers=4;
SET GLOBAL replica_parallel_type='DATABASE';
include/start_slave.inc
[connection slave]
TRUNCATE TABLE performance_schema.events_transactions_current;
---- Setup ----
[connection master]
CREATE TABLE t ( f INT) ENGINE=INNODB;
---- XA PREPARE ----
XA START 'xatest';
INSERT INTO t VALUES (10);
XA END 'xatest';
XA PREPARE 'xatest';
include/sync_slave_sql_with_master.inc
# Wait for XA_STATE to become PREPARED on slave
# Expecting one prepared transaction
XA RECOVER;
formatID gtrid_length bqual_length data
1 6 0 xatest
Waiting until gtid is MASTER_UUID:2
---- XA COMMIT ----
[connection master]
XA COMMIT 'xatest';
include/sync_slave_sql_with_master.inc
# Wait for XA_STATE to become COMMITTED on slave
# Expecting no prepared transactions
XA RECOVER;
formatID gtrid_length bqual_length data
Waiting until gtid is MASTER_UUID:3
include/diff_tables.inc [master:t,slave:t]
[connection master]
DROP TABLE t;
include/sync_slave_sql_with_master.inc
include/rpl_reset.inc
####################################################################
# Test Case 3: Enable Multithreaded Slave with replica_parallel_type as
# LOGICAL_CLOCK. Verify that slave displays appropriate XA_STATE in
# performance schema table, post XA PREPARE AND XA COMMIT command
# execution.
####################################################################
include/stop_slave.inc
SET GLOBAL replica_parallel_workers=4;
SET GLOBAL replica_parallel_type='LOGICAL_CLOCK';
include/start_slave.inc
[connection slave]
TRUNCATE TABLE performance_schema.events_transactions_current;
---- Setup ----
[connection master]
CREATE TABLE t ( f INT) ENGINE=INNODB;
---- XA PREPARE ----
XA START 'xatest';
INSERT INTO t VALUES (10);
XA END 'xatest';
XA PREPARE 'xatest';
include/sync_slave_sql_with_master.inc
# Wait for XA_STATE to become PREPARED on slave
# Expecting one prepared transaction
XA RECOVER;
formatID gtrid_length bqual_length data
1 6 0 xatest
Waiting until gtid is MASTER_UUID:2
---- XA COMMIT ----
[connection master]
XA COMMIT 'xatest';
include/sync_slave_sql_with_master.inc
# Wait for XA_STATE to become COMMITTED on slave
# Expecting no prepared transactions
XA RECOVER;
formatID gtrid_length bqual_length data
Waiting until gtid is MASTER_UUID:3
include/diff_tables.inc [master:t,slave:t]
[connection master]
DROP TABLE t;
include/sync_slave_sql_with_master.inc
[connection slave]
include/stop_slave.inc
set @@global.replica_parallel_workers= @save_replica_parallel_workers;
set @@global.replica_parallel_type= @replica_parallel_type;
include/start_slave.inc
include/rpl_end.inc
|
