mirror of
https://github.com/MariaDB/server.git
synced 2025-02-09 23:24:11 +01:00
51c8289ed6
The galera.galera_parallel_autoinc_manytrx mtr test opens and runs test scenario through 3 connections to node 1 and one connection to node 2. In the test initialization phase, the test creates two tables 't1' and 'ten' and then creates a stored procedure 'p1' to operate on these tables. These 3 create DDL statements are issued through same connection to node 1. In the next test phase, the mtr script uses send command to launch the call for the p1 stored procedure through all 3 connections to node 1 and through one connection to node 2. As the mtr send command is asynchronous, this test phase is non blocking and fast operation. Now, if the replication between nodes is slow, it may happen that the initialization phase DDL statements have not been received or have not been fully applied in node 2. Therefore there is no guarantee that the test tables and the stored procedure have been created in node 2. Yet, the test is trying to call p1 in node 2. In the failure case error logs, there is error message "MTR failed: query 'reap' failed: 1305: PROCEDURE test.p1 does not exist" The reap command through connection to node 2, is the first place where test execution may observe that test tables and/or stored procedure are not yet created in node 2. The fix in this commit adds a wait condition in connection to node 2, to wait until the stored procedure is created before calling the stored procedure. The wait is implemented by looking in information_schema.routines for the p1 stored procedure.
37 lines
890 B
Text
37 lines
890 B
Text
connection node_2;
|
|
connection node_1;
|
|
connection node_1;
|
|
CREATE TABLE ten (f1 INTEGER) Engine=InnoDB;
|
|
INSERT INTO ten VALUES (1),(2),(3),(4),(5),(6),(7),(8),(9),(10);
|
|
CREATE TABLE t1 (f1 INTEGER AUTO_INCREMENT PRIMARY KEY, f2 INTEGER) Engine=InnoDB;
|
|
connection node_2;
|
|
set session wsrep_sync_wait=15;
|
|
SET GLOBAL wsrep_slave_threads = 4;
|
|
connection node_1;
|
|
CREATE PROCEDURE p1 (repeat_count int)
|
|
BEGIN
|
|
DECLARE current_num int;
|
|
SET current_num = 0;
|
|
WHILE current_num < repeat_count do
|
|
INSERT INTO t1 (f2) SELECT 1 FROM ten AS a1;
|
|
COMMIT;
|
|
SET current_num = current_num + 1;
|
|
END WHILE;
|
|
END|
|
|
call p1(1000);
|
|
connection node_1;
|
|
connection node_1a;
|
|
connection node_1b;
|
|
connection node_2;
|
|
SELECT COUNT(*) FROM t1;
|
|
COUNT(*)
|
|
40000
|
|
SELECT COUNT(DISTINCT f1) FROM t1;
|
|
COUNT(DISTINCT f1)
|
|
40000
|
|
disconnect node_1a;
|
|
disconnect node_1b;
|
|
connection default;
|
|
DROP TABLE t1;
|
|
DROP TABLE ten;
|
|
DROP PROCEDURE p1;
|