mirror of
https://github.com/MariaDB/server.git
synced 2025-01-19 05:22:25 +01:00
e7c56ceb8b
Pushing test case for bug only. Bug already fixed as a result of the patch for BUG#19958. mysql-test/extra/rpl_tests/rpl_row_basic.test: Adding test to see that no error is given on slave when deleting rows that don't exist on table without primary key. mysql-test/suite/rpl/r/rpl_row_basic_2myisam.result: Result change. mysql-test/suite/rpl/r/rpl_row_basic_3innodb.result: Result change. mysql-test/suite/rpl_ndb/r/rpl_row_basic_7ndb.result: Result change.
255 lines
7.3 KiB
Text
255 lines
7.3 KiB
Text
#
|
|
# Basic tests of row-level logging
|
|
#
|
|
|
|
#
|
|
# First we test tables with only an index.
|
|
#
|
|
|
|
eval CREATE TABLE t1 (C1 CHAR(1), C2 CHAR(1), INDEX (C1)$extra_index_t1) ENGINE = $type ;
|
|
SELECT * FROM t1;
|
|
sync_slave_with_master;
|
|
SELECT * FROM t1;
|
|
|
|
# Testing insert
|
|
connection master;
|
|
INSERT INTO t1 VALUES ('A','B'), ('X','Y'), ('X','X');
|
|
INSERT INTO t1 VALUES ('A','C'), ('X','Z'), ('A','A');
|
|
SELECT * FROM t1 ORDER BY C1,C2;
|
|
sync_slave_with_master;
|
|
SELECT * FROM t1 ORDER BY C1,C2;
|
|
|
|
# Testing delete
|
|
# Observe that are several rows having the value for the index but only one
|
|
# should be deleted.
|
|
connection master;
|
|
DELETE FROM t1 WHERE C1 = C2;
|
|
SELECT * FROM t1 ORDER BY C1,C2;
|
|
sync_slave_with_master;
|
|
SELECT * FROM t1 ORDER BY C1,C2;
|
|
|
|
#
|
|
# Testing update.
|
|
# Note that we have a condition on a column that is not part of the index for
|
|
# the table. The right row should be updated nevertheless.
|
|
#
|
|
connection master;
|
|
UPDATE t1 SET C2 = 'I' WHERE C1 = 'A' AND C2 = 'C';
|
|
SELECT * FROM t1 ORDER BY C1,C2;
|
|
sync_slave_with_master;
|
|
SELECT * FROM t1 ORDER BY C1,C2;
|
|
|
|
# Testing update with a condition that does not match any rows, but
|
|
# which has a match for the index.
|
|
connection master;
|
|
UPDATE t1 SET c2 = 'Q' WHERE c1 = 'A' AND c2 = 'N';
|
|
SELECT * FROM t1 ORDER BY c1,c2;
|
|
sync_slave_with_master;
|
|
SELECT * FROM t1 ORDER BY c1,c2;
|
|
|
|
#
|
|
# Testing table with primary key
|
|
#
|
|
connection master;
|
|
eval CREATE TABLE t2 (c1 INT, c12 char(1), c2 INT, PRIMARY KEY (c1)) ENGINE = $type ;
|
|
INSERT INTO t2
|
|
VALUES (1,'A',2), (2,'A',4), (3,'A',9), (4,'A',15), (5,'A',25),
|
|
(6,'A',35), (7,'A',50), (8,'A',64), (9,'A',81);
|
|
SELECT * FROM t2 ORDER BY c1,c2;
|
|
SELECT * FROM t2 WHERE c2 = c1 * c1 ORDER BY c1,c2;
|
|
sync_slave_with_master;
|
|
SELECT * FROM t2 ORDER BY c1,c2;
|
|
SELECT * FROM t2 WHERE c2 = c1 * c1 ORDER BY c1,c2;
|
|
|
|
connection master;
|
|
UPDATE t2 SET c2 = c1*c1 WHERE c2 != c1*c1;
|
|
SELECT * FROM t2 WHERE c2 = c1 * c1 ORDER BY c1,c2;
|
|
sync_slave_with_master;
|
|
SELECT * FROM t2 WHERE c2 = c1 * c1 ORDER BY c1,c2;
|
|
|
|
# Testing update with a condition that does not match any rows, but
|
|
# which has a match for the primary key.
|
|
connection master;
|
|
UPDATE t2 SET c12 = 'Q' WHERE c1 = 1 AND c2 = 999;
|
|
SELECT * FROM t2 ORDER BY c1,c2;
|
|
sync_slave_with_master;
|
|
SELECT * FROM t2 ORDER BY c1,c2;
|
|
|
|
connection master;
|
|
DELETE FROM t2 WHERE c1 % 4 = 0;
|
|
SELECT * FROM t2 ORDER BY c1,c2;
|
|
sync_slave_with_master;
|
|
SELECT * FROM t2 ORDER BY c1,c2;
|
|
|
|
connection master;
|
|
UPDATE t2 SET c12='X';
|
|
|
|
#
|
|
# Testing table with a multi-column primary key.
|
|
#
|
|
connection master;
|
|
eval CREATE TABLE t3 (C1 CHAR(1), C2 CHAR(1), pk1 INT, C3 CHAR(1), pk2 INT, PRIMARY KEY (pk1,pk2)) ENGINE = $type ;
|
|
|
|
INSERT INTO t3 VALUES ('A','B',1,'B',1), ('X','Y',2,'B',1), ('X','X',3,'B',1);
|
|
INSERT INTO t3 VALUES ('A','C',1,'B',2), ('X','Z',2,'B',2), ('A','A',3,'B',2);
|
|
SELECT * FROM t3 ORDER BY C1,C2;
|
|
sync_slave_with_master;
|
|
SELECT * FROM t3 ORDER BY C1,C2;
|
|
|
|
connection master;
|
|
DELETE FROM t3 WHERE C1 = C2;
|
|
SELECT * FROM t3 ORDER BY C1,C2;
|
|
sync_slave_with_master;
|
|
SELECT * FROM t3 ORDER BY C1,C2;
|
|
|
|
connection master;
|
|
UPDATE t3 SET C2 = 'I' WHERE C1 = 'A' AND C2 = 'C';
|
|
SELECT * FROM t3 ORDER BY C1,C2;
|
|
sync_slave_with_master;
|
|
SELECT * FROM t3 ORDER BY C1,C2;
|
|
|
|
#
|
|
# Testing table without index or primary key
|
|
#
|
|
connection master;
|
|
eval CREATE TABLE t6 (C1 CHAR(1), C2 CHAR(1), C3 INT$extra_index_t6) ENGINE = $type;
|
|
|
|
# Testing insert
|
|
INSERT INTO t6 VALUES ('A','B',1), ('X','Y',2), ('X','X',3);
|
|
INSERT INTO t6 VALUES ('A','C',4), ('X','Z',5), ('A','A',6);
|
|
SELECT * FROM t6 ORDER BY C3;
|
|
sync_slave_with_master;
|
|
SELECT * FROM t6 ORDER BY C3;
|
|
|
|
# Testing delete
|
|
# Observe that are several rows having the value for the index but only one
|
|
# should be deleted.
|
|
connection master;
|
|
DELETE FROM t6 WHERE C1 = C2;
|
|
SELECT * FROM t6 ORDER BY C3;
|
|
sync_slave_with_master;
|
|
SELECT * FROM t6 ORDER BY C3;
|
|
|
|
#
|
|
# Testing update.
|
|
# Note that we have a condition on a column that is not part of the index for
|
|
# the table. The right row should be updated nevertheless.
|
|
#
|
|
connection master;
|
|
UPDATE t6 SET C2 = 'I' WHERE C1 = 'A' AND C2 = 'C';
|
|
SELECT * FROM t6 ORDER BY C3;
|
|
sync_slave_with_master;
|
|
SELECT * FROM t6 ORDER BY C3;
|
|
|
|
# now mixing the 3 tables without begin/commit
|
|
connection master;
|
|
eval CREATE TABLE t5 (C1 CHAR(1), C2 CHAR(1), C3 INT PRIMARY KEY) ENGINE = $type ;
|
|
INSERT INTO t5 VALUES ('A','B',1), ('X','Y',2), ('X','X',3);
|
|
INSERT INTO t5 VALUES ('A','C',4), ('X','Z',5), ('A','A',6);
|
|
|
|
UPDATE t5,t2,t3 SET t5.C2='Q', t2.c12='R', t3.C3 ='S' WHERE t5.C1 = t2.c12 AND t5.C1 = t3.C1;
|
|
SELECT * FROM t5,t2,t3 WHERE t5.C2='Q' AND t2.c12='R' AND t3.C3 ='S' ORDER BY t5.C3,t2.c1,t3.pk1,t3.pk2;
|
|
sync_slave_with_master;
|
|
SELECT * FROM t5,t2,t3 WHERE t5.C2='Q' AND t2.c12='R' AND t3.C3 ='S' ORDER BY t5.C3,t2.c1,t3.pk1,t3.pk2;
|
|
|
|
#
|
|
# Testing special column types
|
|
#
|
|
|
|
connection master;
|
|
eval CREATE TABLE t4 (C1 CHAR(1) PRIMARY KEY, B1 BIT(1), B2 BIT(1) NOT NULL DEFAULT 0, C2 CHAR(1) NOT NULL DEFAULT 'A') ENGINE = $type ;
|
|
|
|
INSERT INTO t4 SET C1 = 1;
|
|
SELECT C1,HEX(B1),HEX(B2) FROM t4 ORDER BY C1;
|
|
sync_slave_with_master;
|
|
SELECT C1,HEX(B1),HEX(B2) FROM t4 ORDER BY C1;
|
|
|
|
#
|
|
# Testing conflicting operations
|
|
#
|
|
connection master;
|
|
eval CREATE TABLE t7 (C1 INT PRIMARY KEY, C2 INT) ENGINE = $type ;
|
|
sync_slave_with_master;
|
|
--echo --- on slave: original values ---
|
|
INSERT INTO t7 VALUES (1,3), (2,6), (3,9);
|
|
SELECT * FROM t7 ORDER BY C1;
|
|
|
|
connection master;
|
|
--echo --- on master: new values inserted ---
|
|
INSERT INTO t7 VALUES (1,2), (2,4), (3,6);
|
|
SELECT * FROM t7 ORDER BY C1;
|
|
sync_slave_with_master;
|
|
--echo --- on slave: old values should be overwritten by replicated values ---
|
|
SELECT * FROM t7 ORDER BY C1;
|
|
|
|
#
|
|
# A more complicated test where the table has several keys and we are
|
|
# causing a conflict for a key that is not "last".
|
|
#
|
|
connection master;
|
|
--echo --- on master ---
|
|
eval CREATE TABLE t8 (a INT PRIMARY KEY, b INT UNIQUE, c INT UNIQUE) ENGINE = $type ;
|
|
|
|
# First we make sure that the constraints are correctly set.
|
|
INSERT INTO t8 VALUES (99,99,99);
|
|
--error ER_DUP_ENTRY
|
|
INSERT INTO t8 VALUES (99,22,33);
|
|
--error ER_DUP_ENTRY
|
|
INSERT INTO t8 VALUES (11,99,33);
|
|
--error ER_DUP_ENTRY
|
|
INSERT INTO t8 VALUES (11,22,99);
|
|
SELECT * FROM t8 ORDER BY a;
|
|
|
|
sync_slave_with_master;
|
|
--echo --- on slave ---
|
|
SELECT * FROM t8 ORDER BY a;
|
|
INSERT INTO t8 VALUES (1,2,3), (2,4,6), (3,6,9);
|
|
SELECT * FROM t8 ORDER BY a;
|
|
|
|
connection master;
|
|
--echo --- on master ---
|
|
# We insert a row that will cause conflict on the primary key but not
|
|
# on the other keys.
|
|
INSERT INTO t8 VALUES (2,4,8);
|
|
sync_slave_with_master;
|
|
--echo --- on slave ---
|
|
SELECT * FROM t8 ORDER BY a;
|
|
|
|
# BUG#31552: Replication breaks when deleting rows from out-of-sync
|
|
# table without PK
|
|
|
|
--echo **** Test for BUG#31552 ****
|
|
|
|
--echo **** On Master ****
|
|
# Clean up t1 so that we can use it.
|
|
connection master;
|
|
DELETE FROM t1;
|
|
sync_slave_with_master;
|
|
|
|
# Just to get a clean binary log
|
|
source include/reset_master_and_slave.inc;
|
|
|
|
--echo **** On Master ****
|
|
connection master;
|
|
INSERT INTO t1 VALUES ('K','K'), ('L','L'), ('M','M');
|
|
--echo **** On Master ****
|
|
sync_slave_with_master;
|
|
DELETE FROM t1 WHERE C1 = 'L';
|
|
|
|
connection master;
|
|
DELETE FROM t1;
|
|
query_vertical SELECT COUNT(*) FROM t1 ORDER BY c1,c2;
|
|
sync_slave_with_master;
|
|
let $last_error = query_get_value("SHOW SLAVE STATUS", Last_SQL_Errno, 1);
|
|
disable_query_log;
|
|
eval SELECT "$last_error" AS Last_SQL_Error;
|
|
enable_query_log;
|
|
query_vertical SELECT COUNT(*) FROM t1 ORDER BY c1,c2;
|
|
|
|
#
|
|
# cleanup
|
|
#
|
|
|
|
connection master;
|
|
DROP TABLE IF EXISTS t1,t2,t3,t4,t5,t6,t7,t8;
|
|
sync_slave_with_master;
|