Browse Source
BUG#28777, WL#4293: SHOW BINLOG EVENTS does not work on relay log
BUG#28777, WL#4293: SHOW BINLOG EVENTS does not work on relay log
files
NOTE: this is the backport to next-mr.
SHOW BINLOG EVENTS does not work with relay log files. If issuing
"SHOW BINLOG EVENTS IN 'relay-log.000001'" in a non-empty relay
log file (relay-log.000001), mysql reports empty set.
This patch addresses this issue by extending the SHOW command
with RELAYLOG. Events in relay log files can now be inspected by
issuing SHOW RELAYLOG EVENTS [IN 'log_name'] [FROM pos] [LIMIT
[offset,] row_count].
pull/73/head
14 changed files with 679 additions and 12 deletions
-
121mysql-test/extra/rpl_tests/rpl_show_relaylog_events.inc
-
27mysql-test/include/show_binlog_events.inc
-
35mysql-test/include/show_relaylog_events.inc
-
274mysql-test/suite/rpl/r/rpl_row_show_relaylog_events.result
-
148mysql-test/suite/rpl/r/rpl_stm_mix_show_relaylog_events.result
-
18mysql-test/suite/rpl/t/rpl_row_show_relaylog_events.test
-
18mysql-test/suite/rpl/t/rpl_stm_mix_show_relaylog_events.test
-
1sql/lex.h
-
1sql/mysqld.cc
-
1sql/sp_head.cc
-
2sql/sql_lex.h
-
1sql/sql_parse.cc
-
37sql/sql_repl.cc
-
7sql/sql_yacc.yy
@ -0,0 +1,121 @@ |
|||
-- connection master |
|||
|
|||
CREATE TABLE t1 (a INT); |
|||
INSERT INTO t1 VALUES (1); |
|||
INSERT INTO t1 VALUES (2); |
|||
INSERT INTO t1 VALUES (3); |
|||
INSERT INTO t1 VALUES (4); |
|||
INSERT INTO t1 VALUES (5); |
|||
INSERT INTO t1 VALUES (6); |
|||
|
|||
-- echo [MASTER] ********* SOW BINLOG EVENTS IN ... ********* |
|||
let $binary_log_file= master-bin.000001; |
|||
-- source include/show_binlog_events.inc |
|||
|
|||
-- echo [MASTER] ********* SOW BINLOG EVENTS ********* |
|||
let $binary_log_file= ; |
|||
-- source include/show_binlog_events.inc |
|||
|
|||
-- echo [MASTER] ********* SOW BINLOG EVENTS ... LIMIT rows ********* |
|||
let $binary_log_file= ; |
|||
let $binary_log_limit_row= 3; |
|||
-- source include/show_binlog_events.inc |
|||
|
|||
-- echo [MASTER] ********* SOW BINLOG EVENTS ... LIMIT offset,rows ********* |
|||
let $binary_log_file= ; |
|||
let $binary_log_limit_row= 3; |
|||
let $binary_log_limit_offset= 1; |
|||
-- source include/show_binlog_events.inc |
|||
|
|||
# clear show_binlog_event/show_relaylog_events parameters |
|||
let $binary_log_file= ; |
|||
let $binary_log_limit_row= ; |
|||
let $binary_log_limit_offset= ; |
|||
|
|||
-- sync_slave_with_master |
|||
|
|||
-- echo [SLAVE] ********* SOW BINLOG EVENTS IN ... ********* |
|||
let $binary_log_file= slave-bin.000001; |
|||
-- source include/show_binlog_events.inc |
|||
|
|||
-- echo [SLAVE] ********* SOW BINLOG EVENTS ********* |
|||
let $binary_log_file= ; |
|||
-- source include/show_binlog_events.inc |
|||
|
|||
-- echo [SLAVE] ********* SOW BINLOG EVENTS ... LIMIT rows ********* |
|||
let $binary_log_file= ; |
|||
let $binary_log_limit_row= 3; |
|||
-- source include/show_binlog_events.inc |
|||
|
|||
-- echo [SLAVE] ********* SOW BINLOG EVENTS ... LIMIT offset,rows ********* |
|||
let $binary_log_file= ; |
|||
let $binary_log_limit_row= 3; |
|||
let $binary_log_limit_offset= 1; |
|||
-- source include/show_binlog_events.inc |
|||
|
|||
# clear show_binlog_event/show_relaylog_events parameters |
|||
let $binary_log_file= ; |
|||
let $binary_log_limit_row= ; |
|||
let $binary_log_limit_offset= ; |
|||
|
|||
-- echo [SLAVE] ********* SOW RELAYLOG EVENTS IN ... ********* |
|||
let $binary_log_file= slave-relay-bin.000003; |
|||
-- source include/show_relaylog_events.inc |
|||
|
|||
-- echo [SLAVE] ********* SOW RELAYLOG EVENTS ********* |
|||
let $binary_log_file= ; |
|||
-- source include/show_relaylog_events.inc |
|||
|
|||
-- echo [MASTER] ********* SOW RELAYLOG EVENTS ... LIMIT rows ********* |
|||
let $binary_log_file= slave-relay-bin.000003; |
|||
let $binary_log_limit_row= 3; |
|||
let $binary_log_limit_offset= ; |
|||
-- source include/show_relaylog_events.inc |
|||
|
|||
-- echo [MASTER] ********* SOW RELAYLOG EVENTS ... LIMIT offset,rows ********* |
|||
let $binary_log_file= slave-relay-bin.000003; |
|||
let $binary_log_limit_offset= 1; |
|||
let $binary_log_limit_row= 3; |
|||
-- source include/show_relaylog_events.inc |
|||
|
|||
FLUSH LOGS; |
|||
|
|||
-- connection master |
|||
FLUSH LOGS; |
|||
DROP TABLE t1; |
|||
|
|||
# clear show_binlog_event/show_relaylog_events parameters |
|||
let $binary_log_file= ; |
|||
let $binary_log_limit_row= ; |
|||
let $binary_log_limit_offset= ; |
|||
|
|||
-- echo [MASTER] ********* SOW BINLOG EVENTS IN ... ********* |
|||
let $binary_log_file= master-bin.000002; |
|||
-- source include/show_binlog_events.inc |
|||
|
|||
-- echo [MASTER] ********* SOW BINLOG EVENTS ********* |
|||
let $binary_log_file= ; |
|||
-- source include/show_binlog_events.inc |
|||
|
|||
-- sync_slave_with_master |
|||
|
|||
-- echo [SLAVE] ********* SOW BINLOG EVENTS IN ... ********* |
|||
let $binary_log_file= slave-bin.000002; |
|||
-- source include/show_binlog_events.inc |
|||
|
|||
-- echo [SLAVE] ********* SOW BINLOG EVENTS ********* |
|||
let $binary_log_file= ; |
|||
-- source include/show_binlog_events.inc |
|||
|
|||
-- echo [SLAVE] ********* SOW RELAYLOG EVENTS IN ... ********* |
|||
let $binary_log_file= slave-relay-bin.000005; |
|||
-- source include/show_relaylog_events.inc |
|||
|
|||
-- echo [SLAVE] ********* SOW RELAYLOG EVENTS ********* |
|||
let $binary_log_file= ; |
|||
-- source include/show_relaylog_events.inc |
|||
|
|||
# clear show_binlog_event/show_relaylog_events parameters |
|||
let $binary_log_name= ; |
|||
let $binary_log_limit_row= ; |
|||
let $binary_log_limit_offset= ; |
|||
@ -1,10 +1,35 @@ |
|||
# $binlog_start can be set by caller or take a default value |
|||
# $binary_log_file the name of the log file show |
|||
# $binary_log_limit_row - sets the number of binlog rows to be returned |
|||
# $binary_log_limit_offset - sets the offset where to start returning events |
|||
|
|||
let $show_binlog_events= show binlog events; |
|||
|
|||
if (!$binlog_start) |
|||
{ |
|||
# defaults to chop the first event in the binary log |
|||
let $binlog_start=106; |
|||
} |
|||
|
|||
if (!`SELECT '$binary_log_file' = ''`) |
|||
{ |
|||
let $show_binlog_events= $show_binlog_events in '$binary_log_file'; |
|||
} |
|||
let $show_binlog_events= $show_binlog_events from $binlog_start; |
|||
|
|||
if ($binary_log_limit_row) |
|||
{ |
|||
let $limit= limit; |
|||
if ($binary_log_limit_offset) |
|||
{ |
|||
let $limit= $limit $binary_log_limit_offset, ; |
|||
} |
|||
|
|||
let $limit= $limit $binary_log_limit_row; |
|||
let $show_binlog_events= $show_binlog_events $limit; |
|||
} |
|||
|
|||
--replace_result $MYSQLTEST_VARDIR MYSQLTEST_VARDIR $binlog_start <binlog_start> |
|||
--replace_column 2 # 4 # 5 # |
|||
--replace_regex /\/\* xid=.* \*\//\/* XID *\// /table_id: [0-9]+/table_id: #/ /file_id=[0-9]+/file_id=#/ /block_len=[0-9]+/block_len=#/ |
|||
--eval show binlog events from $binlog_start |
|||
--eval $show_binlog_events |
|||
@ -0,0 +1,35 @@ |
|||
# $binlog_start can be set by caller or take a default value |
|||
# $binary_log_file the name of the log file show |
|||
# $binary_log_limit_row - sets the number of binlog rows to be returned |
|||
# $binary_log_limit_offset - sets the offset where to start returning events |
|||
|
|||
let $show_binlog_events= show relaylog events; |
|||
|
|||
if (!$binlog_start) |
|||
{ |
|||
# defaults to chop the first event in the binary log |
|||
let $binlog_start=106; |
|||
} |
|||
|
|||
if (!`SELECT '$binary_log_file' = ''`) |
|||
{ |
|||
let $show_binlog_events= $show_binlog_events in '$binary_log_file'; |
|||
} |
|||
let $show_binlog_events= $show_binlog_events from $binlog_start; |
|||
|
|||
if ($binary_log_limit_row) |
|||
{ |
|||
let $limit= limit; |
|||
if ($binary_log_limit_offset) |
|||
{ |
|||
let $limit= $limit $binary_log_limit_offset, ; |
|||
} |
|||
|
|||
let $limit= $limit $binary_log_limit_row; |
|||
let $show_binlog_events= $show_binlog_events $limit; |
|||
} |
|||
|
|||
--replace_result $MYSQLTEST_VARDIR MYSQLTEST_VARDIR $binlog_start <binlog_start> |
|||
--replace_column 2 # 4 # 5 # |
|||
--replace_regex /\/\* xid=.* \*\//\/* XID *\// /table_id: [0-9]+/table_id: #/ /file_id=[0-9]+/file_id=#/ /block_len=[0-9]+/block_len=#/ /Server ver:.*$/SERVER_VERSION, BINLOG_VERSION/ |
|||
--eval $show_binlog_events |
|||
@ -0,0 +1,274 @@ |
|||
stop slave; |
|||
drop table if exists t1,t2,t3,t4,t5,t6,t7,t8,t9; |
|||
reset master; |
|||
reset slave; |
|||
drop table if exists t1,t2,t3,t4,t5,t6,t7,t8,t9; |
|||
start slave; |
|||
CREATE TABLE t1 (a INT); |
|||
INSERT INTO t1 VALUES (1); |
|||
INSERT INTO t1 VALUES (2); |
|||
INSERT INTO t1 VALUES (3); |
|||
INSERT INTO t1 VALUES (4); |
|||
INSERT INTO t1 VALUES (5); |
|||
INSERT INTO t1 VALUES (6); |
|||
[MASTER] ********* SOW BINLOG EVENTS IN ... ********* |
|||
show binlog events in 'master-bin.000001' from <binlog_start>; |
|||
Log_name Pos Event_type Server_id End_log_pos Info |
|||
master-bin.000001 # Query # # use `test`; CREATE TABLE t1 (a INT) |
|||
master-bin.000001 # Query # # BEGIN |
|||
master-bin.000001 # Table_map # # table_id: # (test.t1) |
|||
master-bin.000001 # Write_rows # # table_id: # flags: STMT_END_F |
|||
master-bin.000001 # Query # # COMMIT |
|||
master-bin.000001 # Query # # BEGIN |
|||
master-bin.000001 # Table_map # # table_id: # (test.t1) |
|||
master-bin.000001 # Write_rows # # table_id: # flags: STMT_END_F |
|||
master-bin.000001 # Query # # COMMIT |
|||
master-bin.000001 # Query # # BEGIN |
|||
master-bin.000001 # Table_map # # table_id: # (test.t1) |
|||
master-bin.000001 # Write_rows # # table_id: # flags: STMT_END_F |
|||
master-bin.000001 # Query # # COMMIT |
|||
master-bin.000001 # Query # # BEGIN |
|||
master-bin.000001 # Table_map # # table_id: # (test.t1) |
|||
master-bin.000001 # Write_rows # # table_id: # flags: STMT_END_F |
|||
master-bin.000001 # Query # # COMMIT |
|||
master-bin.000001 # Query # # BEGIN |
|||
master-bin.000001 # Table_map # # table_id: # (test.t1) |
|||
master-bin.000001 # Write_rows # # table_id: # flags: STMT_END_F |
|||
master-bin.000001 # Query # # COMMIT |
|||
master-bin.000001 # Query # # BEGIN |
|||
master-bin.000001 # Table_map # # table_id: # (test.t1) |
|||
master-bin.000001 # Write_rows # # table_id: # flags: STMT_END_F |
|||
master-bin.000001 # Query # # COMMIT |
|||
[MASTER] ********* SOW BINLOG EVENTS ********* |
|||
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 t1 (a INT) |
|||
master-bin.000001 # Query # # BEGIN |
|||
master-bin.000001 # Table_map # # table_id: # (test.t1) |
|||
master-bin.000001 # Write_rows # # table_id: # flags: STMT_END_F |
|||
master-bin.000001 # Query # # COMMIT |
|||
master-bin.000001 # Query # # BEGIN |
|||
master-bin.000001 # Table_map # # table_id: # (test.t1) |
|||
master-bin.000001 # Write_rows # # table_id: # flags: STMT_END_F |
|||
master-bin.000001 # Query # # COMMIT |
|||
master-bin.000001 # Query # # BEGIN |
|||
master-bin.000001 # Table_map # # table_id: # (test.t1) |
|||
master-bin.000001 # Write_rows # # table_id: # flags: STMT_END_F |
|||
master-bin.000001 # Query # # COMMIT |
|||
master-bin.000001 # Query # # BEGIN |
|||
master-bin.000001 # Table_map # # table_id: # (test.t1) |
|||
master-bin.000001 # Write_rows # # table_id: # flags: STMT_END_F |
|||
master-bin.000001 # Query # # COMMIT |
|||
master-bin.000001 # Query # # BEGIN |
|||
master-bin.000001 # Table_map # # table_id: # (test.t1) |
|||
master-bin.000001 # Write_rows # # table_id: # flags: STMT_END_F |
|||
master-bin.000001 # Query # # COMMIT |
|||
master-bin.000001 # Query # # BEGIN |
|||
master-bin.000001 # Table_map # # table_id: # (test.t1) |
|||
master-bin.000001 # Write_rows # # table_id: # flags: STMT_END_F |
|||
master-bin.000001 # Query # # COMMIT |
|||
[MASTER] ********* SOW BINLOG EVENTS ... LIMIT rows ********* |
|||
show binlog events from <binlog_start> limit 3; |
|||
Log_name Pos Event_type Server_id End_log_pos Info |
|||
master-bin.000001 # Query # # use `test`; CREATE TABLE t1 (a INT) |
|||
master-bin.000001 # Query # # BEGIN |
|||
master-bin.000001 # Table_map # # table_id: # (test.t1) |
|||
[MASTER] ********* SOW BINLOG EVENTS ... LIMIT offset,rows ********* |
|||
show binlog events from <binlog_start> limit 1, 3; |
|||
Log_name Pos Event_type Server_id End_log_pos Info |
|||
master-bin.000001 # Query # # BEGIN |
|||
master-bin.000001 # Table_map # # table_id: # (test.t1) |
|||
master-bin.000001 # Write_rows # # table_id: # flags: STMT_END_F |
|||
[SLAVE] ********* SOW BINLOG EVENTS IN ... ********* |
|||
show binlog events in 'slave-bin.000001' from <binlog_start>; |
|||
Log_name Pos Event_type Server_id End_log_pos Info |
|||
slave-bin.000001 # Query # # use `test`; CREATE TABLE t1 (a INT) |
|||
slave-bin.000001 # Query # # BEGIN |
|||
slave-bin.000001 # Table_map # # table_id: # (test.t1) |
|||
slave-bin.000001 # Write_rows # # table_id: # flags: STMT_END_F |
|||
slave-bin.000001 # Query # # COMMIT |
|||
slave-bin.000001 # Query # # BEGIN |
|||
slave-bin.000001 # Table_map # # table_id: # (test.t1) |
|||
slave-bin.000001 # Write_rows # # table_id: # flags: STMT_END_F |
|||
slave-bin.000001 # Query # # COMMIT |
|||
slave-bin.000001 # Query # # BEGIN |
|||
slave-bin.000001 # Table_map # # table_id: # (test.t1) |
|||
slave-bin.000001 # Write_rows # # table_id: # flags: STMT_END_F |
|||
slave-bin.000001 # Query # # COMMIT |
|||
slave-bin.000001 # Query # # BEGIN |
|||
slave-bin.000001 # Table_map # # table_id: # (test.t1) |
|||
slave-bin.000001 # Write_rows # # table_id: # flags: STMT_END_F |
|||
slave-bin.000001 # Query # # COMMIT |
|||
slave-bin.000001 # Query # # BEGIN |
|||
slave-bin.000001 # Table_map # # table_id: # (test.t1) |
|||
slave-bin.000001 # Write_rows # # table_id: # flags: STMT_END_F |
|||
slave-bin.000001 # Query # # COMMIT |
|||
slave-bin.000001 # Query # # BEGIN |
|||
slave-bin.000001 # Table_map # # table_id: # (test.t1) |
|||
slave-bin.000001 # Write_rows # # table_id: # flags: STMT_END_F |
|||
slave-bin.000001 # Query # # COMMIT |
|||
[SLAVE] ********* SOW BINLOG EVENTS ********* |
|||
show binlog events from <binlog_start>; |
|||
Log_name Pos Event_type Server_id End_log_pos Info |
|||
slave-bin.000001 # Query # # use `test`; CREATE TABLE t1 (a INT) |
|||
slave-bin.000001 # Query # # BEGIN |
|||
slave-bin.000001 # Table_map # # table_id: # (test.t1) |
|||
slave-bin.000001 # Write_rows # # table_id: # flags: STMT_END_F |
|||
slave-bin.000001 # Query # # COMMIT |
|||
slave-bin.000001 # Query # # BEGIN |
|||
slave-bin.000001 # Table_map # # table_id: # (test.t1) |
|||
slave-bin.000001 # Write_rows # # table_id: # flags: STMT_END_F |
|||
slave-bin.000001 # Query # # COMMIT |
|||
slave-bin.000001 # Query # # BEGIN |
|||
slave-bin.000001 # Table_map # # table_id: # (test.t1) |
|||
slave-bin.000001 # Write_rows # # table_id: # flags: STMT_END_F |
|||
slave-bin.000001 # Query # # COMMIT |
|||
slave-bin.000001 # Query # # BEGIN |
|||
slave-bin.000001 # Table_map # # table_id: # (test.t1) |
|||
slave-bin.000001 # Write_rows # # table_id: # flags: STMT_END_F |
|||
slave-bin.000001 # Query # # COMMIT |
|||
slave-bin.000001 # Query # # BEGIN |
|||
slave-bin.000001 # Table_map # # table_id: # (test.t1) |
|||
slave-bin.000001 # Write_rows # # table_id: # flags: STMT_END_F |
|||
slave-bin.000001 # Query # # COMMIT |
|||
slave-bin.000001 # Query # # BEGIN |
|||
slave-bin.000001 # Table_map # # table_id: # (test.t1) |
|||
slave-bin.000001 # Write_rows # # table_id: # flags: STMT_END_F |
|||
slave-bin.000001 # Query # # COMMIT |
|||
[SLAVE] ********* SOW BINLOG EVENTS ... LIMIT rows ********* |
|||
show binlog events from <binlog_start> limit 3; |
|||
Log_name Pos Event_type Server_id End_log_pos Info |
|||
slave-bin.000001 # Query # # use `test`; CREATE TABLE t1 (a INT) |
|||
slave-bin.000001 # Query # # BEGIN |
|||
slave-bin.000001 # Table_map # # table_id: # (test.t1) |
|||
[SLAVE] ********* SOW BINLOG EVENTS ... LIMIT offset,rows ********* |
|||
show binlog events from <binlog_start> limit 1, 3; |
|||
Log_name Pos Event_type Server_id End_log_pos Info |
|||
slave-bin.000001 # Query # # BEGIN |
|||
slave-bin.000001 # Table_map # # table_id: # (test.t1) |
|||
slave-bin.000001 # Write_rows # # table_id: # flags: STMT_END_F |
|||
[SLAVE] ********* SOW RELAYLOG EVENTS IN ... ********* |
|||
show relaylog events in 'slave-relay-bin.000003' from <binlog_start>; |
|||
Log_name Pos Event_type Server_id End_log_pos Info |
|||
slave-relay-bin.000003 # Rotate # # master-bin.000001;pos=4 |
|||
slave-relay-bin.000003 # Format_desc # # SERVER_VERSION, BINLOG_VERSION |
|||
slave-relay-bin.000003 # Query # # use `test`; CREATE TABLE t1 (a INT) |
|||
slave-relay-bin.000003 # Query # # BEGIN |
|||
slave-relay-bin.000003 # Table_map # # table_id: # (test.t1) |
|||
slave-relay-bin.000003 # Write_rows # # table_id: # flags: STMT_END_F |
|||
slave-relay-bin.000003 # Query # # COMMIT |
|||
slave-relay-bin.000003 # Query # # BEGIN |
|||
slave-relay-bin.000003 # Table_map # # table_id: # (test.t1) |
|||
slave-relay-bin.000003 # Write_rows # # table_id: # flags: STMT_END_F |
|||
slave-relay-bin.000003 # Query # # COMMIT |
|||
slave-relay-bin.000003 # Query # # BEGIN |
|||
slave-relay-bin.000003 # Table_map # # table_id: # (test.t1) |
|||
slave-relay-bin.000003 # Write_rows # # table_id: # flags: STMT_END_F |
|||
slave-relay-bin.000003 # Query # # COMMIT |
|||
slave-relay-bin.000003 # Query # # BEGIN |
|||
slave-relay-bin.000003 # Table_map # # table_id: # (test.t1) |
|||
slave-relay-bin.000003 # Write_rows # # table_id: # flags: STMT_END_F |
|||
slave-relay-bin.000003 # Query # # COMMIT |
|||
slave-relay-bin.000003 # Query # # BEGIN |
|||
slave-relay-bin.000003 # Table_map # # table_id: # (test.t1) |
|||
slave-relay-bin.000003 # Write_rows # # table_id: # flags: STMT_END_F |
|||
slave-relay-bin.000003 # Query # # COMMIT |
|||
slave-relay-bin.000003 # Query # # BEGIN |
|||
slave-relay-bin.000003 # Table_map # # table_id: # (test.t1) |
|||
slave-relay-bin.000003 # Write_rows # # table_id: # flags: STMT_END_F |
|||
slave-relay-bin.000003 # Query # # COMMIT |
|||
[SLAVE] ********* SOW RELAYLOG EVENTS ********* |
|||
show relaylog events from <binlog_start>; |
|||
Log_name Pos Event_type Server_id End_log_pos Info |
|||
slave-relay-bin.000002 # Rotate # # slave-relay-bin.000003;pos=4 |
|||
[MASTER] ********* SOW RELAYLOG EVENTS ... LIMIT rows ********* |
|||
show relaylog events in 'slave-relay-bin.000003' from <binlog_start> limit 3; |
|||
Log_name Pos Event_type Server_id End_log_pos Info |
|||
slave-relay-bin.000003 # Rotate # # master-bin.000001;pos=4 |
|||
slave-relay-bin.000003 # Format_desc # # SERVER_VERSION, BINLOG_VERSION |
|||
slave-relay-bin.000003 # Query # # use `test`; CREATE TABLE t1 (a INT) |
|||
[MASTER] ********* SOW RELAYLOG EVENTS ... LIMIT offset,rows ********* |
|||
show relaylog events in 'slave-relay-bin.000003' from <binlog_start> limit 1, 3; |
|||
Log_name Pos Event_type Server_id End_log_pos Info |
|||
slave-relay-bin.000003 # Format_desc # # SERVER_VERSION, BINLOG_VERSION |
|||
slave-relay-bin.000003 # Query # # use `test`; CREATE TABLE t1 (a INT) |
|||
slave-relay-bin.000003 # Query # # BEGIN |
|||
FLUSH LOGS; |
|||
FLUSH LOGS; |
|||
DROP TABLE t1; |
|||
[MASTER] ********* SOW BINLOG EVENTS IN ... ********* |
|||
show binlog events in 'master-bin.000002' from <binlog_start>; |
|||
Log_name Pos Event_type Server_id End_log_pos Info |
|||
master-bin.000002 # Query # # use `test`; DROP TABLE t1 |
|||
[MASTER] ********* SOW BINLOG EVENTS ********* |
|||
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 t1 (a INT) |
|||
master-bin.000001 # Query # # BEGIN |
|||
master-bin.000001 # Table_map # # table_id: # (test.t1) |
|||
master-bin.000001 # Write_rows # # table_id: # flags: STMT_END_F |
|||
master-bin.000001 # Query # # COMMIT |
|||
master-bin.000001 # Query # # BEGIN |
|||
master-bin.000001 # Table_map # # table_id: # (test.t1) |
|||
master-bin.000001 # Write_rows # # table_id: # flags: STMT_END_F |
|||
master-bin.000001 # Query # # COMMIT |
|||
master-bin.000001 # Query # # BEGIN |
|||
master-bin.000001 # Table_map # # table_id: # (test.t1) |
|||
master-bin.000001 # Write_rows # # table_id: # flags: STMT_END_F |
|||
master-bin.000001 # Query # # COMMIT |
|||
master-bin.000001 # Query # # BEGIN |
|||
master-bin.000001 # Table_map # # table_id: # (test.t1) |
|||
master-bin.000001 # Write_rows # # table_id: # flags: STMT_END_F |
|||
master-bin.000001 # Query # # COMMIT |
|||
master-bin.000001 # Query # # BEGIN |
|||
master-bin.000001 # Table_map # # table_id: # (test.t1) |
|||
master-bin.000001 # Write_rows # # table_id: # flags: STMT_END_F |
|||
master-bin.000001 # Query # # COMMIT |
|||
master-bin.000001 # Query # # BEGIN |
|||
master-bin.000001 # Table_map # # table_id: # (test.t1) |
|||
master-bin.000001 # Write_rows # # table_id: # flags: STMT_END_F |
|||
master-bin.000001 # Query # # COMMIT |
|||
master-bin.000001 # Rotate # # master-bin.000002;pos=4 |
|||
[SLAVE] ********* SOW BINLOG EVENTS IN ... ********* |
|||
show binlog events in 'slave-bin.000002' from <binlog_start>; |
|||
Log_name Pos Event_type Server_id End_log_pos Info |
|||
slave-bin.000002 # Query # # use `test`; DROP TABLE t1 |
|||
[SLAVE] ********* SOW BINLOG EVENTS ********* |
|||
show binlog events from <binlog_start>; |
|||
Log_name Pos Event_type Server_id End_log_pos Info |
|||
slave-bin.000001 # Query # # use `test`; CREATE TABLE t1 (a INT) |
|||
slave-bin.000001 # Query # # BEGIN |
|||
slave-bin.000001 # Table_map # # table_id: # (test.t1) |
|||
slave-bin.000001 # Write_rows # # table_id: # flags: STMT_END_F |
|||
slave-bin.000001 # Query # # COMMIT |
|||
slave-bin.000001 # Query # # BEGIN |
|||
slave-bin.000001 # Table_map # # table_id: # (test.t1) |
|||
slave-bin.000001 # Write_rows # # table_id: # flags: STMT_END_F |
|||
slave-bin.000001 # Query # # COMMIT |
|||
slave-bin.000001 # Query # # BEGIN |
|||
slave-bin.000001 # Table_map # # table_id: # (test.t1) |
|||
slave-bin.000001 # Write_rows # # table_id: # flags: STMT_END_F |
|||
slave-bin.000001 # Query # # COMMIT |
|||
slave-bin.000001 # Query # # BEGIN |
|||
slave-bin.000001 # Table_map # # table_id: # (test.t1) |
|||
slave-bin.000001 # Write_rows # # table_id: # flags: STMT_END_F |
|||
slave-bin.000001 # Query # # COMMIT |
|||
slave-bin.000001 # Query # # BEGIN |
|||
slave-bin.000001 # Table_map # # table_id: # (test.t1) |
|||
slave-bin.000001 # Write_rows # # table_id: # flags: STMT_END_F |
|||
slave-bin.000001 # Query # # COMMIT |
|||
slave-bin.000001 # Query # # BEGIN |
|||
slave-bin.000001 # Table_map # # table_id: # (test.t1) |
|||
slave-bin.000001 # Write_rows # # table_id: # flags: STMT_END_F |
|||
slave-bin.000001 # Query # # COMMIT |
|||
slave-bin.000001 # Rotate # # slave-bin.000002;pos=4 |
|||
[SLAVE] ********* SOW RELAYLOG EVENTS IN ... ********* |
|||
show relaylog events in 'slave-relay-bin.000005' from <binlog_start>; |
|||
Log_name Pos Event_type Server_id End_log_pos Info |
|||
slave-relay-bin.000005 # Rotate # # master-bin.000002;pos=4 |
|||
slave-relay-bin.000005 # Rotate # # slave-relay-bin.000006;pos=4 |
|||
[SLAVE] ********* SOW RELAYLOG EVENTS ********* |
|||
show relaylog events from <binlog_start>; |
|||
Log_name Pos Event_type Server_id End_log_pos Info |
|||
slave-relay-bin.000005 # Rotate # # master-bin.000002;pos=4 |
|||
slave-relay-bin.000005 # Rotate # # slave-relay-bin.000006;pos=4 |
|||
@ -0,0 +1,148 @@ |
|||
stop slave; |
|||
drop table if exists t1,t2,t3,t4,t5,t6,t7,t8,t9; |
|||
reset master; |
|||
reset slave; |
|||
drop table if exists t1,t2,t3,t4,t5,t6,t7,t8,t9; |
|||
start slave; |
|||
CREATE TABLE t1 (a INT); |
|||
INSERT INTO t1 VALUES (1); |
|||
INSERT INTO t1 VALUES (2); |
|||
INSERT INTO t1 VALUES (3); |
|||
INSERT INTO t1 VALUES (4); |
|||
INSERT INTO t1 VALUES (5); |
|||
INSERT INTO t1 VALUES (6); |
|||
[MASTER] ********* SOW BINLOG EVENTS IN ... ********* |
|||
show binlog events in 'master-bin.000001' from <binlog_start>; |
|||
Log_name Pos Event_type Server_id End_log_pos Info |
|||
master-bin.000001 # Query # # use `test`; CREATE TABLE t1 (a INT) |
|||
master-bin.000001 # Query # # use `test`; INSERT INTO t1 VALUES (1) |
|||
master-bin.000001 # Query # # use `test`; INSERT INTO t1 VALUES (2) |
|||
master-bin.000001 # Query # # use `test`; INSERT INTO t1 VALUES (3) |
|||
master-bin.000001 # Query # # use `test`; INSERT INTO t1 VALUES (4) |
|||
master-bin.000001 # Query # # use `test`; INSERT INTO t1 VALUES (5) |
|||
master-bin.000001 # Query # # use `test`; INSERT INTO t1 VALUES (6) |
|||
[MASTER] ********* SOW BINLOG EVENTS ********* |
|||
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 t1 (a INT) |
|||
master-bin.000001 # Query # # use `test`; INSERT INTO t1 VALUES (1) |
|||
master-bin.000001 # Query # # use `test`; INSERT INTO t1 VALUES (2) |
|||
master-bin.000001 # Query # # use `test`; INSERT INTO t1 VALUES (3) |
|||
master-bin.000001 # Query # # use `test`; INSERT INTO t1 VALUES (4) |
|||
master-bin.000001 # Query # # use `test`; INSERT INTO t1 VALUES (5) |
|||
master-bin.000001 # Query # # use `test`; INSERT INTO t1 VALUES (6) |
|||
[MASTER] ********* SOW BINLOG EVENTS ... LIMIT rows ********* |
|||
show binlog events from <binlog_start> limit 3; |
|||
Log_name Pos Event_type Server_id End_log_pos Info |
|||
master-bin.000001 # Query # # use `test`; CREATE TABLE t1 (a INT) |
|||
master-bin.000001 # Query # # use `test`; INSERT INTO t1 VALUES (1) |
|||
master-bin.000001 # Query # # use `test`; INSERT INTO t1 VALUES (2) |
|||
[MASTER] ********* SOW BINLOG EVENTS ... LIMIT offset,rows ********* |
|||
show binlog events from <binlog_start> limit 1, 3; |
|||
Log_name Pos Event_type Server_id End_log_pos Info |
|||
master-bin.000001 # Query # # use `test`; INSERT INTO t1 VALUES (1) |
|||
master-bin.000001 # Query # # use `test`; INSERT INTO t1 VALUES (2) |
|||
master-bin.000001 # Query # # use `test`; INSERT INTO t1 VALUES (3) |
|||
[SLAVE] ********* SOW BINLOG EVENTS IN ... ********* |
|||
show binlog events in 'slave-bin.000001' from <binlog_start>; |
|||
Log_name Pos Event_type Server_id End_log_pos Info |
|||
slave-bin.000001 # Query # # use `test`; CREATE TABLE t1 (a INT) |
|||
slave-bin.000001 # Query # # use `test`; INSERT INTO t1 VALUES (1) |
|||
slave-bin.000001 # Query # # use `test`; INSERT INTO t1 VALUES (2) |
|||
slave-bin.000001 # Query # # use `test`; INSERT INTO t1 VALUES (3) |
|||
slave-bin.000001 # Query # # use `test`; INSERT INTO t1 VALUES (4) |
|||
slave-bin.000001 # Query # # use `test`; INSERT INTO t1 VALUES (5) |
|||
slave-bin.000001 # Query # # use `test`; INSERT INTO t1 VALUES (6) |
|||
[SLAVE] ********* SOW BINLOG EVENTS ********* |
|||
show binlog events from <binlog_start>; |
|||
Log_name Pos Event_type Server_id End_log_pos Info |
|||
slave-bin.000001 # Query # # use `test`; CREATE TABLE t1 (a INT) |
|||
slave-bin.000001 # Query # # use `test`; INSERT INTO t1 VALUES (1) |
|||
slave-bin.000001 # Query # # use `test`; INSERT INTO t1 VALUES (2) |
|||
slave-bin.000001 # Query # # use `test`; INSERT INTO t1 VALUES (3) |
|||
slave-bin.000001 # Query # # use `test`; INSERT INTO t1 VALUES (4) |
|||
slave-bin.000001 # Query # # use `test`; INSERT INTO t1 VALUES (5) |
|||
slave-bin.000001 # Query # # use `test`; INSERT INTO t1 VALUES (6) |
|||
[SLAVE] ********* SOW BINLOG EVENTS ... LIMIT rows ********* |
|||
show binlog events from <binlog_start> limit 3; |
|||
Log_name Pos Event_type Server_id End_log_pos Info |
|||
slave-bin.000001 # Query # # use `test`; CREATE TABLE t1 (a INT) |
|||
slave-bin.000001 # Query # # use `test`; INSERT INTO t1 VALUES (1) |
|||
slave-bin.000001 # Query # # use `test`; INSERT INTO t1 VALUES (2) |
|||
[SLAVE] ********* SOW BINLOG EVENTS ... LIMIT offset,rows ********* |
|||
show binlog events from <binlog_start> limit 1, 3; |
|||
Log_name Pos Event_type Server_id End_log_pos Info |
|||
slave-bin.000001 # Query # # use `test`; INSERT INTO t1 VALUES (1) |
|||
slave-bin.000001 # Query # # use `test`; INSERT INTO t1 VALUES (2) |
|||
slave-bin.000001 # Query # # use `test`; INSERT INTO t1 VALUES (3) |
|||
[SLAVE] ********* SOW RELAYLOG EVENTS IN ... ********* |
|||
show relaylog events in 'slave-relay-bin.000003' from <binlog_start>; |
|||
Log_name Pos Event_type Server_id End_log_pos Info |
|||
slave-relay-bin.000003 # Rotate # # master-bin.000001;pos=4 |
|||
slave-relay-bin.000003 # Format_desc # # SERVER_VERSION, BINLOG_VERSION |
|||
slave-relay-bin.000003 # Query # # use `test`; CREATE TABLE t1 (a INT) |
|||
slave-relay-bin.000003 # Query # # use `test`; INSERT INTO t1 VALUES (1) |
|||
slave-relay-bin.000003 # Query # # use `test`; INSERT INTO t1 VALUES (2) |
|||
slave-relay-bin.000003 # Query # # use `test`; INSERT INTO t1 VALUES (3) |
|||
slave-relay-bin.000003 # Query # # use `test`; INSERT INTO t1 VALUES (4) |
|||
slave-relay-bin.000003 # Query # # use `test`; INSERT INTO t1 VALUES (5) |
|||
slave-relay-bin.000003 # Query # # use `test`; INSERT INTO t1 VALUES (6) |
|||
[SLAVE] ********* SOW RELAYLOG EVENTS ********* |
|||
show relaylog events from <binlog_start>; |
|||
Log_name Pos Event_type Server_id End_log_pos Info |
|||
slave-relay-bin.000002 # Rotate # # slave-relay-bin.000003;pos=4 |
|||
[MASTER] ********* SOW RELAYLOG EVENTS ... LIMIT rows ********* |
|||
show relaylog events in 'slave-relay-bin.000003' from <binlog_start> limit 3; |
|||
Log_name Pos Event_type Server_id End_log_pos Info |
|||
slave-relay-bin.000003 # Rotate # # master-bin.000001;pos=4 |
|||
slave-relay-bin.000003 # Format_desc # # SERVER_VERSION, BINLOG_VERSION |
|||
slave-relay-bin.000003 # Query # # use `test`; CREATE TABLE t1 (a INT) |
|||
[MASTER] ********* SOW RELAYLOG EVENTS ... LIMIT offset,rows ********* |
|||
show relaylog events in 'slave-relay-bin.000003' from <binlog_start> limit 1, 3; |
|||
Log_name Pos Event_type Server_id End_log_pos Info |
|||
slave-relay-bin.000003 # Format_desc # # SERVER_VERSION, BINLOG_VERSION |
|||
slave-relay-bin.000003 # Query # # use `test`; CREATE TABLE t1 (a INT) |
|||
slave-relay-bin.000003 # Query # # use `test`; INSERT INTO t1 VALUES (1) |
|||
FLUSH LOGS; |
|||
FLUSH LOGS; |
|||
DROP TABLE t1; |
|||
[MASTER] ********* SOW BINLOG EVENTS IN ... ********* |
|||
show binlog events in 'master-bin.000002' from <binlog_start>; |
|||
Log_name Pos Event_type Server_id End_log_pos Info |
|||
master-bin.000002 # Query # # use `test`; DROP TABLE t1 |
|||
[MASTER] ********* SOW BINLOG EVENTS ********* |
|||
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 t1 (a INT) |
|||
master-bin.000001 # Query # # use `test`; INSERT INTO t1 VALUES (1) |
|||
master-bin.000001 # Query # # use `test`; INSERT INTO t1 VALUES (2) |
|||
master-bin.000001 # Query # # use `test`; INSERT INTO t1 VALUES (3) |
|||
master-bin.000001 # Query # # use `test`; INSERT INTO t1 VALUES (4) |
|||
master-bin.000001 # Query # # use `test`; INSERT INTO t1 VALUES (5) |
|||
master-bin.000001 # Query # # use `test`; INSERT INTO t1 VALUES (6) |
|||
master-bin.000001 # Rotate # # master-bin.000002;pos=4 |
|||
[SLAVE] ********* SOW BINLOG EVENTS IN ... ********* |
|||
show binlog events in 'slave-bin.000002' from <binlog_start>; |
|||
Log_name Pos Event_type Server_id End_log_pos Info |
|||
slave-bin.000002 # Query # # use `test`; DROP TABLE t1 |
|||
[SLAVE] ********* SOW BINLOG EVENTS ********* |
|||
show binlog events from <binlog_start>; |
|||
Log_name Pos Event_type Server_id End_log_pos Info |
|||
slave-bin.000001 # Query # # use `test`; CREATE TABLE t1 (a INT) |
|||
slave-bin.000001 # Query # # use `test`; INSERT INTO t1 VALUES (1) |
|||
slave-bin.000001 # Query # # use `test`; INSERT INTO t1 VALUES (2) |
|||
slave-bin.000001 # Query # # use `test`; INSERT INTO t1 VALUES (3) |
|||
slave-bin.000001 # Query # # use `test`; INSERT INTO t1 VALUES (4) |
|||
slave-bin.000001 # Query # # use `test`; INSERT INTO t1 VALUES (5) |
|||
slave-bin.000001 # Query # # use `test`; INSERT INTO t1 VALUES (6) |
|||
slave-bin.000001 # Rotate # # slave-bin.000002;pos=4 |
|||
[SLAVE] ********* SOW RELAYLOG EVENTS IN ... ********* |
|||
show relaylog events in 'slave-relay-bin.000005' from <binlog_start>; |
|||
Log_name Pos Event_type Server_id End_log_pos Info |
|||
slave-relay-bin.000005 # Rotate # # master-bin.000002;pos=4 |
|||
slave-relay-bin.000005 # Rotate # # slave-relay-bin.000006;pos=4 |
|||
[SLAVE] ********* SOW RELAYLOG EVENTS ********* |
|||
show relaylog events from <binlog_start>; |
|||
Log_name Pos Event_type Server_id End_log_pos Info |
|||
slave-relay-bin.000005 # Rotate # # master-bin.000002;pos=4 |
|||
slave-relay-bin.000005 # Rotate # # slave-relay-bin.000006;pos=4 |
|||
@ -0,0 +1,18 @@ |
|||
# BUG#28777 SHOW BINLOG EVENTS does not work on relay log files |
|||
# |
|||
# GOAL |
|||
# ==== |
|||
# |
|||
# Test that SHOW BINLOG EVENTS and the new SHOW RELAYLOG EVENTS works after |
|||
# the patch, both on master and slave. |
|||
# |
|||
# HOW |
|||
# === |
|||
# |
|||
# This test issues SHOW [BINLOG|RELAYLOG] EVENTS both on master and slave after |
|||
# some statements have been issued. |
|||
|
|||
-- source include/master-slave.inc |
|||
-- source include/have_binlog_format_row.inc |
|||
|
|||
-- source extra/rpl_tests/rpl_show_relaylog_events.inc |
|||
@ -0,0 +1,18 @@ |
|||
# BUG#28777 SHOW BINLOG EVENTS does not work on relay log files |
|||
# |
|||
# GOAL |
|||
# ==== |
|||
# |
|||
# Test that SHOW BINLOG EVENTS and the new SHOW RELAYLOG EVENTS works after |
|||
# the patch, both on master and slave. |
|||
# |
|||
# HOW |
|||
# === |
|||
# |
|||
# This test issues SHOW [BINLOG|RELAYLOG] EVENTS both on master and slave after |
|||
# some statements have been issued. |
|||
|
|||
-- source include/master-slave.inc |
|||
-- source include/have_binlog_format_mixed_or_statement.inc |
|||
|
|||
-- source extra/rpl_tests/rpl_show_relaylog_events.inc |
|||
Write
Preview
Loading…
Cancel
Save
Reference in new issue