#############################################################
# Author:  Serge Kozlov <skozlov@mysql.com>
# Date:    03/17/2008
# Purpose: Testing cluster circular replication based on two
# independent channels between two clusters
#############################################################
--source include/have_ndb.inc
--source include/ndb_master-slave_2ch.inc
--source include/have_binlog_format_mixed_or_row.inc
--echo

# Check server_id and set auto_increment_* variables
--echo *** Check server_id of mysqld servers ***
--connection master
SHOW VARIABLES LIKE "server_id";
SET auto_increment_offset = 1;
SET auto_increment_increment = 2;
--connection master1
SHOW VARIABLES LIKE "server_id";
SET auto_increment_offset = 1;
SET auto_increment_increment = 2;
--connection slave
SHOW VARIABLES LIKE "server_id";
SET auto_increment_offset = 2;
SET auto_increment_increment = 2;
--connection slave1
SHOW VARIABLES LIKE "server_id";
SET auto_increment_offset = 2;
SET auto_increment_increment = 2;
--echo

# Preparing data.
--echo *** Preparing data ***
--connection master
CREATE TABLE t1 (a INT NOT NULL AUTO_INCREMENT, b VARCHAR(100), c INT NOT NULL, PRIMARY KEY(a)) ENGINE=ndb;

let $wait_binlog_event= CREATE TABLE t1;
--source include/wait_for_binlog_event.inc
--connection master1
--source include/wait_for_binlog_event.inc
--connection slave
--source include/wait_for_binlog_event.inc
--connection slave1
--source include/wait_for_binlog_event.inc
--echo

#
# Testing
#

--echo *** Basic testing  ***
# insert data via all hosts
--echo Insert rows via all hosts
--disable_query_log
let $counter= 10;
while ($counter) {
 --connection master
 INSERT INTO t1(b,c) VALUES('master',1);
 --connection master1
 INSERT INTO t1(b,c) VALUES('master1',1);
 --connection slave
 INSERT INTO t1(b,c) VALUES('slave',1);
 --connection slave1
 INSERT INTO t1(b,c) VALUES('slave1',1);
 dec $counter;
}
--connection master
--enable_query_log

# Wait replication between clusters
let $wait_condition= SELECT COUNT(*)=40 FROM t1 WHERE c = 1;
--source include/wait_condition.inc
--connection slave
--source include/wait_condition.inc

# Check data
--echo Check data on both clusters 
let $diff_tables= master:t1, slave:t1;
source include/diff_tables.inc;

--echo *** Transaction testing ***
# Start transaction for one mysqld and do mass of inserts for other.
# Do it for for both clusters

--connection master
BEGIN;
--connection slave1
BEGIN;
let $counter= 100;
--connection master
--disable_query_log
while ($counter) {
 --connection master
 INSERT INTO t1(b,c) VALUES('master',2);
 --connection master1
 INSERT INTO t1(b,c) VALUES('master1',2);
 --connection slave
 INSERT INTO t1(b,c) VALUES('slave',2);
 --connection slave1
 INSERT INTO t1(b,c) VALUES('slave1',2);
 dec $counter;
}
--connection master
--enable_query_log
COMMIT;
--connection slave1
COMMIT;

# Wait replication between clusters
--connection master
let $wait_condition= SELECT COUNT(*)=400 FROM t1 WHERE c = 2;
--source include/wait_condition.inc
--connection slave
--source include/wait_condition.inc

--echo Check data on both clusters 
let $diff_tables= master:t1, slave:t1;
source include/diff_tables.inc;

# Start transaction and then roll back

--connection master
BEGIN;
--connection slave1
BEGIN;
let $counter= 100;
--connection master
--disable_query_log
while ($counter) {
 --connection master
 INSERT INTO t1(b,c) VALUES('master',3);
 --connection master1
 INSERT INTO t1(b,c) VALUES('master1',3);
 --connection slave
 INSERT INTO t1(b,c) VALUES('slave',3);
 --connection slave1
 INSERT INTO t1(b,c) VALUES('slave1',3);
 dec $counter;
}
--connection master
--enable_query_log
ROLLBACK;
--connection slave1
ROLLBACK;

# Wait replication between clusters
--connection master
let $wait_condition= SELECT COUNT(*)=200 FROM t1 WHERE c = 3;
--source include/wait_condition.inc
--connection slave
--source include/wait_condition.inc

--echo Check data on both clusters 
let $diff_tables= master:t1, slave:t1;
source include/diff_tables.inc;

# Clean up
--connection master
DROP TABLE IF EXISTS t1;
--connection slave
# Wait until table is dropped on slave.
--let $query= SELECT COUNT(*) FROM t1
--source include/wait_for_query_to_fail.inc
--echo

# End of test 5.1
--source include/rpl_end.inc