drop table if exists t1,t2,t3;
drop table if exists t1,t2,t3;
CREATE TABLE t3 (dummy INT PRIMARY KEY) ENGINE = NDB;
DROP TABLE t3;
reset master;
reset master;
CREATE TABLE t2 (a INT PRIMARY KEY, b int) ENGINE = NDB;
INSERT INTO t2 VALUES (1,1),(2,2);
show binlog events from <binlog_start>;
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
mysqld-bin.000001	#	Query	2	#	use `test`; CREATE TABLE t2 (a INT PRIMARY KEY, b int) ENGINE = NDB
mysqld-bin.000001	#	Query	2	#	BEGIN
mysqld-bin.000001	#	Table_map	2	#	table_id: # (test.t2)
mysqld-bin.000001	#	Table_map	2	#	table_id: # (mysql.ndb_apply_status)
mysqld-bin.000001	#	Write_rows	2	#	table_id: #
mysqld-bin.000001	#	Write_rows	2	#	table_id: # flags: STMT_END_F
mysqld-bin.000001	#	Query	2	#	COMMIT
select * from t2 order by a;
a	b
1	1
2	2
SELECT @the_epoch:=epoch,inserts,updates,deletes,schemaops FROM 
mysql.ndb_binlog_index ORDER BY epoch DESC LIMIT 1;
@the_epoch:=epoch	inserts	updates	deletes	schemaops
<the_epoch>	2	0	0	0
SELECT * FROM t2 ORDER BY a;
a	b
1	1
2	2
DROP TABLE t2;
show binlog events from <binlog_start>;
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
mysqld-bin.000001	#	Query	2	#	use `test`; CREATE TABLE t2 (a INT PRIMARY KEY, b int) ENGINE = NDB
mysqld-bin.000001	#	Query	1	#	BEGIN
mysqld-bin.000001	#	Table_map	1	#	table_id: # (test.t2)
mysqld-bin.000001	#	Table_map	1	#	table_id: # (mysql.ndb_apply_status)
mysqld-bin.000001	#	Write_rows	1	#	table_id: #
mysqld-bin.000001	#	Write_rows	1	#	table_id: # flags: STMT_END_F
mysqld-bin.000001	#	Query	1	#	COMMIT
mysqld-bin.000001	#	Query	1	#	use `test`; DROP TABLE t2
SELECT inserts,updates,deletes,schemaops FROM 
mysql.ndb_binlog_index WHERE epoch=<the_epoch>;
inserts	updates	deletes	schemaops
2	0	0	0
reset master;
reset master;
CREATE TABLE t1 (a INT PRIMARY KEY) ENGINE = NDB;
INSERT INTO t1 VALUES (1),(2);
show binlog events from <binlog_start>;
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
mysqld-bin.000001	#	Query	2	#	use `test`; CREATE TABLE t1 (a INT PRIMARY KEY) ENGINE = NDB
mysqld-bin.000001	#	Query	2	#	BEGIN
mysqld-bin.000001	#	Table_map	2	#	table_id: # (test.t1)
mysqld-bin.000001	#	Table_map	2	#	table_id: # (mysql.ndb_apply_status)
mysqld-bin.000001	#	Write_rows	2	#	table_id: #
mysqld-bin.000001	#	Write_rows	2	#	table_id: # flags: STMT_END_F
mysqld-bin.000001	#	Query	2	#	COMMIT
SELECT @the_epoch2:=epoch,inserts,updates,deletes,schemaops FROM 
mysql.ndb_binlog_index ORDER BY epoch DESC LIMIT 1;
@the_epoch2:=epoch	inserts	updates	deletes	schemaops
<the_epoch2>	2	0	0	0
SELECT inserts,updates,deletes,schemaops FROM
mysql.ndb_binlog_index WHERE epoch > <the_epoch> AND epoch <= <the_epoch2>;
inserts	updates	deletes	schemaops
2	0	0	0
drop table t1;
show binlog events from <binlog_start>;
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
mysqld-bin.000001	#	Query	2	#	use `test`; CREATE TABLE t1 (a INT PRIMARY KEY) ENGINE = NDB
mysqld-bin.000001	#	Query	2	#	BEGIN
mysqld-bin.000001	#	Table_map	2	#	table_id: # (test.t1)
mysqld-bin.000001	#	Table_map	2	#	table_id: # (mysql.ndb_apply_status)
mysqld-bin.000001	#	Write_rows	2	#	table_id: #
mysqld-bin.000001	#	Write_rows	2	#	table_id: # flags: STMT_END_F
mysqld-bin.000001	#	Query	2	#	COMMIT
mysqld-bin.000001	#	Query	2	#	use `test`; drop table t1
SELECT inserts,updates,deletes,schemaops FROM
mysql.ndb_binlog_index WHERE epoch > <the_epoch> AND epoch <= <the_epoch2>;
inserts	updates	deletes	schemaops
2	0	0	0