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
|
# Tests for PERFORMANCE_SCHEMA
# Test requires master-info-repository=TABLE, relay-log-info-repository=TABLE
--source include/have_slave_repository_type_table.inc
#setup
let $select_column = SERVICE_STATE;
let $table = performance_schema.replication_applier_status_by_worker;
--disable_warnings
--source include/master-slave.inc
--connection slave
--source include/stop_slave.inc
RESET SLAVE ALL;
SET @old_replica_parallel_workers= @@global.replica_parallel_workers;
SET GLOBAL replica_parallel_workers = 4;
--disable_query_log
--eval CHANGE REPLICATION SOURCE TO SOURCE_HOST='localhost', SOURCE_USER='root', SOURCE_PORT=$MASTER_MYPORT, SOURCE_DELAY=0 FOR CHANNEL 'channel_1';
--enable_query_log
--source include/start_slave.inc
--connection master
--let $rpl_channel_name= 'channel_1'
--let $sync_slave_connection= slave
--source include/sync_slave_sql_with_master.inc
select CHANNEL_NAME, WORKER_ID, THREAD_ID
from performance_schema.replication_applier_status_by_worker
where WORKER_ID = 1
into @c_name, @w_id, @t_id;
# Make sure we found data to look at.
select @c_name, @w_id, @t_id is not null;
# Debug
# select * from performance_schema.replication_applier_status_by_worker;
--enable_warnings
###########################################################################
# Test index on CHANNEL_NAME, WORKER_ID
###########################################################################
let $column_count = 2;
let $col1 = CHANNEL_NAME;
let $col2 = WORKER_ID;
let $col1_act = @c_name;
let $col2_act = @w_id;
--source ../include/idx_explain_test.inc
###########################################################################
# Test index on THREAD_ID
###########################################################################
let $column_count = 1;
let $col1 = THREAD_ID;
let $col1_act = @t_id;
--source ../include/idx_explain_test.inc
# Cleanup
source include/stop_slave.inc;
RESET SLAVE ALL;
SET GLOBAL replica_parallel_workers= @old_replica_parallel_workers;
--disable_warnings
--disable_query_log
eval CHANGE REPLICATION SOURCE to SOURCE_HOST='127.0.0.1', SOURCE_PORT=$MASTER_MYPORT, SOURCE_USER='root';
--enable_query_log
--enable_warnings
--let $rpl_channel_name=
--let $sync_slave_connection= slave
source include/start_slave.inc;
--connection master
--source include/rpl_end.inc
|
