Commit 4eb4d078 authored by Jan Lindström's avatar Jan Lindström

Fix Galera test galera_as_slave_ctas.

parent 9ab171ed
connect node_2a, 127.0.0.1, root, , test, $NODE_MYPORT_2; connection node_2;
connection node_1;
connect node_3, 127.0.0.1, root, , test, $NODE_MYPORT_3; connect node_3, 127.0.0.1, root, , test, $NODE_MYPORT_3;
connection node_2a; SELECT @@wsrep_on;
@@wsrep_on
0
connection node_1;
START SLAVE; START SLAVE;
connection default; connection node_3;
SHOW VARIABLES LIKE 'binlog_format'; SHOW VARIABLES LIKE 'binlog_format';
Variable_name Value Variable_name Value
binlog_format ROW binlog_format ROW
connection default;
CREATE TABLE source (f1 INTEGER PRIMARY KEY) ENGINE=InnoDB; CREATE TABLE source (f1 INTEGER PRIMARY KEY) ENGINE=InnoDB;
CREATE TABLE target AS SELECT * FROM source; CREATE TABLE target AS SELECT * FROM source;
connection node_2a; connection node_1;
connection node_2;
connection node_3; connection node_3;
connection default;
DROP TABLE target; DROP TABLE target;
INSERT INTO source VALUES(1); INSERT INTO source VALUES(1);
CREATE TABLE target AS SELECT * FROM source; CREATE TABLE target AS SELECT * FROM source;
connection node_2a; connection node_1;
connection node_2;
connection node_3; connection node_3;
connection default;
DROP TABLE source; DROP TABLE source;
DROP TABLE target; DROP TABLE target;
connection node_3; connection node_2;
connection node_2a; connection node_1;
STOP SLAVE; STOP SLAVE;
RESET SLAVE ALL; RESET SLAVE ALL;
connection default; connection node_3;
RESET MASTER; RESET MASTER;
disconnect node_2a;
...@@ -6,69 +6,69 @@ ...@@ -6,69 +6,69 @@
# #
--source include/have_innodb.inc --source include/have_innodb.inc
--source include/have_log_bin.inc
--source include/galera_cluster.inc
# As node #1 is not a Galera node, we connect to node #2 in order to run include/galera_cluster.inc # As node #3 is not a Galera node, and galera_cluster.inc does not open connetion to it
--connect node_2a, 127.0.0.1, root, , test, $NODE_MYPORT_2 # we open the node_3 connection here
--connect node_3, 127.0.0.1, root, , test, $NODE_MYPORT_3 --connect node_3, 127.0.0.1, root, , test, $NODE_MYPORT_3
SELECT @@wsrep_on;
--connection node_2a --connection node_1
--disable_query_log --disable_query_log
--eval CHANGE MASTER TO MASTER_HOST='127.0.0.1', MASTER_USER='root', MASTER_PORT=$NODE_MYPORT_1; --eval CHANGE MASTER TO MASTER_HOST='127.0.0.1', MASTER_USER='root', MASTER_PORT=$NODE_MYPORT_3;
--enable_query_log --enable_query_log
START SLAVE; START SLAVE;
# make sure master server has binlog_format=ROW # make sure master server has binlog_format=ROW
--connection default --connection node_3
SHOW VARIABLES LIKE 'binlog_format'; SHOW VARIABLES LIKE 'binlog_format';
# #
# test phase one, issue CTAS with empty source table # test phase one, issue CTAS with empty source table
# #
--connection default
CREATE TABLE source (f1 INTEGER PRIMARY KEY) ENGINE=InnoDB; CREATE TABLE source (f1 INTEGER PRIMARY KEY) ENGINE=InnoDB;
CREATE TABLE target AS SELECT * FROM source; CREATE TABLE target AS SELECT * FROM source;
--connection node_2a --connection node_1
--let $wait_condition = SELECT COUNT(*) = 1 FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_NAME = 'target'; --let $wait_condition = SELECT COUNT(*) = 1 FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_NAME = 'target';
--source include/wait_condition.inc --source include/wait_condition.inc
--connection node_3 --connection node_2
--let $wait_condition = SELECT COUNT(*) = 1 FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_NAME = 'target'; --let $wait_condition = SELECT COUNT(*) = 1 FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_NAME = 'target';
--source include/wait_condition.inc --source include/wait_condition.inc
# #
# test phase two, issue CTAS with populated source table # test phase two, issue CTAS with populated source table
# #
--connection default --connection node_3
DROP TABLE target; DROP TABLE target;
INSERT INTO source VALUES(1); INSERT INTO source VALUES(1);
CREATE TABLE target AS SELECT * FROM source; CREATE TABLE target AS SELECT * FROM source;
--connection node_2a --connection node_1
--let $wait_condition = SELECT COUNT(*) = 1 FROM target; --let $wait_condition = SELECT COUNT(*) = 1 FROM target;
--source include/wait_condition.inc --source include/wait_condition.inc
--connection node_3 --connection node_2
--let $wait_condition = SELECT COUNT(*) = 1 FROM target; --let $wait_condition = SELECT COUNT(*) = 1 FROM target;
--source include/wait_condition.inc --source include/wait_condition.inc
--connection default --connection node_3
DROP TABLE source; DROP TABLE source;
DROP TABLE target; DROP TABLE target;
--connection node_3 --connection node_2
--let $wait_condition = SELECT COUNT(*) = 0 FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_NAME = 'target'; --let $wait_condition = SELECT COUNT(*) = 0 FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_NAME = 'target';
--source include/wait_condition.inc --source include/wait_condition.inc
--connection node_1
--connection node_2a
STOP SLAVE; STOP SLAVE;
RESET SLAVE ALL; RESET SLAVE ALL;
--connection default --connection node_3
RESET MASTER; RESET MASTER;
--disconnect node_2a
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