1include/master-slave.inc 2[connection master] 3CREATE TABLE t1 (c1 CHAR(15), c2 CHAR(15), c3 INT, PRIMARY KEY (c3)) ENGINE = NDB ; 4INSERT INTO t1 VALUES ("row1","will go away",1); 5SELECT * FROM t1 ORDER BY c3; 6c1 c2 c3 7row1 will go away 1 8SELECT @the_epoch:=MAX(epoch) FROM mysql.ndb_apply_status; 9@the_epoch:=MAX(epoch) 10<the_epoch> 11SELECT * FROM t1 ORDER BY c3; 12c1 c2 c3 13row1 will go away 1 14INSERT INTO t1 VALUES ("row2","will go away",2),("row3","will change",3),("row4","D",4); 15DELETE FROM t1 WHERE c3 = 1; 16UPDATE t1 SET c2="should go away" WHERE c3 = 2; 17UPDATE t1 SET c2="C" WHERE c3 = 3; 18DELETE FROM t1 WHERE c3 = 2; 19SELECT * FROM t1 ORDER BY c3; 20c1 c2 c3 21row3 C 3 22row4 D 4 23SELECT * FROM t1 ORDER BY c3; 24c1 c2 c3 25row3 C 3 26row4 D 4 27include/check_slave_is_running.inc 28STOP SLAVE; 29CHANGE MASTER TO 30master_log_file = 'master-bin.000001', 31master_log_pos = <the_pos> ; 32include/check_slave_no_error.inc 33START SLAVE; 34SELECT * FROM t1 ORDER BY c3; 35c1 c2 c3 36row3 C 3 37row4 D 4 38SELECT * FROM t1 ORDER BY c3; 39c1 c2 c3 40row3 C 3 41row4 D 4 42STOP SLAVE; 43DROP TABLE t1; 44RESET master; 45DROP TABLE t1; 46RESET slave; 47START SLAVE; 48CREATE TABLE t1 (c1 CHAR(15) NOT NULL, c2 CHAR(15) NOT NULL, c3 INT NOT NULL, PRIMARY KEY (c3)) ENGINE = NDB ; 49INSERT INTO t1 VALUES ("row1","remove on slave",1); 50DELETE FROM t1; 51BEGIN; 52UPDATE t1 SET c2="does not exist" WHERE c3=1; 53INSERT INTO t1 VALUES ("row2","new on slave",2); 54COMMIT; 55SELECT * FROM t1; 56c1 c2 c3 57row2 new on slave 2 58include/check_slave_is_running.inc 59DROP TABLE IF EXISTS t1; 60include/rpl_end.inc 61