Note #### Sending passwords in plain text without SSL/TLS is extremely insecure.
Note #### Storing MySQL user name or password information in the master info repository is not secure and is therefore not recommended. Please consider using the USER and PASSWORD connection options for START SLAVE; see the 'START SLAVE Syntax' in the MySQL Manual for more information.
[connection master]
[connection master]
connection master;
connection master;
drop table if exists t1;
drop table if exists t1;
...
@@ -17,19 +14,22 @@ kp2 int,
...
@@ -17,19 +14,22 @@ kp2 int,
col1 int,
col1 int,
key (kp1,kp2)
key (kp1,kp2)
) engine=rocksdb;
) engine=rocksdb;
set @tmp_binlog_format=@@binlog_format;
set @@binlog_format=ROW;
insert into t2 select a,a,a,a from t1;
insert into t2 select a,a,a,a from t1;
create table t3 like t2;
create table t3 like t2;
insert into t3 select * from t2;
insert into t3 select * from t2;
set binlog_format=@tmp_binlog_format;
include/sync_slave_sql_with_master.inc
include/sync_slave_sql_with_master.inc
connection slave;
connection slave;
set global debug= 'd,dbug.rocksdb.get_row_by_rowid';
set global debug_dbug= 'd,dbug.rocksdb.get_row_by_rowid';
include/stop_slave.inc
include/stop_slave.inc
include/start_slave.inc
include/start_slave.inc
connection master;
connection master;
update t2 set col1=100 where kp1 between 1 and 3 and mod(kp2,2)=0;
update t2 set col1=100 where kp1 between 1 and 3 and mod(kp2,2)=0;
connection slave;
connection slave;
set debug_sync= 'now WAIT_FOR Reached';
set debug_sync= 'now WAIT_FOR Reached';
set global debug = '';
set global debug_dbug = '';
set sql_log_bin=0;
set sql_log_bin=0;
delete from t2 where pk=2;
delete from t2 where pk=2;
delete from t2 where pk=3;
delete from t2 where pk=3;
...
@@ -43,7 +43,7 @@ pk kp1 kp2 col1
...
@@ -43,7 +43,7 @@ pk kp1 kp2 col1
1 1 1 1
1 1 1 1
4 4 4 4
4 4 4 4
connection slave;
connection slave;
set global debug= 'd,dbug.rocksdb.get_row_by_rowid';
set global debug_dbug= 'd,dbug.rocksdb.get_row_by_rowid';
include/stop_slave.inc
include/stop_slave.inc
include/start_slave.inc
include/start_slave.inc
connection master;
connection master;
...
@@ -51,7 +51,7 @@ update t3 set col1=100 where kp1 between 1 and 4 and mod(kp2,2)=0;
...
@@ -51,7 +51,7 @@ update t3 set col1=100 where kp1 between 1 and 4 and mod(kp2,2)=0;
connection slave;
connection slave;
call mtr.add_suppression("Deadlock found when trying to get lock");
call mtr.add_suppression("Deadlock found when trying to get lock");