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
|
# The test file is invoked from rpl.rpl_perfschema_order_by.test
#
# === References ===
# Bug #22958077: ORDER BY LAST_SEEN_TRANSACTION RESULTS IN EMPTY SET (OR DEBUG
# ASSERTION)
--echo # 1) Create a database on server_1.
--let $rpl_connection_name= server_1
--source include/rpl_connection.inc
CREATE DATABASE db1;
--echo # 2) create database on server_3.
--let $rpl_connection_name= server_3
--source include/rpl_connection.inc
CREATE DATABASE db3;
--echo # 3) sync the slave (server_2) with both masters (server_1 and server_3).
#sync the slave with server_1
--let $rpl_connection_name= server_1
--source include/rpl_connection.inc
--let $rpl_channel_name= 'channel_1'
--let $sync_slave_connection= server_2
--source include/sync_slave_sql_with_master.inc
# sync the slave with server_3
--let $rpl_connection_name= server_3
--source include/rpl_connection.inc
--let $rpl_channel_name= 'channel_3'
--let $sync_slave_connection=server_2
--source include/sync_slave_sql_with_master.inc
# Restart slave for channel_3 so that SELECT returns unsorted data.
--let $rpl_channel_name= 'channel_3'
--source include/stop_slave.inc
--source include/start_slave.inc
--echo
SELECT CHANNEL_NAME FROM performance_schema.replication_applier_configuration;
SELECT CHANNEL_NAME FROM performance_schema.replication_applier_configuration ORDER BY CHANNEL_NAME;
--echo
SELECT CHANNEL_NAME FROM performance_schema.replication_applier_status;
SELECT CHANNEL_NAME FROM performance_schema.replication_applier_status ORDER BY CHANNEL_NAME;
--echo
SELECT CHANNEL_NAME, LAST_ERROR_MESSAGE FROM performance_schema.replication_connection_status;
SELECT CHANNEL_NAME, LAST_ERROR_MESSAGE FROM performance_schema.replication_connection_status ORDER BY CHANNEL_NAME;
--echo
SELECT CHANNEL_NAME, TLS_VERSION FROM performance_schema.replication_connection_configuration;
SELECT CHANNEL_NAME, TLS_VERSION FROM performance_schema.replication_connection_configuration ORDER BY CHANNEL_NAME;
--let $is_mts= `SELECT @@global.replica_parallel_workers`
if ($is_mts)
{
--echo
SELECT CHANNEL_NAME, LAST_ERROR_MESSAGE FROM performance_schema.replication_applier_status_by_coordinator;
SELECT CHANNEL_NAME, LAST_ERROR_MESSAGE FROM performance_schema.replication_applier_status_by_coordinator ORDER BY CHANNEL_NAME;
}
--echo
SELECT CHANNEL_NAME, LAST_ERROR_MESSAGE FROM performance_schema.replication_applier_status_by_worker;
SELECT CHANNEL_NAME, LAST_ERROR_MESSAGE FROM performance_schema.replication_applier_status_by_worker ORDER BY CHANNEL_NAME;
--echo
# Cleanup
--let $rpl_connection_name= server_1
--source include/rpl_connection.inc
DROP DATABASE db1;
--let $rpl_connection_name= server_3
--source include/rpl_connection.inc
DROP DATABASE db3;
#sync the slave with server_1
--let $rpl_connection_name= server_1
--source include/rpl_connection.inc
--let $rpl_channel_name= 'channel_1'
--let $sync_slave_connection= server_2
--source include/sync_slave_sql_with_master.inc
# sync the slave with server_3
--let $rpl_connection_name= server_3
--source include/rpl_connection.inc
--let $rpl_channel_name= 'channel_3'
--let $sync_slave_connection=server_2
--source include/sync_slave_sql_with_master.inc
|
