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
|
#
# ==== Purpose ====
#
# This test checks if the immediate_commit_timestamp (ICT) and the
# original_commit_timestamp (OCT) are generated and replicated correctly in a
# server_1 (Master) -> server_2,server_3-> server_2 topology, all of them mysql-5.8+
#
# ==== Implementation ====
#
# Considering the Multi Source replication, we make the following
# assertions:
# 1) original_commit_timestamp is same across topology for a transaction.
# 2) On the original server, original_commit_timestamp = immediate_commit_timestamp.
# 2) the immediate_commit_timestamp increases as we go down in the topology.
#
#
# ==== References ====
#
# WL#7319 Infrastructure for correct replication lag monitoring
# Legend:
# OCT: original_commit_timestamp
# ICT: immediate_commit_timestamp
--source include/have_binlog_format_row.inc
# Test requires master-info-repository=TABLE, relay-log-info-repository=TABLE
--source include/have_slave_repository_type_table.inc
# Establish the msr topology.
--let $rpl_topology=1->2,3->2
--let $rpl_multi_source= 1
--source include/rpl_init.inc
--let $rpl_connection_name= server_1
--source include/rpl_connection.inc
--let $server_1_uuid= query_get_value(select @@global.server_uuid, @@global.server_uuid, 1)
CREATE DATABASE db1;
CREATE TABLE db1.t1(a int);
INSERT INTO db1.t1 VALUES(1);
UPDATE db1.t1 SET a=2;
DELETE FROM db1.t1 WHERE a=1;
DROP TABLE db1.t1;
DROP DATABASE db1;
--let $rpl_channel_name= 'channel_1'
--let $sync_slave_connection=server_2
--source include/sync_slave_sql_with_master.inc
--let $rpl_connection_name= server_3
--source include/rpl_connection.inc
--let $server_3_uuid= query_get_value(select @@global.server_uuid, @@global.server_uuid, 1)
CREATE DATABASE db2;
CREATE TABLE db2.t2(a int);
INSERT INTO db2.t2 VALUES(1);
UPDATE db2.t2 SET a=2;
DELETE FROM db2.t2 WHERE a=1;
DROP TABLE db2.t2;
DROP DATABASE db2;
--let $rpl_channel_name= 'channel_3'
--let $sync_slave_connection=server_2
--source include/sync_slave_sql_with_master.inc
--let $check_master_OCT= 1
--let $check_master_slave_ICT= 1
--let $i=1
while($i<8)
{
--let $gtid= $server_1_uuid:$i
--let $master= server_1
--let $slave=server_2
--source extra/rpl_tests/rpl_replication_timestamps.inc
--let $gtid= $server_3_uuid:$i
--let $master=server_3
--let $slave=server_2
--source extra/rpl_tests/rpl_replication_timestamps.inc
--inc $i
}
--let $rpl_skip_sync= 1
--source include/rpl_end.inc
|
