mirror of
https://github.com/MariaDB/server.git
synced 2025-01-31 02:51:44 +01:00
9854fb6fa7
This patch adds for "--ps-protocol" second execution of queries "SELECT". Also in this patch it is added ability to disable/enable (--disable_ps2_protocol/--enable_ps2_protocol) second execution for "--ps-prototocol" in testcases.
124 lines
3.5 KiB
Text
124 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 written to the binary log using 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 ====
|
|
|
|
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
|
|
--disable_ps2_protocol
|
|
SELECT FOUND_ROWS() INTO @a;
|
|
--enable_ps2_protocol
|
|
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
|
|
--disable_ps2_protocol
|
|
SELECT FOUND_ROWS() INTO @a;
|
|
--enable_ps2_protocol
|
|
INSERT INTO logtbl VALUES(1,2,@a);
|
|
|
|
SELECT * FROM logtbl WHERE sect = 1 ORDER BY sect,test;
|
|
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.
|
|
|
|
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;
|
|
--disable_ps2_protocol
|
|
SELECT FOUND_ROWS() INTO @found_rows;
|
|
--enable_ps2_protocol
|
|
CALL just_log(2,3,@found_rows);
|
|
|
|
SELECT * FROM logtbl WHERE sect = 2 ORDER BY sect,test;
|
|
sync_slave_with_master;
|
|
SELECT * FROM logtbl WHERE sect = 2 ORDER BY sect,test;
|
|
|
|
|
|
--echo ==== Stored functions ====
|
|
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;
|
|
--disable_ps2_protocol
|
|
SELECT FOUND_ROWS() INTO @found_rows;
|
|
SELECT log_rows(3,1,@found_rows), log_rows(3,2,@found_rows);
|
|
--enable_ps2_protocol
|
|
|
|
SELECT * FROM logtbl WHERE sect = 3 ORDER BY sect,test;
|
|
sync_slave_with_master;
|
|
SELECT * FROM logtbl WHERE sect = 3 ORDER BY sect,test;
|
|
|
|
|
|
--echo ==== Cleanup ====
|
|
connection master;
|
|
DROP TABLE t1, logtbl;
|
|
DROP PROCEDURE just_log;
|
|
DROP PROCEDURE calc_and_log;
|
|
DROP FUNCTION log_rows;
|
|
|
|
--source include/rpl_end.inc
|