Skip to content

M
MariaDB
Commit 05b1de99 authored by Elena Stepanova's avatar Elena Stepanova
Browse files
Options

More tests and test cleanup for MDEV-253 (Multi-source replication)

parent 1def7017
Expand all Show whitespace changes
Inline Side-by-side
Showing with 669 additions and 59 deletions
mysql-test/suite/multi_source/info_logs.result
View file @ 05b1de99
...@@ -87,6 +87,10 @@ show all slaves status; ...@@ -87,6 +87,10 @@ show all slaves status;
Connection_name Slave_SQL_State Slave_IO_State Master_Host Master_User Master_Port Connect_Retry Master_Log_File Read_Master_Log_Pos Relay_Log_File Relay_Log_Pos Relay_Master_Log_File Slave_IO_Running Slave_SQL_Running Replicate_Do_DB Replicate_Ignore_DB Replicate_Do_Table Replicate_Ignore_Table Replicate_Wild_Do_Table Replicate_Wild_Ignore_Table Last_Errno Last_Error Skip_Counter Exec_Master_Log_Pos Relay_Log_Space Until_Condition Until_Log_File Until_Log_Pos Master_SSL_Allowed Master_SSL_CA_File Master_SSL_CA_Path Master_SSL_Cert Master_SSL_Cipher Master_SSL_Key Seconds_Behind_Master Master_SSL_Verify_Server_Cert Last_IO_Errno Last_IO_Error Last_SQL_Errno Last_SQL_Error Replicate_Ignore_Server_Ids Master_Server_Id Retried_transactions Max_relay_log_size Executed_log_entries Slave_received_heartbeats Slave_heartbeat_period Connection_name Slave_SQL_State Slave_IO_State Master_Host Master_User Master_Port Connect_Retry Master_Log_File Read_Master_Log_Pos Relay_Log_File Relay_Log_Pos Relay_Master_Log_File Slave_IO_Running Slave_SQL_Running Replicate_Do_DB Replicate_Ignore_DB Replicate_Do_Table Replicate_Ignore_Table Replicate_Wild_Do_Table Replicate_Wild_Ignore_Table Last_Errno Last_Error Skip_Counter Exec_Master_Log_Pos Relay_Log_Space Until_Condition Until_Log_File Until_Log_Pos Master_SSL_Allowed Master_SSL_CA_File Master_SSL_CA_Path Master_SSL_Cert Master_SSL_Cipher Master_SSL_Key Seconds_Behind_Master Master_SSL_Verify_Server_Cert Last_IO_Errno Last_IO_Error Last_SQL_Errno Last_SQL_Error Replicate_Ignore_Server_Ids Master_Server_Id Retried_transactions Max_relay_log_size Executed_log_entries Slave_received_heartbeats Slave_heartbeat_period
Slave has read all relay log; waiting for the slave I/O thread to update it Waiting for master to send event 127.0.0.1 root MYPORT_1 60 master-bin.000001 286 relay.000002 572 master-bin.000001 Yes Yes 0 0 286 857 None 0 No 0 No 0 0 1 0 1073741824 6 0 60.000 Slave has read all relay log; waiting for the slave I/O thread to update it Waiting for master to send event 127.0.0.1 root MYPORT_1 60 master-bin.000001 286 relay.000002 572 master-bin.000001 Yes Yes 0 0 286 857 None 0 No 0 No 0 0 1 0 1073741824 6 0 60.000
MASTER 2.2 Slave has read all relay log; waiting for the slave I/O thread to update it Waiting for master to send event 127.0.0.1 root MYPORT_2 60 master-bin.000001 286 relay-master@00202@002e2.000002 572 master-bin.000001 Yes Yes 0 0 286 876 None 0 No 0 No 0 0 2 0 1073741824 6 0 60.000 MASTER 2.2 Slave has read all relay log; waiting for the slave I/O thread to update it Waiting for master to send event 127.0.0.1 root MYPORT_2 60 master-bin.000001 286 relay-master@00202@002e2.000002 572 master-bin.000001 Yes Yes 0 0 286 876 None 0 No 0 No 0 0 2 0 1073741824 6 0 60.000
include/wait_for_slave_to_start.inc
set default_master_connection = 'MASTER 2.2';
include/wait_for_slave_to_start.inc
set default_master_connection = '';
show all slaves status; show all slaves status;
Connection_name Slave_SQL_State Slave_IO_State Master_Host Master_User Master_Port Connect_Retry Master_Log_File Read_Master_Log_Pos Relay_Log_File Relay_Log_Pos Relay_Master_Log_File Slave_IO_Running Slave_SQL_Running Replicate_Do_DB Replicate_Ignore_DB Replicate_Do_Table Replicate_Ignore_Table Replicate_Wild_Do_Table Replicate_Wild_Ignore_Table Last_Errno Last_Error Skip_Counter Exec_Master_Log_Pos Relay_Log_Space Until_Condition Until_Log_File Until_Log_Pos Master_SSL_Allowed Master_SSL_CA_File Master_SSL_CA_Path Master_SSL_Cert Master_SSL_Cipher Master_SSL_Key Seconds_Behind_Master Master_SSL_Verify_Server_Cert Last_IO_Errno Last_IO_Error Last_SQL_Errno Last_SQL_Error Replicate_Ignore_Server_Ids Master_Server_Id Retried_transactions Max_relay_log_size Executed_log_entries Slave_received_heartbeats Slave_heartbeat_period Connection_name Slave_SQL_State Slave_IO_State Master_Host Master_User Master_Port Connect_Retry Master_Log_File Read_Master_Log_Pos Relay_Log_File Relay_Log_Pos Relay_Master_Log_File Slave_IO_Running Slave_SQL_Running Replicate_Do_DB Replicate_Ignore_DB Replicate_Do_Table Replicate_Ignore_Table Replicate_Wild_Do_Table Replicate_Wild_Ignore_Table Last_Errno Last_Error Skip_Counter Exec_Master_Log_Pos Relay_Log_Space Until_Condition Until_Log_File Until_Log_Pos Master_SSL_Allowed Master_SSL_CA_File Master_SSL_CA_Path Master_SSL_Cert Master_SSL_Cipher Master_SSL_Key Seconds_Behind_Master Master_SSL_Verify_Server_Cert Last_IO_Errno Last_IO_Error Last_SQL_Errno Last_SQL_Error Replicate_Ignore_Server_Ids Master_Server_Id Retried_transactions Max_relay_log_size Executed_log_entries Slave_received_heartbeats Slave_heartbeat_period
Slave has read all relay log; waiting for the slave I/O thread to update it Waiting for master to send event 127.0.0.1 root MYPORT_1 60 master-bin.000001 286 relay.000004 532 master-bin.000001 Yes Yes 0 0 286 817 None 0 No 0 No 0 0 1 0 1073741824 6 0 60.000 Slave has read all relay log; waiting for the slave I/O thread to update it Waiting for master to send event 127.0.0.1 root MYPORT_1 60 master-bin.000001 286 relay.000004 532 master-bin.000001 Yes Yes 0 0 286 817 None 0 No 0 No 0 0 1 0 1073741824 6 0 60.000
...@@ -106,10 +110,6 @@ relay.bin.info ...@@ -106,10 +110,6 @@ relay.bin.info
MASTER 2.2 MASTER 2.2
# EOF # EOF
# #
stop slave; include/reset_master_slave.inc
include/wait_for_slave_to_stop.inc include/reset_master_slave.inc
set default_master_connection = 'MASTER 2.2'; include/reset_master_slave.inc
stop slave;
include/wait_for_slave_to_stop.inc
reset slave all;
reset slave '' all;
mysql-test/suite/multi_source/info_logs.test
View file @ 05b1de99
...@@ -56,6 +56,12 @@ start slave 'MASTER 2.2'; ...@@ -56,6 +56,12 @@ start slave 'MASTER 2.2';
set default_master_connection = 'MASTER 2.2'; set default_master_connection = 'MASTER 2.2';
--source include/wait_for_slave_to_start.inc --source include/wait_for_slave_to_start.inc
--connect (master2,127.0.0.1,root,,,$SERVER_MYPORT_2)
--save_master_pos
--connection slave
--sync_with_master 0,'MASTER 2.2'
# Check the files # Check the files
--echo # --echo #
...@@ -102,6 +108,12 @@ master_user='root'; ...@@ -102,6 +108,12 @@ master_user='root';
start slave; start slave;
--source include/wait_for_slave_to_start.inc --source include/wait_for_slave_to_start.inc
--connect (master1,127.0.0.1,root,,,$SERVER_MYPORT_1)
--save_master_pos
--connection slave
--sync_with_master
# Check the files # Check the files
--echo # --echo #
...@@ -115,7 +127,6 @@ start slave; ...@@ -115,7 +127,6 @@ start slave;
--echo # EOF --echo # EOF
--echo # --echo #
--sleep 5
--replace_result $SERVER_MYPORT_1 MYPORT_1 $SERVER_MYPORT_2 MYPORT_2 --replace_result $SERVER_MYPORT_1 MYPORT_1 $SERVER_MYPORT_2 MYPORT_2
show all slaves status; show all slaves status;
...@@ -127,6 +138,10 @@ restart ...@@ -127,6 +138,10 @@ restart
EOF EOF
--shutdown_server 60 --shutdown_server 60
--source include/wait_until_connected_again.inc --source include/wait_until_connected_again.inc
--source include/wait_for_slave_to_start.inc
set default_master_connection = 'MASTER 2.2';
--source include/wait_for_slave_to_start.inc
set default_master_connection = '';
--replace_result $SERVER_MYPORT_1 MYPORT_1 $SERVER_MYPORT_2 MYPORT_2 --replace_result $SERVER_MYPORT_1 MYPORT_1 $SERVER_MYPORT_2 MYPORT_2
show all slaves status; show all slaves status;
...@@ -148,13 +163,14 @@ show all slaves status; ...@@ -148,13 +163,14 @@ show all slaves status;
# Cleanup # Cleanup
stop slave; --source reset_master_slave.inc
--source include/wait_for_slave_to_stop.inc --disconnect slave
set default_master_connection = 'MASTER 2.2'; --connection master1
stop slave; --source reset_master_slave.inc
--source include/wait_for_slave_to_stop.inc --disconnect master1
reset slave all;
reset slave '' all; --connection master2
--source reset_master_slave.inc
--disconnect master2
--disconnect slave
mysql-test/suite/multi_source/multisource.result 0 → 100644
View file @ 05b1de99
This diff is collapsed.
mysql-test/suite/multi_source/multisource.test 0 → 100644
View file @ 05b1de99
--source include/have_innodb.inc
--connect (slave,127.0.0.1,root,,,$SERVER_MYPORT_3)
# Start replication from the first master
--replace_result $SERVER_MYPORT_1 MYPORT_1
eval change master 'master1' to
master_port=$SERVER_MYPORT_1,
master_host='127.0.0.1',
master_user='root';
start slave 'master1';
set default_master_connection = 'master1';
--source include/wait_for_slave_to_start.inc
--connect (master1,127.0.0.1,root,,,$SERVER_MYPORT_1)
--save_master_pos
--connection slave
--sync_with_master 0,'master1'
# each of the 3 commands should produce
# 'master1' status
--replace_result $SERVER_MYPORT_1 MYPORT_1
show slave 'master1' status;
--replace_result $SERVER_MYPORT_1 MYPORT_1
show slave status;
--replace_result $SERVER_MYPORT_1 MYPORT_1
show all slaves status;
# Check that replication actually works
--connection master1
--disable_warnings
drop database if exists db1;
--enable_warnings
create database db1;
use db1;
create table t1 (i int auto_increment, f1 varchar(16), primary key pk (i,f1)) engine=MyISAM;
insert into t1 (f1) values ('one'),('two');
--save_master_pos
--connection slave
--sync_with_master 0,'master1'
--sorted_result
select * from db1.t1;
--let $datadir = `SELECT @@datadir`
--echo # List of relay log files in the datadir
--list_files $datadir mysqld-relay-bin-master1.*
# Check that relay logs are recognizable
show relaylog events;
show relaylog events in 'mysqld-relay-bin-master1.000002';
# Try to configure connection with the same name again,
# should get an error because the slave is running
--replace_result $SERVER_MYPORT_2 MYPORT_2
--error ER_SLAVE_MUST_STOP
eval change master 'master1' to
master_port=$SERVER_MYPORT_2,
master_host='127.0.0.1',
master_user='root';
# Try to configure using the default connection name
# (which is 'master1' at the moment),
# again, should get an error
--replace_result $SERVER_MYPORT_2 MYPORT_2
--error ER_SLAVE_MUST_STOP
eval change master to
master_port=$SERVER_MYPORT_2,
master_host='127.0.0.1',
master_user='root';
# Try to configure a connection with the same master
# using a different name, should get a conflict
--replace_result $SERVER_MYPORT_1 MYPORT_1
--error ER_CONNECTION_ALREADY_EXISTS
eval change master 'master2' to
master_port=$SERVER_MYPORT_1,
master_host='127.0.0.1',
master_user='root';
# Set up a proper 'default' connection to master2
set default_master_connection = '';
--replace_result $SERVER_MYPORT_2 MYPORT_2
eval change master to
master_port=$SERVER_MYPORT_2,
master_host='127.0.0.1',
master_user='root';
start slave;
--source include/wait_for_slave_to_start.inc
# See both connections in the same status output
--replace_result $SERVER_MYPORT_1 MYPORT_1 $SERVER_MYPORT_2 MYPORT_2
show all slaves status;
# Check that replication from two servers actually works
--connection master1
insert into t1 (f1) values ('three');
--save_master_pos
--connect (master2,127.0.0.1,root,,,$SERVER_MYPORT_2)
--disable_warnings
drop database if exists db2;
--enable_warnings
create database db2;
use db2;
create table t1 (pk int auto_increment primary key, f1 int) engine=InnoDB;
begin;
insert into t1 (f1) values (1),(2);
--connection slave
--sync_with_master 0,'master1'
--connection master2
--save_master_pos
--connection slave
--sync_with_master 0
--sorted_result
select * from db1.t1;
select * from db2.t1;
--connection master2
commit;
--save_master_pos
--connection slave
--sync_with_master 0
--sorted_result
select * from db2.t1;
# Flush and purge logs on one master,
# make sure slaves don't get confused
--connection master1
flush logs;
--save_master_pos
--connection slave
--sync_with_master 0, 'master1'
--connection master1
purge binary logs to 'master-bin.000002';
show binary logs;
insert into t1 (f1) values ('four');
create table db1.t3 (f1 int) engine=InnoDB;
--save_master_pos
--connection slave
--sync_with_master 0,'master1'
--replace_result $SERVER_MYPORT_1 MYPORT_1 $SERVER_MYPORT_2 MYPORT_2
show all slaves status;
--sorted_result
select * from db1.t1;
# This should show relay log events for the default master
# (the one with the empty name)
show relaylog events;
show relaylog events in 'mysqld-relay-bin.000002';
# Make sure we don't lose control over replication connections
# after reconnecting to the slave
--disconnect slave
--connect (slave,127.0.0.1,root,,,$SERVER_MYPORT_3)
stop slave io_thread;
show status like 'Slave_running';
set default_master_connection = 'master1';
show status like 'Slave_running';
# Cleanup
drop database db1;
drop database db2;
--source reset_master_slave.inc
--disconnect slave
--connection master1
drop database db1;
--source reset_master_slave.inc
--disconnect master1
--connection master2
drop database db2;
--source reset_master_slave.inc
--disconnect master2
mysql-test/suite/multi_source/relaylog_events.result
View file @ 05b1de99
...@@ -23,7 +23,5 @@ Log_name Pos Event_type Server_id End_log_pos Info ...@@ -23,7 +23,5 @@ Log_name Pos Event_type Server_id End_log_pos Info
mysqld-relay-bin-master1.000001 4 Format_desc 3 246 Server version mysqld-relay-bin-master1.000001 4 Format_desc 3 246 Server version
mysqld-relay-bin-master1.000001 246 Rotate 3 304 mysqld-relay-bin-master1.000002;pos=4 mysqld-relay-bin-master1.000001 246 Rotate 3 304 mysqld-relay-bin-master1.000002;pos=4
drop table t1; drop table t1;
stop slave; include/reset_master_slave.inc
include/wait_for_slave_to_stop.inc include/reset_master_slave.inc
reset slave 'master1' all;
reset master;
mysql-test/suite/multi_source/relaylog_events.test
View file @ 05b1de99
...@@ -39,14 +39,11 @@ drop table t1; ...@@ -39,14 +39,11 @@ drop table t1;
--connection slave --connection slave
--sync_with_master 0,'master1' --sync_with_master 0,'master1'
stop slave;
--source include/wait_for_slave_to_stop.inc
reset slave 'master1' all;
--source reset_master_slave.inc
--disconnect slave --disconnect slave
--connection master1 --connection master1
reset master; --source reset_master_slave.inc
--disconnect master1 --disconnect master1
mysql-test/suite/multi_source/reset_master_slave.inc 0 → 100644
View file @ 05b1de99
#
# The include file runs RESET ALL for every replication connection
# currently present in SHOW FULL SLAVE STATUS output on the server,
# and also runs RESET MASTER on the same server.
#
--let $include_filename= reset_master_slave.inc
--source include/begin_include_file.inc
--disable_query_log
--disable_result_log
--disable_warnings
--let $default_master = `SELECT @@default_master_connection`
--let $con_name = query_get_value(show all slaves status, Connection_name, 1)
while ($con_name != 'No such row')
{
eval set default_master_connection = '$con_name';
stop slave;
--source include/wait_for_slave_to_stop.inc
reset slave all;
--let $con_name = query_get_value(show all slaves status, Connection_name, 1)
}
--error 0,ER_FLUSH_MASTER_BINLOG_CLOSED
reset master;
eval set default_master_connection = '$default_master';
--source include/end_include_file.inc
mysql-test/suite/multi_source/reset_slave.result
View file @ 05b1de99
...@@ -23,5 +23,6 @@ reset slave 'master1' all; ...@@ -23,5 +23,6 @@ reset slave 'master1' all;
show slave 'master1' status; show slave 'master1' status;
ERROR HY000: There is no master connection 'master1' ERROR HY000: There is no master connection 'master1'
drop table t1; drop table t1;
include/reset_master_slave.inc
drop table t1; drop table t1;
reset master; include/reset_master_slave.inc
mysql-test/suite/multi_source/reset_slave.test
View file @ 05b1de99
...@@ -51,11 +51,12 @@ show slave 'master1' status; ...@@ -51,11 +51,12 @@ show slave 'master1' status;
# Cleanup # Cleanup
drop table t1; drop table t1;
--source reset_master_slave.inc
--disconnect slave --disconnect slave
--connection master1 --connection master1
drop table t1; drop table t1;
reset master; --source reset_master_slave.inc
--disconnect master1 --disconnect master1
......
mysql-test/suite/multi_source/simple.result
View file @ 05b1de99
...@@ -72,4 +72,6 @@ show all slaves status; ...@@ -72,4 +72,6 @@ show all slaves status;
Connection_name Slave_SQL_State Slave_IO_State Master_Host Master_User Master_Port Connect_Retry Master_Log_File Read_Master_Log_Pos Relay_Log_File Relay_Log_Pos Relay_Master_Log_File Slave_IO_Running Slave_SQL_Running Replicate_Do_DB Replicate_Ignore_DB Replicate_Do_Table Replicate_Ignore_Table Replicate_Wild_Do_Table Replicate_Wild_Ignore_Table Last_Errno Last_Error Skip_Counter Exec_Master_Log_Pos Relay_Log_Space Until_Condition Until_Log_File Until_Log_Pos Master_SSL_Allowed Master_SSL_CA_File Master_SSL_CA_Path Master_SSL_Cert Master_SSL_Cipher Master_SSL_Key Seconds_Behind_Master Master_SSL_Verify_Server_Cert Last_IO_Errno Last_IO_Error Last_SQL_Errno Last_SQL_Error Replicate_Ignore_Server_Ids Master_Server_Id Retried_transactions Max_relay_log_size Executed_log_entries Slave_received_heartbeats Slave_heartbeat_period Connection_name Slave_SQL_State Slave_IO_State Master_Host Master_User Master_Port Connect_Retry Master_Log_File Read_Master_Log_Pos Relay_Log_File Relay_Log_Pos Relay_Master_Log_File Slave_IO_Running Slave_SQL_Running Replicate_Do_DB Replicate_Ignore_DB Replicate_Do_Table Replicate_Ignore_Table Replicate_Wild_Do_Table Replicate_Wild_Ignore_Table Last_Errno Last_Error Skip_Counter Exec_Master_Log_Pos Relay_Log_Space Until_Condition Until_Log_File Until_Log_Pos Master_SSL_Allowed Master_SSL_CA_File Master_SSL_CA_Path Master_SSL_Cert Master_SSL_Cipher Master_SSL_Key Seconds_Behind_Master Master_SSL_Verify_Server_Cert Last_IO_Errno Last_IO_Error Last_SQL_Errno Last_SQL_Error Replicate_Ignore_Server_Ids Master_Server_Id Retried_transactions Max_relay_log_size Executed_log_entries Slave_received_heartbeats Slave_heartbeat_period
slave2 127.0.0.1 root MYPORT_2 60 master-bin.000001 286 mysqld-relay-bin-slave2.000002 572 master-bin.000001 No No 0 0 286 875 None 0 No NULL No 0 0 2 0 1073741824 6 0 60.000 slave2 127.0.0.1 root MYPORT_2 60 master-bin.000001 286 mysqld-relay-bin-slave2.000002 572 master-bin.000001 No No 0 0 286 875 None 0 No NULL No 0 0 2 0 1073741824 6 0 60.000
stop all slaves; stop all slaves;
reset slave 'slave2' all; include/reset_master_slave.inc
include/reset_master_slave.inc
include/reset_master_slave.inc
mysql-test/suite/multi_source/simple.test
View file @ 05b1de99
...@@ -59,4 +59,13 @@ stop all slaves; ...@@ -59,4 +59,13 @@ stop all slaves;
# #
# clean up # clean up
# #
reset slave 'slave2' all;
--source reset_master_slave.inc
--disconnect slave
--connection master1
--source reset_master_slave.inc
--disconnect master1
--connection master2
--source reset_master_slave.inc
--disconnect master2
mysql-test/suite/multi_source/skip_counter.result
View file @ 05b1de99
connect master1,127.0.0.1,root,,,$SERVER_MYPORT_1;
drop database if exists db; drop database if exists db;
create database db; create database db;
create table db.t1 (i int) engine=MyISAM; create table db.t1 (i int) engine=MyISAM;
connect master2,127.0.0.1,root,,,$SERVER_MYPORT_2;
drop database if exists db; drop database if exists db;
create database db; create database db;
create table db.t2 (i int) engine=MyISAM; create table db.t2 (i int) engine=MyISAM;
connect slave,127.0.0.1,root,,,$SERVER_MYPORT_3;
change master 'master1' to change master 'master1' to
master_port=MYPORT_1, master_port=MYPORT_1,
master_host='127.0.0.1', master_host='127.0.0.1',
...@@ -101,26 +98,16 @@ select @@global.max_relay_log_size; ...@@ -101,26 +98,16 @@ select @@global.max_relay_log_size;
start slave 'master2'; start slave 'master2';
include/wait_for_slave_to_start.inc include/wait_for_slave_to_start.inc
set default_master_connection = ''; set default_master_connection = '';
connection master2;
connection slave;
show tables in db; show tables in db;
Tables_in_db Tables_in_db
t1 t1
t2 t2
drop database db; drop database db;
set default_master_connection = 'master1';
stop slave;
include/wait_for_slave_to_stop.inc
set default_master_connection = 'master2';
stop slave;
include/wait_for_slave_to_stop.inc
set global sql_slave_skip_counter = 0; set global sql_slave_skip_counter = 0;
set global max_relay_log_size = 1073741824; set global max_relay_log_size = 1073741824;
set global max_binlog_size = 1073741824; set global max_binlog_size = 1073741824;
disconnect slave; include/reset_master_slave.inc
connection master1;
drop database db; drop database db;
disconnect master1; include/reset_master_slave.inc
connection master2;
drop database db; drop database db;
disconnect master2; include/reset_master_slave.inc
mysql-test/suite/multi_source/skip_counter.test
View file @ 05b1de99
...@@ -2,8 +2,6 @@ ...@@ -2,8 +2,6 @@
# Test of sql_slave_skip_counter and rpl_max_size # Test of sql_slave_skip_counter and rpl_max_size
# #
--enable_connect_log
# Create a schema and a table i # Create a schema and a table i
# on the 1st master # on the 1st master
...@@ -28,7 +26,6 @@ create database db; ...@@ -28,7 +26,6 @@ create database db;
create table db.t2 (i int) engine=MyISAM; create table db.t2 (i int) engine=MyISAM;
--connect (slave,127.0.0.1,root,,,$SERVER_MYPORT_3) --connect (slave,127.0.0.1,root,,,$SERVER_MYPORT_3)
--disable_connect_log
# Start replication from the first master # Start replication from the first master
...@@ -106,14 +103,11 @@ start slave 'master2'; ...@@ -106,14 +103,11 @@ start slave 'master2';
--source include/wait_for_slave_to_start.inc --source include/wait_for_slave_to_start.inc
set default_master_connection = ''; set default_master_connection = '';
--enable_connect_log
--connection master2 --connection master2
--save_master_pos --save_master_pos
--connection slave --connection slave
--disable_connect_log
--sync_with_master 0,'master2' --sync_with_master 0,'master2'
# If the skip_counter worked as expected, we should # If the skip_counter worked as expected, we should
...@@ -127,25 +121,21 @@ show tables in db; ...@@ -127,25 +121,21 @@ show tables in db;
# Cleanup # Cleanup
drop database db; drop database db;
set default_master_connection = 'master1';
stop slave;
--source include/wait_for_slave_to_stop.inc
set default_master_connection = 'master2';
stop slave;
--source include/wait_for_slave_to_stop.inc
--eval set global sql_slave_skip_counter = $skip_counter_saved --eval set global sql_slave_skip_counter = $skip_counter_saved
--eval set global max_relay_log_size = $max_relay_log_size_saved --eval set global max_relay_log_size = $max_relay_log_size_saved
--eval set global max_binlog_size = $max_binlog_size_saved --eval set global max_binlog_size = $max_binlog_size_saved
--enable_connect_log --source reset_master_slave.inc
--disconnect slave --disconnect slave
--connection master1 --connection master1
drop database db; drop database db;
--source reset_master_slave.inc
--disconnect master1 --disconnect master1
--connection master2 --connection master2
drop database db; drop database db;
--source reset_master_slave.inc
--disconnect master2 --disconnect master2
mysql-test/suite/multi_source/status_vars.result 0 → 100644
View file @ 05b1de99
call mtr.add_suppression("Connection 'master1' already exists");
change master 'master1' to
master_port=MYPORT_1,
master_host='127.0.0.1',
master_user='root',
master_heartbeat_period = 25;
start slave 'master1';
set default_master_connection = 'master1';
include/wait_for_slave_to_start.inc
set default_master_connection = '';
change master to
master_port=MYPORT_2,
master_host='127.0.0.1',
master_user='root',
master_heartbeat_period=35;
start slave;
include/wait_for_slave_to_start.inc
#
# Check how status works for the default connection, anonymous or named
#
# Slave_running and Slave_heartbeat_period should be local for a connection
#
set default_master_connection = '';
show status like 'Slave_running';
Variable_name Value
Slave_running ON
show status like 'Slave_heartbeat_period';
Variable_name Value
Slave_heartbeat_period 35.000
stop slave io_thread;
include/wait_for_slave_io_to_stop.inc
show status like 'Slave_running';
Variable_name Value
Slave_running OFF
set default_master_connection = 'master1';
show status like 'Slave_running';
Variable_name Value
Slave_running ON
show status like 'Slave_heartbeat_period';
Variable_name Value
Slave_heartbeat_period 25.000
#
# Slave_received_heartbeats should also be local
#
set default_master_connection = '';
stop slave sql_thread;
include/wait_for_slave_sql_to_stop.inc
change master to master_heartbeat_period=1;
show status like 'Slave_received_heartbeats';
Variable_name Value
Slave_received_heartbeats 0
start slave;
include/wait_for_slave_to_start.inc
show status like 'Slave_received_heartbeats';
Variable_name Value
Slave_received_heartbeats 2
stop slave;
include/wait_for_slave_to_stop.inc
set default_master_connection = 'master1';
show status like 'Slave_received_heartbeats';
Variable_name Value
Slave_received_heartbeats 0
stop slave;
include/wait_for_slave_to_stop.inc
change master to master_heartbeat_period=2;
start slave;
include/wait_for_slave_to_start.inc
show status like 'Slave_received_heartbeats';
Variable_name Value
Slave_received_heartbeats 1
#
# Slave_open_temp_tables should be global
#
set default_master_connection = '';
start slave;
include/wait_for_slave_to_start.inc
set binlog_format = statement;
create temporary table tmp1 (i int) engine=MyISAM;
show status like 'Slave_open_temp_tables';
Variable_name Value
Slave_open_temp_tables 1
set default_master_connection = 'master1';
show status like 'Slave_open_temp_tables';
Variable_name Value
Slave_open_temp_tables 1
set binlog_format = statement;
create temporary table tmp1 (i int) engine=MyISAM;
show status like 'Slave_open_temp_tables';
Variable_name Value
Slave_open_temp_tables 2
set default_master_connection = '';
show status like 'Slave_open_temp_tables';
Variable_name Value
Slave_open_temp_tables 2
include/reset_master_slave.inc
include/reset_master_slave.inc
include/reset_master_slave.inc
mysql-test/suite/multi_source/status_vars.test 0 → 100644
View file @ 05b1de99
--connect (slave,127.0.0.1,root,,,$SERVER_MYPORT_3)
call mtr.add_suppression("Connection 'master1' already exists");
# Start replication from the first master
--replace_result $SERVER_MYPORT_1 MYPORT_1
eval change master 'master1' to
master_port=$SERVER_MYPORT_1,
master_host='127.0.0.1',
master_user='root',
master_heartbeat_period = 25;
start slave 'master1';
set default_master_connection = 'master1';
--source include/wait_for_slave_to_start.inc
# Set up a proper 'default' connection to master2
set default_master_connection = '';
--replace_result $SERVER_MYPORT_2 MYPORT_2
eval change master to
master_port=$SERVER_MYPORT_2,
master_host='127.0.0.1',
master_user='root',
master_heartbeat_period=35;
start slave;
--source include/wait_for_slave_to_start.inc
--echo #
--echo # Check how status works for the default connection, anonymous or named
--echo #
--echo # Slave_running and Slave_heartbeat_period should be local for a connection
--echo #
set default_master_connection = '';
show status like 'Slave_running';
show status like 'Slave_heartbeat_period';
stop slave io_thread;
--source include/wait_for_slave_io_to_stop.inc
show status like 'Slave_running';
set default_master_connection = 'master1';
show status like 'Slave_running';
show status like 'Slave_heartbeat_period';
--echo #
--echo # Slave_received_heartbeats should also be local
--echo #
set default_master_connection = '';
stop slave sql_thread;
--source include/wait_for_slave_sql_to_stop.inc
change master to master_heartbeat_period=1;
show status like 'Slave_received_heartbeats';
start slave;
--source include/wait_for_slave_to_start.inc
--let $status_var = Slave_received_heartbeats
--let $status_var_value = 2
# The units are tens of seconds
--let $status_timeout = 30
--source include/wait_for_status_var.inc
show status like 'Slave_received_heartbeats';
stop slave;
--source include/wait_for_slave_to_stop.inc
set default_master_connection = 'master1';
show status like 'Slave_received_heartbeats';
stop slave;
--source include/wait_for_slave_to_stop.inc
change master to master_heartbeat_period=2;
start slave;
--source include/wait_for_slave_to_start.inc
--let $status_var = Slave_received_heartbeats
--let $status_var_value = 1
--let $status_timeout = 30
--source include/wait_for_status_var.inc
show status like 'Slave_received_heartbeats';
--echo #
--echo # Slave_open_temp_tables should be global
--echo #
set default_master_connection = '';
start slave;
--source include/wait_for_slave_to_start.inc
--connect (master1,127.0.0.1,root,,,$SERVER_MYPORT_1)
set binlog_format = statement;
create temporary table tmp1 (i int) engine=MyISAM;
--save_master_pos
--connection slave
--sync_with_master 0,'master1'
show status like 'Slave_open_temp_tables';
set default_master_connection = 'master1';
show status like 'Slave_open_temp_tables';
--connect (master2,127.0.0.1,root,,,$SERVER_MYPORT_2)
set binlog_format = statement;
create temporary table tmp1 (i int) engine=MyISAM;
--save_master_pos
--connection slave
--sync_with_master 0,''
show status like 'Slave_open_temp_tables';
set default_master_connection = '';
show status like 'Slave_open_temp_tables';
# Cleanup
--source reset_master_slave.inc
--disconnect slave
--connection master1
--source reset_master_slave.inc
--disconnect master1
--connection master2
--source reset_master_slave.inc
--disconnect master2
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment
GitLab Nexedi Edition | About GitLab | About Nexedi | 沪ICP备2021021310号-2 | 沪ICP备2021021310号-7