Skip to content

M
MariaDB
Commit fe4f766e authored by Jan Lindström's avatar Jan Lindström
Browse files
Options

Add wait_condition to wait that node returns to ready state before 

accessing it.
parent 5709a777
Show whitespace changes
Inline Side-by-side
Showing with 67 additions and 54 deletions
mysql-test/suite/galera/r/galera_var_ignore_apply_errors.result
View file @ fe4f766e
...@@ -38,13 +38,13 @@ INSERT INTO t1 VALUES (1); ...@@ -38,13 +38,13 @@ INSERT INTO t1 VALUES (1);
SET GLOBAL wsrep_on = ON; SET GLOBAL wsrep_on = ON;
DELETE FROM t1 WHERE f1 = 1; DELETE FROM t1 WHERE f1 = 1;
connection node_1; connection node_1;
SELECT COUNT(*) = 0 FROM t1; SELECT COUNT(*) as expect_0 FROM t1;
COUNT(*) = 0 expect_0
1 0
connection node_2; connection node_2;
SELECT COUNT(*) = 0 FROM t1; SELECT COUNT(*) as expect_0 FROM t1;
COUNT(*) = 0 expect_0
1 0
DROP TABLE t1; DROP TABLE t1;
connection node_1; connection node_1;
CREATE TABLE t1 (f1 INTEGER); CREATE TABLE t1 (f1 INTEGER);
...@@ -58,12 +58,12 @@ DELETE FROM t1 WHERE f1 = 1; ...@@ -58,12 +58,12 @@ DELETE FROM t1 WHERE f1 = 1;
DELETE FROM t1 WHERE f1 = 2; DELETE FROM t1 WHERE f1 = 2;
COMMIT; COMMIT;
connection node_1; connection node_1;
SELECT COUNT(*) = 1 FROM t1; SELECT COUNT(*) as expect_1 FROM t1;
COUNT(*) = 1 expect_1
1 1
connection node_2; connection node_2;
SELECT COUNT(*) = 1 FROM t1; SELECT COUNT(*) as expect_1 FROM t1;
COUNT(*) = 1 expect_1
1 1
DROP TABLE t1; DROP TABLE t1;
connection node_1; connection node_1;
...@@ -75,16 +75,16 @@ DELETE FROM t1 WHERE f1 = 3; ...@@ -75,16 +75,16 @@ DELETE FROM t1 WHERE f1 = 3;
SET SESSION wsrep_on = ON; SET SESSION wsrep_on = ON;
connection node_1; connection node_1;
DELETE FROM t1; DELETE FROM t1;
SELECT COUNT(*) = 0 FROM t1; SELECT COUNT(*) as expect_0 FROM t1;
COUNT(*) = 0 expect_0
1 0
connection node_2; connection node_2;
SELECT VARIABLE_VALUE = 'Primary' FROM INFORMATION_SCHEMA.GLOBAL_STATUS WHERE VARIABLE_NAME = 'wsrep_cluster_status'; SELECT VARIABLE_VALUE = 'Primary' FROM INFORMATION_SCHEMA.GLOBAL_STATUS WHERE VARIABLE_NAME = 'wsrep_cluster_status';
VARIABLE_VALUE = 'Primary' VARIABLE_VALUE = 'Primary'
1 1
SELECT COUNT(*) = 0 FROM t1; SELECT COUNT(*) as expect_0 FROM t1;
COUNT(*) = 0 expect_0
1 0
DROP TABLE t1; DROP TABLE t1;
connection node_1; connection node_1;
CREATE TABLE t1 (f1 INTEGER PRIMARY KEY) ENGINE=InnoDB; CREATE TABLE t1 (f1 INTEGER PRIMARY KEY) ENGINE=InnoDB;
...@@ -103,16 +103,16 @@ DELETE FROM t1 WHERE f1 = 4; ...@@ -103,16 +103,16 @@ DELETE FROM t1 WHERE f1 = 4;
DELETE FROM t1 WHERE f1 = 5; DELETE FROM t1 WHERE f1 = 5;
COMMIT; COMMIT;
SET AUTOCOMMIT=ON; SET AUTOCOMMIT=ON;
SELECT COUNT(*) = 0 FROM t1; SELECT COUNT(*) as expect_0 FROM t1;
COUNT(*) = 0 expect_0
1 0
connection node_2; connection node_2;
SELECT VARIABLE_VALUE = 'Primary' FROM INFORMATION_SCHEMA.GLOBAL_STATUS WHERE VARIABLE_NAME = 'wsrep_cluster_status'; SELECT VARIABLE_VALUE = 'Primary' FROM INFORMATION_SCHEMA.GLOBAL_STATUS WHERE VARIABLE_NAME = 'wsrep_cluster_status';
VARIABLE_VALUE = 'Primary' VARIABLE_VALUE = 'Primary'
1 1
SELECT COUNT(*) = 0 FROM t1; SELECT COUNT(*) as expect_0 FROM t1;
COUNT(*) = 0 expect_0
1 0
DROP TABLE t1; DROP TABLE t1;
connection node_1; connection node_1;
CREATE TABLE t1 (f1 INTEGER PRIMARY KEY) ENGINE=InnoDB; CREATE TABLE t1 (f1 INTEGER PRIMARY KEY) ENGINE=InnoDB;
...@@ -126,16 +126,16 @@ DELETE FROM t1 WHERE f1 = 3; ...@@ -126,16 +126,16 @@ DELETE FROM t1 WHERE f1 = 3;
SET SESSION wsrep_on = ON; SET SESSION wsrep_on = ON;
connection node_1; connection node_1;
DELETE t1, t2 FROM t1 JOIN t2 WHERE t1.f1 = t2.f1; DELETE t1, t2 FROM t1 JOIN t2 WHERE t1.f1 = t2.f1;
SELECT COUNT(*) = 0 FROM t1; SELECT COUNT(*) as expect_0 FROM t1;
COUNT(*) = 0 expect_0
1 0
connection node_2; connection node_2;
SELECT VARIABLE_VALUE = 'Primary' FROM INFORMATION_SCHEMA.GLOBAL_STATUS WHERE VARIABLE_NAME = 'wsrep_cluster_status'; SELECT VARIABLE_VALUE = 'Primary' FROM INFORMATION_SCHEMA.GLOBAL_STATUS WHERE VARIABLE_NAME = 'wsrep_cluster_status';
VARIABLE_VALUE = 'Primary' VARIABLE_VALUE = 'Primary'
1 1
SELECT COUNT(*) = 0 FROM t1; SELECT COUNT(*) as expect_0 FROM t1;
COUNT(*) = 0 expect_0
1 0
DROP TABLE t1,t2; DROP TABLE t1,t2;
connection node_1; connection node_1;
CREATE TABLE parent (id INT NOT NULL, PRIMARY KEY (id)) ENGINE=INNODB; CREATE TABLE parent (id INT NOT NULL, PRIMARY KEY (id)) ENGINE=INNODB;
...@@ -148,22 +148,22 @@ DELETE FROM child WHERE parent_id = 2; ...@@ -148,22 +148,22 @@ DELETE FROM child WHERE parent_id = 2;
SET SESSION wsrep_on = ON; SET SESSION wsrep_on = ON;
connection node_1; connection node_1;
DELETE FROM parent; DELETE FROM parent;
SELECT COUNT(*) = 0 FROM parent; SELECT COUNT(*) as expect_0 FROM parent;
COUNT(*) = 0 expect_0
1 0
SELECT COUNT(*) = 0 FROM child; SELECT COUNT(*) as expect_0 FROM child;
COUNT(*) = 0 expect_0
1 0
connection node_2; connection node_2;
SELECT VARIABLE_VALUE = 'Primary' FROM INFORMATION_SCHEMA.GLOBAL_STATUS WHERE VARIABLE_NAME = 'wsrep_cluster_status'; SELECT VARIABLE_VALUE = 'Primary' FROM INFORMATION_SCHEMA.GLOBAL_STATUS WHERE VARIABLE_NAME = 'wsrep_cluster_status';
VARIABLE_VALUE = 'Primary' VARIABLE_VALUE = 'Primary'
1 1
SELECT COUNT(*) = 0 FROM parent; SELECT COUNT(*) as expect_0 FROM parent;
COUNT(*) = 0 expect_0
1 0
SELECT COUNT(*) = 0 FROM child; SELECT COUNT(*) as expect_0 FROM child;
COUNT(*) = 0 expect_0
1 0
DROP TABLE child, parent; DROP TABLE child, parent;
connection node_2; connection node_2;
SET GLOBAL wsrep_ignore_apply_errors = 4; SET GLOBAL wsrep_ignore_apply_errors = 4;
......
mysql-test/suite/galera/t/galera_var_ignore_apply_errors.test
View file @ fe4f766e
...@@ -18,12 +18,14 @@ SET GLOBAL wsrep_ignore_apply_errors = 1; ...@@ -18,12 +18,14 @@ SET GLOBAL wsrep_ignore_apply_errors = 1;
SET GLOBAL wsrep_on = OFF; SET GLOBAL wsrep_on = OFF;
CREATE TABLE t1 (f1 INTEGER); CREATE TABLE t1 (f1 INTEGER);
SET GLOBAL wsrep_on = ON; SET GLOBAL wsrep_on = ON;
--source include/galera_wait_ready.inc
DROP TABLE t1; DROP TABLE t1;
# Drop schema that does not exist # Drop schema that does not exist
SET GLOBAL wsrep_on = OFF; SET GLOBAL wsrep_on = OFF;
CREATE SCHEMA s1; CREATE SCHEMA s1;
SET GLOBAL wsrep_on = ON; SET GLOBAL wsrep_on = ON;
--source include/galera_wait_ready.inc
DROP SCHEMA s1; DROP SCHEMA s1;
# Drop index that does not exist using DROP INDEX # Drop index that does not exist using DROP INDEX
...@@ -31,6 +33,7 @@ CREATE TABLE t1 (f1 INTEGER); ...@@ -31,6 +33,7 @@ CREATE TABLE t1 (f1 INTEGER);
SET GLOBAL wsrep_on = OFF; SET GLOBAL wsrep_on = OFF;
CREATE INDEX idx1 ON t1 (f1); CREATE INDEX idx1 ON t1 (f1);
SET GLOBAL wsrep_on = ON; SET GLOBAL wsrep_on = ON;
--source include/galera_wait_ready.inc
DROP INDEX idx1 ON t1; DROP INDEX idx1 ON t1;
DROP TABLE t1; DROP TABLE t1;
...@@ -39,6 +42,7 @@ CREATE TABLE t1 (f1 INTEGER); ...@@ -39,6 +42,7 @@ CREATE TABLE t1 (f1 INTEGER);
SET GLOBAL wsrep_on = OFF; SET GLOBAL wsrep_on = OFF;
CREATE INDEX idx1 ON t1 (f1); CREATE INDEX idx1 ON t1 (f1);
SET GLOBAL wsrep_on = ON; SET GLOBAL wsrep_on = ON;
--source include/galera_wait_ready.inc
ALTER TABLE t1 DROP INDEX idx1; ALTER TABLE t1 DROP INDEX idx1;
DROP TABLE t1; DROP TABLE t1;
...@@ -47,6 +51,7 @@ CREATE TABLE t1 (f1 INTEGER); ...@@ -47,6 +51,7 @@ CREATE TABLE t1 (f1 INTEGER);
SET GLOBAL wsrep_on = OFF; SET GLOBAL wsrep_on = OFF;
ALTER TABLE t1 ADD COLUMN f2 INTEGER; ALTER TABLE t1 ADD COLUMN f2 INTEGER;
SET GLOBAL wsrep_on = ON; SET GLOBAL wsrep_on = ON;
--source include/galera_wait_ready.inc
ALTER TABLE t1 DROP COLUMN f2; ALTER TABLE t1 DROP COLUMN f2;
DROP TABLE t1; DROP TABLE t1;
...@@ -64,12 +69,13 @@ CREATE TABLE t1 (f1 INTEGER); ...@@ -64,12 +69,13 @@ CREATE TABLE t1 (f1 INTEGER);
SET GLOBAL wsrep_on = OFF; SET GLOBAL wsrep_on = OFF;
INSERT INTO t1 VALUES (1); INSERT INTO t1 VALUES (1);
SET GLOBAL wsrep_on = ON; SET GLOBAL wsrep_on = ON;
--source include/galera_wait_ready.inc
DELETE FROM t1 WHERE f1 = 1; DELETE FROM t1 WHERE f1 = 1;
--connection node_1 --connection node_1
SELECT COUNT(*) = 0 FROM t1; SELECT COUNT(*) as expect_0 FROM t1;
--connection node_2 --connection node_2
SELECT COUNT(*) = 0 FROM t1; SELECT COUNT(*) as expect_0 FROM t1;
DROP TABLE t1; DROP TABLE t1;
...@@ -80,6 +86,7 @@ INSERT INTO t1 VALUES (2); ...@@ -80,6 +86,7 @@ INSERT INTO t1 VALUES (2);
SET GLOBAL wsrep_on = OFF; SET GLOBAL wsrep_on = OFF;
INSERT INTO t1 VALUES (1); INSERT INTO t1 VALUES (1);
SET GLOBAL wsrep_on = ON; SET GLOBAL wsrep_on = ON;
--source include/galera_wait_ready.inc
START TRANSACTION; START TRANSACTION;
INSERT INTO t1 VALUES (3); INSERT INTO t1 VALUES (3);
DELETE FROM t1 WHERE f1 = 1; DELETE FROM t1 WHERE f1 = 1;
...@@ -87,9 +94,9 @@ DELETE FROM t1 WHERE f1 = 2; ...@@ -87,9 +94,9 @@ DELETE FROM t1 WHERE f1 = 2;
COMMIT; COMMIT;
--connection node_1 --connection node_1
SELECT COUNT(*) = 1 FROM t1; SELECT COUNT(*) as expect_1 FROM t1;
--connection node_2 --connection node_2
SELECT COUNT(*) = 1 FROM t1; SELECT COUNT(*) as expect_1 FROM t1;
DROP TABLE t1; DROP TABLE t1;
...@@ -107,13 +114,14 @@ INSERT INTO t1 VALUES (1),(2),(3),(4),(5); ...@@ -107,13 +114,14 @@ INSERT INTO t1 VALUES (1),(2),(3),(4),(5);
SET SESSION wsrep_on = OFF; SET SESSION wsrep_on = OFF;
DELETE FROM t1 WHERE f1 = 3; DELETE FROM t1 WHERE f1 = 3;
SET SESSION wsrep_on = ON; SET SESSION wsrep_on = ON;
--source include/galera_wait_ready.inc
--connection node_1 --connection node_1
DELETE FROM t1; DELETE FROM t1;
SELECT COUNT(*) = 0 FROM t1; SELECT COUNT(*) as expect_0 FROM t1;
--connection node_2 --connection node_2
SELECT VARIABLE_VALUE = 'Primary' FROM INFORMATION_SCHEMA.GLOBAL_STATUS WHERE VARIABLE_NAME = 'wsrep_cluster_status'; SELECT VARIABLE_VALUE = 'Primary' FROM INFORMATION_SCHEMA.GLOBAL_STATUS WHERE VARIABLE_NAME = 'wsrep_cluster_status';
SELECT COUNT(*) = 0 FROM t1; SELECT COUNT(*) as expect_0 FROM t1;
DROP TABLE t1; DROP TABLE t1;
# #
...@@ -130,6 +138,8 @@ INSERT INTO t1 VALUES (1),(2),(3),(4),(5); ...@@ -130,6 +138,8 @@ INSERT INTO t1 VALUES (1),(2),(3),(4),(5);
SET SESSION wsrep_on = OFF; SET SESSION wsrep_on = OFF;
DELETE FROM t1 WHERE f1 = 3; DELETE FROM t1 WHERE f1 = 3;
SET SESSION wsrep_on = ON; SET SESSION wsrep_on = ON;
--source include/galera_wait_ready.inc
--connection node_1 --connection node_1
SET AUTOCOMMIT=OFF; SET AUTOCOMMIT=OFF;
...@@ -142,10 +152,10 @@ DELETE FROM t1 WHERE f1 = 5; ...@@ -142,10 +152,10 @@ DELETE FROM t1 WHERE f1 = 5;
COMMIT; COMMIT;
SET AUTOCOMMIT=ON; SET AUTOCOMMIT=ON;
SELECT COUNT(*) = 0 FROM t1; SELECT COUNT(*) as expect_0 FROM t1;
--connection node_2 --connection node_2
SELECT VARIABLE_VALUE = 'Primary' FROM INFORMATION_SCHEMA.GLOBAL_STATUS WHERE VARIABLE_NAME = 'wsrep_cluster_status'; SELECT VARIABLE_VALUE = 'Primary' FROM INFORMATION_SCHEMA.GLOBAL_STATUS WHERE VARIABLE_NAME = 'wsrep_cluster_status';
SELECT COUNT(*) = 0 FROM t1; SELECT COUNT(*) as expect_0 FROM t1;
DROP TABLE t1; DROP TABLE t1;
# #
...@@ -166,14 +176,15 @@ SET SESSION wsrep_on = OFF; ...@@ -166,14 +176,15 @@ SET SESSION wsrep_on = OFF;
DELETE FROM t2 WHERE f1 = 2; DELETE FROM t2 WHERE f1 = 2;
DELETE FROM t1 WHERE f1 = 3; DELETE FROM t1 WHERE f1 = 3;
SET SESSION wsrep_on = ON; SET SESSION wsrep_on = ON;
--source include/galera_wait_ready.inc
--connection node_1 --connection node_1
DELETE t1, t2 FROM t1 JOIN t2 WHERE t1.f1 = t2.f1; DELETE t1, t2 FROM t1 JOIN t2 WHERE t1.f1 = t2.f1;
SELECT COUNT(*) = 0 FROM t1; SELECT COUNT(*) as expect_0 FROM t1;
--connection node_2 --connection node_2
SELECT VARIABLE_VALUE = 'Primary' FROM INFORMATION_SCHEMA.GLOBAL_STATUS WHERE VARIABLE_NAME = 'wsrep_cluster_status'; SELECT VARIABLE_VALUE = 'Primary' FROM INFORMATION_SCHEMA.GLOBAL_STATUS WHERE VARIABLE_NAME = 'wsrep_cluster_status';
SELECT COUNT(*) = 0 FROM t1; SELECT COUNT(*) as expect_0 FROM t1;
DROP TABLE t1,t2; DROP TABLE t1,t2;
# #
...@@ -193,16 +204,17 @@ INSERT INTO child VALUES (1,1),(2,2),(3,3); ...@@ -193,16 +204,17 @@ INSERT INTO child VALUES (1,1),(2,2),(3,3);
SET SESSION wsrep_on = OFF; SET SESSION wsrep_on = OFF;
DELETE FROM child WHERE parent_id = 2; DELETE FROM child WHERE parent_id = 2;
SET SESSION wsrep_on = ON; SET SESSION wsrep_on = ON;
--source include/galera_wait_ready.inc
--connection node_1 --connection node_1
DELETE FROM parent; DELETE FROM parent;
SELECT COUNT(*) = 0 FROM parent; SELECT COUNT(*) as expect_0 FROM parent;
SELECT COUNT(*) = 0 FROM child; SELECT COUNT(*) as expect_0 FROM child;
--connection node_2 --connection node_2
SELECT VARIABLE_VALUE = 'Primary' FROM INFORMATION_SCHEMA.GLOBAL_STATUS WHERE VARIABLE_NAME = 'wsrep_cluster_status'; SELECT VARIABLE_VALUE = 'Primary' FROM INFORMATION_SCHEMA.GLOBAL_STATUS WHERE VARIABLE_NAME = 'wsrep_cluster_status';
SELECT COUNT(*) = 0 FROM parent; SELECT COUNT(*) as expect_0 FROM parent;
SELECT COUNT(*) = 0 FROM child; SELECT COUNT(*) as expect_0 FROM child;
DROP TABLE child, parent; DROP TABLE child, parent;
# #
...@@ -217,6 +229,7 @@ SET GLOBAL wsrep_ignore_apply_errors = 4; ...@@ -217,6 +229,7 @@ SET GLOBAL wsrep_ignore_apply_errors = 4;
SET GLOBAL wsrep_on = OFF; SET GLOBAL wsrep_on = OFF;
CREATE TABLE t1 (f1 INTEGER); CREATE TABLE t1 (f1 INTEGER);
SET GLOBAL wsrep_on = ON; SET GLOBAL wsrep_on = ON;
--source include/galera_wait_ready.inc
--connection node_1 --connection node_1
CREATE TABLE t1 (f1 INTEGER, f2 INTEGER); CREATE TABLE t1 (f1 INTEGER, f2 INTEGER);
DROP TABLE t1; DROP TABLE t1;
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment
GitLab Nexedi Edition | About GitLab | About Nexedi | 沪ICP备2021021310号-2 | 沪ICP备2021021310号-7