mirror of
https://github.com/MariaDB/server.git
synced 2025-07-29 05:21:33 +03:00
WL#5867, reorganize test cases of bugs suite
This commit is contained in:
@ -2,6 +2,9 @@
|
|||||||
# in alphabetical order. This also helps with merge conflict resolution.
|
# in alphabetical order. This also helps with merge conflict resolution.
|
||||||
|
|
||||||
binlog.binlog_multi_engine # joro : NDB tests marked as experimental as agreed with bochklin
|
binlog.binlog_multi_engine # joro : NDB tests marked as experimental as agreed with bochklin
|
||||||
|
binlog.binlog_bug23533 # WL#5867: skozlov: test case moved from unused bugs suite
|
||||||
|
binlog.binlog_bug36391 # WL#5867: skozlov: test case moved from unused bugs suite
|
||||||
|
|
||||||
|
|
||||||
funcs_1.charset_collation_1 # depends on compile-time decisions
|
funcs_1.charset_collation_1 # depends on compile-time decisions
|
||||||
funcs_1.is_cml_ndb # joro : NDB tests marked as experimental as agreed with bochklin
|
funcs_1.is_cml_ndb # joro : NDB tests marked as experimental as agreed with bochklin
|
||||||
@ -24,6 +27,8 @@ ndb.* # joro : NDB tests marked as experiment
|
|||||||
rpl.rpl_innodb_bug28430 @solaris # Bug#46029
|
rpl.rpl_innodb_bug28430 @solaris # Bug#46029
|
||||||
rpl.rpl_row_sp011 @solaris # Joro : Bug #45445
|
rpl.rpl_row_sp011 @solaris # Joro : Bug #45445
|
||||||
rpl.rpl_stop_slave @freebsd # Sven : BUG#12345981
|
rpl.rpl_stop_slave @freebsd # Sven : BUG#12345981
|
||||||
|
rpl.rpl_bug37426 # WL#5867: skozlov: test case moved from unused bugs suite
|
||||||
|
|
||||||
|
|
||||||
rpl_ndb.* # joro : NDB tests marked as experimental as agreed with bochklin
|
rpl_ndb.* # joro : NDB tests marked as experimental as agreed with bochklin
|
||||||
rpl_ndb.rpl_ndb_log # Bug#38998
|
rpl_ndb.rpl_ndb_log # Bug#38998
|
||||||
|
@ -1,23 +1,19 @@
|
|||||||
stop slave;
|
|
||||||
drop table if exists t1,t2,t3,t4,t5,t6,t7,t8,t9;
|
|
||||||
reset master;
|
|
||||||
reset slave;
|
|
||||||
drop table if exists t1,t2,t3,t4,t5,t6,t7,t8,t9;
|
|
||||||
start slave;
|
|
||||||
DROP TABLE IF EXISTS t1,t2;
|
|
||||||
SET AUTOCOMMIT=0;
|
SET AUTOCOMMIT=0;
|
||||||
SET GLOBAL max_binlog_cache_size=4096;
|
|
||||||
SHOW VARIABLES LIKE 'max_binlog_cache_size';
|
|
||||||
Variable_name Value
|
|
||||||
max_binlog_cache_size 4096
|
|
||||||
CREATE TABLE t1 (a INT NOT NULL AUTO_INCREMENT, b TEXT, PRIMARY KEY(a)) ENGINE=InnoDB;
|
CREATE TABLE t1 (a INT NOT NULL AUTO_INCREMENT, b TEXT, PRIMARY KEY(a)) ENGINE=InnoDB;
|
||||||
SELECT COUNT(*) FROM t1;
|
SELECT COUNT(*) FROM t1;
|
||||||
COUNT(*)
|
COUNT(*)
|
||||||
1000
|
1000
|
||||||
|
SHOW VARIABLES LIKE 'max_binlog_cache_size';
|
||||||
|
Variable_name Value
|
||||||
|
max_binlog_cache_size 4294963200
|
||||||
|
SET @saved_max_binlog_cache_size=@@max_binlog_cache_size;
|
||||||
|
SET GLOBAL max_binlog_cache_size=4096;
|
||||||
START TRANSACTION;
|
START TRANSACTION;
|
||||||
CREATE TABLE t2 SELECT * FROM t1;
|
CREATE TABLE t2 SELECT * FROM t1;
|
||||||
ERROR HY000: Writing one row to the row-based binary log failed
|
ERROR HY000: Multi-statement transaction required more than 'max_binlog_cache_size' bytes of storage; increase this mysqld variable and try again
|
||||||
COMMIT;
|
COMMIT;
|
||||||
SHOW TABLES LIKE 't%';
|
SHOW TABLES LIKE 't%';
|
||||||
Tables_in_test (t%)
|
Tables_in_test (t%)
|
||||||
t1
|
t1
|
||||||
|
SET GLOBAL max_binlog_cache_size=@saved_max_binlog_cache_size;
|
||||||
|
DROP TABLE t1;
|
10
mysql-test/suite/binlog/r/binlog_bug36391.result
Normal file
10
mysql-test/suite/binlog/r/binlog_bug36391.result
Normal file
@ -0,0 +1,10 @@
|
|||||||
|
CREATE TABLE t1(id INT);
|
||||||
|
SHOW TABLES;
|
||||||
|
Tables_in_test
|
||||||
|
t1
|
||||||
|
FLUSH LOGS;
|
||||||
|
DROP TABLE t1;
|
||||||
|
SHOW TABLES;
|
||||||
|
Tables_in_test
|
||||||
|
t1
|
||||||
|
DROP TABLE t1;
|
@ -4,15 +4,13 @@
|
|||||||
#############################################################
|
#############################################################
|
||||||
|
|
||||||
--source include/have_innodb.inc
|
--source include/have_innodb.inc
|
||||||
|
--source include/have_log_bin.inc
|
||||||
--source include/have_binlog_format_row.inc
|
--source include/have_binlog_format_row.inc
|
||||||
--source include/master-slave.inc
|
|
||||||
|
|
||||||
SET AUTOCOMMIT=0;
|
SET AUTOCOMMIT=0;
|
||||||
SET GLOBAL max_binlog_cache_size=4096;
|
|
||||||
SHOW VARIABLES LIKE 'max_binlog_cache_size';
|
|
||||||
|
|
||||||
|
# Create 1st table
|
||||||
CREATE TABLE t1 (a INT NOT NULL AUTO_INCREMENT, b TEXT, PRIMARY KEY(a)) ENGINE=InnoDB;
|
CREATE TABLE t1 (a INT NOT NULL AUTO_INCREMENT, b TEXT, PRIMARY KEY(a)) ENGINE=InnoDB;
|
||||||
|
|
||||||
--disable_query_log
|
--disable_query_log
|
||||||
let $i= 1000;
|
let $i= 1000;
|
||||||
while ($i)
|
while ($i)
|
||||||
@ -21,16 +19,20 @@ while ($i)
|
|||||||
dec $i;
|
dec $i;
|
||||||
}
|
}
|
||||||
--enable_query_log
|
--enable_query_log
|
||||||
|
|
||||||
SELECT COUNT(*) FROM t1;
|
SELECT COUNT(*) FROM t1;
|
||||||
|
|
||||||
|
# Set small value for max_binlog_cache_size
|
||||||
|
SHOW VARIABLES LIKE 'max_binlog_cache_size';
|
||||||
|
SET @saved_max_binlog_cache_size=@@max_binlog_cache_size;
|
||||||
|
SET GLOBAL max_binlog_cache_size=4096;
|
||||||
|
|
||||||
# Copied data from t1 into t2 large than max_binlog_cache_size
|
# Copied data from t1 into t2 large than max_binlog_cache_size
|
||||||
START TRANSACTION;
|
START TRANSACTION;
|
||||||
--error 1534
|
--error 1197
|
||||||
CREATE TABLE t2 SELECT * FROM t1;
|
CREATE TABLE t2 SELECT * FROM t1;
|
||||||
COMMIT;
|
COMMIT;
|
||||||
SHOW TABLES LIKE 't%';
|
SHOW TABLES LIKE 't%';
|
||||||
|
|
||||||
|
|
||||||
# 5.1 End of Test
|
# 5.1 End of Test
|
||||||
--source include/rpl_end.inc
|
SET GLOBAL max_binlog_cache_size=@saved_max_binlog_cache_size;
|
||||||
|
DROP TABLE t1;
|
@ -13,17 +13,18 @@
|
|||||||
#
|
#
|
||||||
#
|
#
|
||||||
|
|
||||||
--source include/master-slave.inc
|
--source include/have_log_bin.inc
|
||||||
|
--source include/have_binlog_format_mixed.inc
|
||||||
|
|
||||||
create table t1(id int);
|
CREATE TABLE t1(id INT);
|
||||||
|
let $binlog= query_get_value(SHOW MASTER STATUS, File, 1);
|
||||||
|
let $binlog_path= `SELECT CONCAT(@@DATADIR, '$binlog')`;
|
||||||
|
SHOW TABLES;
|
||||||
|
FLUSH LOGS;
|
||||||
|
DROP TABLE t1;
|
||||||
|
|
||||||
show tables;
|
--exec $MYSQL_BINLOG $binlog_path | $MYSQL test
|
||||||
|
SHOW TABLES;
|
||||||
|
|
||||||
--source include/show_master_status.inc
|
# Clean up
|
||||||
|
DROP TABLE t1;
|
||||||
flush logs;
|
|
||||||
|
|
||||||
--exec $MYSQL_BINLOG $MYSQL_TEST_DIR/var/log/master-bin.000001 | $MYSQL test
|
|
||||||
|
|
||||||
drop table t1;
|
|
||||||
--source include/rpl_end.inc
|
|
@ -1,8 +0,0 @@
|
|||||||
[row]
|
|
||||||
binlog-format=row
|
|
||||||
|
|
||||||
[stmt]
|
|
||||||
binlog-format=statement
|
|
||||||
|
|
||||||
[mix]
|
|
||||||
binlog-format=mixed
|
|
@ -1,3 +0,0 @@
|
|||||||
a
|
|
||||||
b
|
|
||||||
c
|
|
@ -1,33 +0,0 @@
|
|||||||
stop slave;
|
|
||||||
drop table if exists t1,t2,t3,t4,t5,t6,t7,t8,t9;
|
|
||||||
reset master;
|
|
||||||
reset slave;
|
|
||||||
drop table if exists t1,t2,t3,t4,t5,t6,t7,t8,t9;
|
|
||||||
start slave;
|
|
||||||
|
|
||||||
**** On Master ****
|
|
||||||
CREATE TABLE t1 (b CHAR(10));
|
|
||||||
|
|
||||||
**** On Slave ****
|
|
||||||
STOP SLAVE;
|
|
||||||
|
|
||||||
**** On Master ****
|
|
||||||
LOAD DATA INFILE FILENAME
|
|
||||||
SELECT COUNT(*) FROM t1;
|
|
||||||
COUNT(*)
|
|
||||||
3
|
|
||||||
show binlog events from <binlog_start>;
|
|
||||||
Log_name Pos Event_type Server_id End_log_pos Info
|
|
||||||
master-bin.000001 # Query # # use `test`; CREATE TABLE t1 (b CHAR(10))
|
|
||||||
master-bin.000001 # Begin_load_query # # ;file_id=#;block_len=#
|
|
||||||
master-bin.000001 # Execute_load_query # # use `test`; LOAD DATA INFILE 'MYSQLTEST_VARDIR/tmp/rpl_bug12691.dat' INTO TABLE `t1` FIELDS TERMINATED BY '|' ENCLOSED BY '' ESCAPED BY '\\' LINES TERMINATED BY '\n' (`b`) ;file_id=#
|
|
||||||
|
|
||||||
**** On Slave ****
|
|
||||||
SET GLOBAL SQL_SLAVE_SKIP_COUNTER=1;
|
|
||||||
START SLAVE;
|
|
||||||
SELECT COUNT(*) FROM t1;
|
|
||||||
COUNT(*)
|
|
||||||
0
|
|
||||||
|
|
||||||
**** On Master ****
|
|
||||||
DROP TABLE t1;
|
|
@ -1,16 +0,0 @@
|
|||||||
stop slave;
|
|
||||||
drop table if exists t1,t2,t3,t4,t5,t6,t7,t8,t9;
|
|
||||||
reset master;
|
|
||||||
reset slave;
|
|
||||||
drop table if exists t1,t2,t3,t4,t5,t6,t7,t8,t9;
|
|
||||||
start slave;
|
|
||||||
CREATE TABLE t1 (a VARCHAR(10) PRIMARY KEY) ENGINE=MyISAM;
|
|
||||||
INSERT INTO t1 VALUES ('a');
|
|
||||||
UPDATE t1 SET a = 'MyISAM';
|
|
||||||
SELECT * FROM t1 ORDER BY a;
|
|
||||||
a
|
|
||||||
MyISAM
|
|
||||||
SELECT * FROM t1 ORDER BY a;
|
|
||||||
a
|
|
||||||
MyISAM
|
|
||||||
DROP TABLE t1;
|
|
@ -1,16 +0,0 @@
|
|||||||
stop slave;
|
|
||||||
drop table if exists t1,t2,t3,t4,t5,t6,t7,t8,t9;
|
|
||||||
reset master;
|
|
||||||
reset slave;
|
|
||||||
drop table if exists t1,t2,t3,t4,t5,t6,t7,t8,t9;
|
|
||||||
start slave;
|
|
||||||
CREATE TABLE t1 ( a INT, b INT DEFAULT -3 );
|
|
||||||
INSERT INTO t1 VALUES (1, DEFAULT);
|
|
||||||
UPDATE t1 SET a = 3;
|
|
||||||
SELECT * FROM t1 ORDER BY a;
|
|
||||||
a b
|
|
||||||
3 -3
|
|
||||||
SELECT * FROM t1 ORDER BY a;
|
|
||||||
a b
|
|
||||||
3 -3
|
|
||||||
DROP TABLE t1;
|
|
@ -1,15 +0,0 @@
|
|||||||
stop slave;
|
|
||||||
drop table if exists t1,t2,t3,t4,t5,t6,t7,t8,t9;
|
|
||||||
reset master;
|
|
||||||
reset slave;
|
|
||||||
drop table if exists t1,t2,t3,t4,t5,t6,t7,t8,t9;
|
|
||||||
start slave;
|
|
||||||
create table `t1` (`id` int not null auto_increment primary key);
|
|
||||||
create trigger `trg` before insert on `t1` for each row begin end;
|
|
||||||
set @@global.debug="+d,simulate_bug33029";
|
|
||||||
stop slave;
|
|
||||||
start slave;
|
|
||||||
insert into `t1` values ();
|
|
||||||
select * from t1;
|
|
||||||
id
|
|
||||||
1
|
|
@ -1,18 +0,0 @@
|
|||||||
stop slave;
|
|
||||||
drop table if exists t1,t2,t3,t4,t5,t6,t7,t8,t9;
|
|
||||||
reset master;
|
|
||||||
reset slave;
|
|
||||||
drop table if exists t1,t2,t3,t4,t5,t6,t7,t8,t9;
|
|
||||||
start slave;
|
|
||||||
drop table if exists t1;
|
|
||||||
Warnings:
|
|
||||||
Note 1051 Unknown table 't1'
|
|
||||||
create table t1(id int);
|
|
||||||
show tables;
|
|
||||||
Tables_in_test
|
|
||||||
t1
|
|
||||||
show master status;
|
|
||||||
File Position Binlog_Do_DB Binlog_Ignore_DB
|
|
||||||
master-bin.000001 # <Binlog_Do_DB> <Binlog_Ignore_DB>
|
|
||||||
flush logs;
|
|
||||||
drop table t1;
|
|
@ -1,17 +0,0 @@
|
|||||||
stop slave;
|
|
||||||
drop table if exists t1,t2,t3,t4,t5,t6,t7,t8,t9;
|
|
||||||
reset master;
|
|
||||||
reset slave;
|
|
||||||
drop table if exists t1,t2,t3,t4,t5,t6,t7,t8,t9;
|
|
||||||
start slave;
|
|
||||||
CREATE TABLE char128_utf8 (
|
|
||||||
i1 INT NOT NULL,
|
|
||||||
c CHAR(128) CHARACTER SET utf8 NOT NULL,
|
|
||||||
i2 INT NOT NULL);
|
|
||||||
INSERT INTO char128_utf8 VALUES ( 1, "123", 1 );
|
|
||||||
SELECT * FROM char128_utf8;
|
|
||||||
i1 c i2
|
|
||||||
1 123 1
|
|
||||||
SELECT * FROM char128_utf8;
|
|
||||||
i1 c i2
|
|
||||||
1 123 1
|
|
@ -1,56 +0,0 @@
|
|||||||
stop slave;
|
|
||||||
drop table if exists t1,t2,t3,t4,t5,t6,t7,t8,t9;
|
|
||||||
reset master;
|
|
||||||
reset slave;
|
|
||||||
drop table if exists t1,t2,t3,t4,t5,t6,t7,t8,t9;
|
|
||||||
start slave;
|
|
||||||
create table t1i(n int primary key) engine=innodb;
|
|
||||||
create table t2m(n int primary key) engine=myisam;
|
|
||||||
begin;
|
|
||||||
insert into t1i values (1);
|
|
||||||
insert into t1i values (2);
|
|
||||||
insert into t1i values (3);
|
|
||||||
commit;
|
|
||||||
begin;
|
|
||||||
insert into t1i values (5);
|
|
||||||
begin;
|
|
||||||
insert into t1i values (4);
|
|
||||||
insert into t2m values (1);
|
|
||||||
update t1i set n = 5 where n = 4;
|
|
||||||
commit;
|
|
||||||
zero
|
|
||||||
0
|
|
||||||
*** kill sql thread ***
|
|
||||||
rollback;
|
|
||||||
*** sql thread is *not* running: No ***
|
|
||||||
*** the prove: the killed slave has not finished the current transaction ***
|
|
||||||
three
|
|
||||||
3
|
|
||||||
one
|
|
||||||
1
|
|
||||||
zero
|
|
||||||
0
|
|
||||||
delete from t2m;
|
|
||||||
start slave sql_thread;
|
|
||||||
delete from t1i;
|
|
||||||
delete from t2m;
|
|
||||||
begin;
|
|
||||||
insert into t1i values (5);
|
|
||||||
begin;
|
|
||||||
insert into t1i values (4);
|
|
||||||
update t1i set n = 5 where n = 4;
|
|
||||||
commit;
|
|
||||||
zero
|
|
||||||
0
|
|
||||||
stop slave sql_thread;
|
|
||||||
rollback;
|
|
||||||
*** sql thread is *not* running: No ***
|
|
||||||
*** the prove: the stopped slave has rolled back the current transaction ***
|
|
||||||
zero
|
|
||||||
0
|
|
||||||
zero
|
|
||||||
0
|
|
||||||
one
|
|
||||||
1
|
|
||||||
start slave sql_thread;
|
|
||||||
drop table t1i, t2m;
|
|
@ -1,49 +0,0 @@
|
|||||||
# Bug#12691: Exec_master_log_pos corrupted with SQL_SLAVE_SKIP_COUNTER
|
|
||||||
|
|
||||||
--source include/master-slave.inc
|
|
||||||
--connection master
|
|
||||||
--source include/have_binlog_format_mixed_or_statement.inc
|
|
||||||
|
|
||||||
--echo
|
|
||||||
--echo **** On Master ****
|
|
||||||
CREATE TABLE t1 (b CHAR(10));
|
|
||||||
--echo
|
|
||||||
--echo **** On Slave ****
|
|
||||||
--sync_slave_with_master
|
|
||||||
STOP SLAVE;
|
|
||||||
--source include/wait_for_slave_to_stop.inc
|
|
||||||
|
|
||||||
--connection master
|
|
||||||
|
|
||||||
--echo
|
|
||||||
--echo **** On Master ****
|
|
||||||
--exec cp $MYSQL_TEST_DIR/suite/bugs/data/rpl_bug12691.dat $MYSQLTEST_VARDIR/tmp/
|
|
||||||
--echo LOAD DATA INFILE FILENAME
|
|
||||||
--disable_query_log
|
|
||||||
--eval LOAD DATA INFILE '$MYSQLTEST_VARDIR/tmp/rpl_bug12691.dat' INTO TABLE t1 FIELDS TERMINATED BY '|'
|
|
||||||
--enable_query_log
|
|
||||||
--remove_file $MYSQLTEST_VARDIR/tmp/rpl_bug12691.dat
|
|
||||||
|
|
||||||
SELECT COUNT(*) FROM t1;
|
|
||||||
|
|
||||||
source include/show_binlog_events.inc;
|
|
||||||
|
|
||||||
--save_master_pos
|
|
||||||
|
|
||||||
--connection slave
|
|
||||||
--echo
|
|
||||||
--echo **** On Slave ****
|
|
||||||
SET GLOBAL SQL_SLAVE_SKIP_COUNTER=1;
|
|
||||||
START SLAVE;
|
|
||||||
--source include/wait_for_slave_to_start.inc
|
|
||||||
--sync_with_master
|
|
||||||
|
|
||||||
SELECT COUNT(*) FROM t1;
|
|
||||||
|
|
||||||
# Clean up
|
|
||||||
--connection master
|
|
||||||
--echo
|
|
||||||
--echo **** On Master ****
|
|
||||||
DROP TABLE t1;
|
|
||||||
|
|
||||||
--source include/rpl_end.inc
|
|
@ -1,25 +0,0 @@
|
|||||||
|
|
||||||
# BUG#31582: 5.1-telco-6.1 -> 5.1.22. Slave crashes when reading
|
|
||||||
# UPDATE for VARCHAR
|
|
||||||
|
|
||||||
# This is a problem for any update statement replicating from an old
|
|
||||||
# server to a new server. The bug consisted of a new slave trying to
|
|
||||||
# read two column bitmaps, but there is only one available in the old
|
|
||||||
# format.
|
|
||||||
|
|
||||||
# This test case should be executed replicating from an old server to
|
|
||||||
# a new server, so make sure you have one handy.
|
|
||||||
|
|
||||||
source include/master-slave.inc;
|
|
||||||
|
|
||||||
CREATE TABLE t1 (a VARCHAR(10) PRIMARY KEY) ENGINE=MyISAM;
|
|
||||||
INSERT INTO t1 VALUES ('a');
|
|
||||||
UPDATE t1 SET a = 'MyISAM';
|
|
||||||
SELECT * FROM t1 ORDER BY a;
|
|
||||||
sync_slave_with_master;
|
|
||||||
SELECT * FROM t1 ORDER BY a;
|
|
||||||
|
|
||||||
connection master;
|
|
||||||
DROP TABLE t1;
|
|
||||||
|
|
||||||
--source include/rpl_end.inc
|
|
@ -1,25 +0,0 @@
|
|||||||
#
|
|
||||||
# BUG#31583: 5.1-telco-6.1 -> 5.1.22. Slave returns Error in unknown event
|
|
||||||
|
|
||||||
# This is a problem for any update statement replicating from an old
|
|
||||||
# server to a new server. The bug consisted of a new slave trying to
|
|
||||||
# read two column bitmaps, but there is only one available in the old
|
|
||||||
# format.
|
|
||||||
|
|
||||||
# This test case should be executed replicating from an old server to
|
|
||||||
# a new server, so make sure you have one handy.
|
|
||||||
|
|
||||||
source include/master-slave.inc;
|
|
||||||
|
|
||||||
CREATE TABLE t1 ( a INT, b INT DEFAULT -3 );
|
|
||||||
|
|
||||||
INSERT INTO t1 VALUES (1, DEFAULT);
|
|
||||||
UPDATE t1 SET a = 3;
|
|
||||||
SELECT * FROM t1 ORDER BY a;
|
|
||||||
sync_slave_with_master;
|
|
||||||
SELECT * FROM t1 ORDER BY a;
|
|
||||||
|
|
||||||
connection master;
|
|
||||||
DROP TABLE t1;
|
|
||||||
|
|
||||||
--source include/rpl_end.inc
|
|
@ -1,26 +0,0 @@
|
|||||||
#
|
|
||||||
# Bug #36443 Server crashes when executing insert when insert trigger on table
|
|
||||||
#
|
|
||||||
# Emulating the former bug#33029 situation to see that there is no crash anymore.
|
|
||||||
#
|
|
||||||
|
|
||||||
|
|
||||||
source include/master-slave.inc;
|
|
||||||
|
|
||||||
create table `t1` (`id` int not null auto_increment primary key);
|
|
||||||
create trigger `trg` before insert on `t1` for each row begin end;
|
|
||||||
|
|
||||||
sync_slave_with_master;
|
|
||||||
set @@global.debug="+d,simulate_bug33029";
|
|
||||||
|
|
||||||
stop slave;
|
|
||||||
start slave;
|
|
||||||
|
|
||||||
connection master;
|
|
||||||
|
|
||||||
insert into `t1` values ();
|
|
||||||
|
|
||||||
sync_slave_with_master;
|
|
||||||
select * from t1;
|
|
||||||
|
|
||||||
--source include/rpl_end.inc
|
|
@ -1,166 +0,0 @@
|
|||||||
#
|
|
||||||
# Bug #38205 Row-based Replication (RBR) causes inconsistencies: HA_ERR_FOUND_DUPP_KEY
|
|
||||||
# Bug#319 if while a non-transactional slave is replicating a transaction possible problem
|
|
||||||
#
|
|
||||||
# Verifying the fact that STOP SLAVE in the middle of a group execution waits
|
|
||||||
# for the end of the group before the slave sql thread will stop.
|
|
||||||
# The patch refines STOP SLAVE to not interrupt a transaction or other type of
|
|
||||||
# the replication events group (the part I).
|
|
||||||
# Killing the sql thread continues to provide a "hard" stop (the part II).
|
|
||||||
#
|
|
||||||
# Non-deterministic tests
|
|
||||||
#
|
|
||||||
|
|
||||||
source include/master-slave.inc;
|
|
||||||
source include/have_innodb.inc;
|
|
||||||
|
|
||||||
|
|
||||||
#
|
|
||||||
# Part II, killed sql slave leaves instantly
|
|
||||||
#
|
|
||||||
|
|
||||||
# A. multi-statement transaction as the replication group
|
|
||||||
|
|
||||||
connection master;
|
|
||||||
|
|
||||||
create table t1i(n int primary key) engine=innodb;
|
|
||||||
create table t2m(n int primary key) engine=myisam;
|
|
||||||
|
|
||||||
sync_slave_with_master;
|
|
||||||
|
|
||||||
connection master;
|
|
||||||
|
|
||||||
begin;
|
|
||||||
insert into t1i values (1);
|
|
||||||
insert into t1i values (2);
|
|
||||||
insert into t1i values (3);
|
|
||||||
commit;
|
|
||||||
|
|
||||||
sync_slave_with_master;
|
|
||||||
|
|
||||||
#
|
|
||||||
# todo: first challenge is to find out the SQL thread id
|
|
||||||
# the following is not fully reliable
|
|
||||||
#
|
|
||||||
|
|
||||||
let $id=`SELECT id from information_schema.processlist where user like 'system user' and state like '%Has read all relay log%' or user like 'system user' and state like '%Reading event from the relay log%'`;
|
|
||||||
connection slave;
|
|
||||||
begin;
|
|
||||||
insert into t1i values (5);
|
|
||||||
|
|
||||||
connection master;
|
|
||||||
let $pos0_master= query_get_value(SHOW MASTER STATUS, Position, 1);
|
|
||||||
begin;
|
|
||||||
insert into t1i values (4);
|
|
||||||
insert into t2m values (1); # non-ta update
|
|
||||||
update t1i set n = 5 where n = 4; # to block at. can't be played with killed
|
|
||||||
commit;
|
|
||||||
let $pos1_master= query_get_value(SHOW MASTER STATUS, Position, 1);
|
|
||||||
|
|
||||||
connection slave;
|
|
||||||
# slave sql thread must be locked out by the conn `slave' explicit lock
|
|
||||||
let $pos0_slave= query_get_value(SHOW SLAVE STATUS, Exec_Master_Log_Pos, 1);
|
|
||||||
--disable_query_log
|
|
||||||
eval select $pos0_master - $pos0_slave as zero;
|
|
||||||
--enable_query_log
|
|
||||||
|
|
||||||
connection slave1;
|
|
||||||
|
|
||||||
let $count= 1;
|
|
||||||
let $table= t2m;
|
|
||||||
source include/wait_until_rows_count.inc;
|
|
||||||
#
|
|
||||||
# todo: may fail as said above
|
|
||||||
#
|
|
||||||
--echo *** kill sql thread ***
|
|
||||||
--disable_query_log
|
|
||||||
eval kill connection $id;
|
|
||||||
--enable_query_log
|
|
||||||
|
|
||||||
connection slave;
|
|
||||||
rollback; # release the sql thread
|
|
||||||
|
|
||||||
connection slave1;
|
|
||||||
|
|
||||||
source include/wait_for_slave_sql_to_stop.inc;
|
|
||||||
let $sql_status= query_get_value(SHOW SLAVE STATUS, Slave_SQL_Running, 1);
|
|
||||||
--echo *** sql thread is *not* running: $sql_status ***
|
|
||||||
let $pos1_slave= query_get_value(SHOW SLAVE STATUS, Exec_Master_Log_Pos, 1);
|
|
||||||
|
|
||||||
connection slave;
|
|
||||||
--echo *** the prove: the killed slave has not finished the current transaction ***
|
|
||||||
|
|
||||||
--disable_query_log
|
|
||||||
select count(*) as three from t1i;
|
|
||||||
eval select $pos1_master > $pos1_slave as one;
|
|
||||||
eval select $pos1_slave - $pos0_slave as zero;
|
|
||||||
--enable_query_log
|
|
||||||
|
|
||||||
delete from t2m; # remove the row to be able to replay
|
|
||||||
start slave sql_thread;
|
|
||||||
|
|
||||||
#
|
|
||||||
# Part I: B The homogenous transaction remains interuptable in between
|
|
||||||
#
|
|
||||||
|
|
||||||
connection master;
|
|
||||||
delete from t1i;
|
|
||||||
delete from t2m;
|
|
||||||
|
|
||||||
sync_slave_with_master;
|
|
||||||
begin;
|
|
||||||
insert into t1i values (5);
|
|
||||||
|
|
||||||
connection master;
|
|
||||||
let $pos0_master= query_get_value(SHOW MASTER STATUS, Position, 1);
|
|
||||||
begin;
|
|
||||||
insert into t1i values (4);
|
|
||||||
update t1i set n = 5 where n = 4; # to block at. not to be played
|
|
||||||
commit;
|
|
||||||
let $pos1_master= query_get_value(SHOW MASTER STATUS, Position, 1);
|
|
||||||
|
|
||||||
|
|
||||||
connection slave1;
|
|
||||||
# slave sql can't advance as must be locked by the conn `slave' trans
|
|
||||||
let $pos0_slave= query_get_value(SHOW SLAVE STATUS, Exec_Master_Log_Pos, 1);
|
|
||||||
--disable_query_log
|
|
||||||
eval select $pos0_master - $pos0_slave as zero;
|
|
||||||
--enable_query_log
|
|
||||||
|
|
||||||
#
|
|
||||||
# the replicated trans is blocked by the slave's local.
|
|
||||||
# However, it's not easy to catch the exact moment when it happens.
|
|
||||||
# The test issues sleep which makes the test either non-deterministic or
|
|
||||||
# wasting too much time.
|
|
||||||
#
|
|
||||||
--sleep 3
|
|
||||||
|
|
||||||
send stop slave sql_thread;
|
|
||||||
|
|
||||||
connection slave;
|
|
||||||
rollback; # release the sql thread
|
|
||||||
|
|
||||||
connection slave1;
|
|
||||||
reap;
|
|
||||||
source include/wait_for_slave_sql_to_stop.inc;
|
|
||||||
let $sql_status= query_get_value(SHOW SLAVE STATUS, Slave_SQL_Running, 1);
|
|
||||||
--echo *** sql thread is *not* running: $sql_status ***
|
|
||||||
|
|
||||||
let $pos1_slave= query_get_value(SHOW SLAVE STATUS, Exec_Master_Log_Pos, 1);
|
|
||||||
|
|
||||||
--echo *** the prove: the stopped slave has rolled back the current transaction ***
|
|
||||||
|
|
||||||
--disable_query_log
|
|
||||||
select count(*) as zero from t1i;
|
|
||||||
eval select $pos0_master - $pos0_slave as zero;
|
|
||||||
eval select $pos1_master > $pos0_slave as one;
|
|
||||||
--enable_query_log
|
|
||||||
|
|
||||||
start slave sql_thread;
|
|
||||||
|
|
||||||
# clean-up
|
|
||||||
|
|
||||||
connection master;
|
|
||||||
drop table t1i, t2m;
|
|
||||||
|
|
||||||
--source include/rpl_end.inc
|
|
12
mysql-test/suite/rpl/r/rpl_bug37426.result
Normal file
12
mysql-test/suite/rpl/r/rpl_bug37426.result
Normal file
@ -0,0 +1,12 @@
|
|||||||
|
include/master-slave.inc
|
||||||
|
[connection master]
|
||||||
|
CREATE TABLE char128_utf8 (i1 INT NOT NULL, c CHAR(128) CHARACTER SET utf8 NOT NULL, i2 INT NOT NULL);
|
||||||
|
INSERT INTO char128_utf8 VALUES ( 1, "123", 1 );
|
||||||
|
SELECT * FROM char128_utf8;
|
||||||
|
i1 c i2
|
||||||
|
1 123 1
|
||||||
|
SELECT * FROM char128_utf8;
|
||||||
|
i1 c i2
|
||||||
|
1 123 1
|
||||||
|
DROP TABLE char128_utf8;
|
||||||
|
include/rpl_end.inc
|
@ -7,15 +7,16 @@ source include/master-slave.inc;
|
|||||||
source include/have_binlog_format_row.inc;
|
source include/have_binlog_format_row.inc;
|
||||||
|
|
||||||
connection master;
|
connection master;
|
||||||
CREATE TABLE char128_utf8 (
|
CREATE TABLE char128_utf8 (i1 INT NOT NULL, c CHAR(128) CHARACTER SET utf8 NOT NULL, i2 INT NOT NULL);
|
||||||
i1 INT NOT NULL,
|
|
||||||
c CHAR(128) CHARACTER SET utf8 NOT NULL,
|
|
||||||
i2 INT NOT NULL);
|
|
||||||
|
|
||||||
INSERT INTO char128_utf8 VALUES ( 1, "123", 1 );
|
INSERT INTO char128_utf8 VALUES ( 1, "123", 1 );
|
||||||
|
|
||||||
SELECT * FROM char128_utf8;
|
SELECT * FROM char128_utf8;
|
||||||
sync_slave_with_master;
|
sync_slave_with_master;
|
||||||
|
|
||||||
SELECT * FROM char128_utf8;
|
SELECT * FROM char128_utf8;
|
||||||
|
|
||||||
|
# Clean up
|
||||||
|
connection master;
|
||||||
|
DROP TABLE char128_utf8;
|
||||||
|
sync_slave_with_master;
|
||||||
--source include/rpl_end.inc
|
--source include/rpl_end.inc
|
Reference in New Issue
Block a user