mirror of
https://github.com/MariaDB/server.git
synced 2025-01-20 22:12:30 +01:00
6c0d316d16
mysql-test/suite/rpl/t/rpl_flushlog_loop.test: added waiting for CREATE TABLE
69 lines
1.9 KiB
Text
69 lines
1.9 KiB
Text
# Testing if "flush logs" command bouncing resulting in logs created in a loop
|
|
# in case of bi-directional replication
|
|
-- source include/master-slave.inc
|
|
|
|
--replace_result $MYSQLTEST_VARDIR MYSQLTEST_VARDIR
|
|
show variables like 'relay_log%';
|
|
|
|
connection slave;
|
|
--disable_warnings
|
|
stop slave;
|
|
--enable_warnings
|
|
--replace_result $MASTER_MYPORT MASTER_PORT
|
|
eval change master to master_host='127.0.0.1',master_user='root',
|
|
master_password='',master_port=$MASTER_MYPORT;
|
|
start slave;
|
|
|
|
#
|
|
# Start replication slave -> master
|
|
#
|
|
connection master;
|
|
--disable_warnings
|
|
stop slave;
|
|
--enable_warnings
|
|
--replace_result $SLAVE_MYPORT SLAVE_PORT
|
|
eval change master to master_host='127.0.0.1',master_user='root',
|
|
master_password='',master_port=$SLAVE_MYPORT;
|
|
start slave;
|
|
|
|
#
|
|
# Wait for start of slave IO and SQL threads
|
|
#
|
|
let $result_pattern= '%127.0.0.1%root%slave-bin.000001%slave-bin.000001%Yes%Yes%0%0%None%';
|
|
--source include/wait_slave_status.inc
|
|
|
|
#
|
|
# Flush logs of slave
|
|
#
|
|
# Create full loop by following way:
|
|
# 1. Insert into t1 on master (1st).
|
|
# 2. Insert into t1 on slave (2nd) when the event (1st) for t1 replicated.
|
|
# 3. Master waits until the event (2nd) for t1 will be replicated.
|
|
|
|
--disable_query_log
|
|
CREATE TABLE t1 (a INT KEY) ENGINE= MyISAM;
|
|
let $wait_binlog_event= CREATE TABLE t1;
|
|
--source include/wait_for_binlog_event.inc
|
|
sync_slave_with_master;
|
|
connection master;
|
|
INSERT INTO t1 VALUE(1);
|
|
--enable_query_log
|
|
FLUSH LOGS;
|
|
connection slave;
|
|
let $wait_condition= SELECT COUNT(*) = 1 FROM t1;
|
|
-- source include/wait_condition.inc
|
|
--disable_query_log
|
|
INSERT INTO t1 VALUE(2);
|
|
--enable_query_log
|
|
connection master;
|
|
let $wait_condition= SELECT COUNT(*) = 2 FROM t1;
|
|
-- source include/wait_condition.inc
|
|
--enable_query_log
|
|
|
|
#
|
|
# Show status of slave
|
|
#
|
|
let $pos= query_get_value(SHOW SLAVE STATUS, Read_Master_Log_Pos, 1);
|
|
--replace_result $SLAVE_MYPORT SLAVE_PORT $pos POSITION
|
|
--replace_column 1 # 8 # 9 # 16 # 23 # 33 # 34 # 35 #
|
|
--query_vertical SHOW SLAVE STATUS
|