include/master-slave.inc
[connection master]
**** Test 1 ****
delete from mysql.ndb_replication;
insert into mysql.ndb_replication values ("test", "t1", 0, 1, NULL);
create table t1 (a int key, b varchar(32), c varchar(32)) engine ndb;
create table t2 (a int key, b varchar(32), c varchar(32)) engine ndb;
insert into t1 values (1,"t1.b from master", "t1.c from master");
insert into t2 values (1,"t2.b from master", "t2.c from master");
select * from t1;
a	b	c
select * from t2;
a	b	c
1	t2.b from master	t2.c from master
drop table t1;
drop table t2;
**** Test 2 ****
delete from mysql.ndb_replication;
insert into mysql.ndb_replication values ("test", "t1", 0, 2, NULL);
set global ndb_log_updated_only=0;
create table t1 (a int key, b varchar(32), c varchar(32)) engine ndb;
create table t2 (a int key, b varchar(32), c varchar(32)) engine ndb;
insert into t1 values (1,"t1.b from master", "t1.c from master");
insert into t2 values (1,"t2.b from master", "t2.c from master");
select * from t1;
a	b	c
1	t1.b from master	t1.c from master
select * from t2;
a	b	c
1	t2.b from master	t2.c from master
update t1 set c="t1.c from slave";
update t2 set c="t2.c from slave";
update t1 set b="updated t1.b from master";
update t2 set b="updated t2.b from master";
select * from t1;
a	b	c
1	updated t1.b from master	t1.c from slave
select * from t2;
a	b	c
1	updated t2.b from master	t2.c from master
drop table t1;
drop table t2;
**** Test 3 ****
delete from mysql.ndb_replication;
insert into mysql.ndb_replication values ("test", "t1", 0, 3, NULL);
set global ndb_log_updated_only=1;
create table t1 (a int key, b varchar(32), c varchar(32)) engine ndb;
create table t2 (a int key, b varchar(32), c varchar(32)) engine ndb;
insert into t1 values (1,"t1.b from master", "t1.c from master");
insert into t2 values (1,"t2.b from master", "t2.c from master");
select * from t1;
a	b	c
1	t1.b from master	t1.c from master
select * from t2;
a	b	c
1	t2.b from master	t2.c from master
update t1 set c="t1.c from slave";
update t2 set c="t2.c from slave";
update t1 set b="updated t1.b from master";
update t2 set b="updated t2.b from master";
select * from t1;
a	b	c
1	updated t1.b from master	t1.c from master
select * from t2;
a	b	c
1	updated t2.b from master	t2.c from slave
drop table t1;
drop table t2;
drop table mysql.ndb_replication;
include/rpl_end.inc