mirror of
https://github.com/MariaDB/server.git
synced 2025-01-21 06:22:28 +01:00
125 lines
3.5 KiB
Text
125 lines
3.5 KiB
Text
source include/have_binlog_format_statement.inc;
|
|
source include/master-slave.inc;
|
|
|
|
disable_query_log;
|
|
call mtr.add_suppression("Unsafe statement binlogged in statement format since BINLOG_FORMAT = STATEMENT");
|
|
enable_query_log;
|
|
|
|
# It is not possible to replicate FOUND_ROWS() using statement-based
|
|
# replication, but there is a workaround that stores the result of
|
|
# FOUND_ROWS() into a user variable and then replicates this instead.
|
|
#
|
|
# The purpose of this test case is to test that the workaround works
|
|
# properly even when inside stored programs (i.e., stored routines and
|
|
# triggers).
|
|
|
|
--echo ==== Initialize ====
|
|
|
|
--echo **** On Master ****
|
|
connection master;
|
|
CREATE TABLE t1 (a INT);
|
|
CREATE TABLE logtbl (sect INT, test INT, count INT);
|
|
|
|
INSERT INTO t1 VALUES (1),(2),(3);
|
|
INSERT INTO t1 SELECT 2*a+3 FROM t1;
|
|
INSERT INTO t1 SELECT 2*a+3 FROM t1;
|
|
INSERT INTO t1 SELECT 2*a+3 FROM t1;
|
|
INSERT INTO t1 SELECT 2*a+3 FROM t1;
|
|
INSERT INTO t1 SELECT 2*a+3 FROM t1;
|
|
INSERT INTO t1 SELECT 2*a+3 FROM t1;
|
|
|
|
|
|
--echo ==== Simple test ====
|
|
|
|
SELECT SQL_CALC_FOUND_ROWS * FROM t1 WHERE a > 5 ORDER BY a LIMIT 1;
|
|
|
|
# Instead of
|
|
# INSERT INTO logtbl VALUES(1, 1, FOUND_ROWS());
|
|
# we write
|
|
SELECT FOUND_ROWS() INTO @a;
|
|
INSERT INTO logtbl VALUES(1,1,@a);
|
|
|
|
SELECT SQL_CALC_FOUND_ROWS * FROM t1 WHERE a < 5 ORDER BY a LIMIT 1;
|
|
# Instead of
|
|
# INSERT INTO logtbl VALUES(1, 2, FOUND_ROWS());
|
|
# we write
|
|
SELECT FOUND_ROWS() INTO @a;
|
|
INSERT INTO logtbl VALUES(1,2,@a);
|
|
|
|
SELECT * FROM logtbl WHERE sect = 1 ORDER BY sect,test;
|
|
--echo **** On Slave ****
|
|
sync_slave_with_master;
|
|
SELECT * FROM logtbl WHERE sect = 1 ORDER BY sect,test;
|
|
|
|
|
|
--echo ==== Stored procedure ====
|
|
|
|
# Here we do both the calculation and the logging. We also do it twice
|
|
# to make sure that there are no limitations on how many times it can
|
|
# be used.
|
|
|
|
--echo **** On Master ****
|
|
connection master;
|
|
--delimiter $$
|
|
CREATE PROCEDURE calc_and_log(sect INT, test INT) BEGIN
|
|
DECLARE cnt INT;
|
|
SELECT SQL_CALC_FOUND_ROWS * FROM t1 WHERE a < 5 ORDER BY a LIMIT 1;
|
|
SELECT FOUND_ROWS() INTO cnt;
|
|
INSERT INTO logtbl VALUES(sect,test,cnt);
|
|
SELECT SQL_CALC_FOUND_ROWS * FROM t1 WHERE a > 5 ORDER BY a LIMIT 1;
|
|
SELECT FOUND_ROWS() INTO cnt;
|
|
INSERT INTO logtbl VALUES(sect,test+1,cnt);
|
|
END $$
|
|
--delimiter ;
|
|
|
|
CALL calc_and_log(2,1);
|
|
|
|
--delimiter $$
|
|
CREATE PROCEDURE just_log(sect INT, test INT, found_rows INT) BEGIN
|
|
INSERT INTO logtbl VALUES (sect,test,found_rows);
|
|
END $$
|
|
--delimiter ;
|
|
|
|
SELECT SQL_CALC_FOUND_ROWS * FROM t1 WHERE a > 5 ORDER BY a LIMIT 1;
|
|
SELECT FOUND_ROWS() INTO @found_rows;
|
|
CALL just_log(2,3,@found_rows);
|
|
|
|
SELECT * FROM logtbl WHERE sect = 2 ORDER BY sect,test;
|
|
--echo **** On Slave ****
|
|
sync_slave_with_master;
|
|
SELECT * FROM logtbl WHERE sect = 2 ORDER BY sect,test;
|
|
|
|
|
|
--echo ==== Stored functions ====
|
|
--echo **** On Master ****
|
|
connection master;
|
|
--delimiter $$
|
|
CREATE FUNCTION log_rows(sect INT, test INT, found_rows INT)
|
|
RETURNS INT
|
|
BEGIN
|
|
INSERT INTO logtbl VALUES(sect,test,found_rows);
|
|
RETURN found_rows;
|
|
END $$
|
|
--delimiter ;
|
|
|
|
SELECT SQL_CALC_FOUND_ROWS * FROM t1 WHERE a > 5 ORDER BY a LIMIT 1;
|
|
SELECT FOUND_ROWS() INTO @found_rows;
|
|
SELECT log_rows(3,1,@found_rows), log_rows(3,2,@found_rows);
|
|
|
|
SELECT * FROM logtbl WHERE sect = 3 ORDER BY sect,test;
|
|
--echo **** On Slave ****
|
|
sync_slave_with_master;
|
|
SELECT * FROM logtbl WHERE sect = 3 ORDER BY sect,test;
|
|
|
|
|
|
--echo ==== Cleanup ====
|
|
--echo **** On Master ****
|
|
connection master;
|
|
DROP TABLE t1, logtbl;
|
|
DROP PROCEDURE just_log;
|
|
DROP PROCEDURE calc_and_log;
|
|
DROP FUNCTION log_rows;
|
|
sync_slave_with_master;
|
|
|
|
source include/reset_master_and_slave.inc;
|
|
|