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
127
128
129
130
131
132
133
134
135
136
137
138
139
140
|
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]
call mtr.add_suppression("Replica SQL for channel '':.* Could not execute Write_rows event on table test.t1");
call mtr.add_suppression("Replica SQL for channel '':.* Could not execute Update_rows event on table d1.t1; Deadlock found when trying to get lock");
call mtr.add_suppression("The replica coordinator and worker threads are stopped, possibly leaving data in inconsistent state");
create view worker_proc_list as SELECT id from Information_Schema.processlist
where state like 'Waiting for an event from Coordinator';
create view coord_proc_list as SELECT id from Information_Schema.processlist where state like 'Replica has read all relay log%';
include/stop_slave.inc
set @save.replica_parallel_workers= @@global.replica_parallel_workers;
set @@global.replica_parallel_workers= 4;
include/start_slave.inc
select min(id) from worker_proc_list into @w_id;
Warnings:
Warning 1287 'INFORMATION_SCHEMA.PROCESSLIST' is deprecated and will be removed in a future release. Please use performance_schema.processlist instead
kill query @w_id;
include/wait_for_slave_sql_to_stop.inc
include/start_slave.inc
select id from coord_proc_list into @c_id;
Warnings:
Warning 1287 'INFORMATION_SCHEMA.PROCESSLIST' is deprecated and will be removed in a future release. Please use performance_schema.processlist instead
kill query @c_id;
include/wait_for_slave_sql_error.inc [errno=1756]
include/start_slave.inc
CREATE TABLE t1 (a int primary key) engine=innodb;
insert into t1 values (1),(2);
include/sync_slave_sql_with_master.inc
insert into t1 values (3);
insert into t1 values (3);
include/wait_for_slave_sql_to_stop.inc
delete from t1 where a=3;
set @save.replica_transaction_retries= @@global.replica_transaction_retries;
set @@global.replica_transaction_retries= 10;
include/start_slave.inc
include/sync_slave_sql_with_master.inc
delete from t1;
include/sync_slave_sql_with_master.inc
insert into t1 values (1),(2),(3);
create table t2m (a int) engine=myisam;
insert into t2m values (1);
include/sync_slave_sql_with_master.inc
begin;
update t1 set a=31 where a=3;
insert into t1 values (5),(6),(7);
update t1 set a=a+10;
begin;
update t1 set a=20 where a=2;
insert into t2m values (2);
update t1 set a=30 where a=3;
commit;
update t1 set a=21 where a=2;
rollback;
include/sync_slave_sql_with_master.inc
stop slave sql_thread;
Warnings:
Warning 1287 'STOP SLAVE' is deprecated and will be removed in a future release. Please use STOP REPLICA instead
set @@global.sql_replica_skip_counter=7;
begin;
select max(a) + 1 from t1 into @a;
insert into t1 set a=@a;
commit;
begin;
select max(a) + 1 from t1 into @a;
insert into t1 set a=@a;
commit;
begin;
select max(a) + 1 from t1 into @a;
insert into t1 set a=@a;
commit;
start slave sql_thread;
Warnings:
Warning 1287 'START SLAVE' is deprecated and will be removed in a future release. Please use START REPLICA instead
include/sync_slave_sql_with_master.inc
include/stop_slave.inc
create table t2 (a int);
insert into t2 values (1);
start slave until SOURCE_LOG_FILE='master-bin.000001', SOURCE_LOG_POS=MASTER_LOG_POS;
Warnings:
Warning 1287 'START SLAVE' is deprecated and will be removed in a future release. Please use START REPLICA instead
include/wait_for_slave_sql_to_stop.inc
include/start_slave.inc
drop table t1;
drop table t2m;
drop table t2;
include/sync_slave_sql_with_master.inc
drop view worker_proc_list;
drop view coord_proc_list;
set @@global.replica_transaction_retries= 0;
include/stop_slave.inc
start slave until sql_after_mts_gaps relay_log_file='dummy';
ERROR 42000: You have an error in your SQL syntax; check the manual that corresponds to your MySQL server version for the right syntax to use near 'relay_log_file='dummy'' at line 1
start slave until sql_after_mts_gaps relay_log_pos=0;
ERROR 42000: You have an error in your SQL syntax; check the manual that corresponds to your MySQL server version for the right syntax to use near 'relay_log_pos=0' at line 1
start slave until sql_after_mts_gaps SOURCE_LOG_FILE='dummy';
ERROR 42000: You have an error in your SQL syntax; check the manual that corresponds to your MySQL server version for the right syntax to use near 'SOURCE_LOG_FILE='dummy'' at line 1
start slave until sql_after_mts_gaps SOURCE_LOG_POS=0;
ERROR 42000: You have an error in your SQL syntax; check the manual that corresponds to your MySQL server version for the right syntax to use near 'SOURCE_LOG_POS=0' at line 1
start slave until sql_after_mts_gaps SQL_BEFORE_GTIDS='dummy';
ERROR 42000: You have an error in your SQL syntax; check the manual that corresponds to your MySQL server version for the right syntax to use near 'SQL_BEFORE_GTIDS='dummy'' at line 1
call mtr.add_suppression('Replica SQL for channel '': Could not execute Update_rows event on table d1.t1; Deadlock found when trying to get lock');
include/start_slave.inc
create database d1;
create database d2;
create table d1.t1 (a int primary key) engine=innodb;
create table d2.t1 (a int primary key) engine=innodb;
create table d1.t2m (a int) engine=myisam;
insert into d1.t1 values (1),(2),(3);
insert into d2.t1 values (1),(2),(3);
insert into d1.t2m values (1);
include/sync_slave_sql_with_master.inc
begin;
update d1.t1 set a=31 where a=3;
insert into d1.t1 values (5),(6),(7);
begin;
update d1.t1 set a=20 where a=2;
insert into d1.t2m values (2);
update d1.t1 set a=30 where a=3;
insert into d1.t1 values (4);
begin;
delete from d2.t1;
commit;
commit;
delete from d1.t1;
update d1.t1 set a=21 where a=2;
include/wait_for_slave_sql_error.inc [errno=1213, 1205]
rollback;
start slave until sql_after_mts_gaps;
Warnings:
Warning 1287 'START SLAVE' is deprecated and will be removed in a future release. Please use START REPLICA instead
include/wait_for_slave_sql_to_stop.inc
set @@global.replica_parallel_workers= @save.replica_parallel_workers;
include/start_slave.inc
drop database d1;
drop database d2;
include/sync_slave_sql_with_master.inc
set @@global.replica_transaction_retries= @save.replica_transaction_retries;
include/rpl_end.inc
|
