mirror of
https://github.com/MariaDB/server.git
synced 2025-01-18 13:02:28 +01:00
acd7132e0a
Start test case with a dummy table create and drop. This ensures that NDB event subscription is properly set up before the real test starts, which otherwise could sometimes cause INSERT events to be lost. mysql-test/r/ndb_binlog_multi.result: Start test with dummy table create/drop to avoid a race. mysql-test/t/ndb_binlog_multi.test: Start test with dummy table create/drop to avoid a race.
80 lines
3.3 KiB
Text
80 lines
3.3 KiB
Text
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
|
|
master-bin1.000001 # Query # # use `test`; CREATE TABLE t2 (a INT PRIMARY KEY, b int) ENGINE = NDB
|
|
master-bin1.000001 # Query # # BEGIN
|
|
master-bin1.000001 # Table_map # # table_id: # (test.t2)
|
|
master-bin1.000001 # Table_map # # table_id: # (cluster.apply_status)
|
|
master-bin1.000001 # Write_rows # # table_id: #
|
|
master-bin1.000001 # Write_rows # # table_id: # flags: STMT_END_F
|
|
master-bin1.000001 # Query # # COMMIT
|
|
select * from t2 order by a;
|
|
a b
|
|
1 1
|
|
2 2
|
|
SELECT @the_epoch:=epoch,inserts,updates,deletes,schemaops FROM
|
|
cluster.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
|
|
master-bin.000001 # Query # # use `test`; CREATE TABLE t2 (a INT PRIMARY KEY, b int) ENGINE = NDB
|
|
master-bin.000001 # Query # # BEGIN
|
|
master-bin.000001 # Table_map # # table_id: # (test.t2)
|
|
master-bin.000001 # Table_map # # table_id: # (cluster.apply_status)
|
|
master-bin.000001 # Write_rows # # table_id: #
|
|
master-bin.000001 # Write_rows # # table_id: # flags: STMT_END_F
|
|
master-bin.000001 # Query # # COMMIT
|
|
master-bin.000001 # Query # # use `test`; DROP TABLE t2
|
|
SELECT inserts,updates,deletes,schemaops FROM
|
|
cluster.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
|
|
master-bin1.000001 # Query # # use `test`; CREATE TABLE t1 (a INT PRIMARY KEY) ENGINE = NDB
|
|
master-bin1.000001 # Query # # BEGIN
|
|
master-bin1.000001 # Table_map # # table_id: # (test.t1)
|
|
master-bin1.000001 # Table_map # # table_id: # (cluster.apply_status)
|
|
master-bin1.000001 # Write_rows # # table_id: #
|
|
master-bin1.000001 # Write_rows # # table_id: # flags: STMT_END_F
|
|
master-bin1.000001 # Query # # COMMIT
|
|
SELECT @the_epoch2:=epoch,inserts,updates,deletes,schemaops FROM
|
|
cluster.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
|
|
cluster.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
|
|
master-bin1.000001 # Query # # use `test`; CREATE TABLE t1 (a INT PRIMARY KEY) ENGINE = NDB
|
|
master-bin1.000001 # Query # # BEGIN
|
|
master-bin1.000001 # Table_map # # table_id: # (test.t1)
|
|
master-bin1.000001 # Table_map # # table_id: # (cluster.apply_status)
|
|
master-bin1.000001 # Write_rows # # table_id: #
|
|
master-bin1.000001 # Write_rows # # table_id: # flags: STMT_END_F
|
|
master-bin1.000001 # Query # # COMMIT
|
|
master-bin1.000001 # Query # # use `test`; drop table t1
|
|
SELECT inserts,updates,deletes,schemaops FROM
|
|
cluster.binlog_index WHERE epoch > <the_epoch> AND epoch <= <the_epoch2>;
|
|
inserts updates deletes schemaops
|
|
2 0 0 0
|