diff options
3 files changed, 282 insertions, 436 deletions
diff --git a/mysql-test/extra/binlog_tests/binlog_row_annotate.inc b/mysql-test/extra/binlog_tests/binlog_row_annotate.inc index b3784ea9606..e53f49149f1 100644 --- a/mysql-test/extra/binlog_tests/binlog_row_annotate.inc +++ b/mysql-test/extra/binlog_tests/binlog_row_annotate.inc @@ -4,7 +4,7 @@ # Please check all dependent tests after modifying it # # Usage: -# --let $use_remote_mysqlbinlog= 1 # optional +# --let use_remote_mysqlbinlog= 1 # optional # --source extra/binlog_tests/binlog_row_annotate.inc # # By default, the script uses mysqlbinlog both with direct access to files @@ -35,13 +35,12 @@ set @old_binlog_checksum=@@binlog_checksum; set global binlog_checksum=NONE; +--let datadir= `select @@datadir` --source include/have_log_bin.inc --source include/binlog_start_pos.inc --source include/have_binlog_format_row.inc ---disable_query_log - set sql_mode=""; # Fix timestamp to avoid varying results @@ -50,14 +49,6 @@ SET timestamp=1000000000; # Delete all existing binary logs RESET MASTER; ---disable_warnings -DROP DATABASE IF EXISTS test1; -DROP DATABASE IF EXISTS test2; -DROP DATABASE IF EXISTS test3; -DROP DATABASE IF EXISTS xtest1; -DROP DATABASE IF EXISTS xtest2; ---enable_warnings - CREATE DATABASE test1; CREATE TABLE test1.t1(a int); @@ -108,7 +99,6 @@ DELETE xtest1.xt1, xtest2.xt2 WHERE xtest1.xt1.a=xtest2.xt2.a AND xtest2.xt2.a=test3.t3.a; FLUSH LOGS; ---enable_query_log --echo ##################################################################################### --echo # The following Annotate_rows events should appear below: @@ -119,11 +109,7 @@ FLUSH LOGS; --echo # - DELETE xtest1.xt1, test2.t2 FROM <...> --echo ##################################################################################### -let $start_pos= `select @binlog_start_pos`; ---replace_column 2 # 5 # ---replace_result $start_pos <start_pos> ---replace_regex /table_id: [0-9]+/table_id: #/ /\/\* xid=.* \*\//\/* xid= *\// ---eval show binlog events in 'master-bin.000001' from $start_pos +--source include/show_binlog_events.inc if (!$use_remote_mysqlbinlog) { @@ -138,9 +124,8 @@ if (!$use_remote_mysqlbinlog) --echo # - DELETE xtest1.xt1, test2.t2 FROM <...> (with one subsequent Table map) --echo ##################################################################################### - let $MYSQLD_DATADIR= `select @@datadir`; --replace_regex /server id [0-9]*/server id #/ /server v [^ ]*/server v #.##.##/ /exec_time=[0-9]*/exec_time=#/ /thread_id=[0-9]*/thread_id=#/ /table id [0-9]*/table id #/ /mapped to number [0-9]*/mapped to number #/ /end_log_pos [0-9]*/end_log_pos #/ /# at [0-9]*/# at #/ - --exec $MYSQL_BINLOG --base64-output=decode-rows -v -v $MYSQLD_DATADIR/master-bin.000001 + --exec $MYSQL_BINLOG --base64-output=decode-rows -v -v $datadir/master-bin.000001 --echo # --echo ##################################################################################### @@ -149,9 +134,8 @@ if (!$use_remote_mysqlbinlog) --echo # - DELETE test1.t1, test2.t2 FROM <...> --echo ##################################################################################### - let $MYSQLD_DATADIR= `select @@datadir`; --replace_regex /server id [0-9]*/server id #/ /server v [^ ]*/server v #.##.##/ /exec_time=[0-9]*/exec_time=#/ /thread_id=[0-9]*/thread_id=#/ /table id [0-9]*/table id #/ /mapped to number [0-9]*/mapped to number #/ /end_log_pos [0-9]*/end_log_pos #/ /# at [0-9]*/# at #/ - --exec $MYSQL_BINLOG --base64-output=decode-rows --database=test1 -v -v $MYSQLD_DATADIR/master-bin.000001 + --exec $MYSQL_BINLOG --base64-output=decode-rows --database=test1 -v -v $datadir/master-bin.000001 --echo # --echo ##################################################################################### @@ -159,11 +143,10 @@ if (!$use_remote_mysqlbinlog) --echo # No Annotates should appear in this output --echo ##################################################################################### - let $MYSQLD_DATADIR= `select @@datadir`; --replace_regex /server id [0-9]*/server id #/ /server v [^ ]*/server v #.##.##/ /exec_time=[0-9]*/exec_time=#/ /thread_id=[0-9]*/thread_id=#/ /table id [0-9]*/table id #/ /mapped to number [0-9]*/mapped to number #/ /end_log_pos [0-9]*/end_log_pos #/ /# at [0-9]*/# at #/ - --exec $MYSQL_BINLOG --base64-output=decode-rows --skip-annotate-row-events -v -v $MYSQLD_DATADIR/master-bin.000001 + --exec $MYSQL_BINLOG --base64-output=decode-rows --skip-annotate-row-events -v -v $datadir/master-bin.000001 - --let $use_remote_mysqlbinlog= 0 + --let use_remote_mysqlbinlog= 0 } --echo # @@ -177,7 +160,6 @@ if (!$use_remote_mysqlbinlog) --echo # - DELETE xtest1.xt1, test2.t2 FROM <...> (with one subsequent Table map) --echo ##################################################################################### -let $MYSQLD_DATADIR= `select @@datadir`; --replace_regex /server id [0-9]*/server id #/ /server v [^ ]*/server v #.##.##/ /exec_time=[0-9]*/exec_time=#/ /thread_id=[0-9]*/thread_id=#/ /table id [0-9]*/table id #/ /mapped to number [0-9]*/mapped to number #/ /end_log_pos [0-9]*/end_log_pos #/ /# at [0-9]*/# at #/ --exec $MYSQL_BINLOG --base64-output=decode-rows -v -v --read-from-remote-server --user=root --host=localhost --port=$MASTER_MYPORT master-bin.000001 @@ -188,7 +170,6 @@ let $MYSQLD_DATADIR= `select @@datadir`; --echo # - DELETE test1.t1, test2.t2 FROM <...> --echo ##################################################################################### -let $MYSQLD_DATADIR= `select @@datadir`; --replace_regex /server id [0-9]*/server id #/ /server v [^ ]*/server v #.##.##/ /exec_time=[0-9]*/exec_time=#/ /thread_id=[0-9]*/thread_id=#/ /table id [0-9]*/table id #/ /mapped to number [0-9]*/mapped to number #/ /end_log_pos [0-9]*/end_log_pos #/ /# at [0-9]*/# at #/ --exec $MYSQL_BINLOG --base64-output=decode-rows --database=test1 -v -v --read-from-remote-server --user=root --host=localhost --port=$MASTER_MYPORT master-bin.000001 @@ -198,18 +179,14 @@ let $MYSQLD_DATADIR= `select @@datadir`; --echo # No Annotates should appear in this output --echo ##################################################################################### -let $MYSQLD_DATADIR= `select @@datadir`; --replace_regex /server id [0-9]*/server id #/ /server v [^ ]*/server v #.##.##/ /exec_time=[0-9]*/exec_time=#/ /thread_id=[0-9]*/thread_id=#/ /table id [0-9]*/table id #/ /mapped to number [0-9]*/mapped to number #/ /end_log_pos [0-9]*/end_log_pos #/ /# at [0-9]*/# at #/ --exec $MYSQL_BINLOG --base64-output=decode-rows --skip-annotate-row-events -v -v --read-from-remote-server --user=root --host=localhost --port=$MASTER_MYPORT master-bin.000001 # Clean-up ---disable_query_log set global binlog_checksum=@old_binlog_checksum; DROP DATABASE test1; DROP DATABASE test2; DROP DATABASE test3; DROP DATABASE xtest1; DROP DATABASE xtest2; ---enable_query_log - diff --git a/mysql-test/suite/binlog/r/binlog_row_annotate.result b/mysql-test/suite/binlog/r/binlog_row_annotate.result index e7b695c00d9..3da1d9877f4 100644 --- a/mysql-test/suite/binlog/r/binlog_row_annotate.result +++ b/mysql-test/suite/binlog/r/binlog_row_annotate.result @@ -1,5 +1,37 @@ set @old_binlog_checksum=@@binlog_checksum; set global binlog_checksum=NONE; +set sql_mode=""; +SET timestamp=1000000000; +RESET MASTER; +CREATE DATABASE test1; +CREATE TABLE test1.t1(a int); +CREATE DATABASE test2; +CREATE TABLE test2.t2(a int); +CREATE VIEW test2.v2 AS SELECT * FROM test2.t2; +CREATE DATABASE test3; +CREATE TABLE test3.t3(a int); +CREATE DATABASE xtest1; +CREATE TABLE xtest1.xt1(a int); +CREATE DATABASE xtest2; +CREATE TABLE xtest2.xt2(a int); +INSERT INTO test1.t1 VALUES (1), (2), (3); +SET SESSION binlog_annotate_row_events = ON; +INSERT INTO test2.t2 VALUES (1), (2), (3); +INSERT INTO test3.t3 VALUES (1), (2), (3); +DELETE test1.t1, test2.t2 +FROM test1.t1 INNER JOIN test2.t2 INNER JOIN test3.t3 +WHERE test1.t1.a=test2.t2.a AND test2.t2.a=test3.t3.a; +INSERT INTO xtest1.xt1 VALUES (1), (2), (3); +INSERT INTO test2.v2 VALUES (1), (2), (3); +DELETE xtest1.xt1, test2.t2 +FROM xtest1.xt1 INNER JOIN test2.t2 INNER JOIN test3.t3 +WHERE xtest1.xt1.a=test2.t2.a AND test2.t2.a=test3.t3.a; +INSERT INTO xtest1.xt1 VALUES (1), (2), (3); +INSERT INTO xtest2.xt2 VALUES (1), (2), (3); +DELETE xtest1.xt1, xtest2.xt2 +FROM xtest1.xt1 INNER JOIN xtest2.xt2 INNER JOIN test3.t3 +WHERE xtest1.xt1.a=xtest2.xt2.a AND xtest2.xt2.a=test3.t3.a; +FLUSH LOGS; ##################################################################################### # The following Annotate_rows events should appear below: # - INSERT INTO test2.t2 VALUES (1), (2), (3) @@ -8,58 +40,50 @@ set global binlog_checksum=NONE; # - INSERT INTO test2.t2 VALUES (1), (2), (3) # - DELETE xtest1.xt1, test2.t2 FROM <...> ##################################################################################### -show binlog events in 'master-bin.000001' from <start_pos>; +include/show_binlog_events.inc Log_name Pos Event_type Server_id End_log_pos Info -master-bin.000001 # Gtid_list 1 # [] -master-bin.000001 # Binlog_checkpoint 1 # master-bin.000001 -master-bin.000001 # Gtid 1 # GTID 0-1-1 -master-bin.000001 # Query 1 # DROP DATABASE IF EXISTS test1 -master-bin.000001 # Gtid 1 # GTID 0-1-2 -master-bin.000001 # Query 1 # DROP DATABASE IF EXISTS test2 -master-bin.000001 # Gtid 1 # GTID 0-1-3 -master-bin.000001 # Query 1 # DROP DATABASE IF EXISTS test3 -master-bin.000001 # Gtid 1 # GTID 0-1-4 -master-bin.000001 # Query 1 # CREATE DATABASE test1 -master-bin.000001 # Gtid 1 # GTID 0-1-5 -master-bin.000001 # Query 1 # CREATE DATABASE test2 -master-bin.000001 # Gtid 1 # GTID 0-1-6 -master-bin.000001 # Query 1 # CREATE DATABASE test3 -master-bin.000001 # Gtid 1 # BEGIN GTID 0-1-7 -master-bin.000001 # Table_map 1 # table_id: # (test1.t1) -master-bin.000001 # Write_rows_v1 1 # table_id: # flags: STMT_END_F -master-bin.000001 # Query 1 # COMMIT -master-bin.000001 # Gtid 1 # BEGIN GTID 0-1-8 -master-bin.000001 # Annotate_rows 1 # INSERT INTO test2.t2 VALUES (1), (2), (3) -master-bin.000001 # Table_map 1 # table_id: # (test2.t2) -master-bin.000001 # Write_rows_v1 1 # table_id: # flags: STMT_END_F -master-bin.000001 # Query 1 # COMMIT -master-bin.000001 # Gtid 1 # BEGIN GTID 0-1-9 -master-bin.000001 # Annotate_rows 1 # INSERT INTO test3.t3 VALUES (1), (2), (3) -master-bin.000001 # Table_map 1 # table_id: # (test3.t3) -master-bin.000001 # Write_rows_v1 1 # table_id: # flags: STMT_END_F -master-bin.000001 # Query 1 # COMMIT -master-bin.000001 # Gtid 1 # BEGIN GTID 0-1-10 -master-bin.000001 # Annotate_rows 1 # DELETE test1.t1, test2.t2 +master-bin.000001 # Gtid # # GTID #-#-# +master-bin.000001 # Query # # CREATE DATABASE test1 +master-bin.000001 # Gtid # # GTID #-#-# +master-bin.000001 # Query # # CREATE DATABASE test2 +master-bin.000001 # Gtid # # GTID #-#-# +master-bin.000001 # Query # # CREATE DATABASE test3 +master-bin.000001 # Gtid # # BEGIN GTID #-#-# +master-bin.000001 # Table_map # # table_id: # (test1.t1) +master-bin.000001 # Write_rows_v1 # # table_id: # flags: STMT_END_F +master-bin.000001 # Query # # COMMIT +master-bin.000001 # Gtid # # BEGIN GTID #-#-# +master-bin.000001 # Annotate_rows # # INSERT INTO test2.t2 VALUES (1), (2), (3) +master-bin.000001 # Table_map # # table_id: # (test2.t2) +master-bin.000001 # Write_rows_v1 # # table_id: # flags: STMT_END_F +master-bin.000001 # Query # # COMMIT +master-bin.000001 # Gtid # # BEGIN GTID #-#-# +master-bin.000001 # Annotate_rows # # INSERT INTO test3.t3 VALUES (1), (2), (3) +master-bin.000001 # Table_map # # table_id: # (test3.t3) +master-bin.000001 # Write_rows_v1 # # table_id: # flags: STMT_END_F +master-bin.000001 # Query # # COMMIT +master-bin.000001 # Gtid # # BEGIN GTID #-#-# +master-bin.000001 # Annotate_rows # # DELETE test1.t1, test2.t2 FROM test1.t1 INNER JOIN test2.t2 INNER JOIN test3.t3 WHERE test1.t1.a=test2.t2.a AND test2.t2.a=test3.t3.a -master-bin.000001 # Table_map 1 # table_id: # (test1.t1) -master-bin.000001 # Table_map 1 # table_id: # (test2.t2) -master-bin.000001 # Delete_rows_v1 1 # table_id: # -master-bin.000001 # Delete_rows_v1 1 # table_id: # flags: STMT_END_F -master-bin.000001 # Query 1 # COMMIT -master-bin.000001 # Gtid 1 # BEGIN GTID 0-1-11 -master-bin.000001 # Annotate_rows 1 # INSERT INTO test2.v2 VALUES (1), (2), (3) -master-bin.000001 # Table_map 1 # table_id: # (test2.t2) -master-bin.000001 # Write_rows_v1 1 # table_id: # flags: STMT_END_F -master-bin.000001 # Query 1 # COMMIT -master-bin.000001 # Gtid 1 # BEGIN GTID 0-1-12 -master-bin.000001 # Annotate_rows 1 # DELETE xtest1.xt1, test2.t2 +master-bin.000001 # Table_map # # table_id: # (test1.t1) +master-bin.000001 # Table_map # # table_id: # (test2.t2) +master-bin.000001 # Delete_rows_v1 # # table_id: # +master-bin.000001 # Delete_rows_v1 # # table_id: # flags: STMT_END_F +master-bin.000001 # Query # # COMMIT +master-bin.000001 # Gtid # # BEGIN GTID #-#-# +master-bin.000001 # Annotate_rows # # INSERT INTO test2.v2 VALUES (1), (2), (3) +master-bin.000001 # Table_map # # table_id: # (test2.t2) +master-bin.000001 # Write_rows_v1 # # table_id: # flags: STMT_END_F +master-bin.000001 # Query # # COMMIT +master-bin.000001 # Gtid # # BEGIN GTID #-#-# +master-bin.000001 # Annotate_rows # # DELETE xtest1.xt1, test2.t2 FROM xtest1.xt1 INNER JOIN test2.t2 INNER JOIN test3.t3 WHERE xtest1.xt1.a=test2.t2.a AND test2.t2.a=test3.t3.a -master-bin.000001 # Table_map 1 # table_id: # (test2.t2) -master-bin.000001 # Delete_rows_v1 1 # table_id: # flags: STMT_END_F -master-bin.000001 # Query 1 # COMMIT -master-bin.000001 # Rotate 1 # master-bin.000002;pos=4 +master-bin.000001 # Table_map # # table_id: # (test2.t2) +master-bin.000001 # Delete_rows_v1 # # table_id: # flags: STMT_END_F +master-bin.000001 # Query # # COMMIT +master-bin.000001 # Rotate # # master-bin.000002;pos=POS # ##################################################################################### # mysqlbinlog @@ -98,7 +122,7 @@ SET @@session.auto_increment_increment=1, @@session.auto_increment_offset=1/*!*/ SET @@session.character_set_client=8,@@session.collation_connection=8,@@session.collation_server=8/*!*/; SET @@session.lc_time_names=0/*!*/; SET @@session.collation_database=DEFAULT/*!*/; -DROP DATABASE IF EXISTS test1 +CREATE DATABASE test1 /*!*/; # at # #010909 4:46:40 server id # end_log_pos # GTID 0-1-2 ddl @@ -106,7 +130,7 @@ DROP DATABASE IF EXISTS test1 # at # #010909 4:46:40 server id # end_log_pos # Query thread_id=# exec_time=# error_code=0 SET TIMESTAMP=1000000000/*!*/; -DROP DATABASE IF EXISTS test2 +CREATE DATABASE test2 /*!*/; # at # #010909 4:46:40 server id # end_log_pos # GTID 0-1-3 ddl @@ -114,35 +138,11 @@ DROP DATABASE IF EXISTS test2 # at # #010909 4:46:40 server id # end_log_pos # Query thread_id=# exec_time=# error_code=0 SET TIMESTAMP=1000000000/*!*/; -DROP DATABASE IF EXISTS test3 -/*!*/; -# at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-4 ddl -/*!100001 SET @@session.gtid_seq_no=4*//*!*/; -# at # -#010909 4:46:40 server id # end_log_pos # Query thread_id=# exec_time=# error_code=0 -SET TIMESTAMP=1000000000/*!*/; -CREATE DATABASE test1 -/*!*/; -# at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-5 ddl -/*!100001 SET @@session.gtid_seq_no=5*//*!*/; -# at # -#010909 4:46:40 server id # end_log_pos # Query thread_id=# exec_time=# error_code=0 -SET TIMESTAMP=1000000000/*!*/; -CREATE DATABASE test2 -/*!*/; -# at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-6 ddl -/*!100001 SET @@session.gtid_seq_no=6*//*!*/; -# at # -#010909 4:46:40 server id # end_log_pos # Query thread_id=# exec_time=# error_code=0 -SET TIMESTAMP=1000000000/*!*/; CREATE DATABASE test3 /*!*/; # at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-7 -/*!100001 SET @@session.gtid_seq_no=7*//*!*/; +#010909 4:46:40 server id # end_log_pos # GTID 0-1-4 +/*!100001 SET @@session.gtid_seq_no=4*//*!*/; BEGIN /*!*/; # at # @@ -164,8 +164,8 @@ SET TIMESTAMP=1000000000/*!*/; COMMIT /*!*/; # at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-8 -/*!100001 SET @@session.gtid_seq_no=8*//*!*/; +#010909 4:46:40 server id # end_log_pos # GTID 0-1-5 +/*!100001 SET @@session.gtid_seq_no=5*//*!*/; BEGIN /*!*/; # at # @@ -190,8 +190,8 @@ SET TIMESTAMP=1000000000/*!*/; COMMIT /*!*/; # at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-9 -/*!100001 SET @@session.gtid_seq_no=9*//*!*/; +#010909 4:46:40 server id # end_log_pos # GTID 0-1-6 +/*!100001 SET @@session.gtid_seq_no=6*//*!*/; BEGIN /*!*/; # at # @@ -216,8 +216,8 @@ SET TIMESTAMP=1000000000/*!*/; COMMIT /*!*/; # at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-10 -/*!100001 SET @@session.gtid_seq_no=10*//*!*/; +#010909 4:46:40 server id # end_log_pos # GTID 0-1-7 +/*!100001 SET @@session.gtid_seq_no=7*//*!*/; BEGIN /*!*/; # at # @@ -257,8 +257,8 @@ SET TIMESTAMP=1000000000/*!*/; COMMIT /*!*/; # at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-11 -/*!100001 SET @@session.gtid_seq_no=11*//*!*/; +#010909 4:46:40 server id # end_log_pos # GTID 0-1-8 +/*!100001 SET @@session.gtid_seq_no=8*//*!*/; BEGIN /*!*/; # at # @@ -283,8 +283,8 @@ SET TIMESTAMP=1000000000/*!*/; COMMIT /*!*/; # at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-12 -/*!100001 SET @@session.gtid_seq_no=12*//*!*/; +#010909 4:46:40 server id # end_log_pos # GTID 0-1-9 +/*!100001 SET @@session.gtid_seq_no=9*//*!*/; BEGIN /*!*/; # at # @@ -351,7 +351,7 @@ SET @@session.auto_increment_increment=1, @@session.auto_increment_offset=1/*!*/ SET @@session.character_set_client=8,@@session.collation_connection=8,@@session.collation_server=8/*!*/; SET @@session.lc_time_names=0/*!*/; SET @@session.collation_database=DEFAULT/*!*/; -DROP DATABASE IF EXISTS test1 +CREATE DATABASE test1 /*!*/; # at # #010909 4:46:40 server id # end_log_pos # GTID 0-1-2 ddl @@ -362,24 +362,8 @@ DROP DATABASE IF EXISTS test1 /*!100001 SET @@session.gtid_seq_no=3*//*!*/; # at # # at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-4 ddl +#010909 4:46:40 server id # end_log_pos # GTID 0-1-4 /*!100001 SET @@session.gtid_seq_no=4*//*!*/; -# at # -#010909 4:46:40 server id # end_log_pos # Query thread_id=# exec_time=# error_code=0 -SET TIMESTAMP=1000000000/*!*/; -CREATE DATABASE test1 -/*!*/; -# at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-5 ddl -/*!100001 SET @@session.gtid_seq_no=5*//*!*/; -# at # -# at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-6 ddl -/*!100001 SET @@session.gtid_seq_no=6*//*!*/; -# at # -# at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-7 -/*!100001 SET @@session.gtid_seq_no=7*//*!*/; BEGIN /*!*/; # at # @@ -401,8 +385,8 @@ SET TIMESTAMP=1000000000/*!*/; COMMIT /*!*/; # at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-8 -/*!100001 SET @@session.gtid_seq_no=8*//*!*/; +#010909 4:46:40 server id # end_log_pos # GTID 0-1-5 +/*!100001 SET @@session.gtid_seq_no=5*//*!*/; BEGIN /*!*/; # at # @@ -414,8 +398,8 @@ SET TIMESTAMP=1000000000/*!*/; COMMIT /*!*/; # at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-9 -/*!100001 SET @@session.gtid_seq_no=9*//*!*/; +#010909 4:46:40 server id # end_log_pos # GTID 0-1-6 +/*!100001 SET @@session.gtid_seq_no=6*//*!*/; BEGIN /*!*/; # at # @@ -427,8 +411,8 @@ SET TIMESTAMP=1000000000/*!*/; COMMIT /*!*/; # at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-10 -/*!100001 SET @@session.gtid_seq_no=10*//*!*/; +#010909 4:46:40 server id # end_log_pos # GTID 0-1-7 +/*!100001 SET @@session.gtid_seq_no=7*//*!*/; BEGIN /*!*/; # at # @@ -458,8 +442,8 @@ SET TIMESTAMP=1000000000/*!*/; COMMIT /*!*/; # at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-11 -/*!100001 SET @@session.gtid_seq_no=11*//*!*/; +#010909 4:46:40 server id # end_log_pos # GTID 0-1-8 +/*!100001 SET @@session.gtid_seq_no=8*//*!*/; BEGIN /*!*/; # at # @@ -471,8 +455,8 @@ SET TIMESTAMP=1000000000/*!*/; COMMIT /*!*/; # at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-12 -/*!100001 SET @@session.gtid_seq_no=12*//*!*/; +#010909 4:46:40 server id # end_log_pos # GTID 0-1-9 +/*!100001 SET @@session.gtid_seq_no=9*//*!*/; BEGIN /*!*/; # at # @@ -523,7 +507,7 @@ SET @@session.auto_increment_increment=1, @@session.auto_increment_offset=1/*!*/ SET @@session.character_set_client=8,@@session.collation_connection=8,@@session.collation_server=8/*!*/; SET @@session.lc_time_names=0/*!*/; SET @@session.collation_database=DEFAULT/*!*/; -DROP DATABASE IF EXISTS test1 +CREATE DATABASE test1 /*!*/; # at # #010909 4:46:40 server id # end_log_pos # GTID 0-1-2 ddl @@ -531,7 +515,7 @@ DROP DATABASE IF EXISTS test1 # at # #010909 4:46:40 server id # end_log_pos # Query thread_id=# exec_time=# error_code=0 SET TIMESTAMP=1000000000/*!*/; -DROP DATABASE IF EXISTS test2 +CREATE DATABASE test2 /*!*/; # at # #010909 4:46:40 server id # end_log_pos # GTID 0-1-3 ddl @@ -539,35 +523,11 @@ DROP DATABASE IF EXISTS test2 # at # #010909 4:46:40 server id # end_log_pos # Query thread_id=# exec_time=# error_code=0 SET TIMESTAMP=1000000000/*!*/; -DROP DATABASE IF EXISTS test3 -/*!*/; -# at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-4 ddl -/*!100001 SET @@session.gtid_seq_no=4*//*!*/; -# at # -#010909 4:46:40 server id # end_log_pos # Query thread_id=# exec_time=# error_code=0 -SET TIMESTAMP=1000000000/*!*/; -CREATE DATABASE test1 -/*!*/; -# at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-5 ddl -/*!100001 SET @@session.gtid_seq_no=5*//*!*/; -# at # -#010909 4:46:40 server id # end_log_pos # Query thread_id=# exec_time=# error_code=0 -SET TIMESTAMP=1000000000/*!*/; -CREATE DATABASE test2 -/*!*/; -# at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-6 ddl -/*!100001 SET @@session.gtid_seq_no=6*//*!*/; -# at # -#010909 4:46:40 server id # end_log_pos # Query thread_id=# exec_time=# error_code=0 -SET TIMESTAMP=1000000000/*!*/; CREATE DATABASE test3 /*!*/; # at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-7 -/*!100001 SET @@session.gtid_seq_no=7*//*!*/; +#010909 4:46:40 server id # end_log_pos # GTID 0-1-4 +/*!100001 SET @@session.gtid_seq_no=4*//*!*/; BEGIN /*!*/; # at # @@ -589,8 +549,8 @@ SET TIMESTAMP=1000000000/*!*/; COMMIT /*!*/; # at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-8 -/*!100001 SET @@session.gtid_seq_no=8*//*!*/; +#010909 4:46:40 server id # end_log_pos # GTID 0-1-5 +/*!100001 SET @@session.gtid_seq_no=5*//*!*/; BEGIN /*!*/; # at # @@ -613,8 +573,8 @@ SET TIMESTAMP=1000000000/*!*/; COMMIT /*!*/; # at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-9 -/*!100001 SET @@session.gtid_seq_no=9*//*!*/; +#010909 4:46:40 server id # end_log_pos # GTID 0-1-6 +/*!100001 SET @@session.gtid_seq_no=6*//*!*/; BEGIN /*!*/; # at # @@ -637,8 +597,8 @@ SET TIMESTAMP=1000000000/*!*/; COMMIT /*!*/; # at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-10 -/*!100001 SET @@session.gtid_seq_no=10*//*!*/; +#010909 4:46:40 server id # end_log_pos # GTID 0-1-7 +/*!100001 SET @@session.gtid_seq_no=7*//*!*/; BEGIN /*!*/; # at # @@ -674,8 +634,8 @@ SET TIMESTAMP=1000000000/*!*/; COMMIT /*!*/; # at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-11 -/*!100001 SET @@session.gtid_seq_no=11*//*!*/; +#010909 4:46:40 server id # end_log_pos # GTID 0-1-8 +/*!100001 SET @@session.gtid_seq_no=8*//*!*/; BEGIN /*!*/; # at # @@ -698,8 +658,8 @@ SET TIMESTAMP=1000000000/*!*/; COMMIT /*!*/; # at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-12 -/*!100001 SET @@session.gtid_seq_no=12*//*!*/; +#010909 4:46:40 server id # end_log_pos # GTID 0-1-9 +/*!100001 SET @@session.gtid_seq_no=9*//*!*/; BEGIN /*!*/; # at # @@ -766,7 +726,7 @@ SET @@session.auto_increment_increment=1, @@session.auto_increment_offset=1/*!*/ SET @@session.character_set_client=8,@@session.collation_connection=8,@@session.collation_server=8/*!*/; SET @@session.lc_time_names=0/*!*/; SET @@session.collation_database=DEFAULT/*!*/; -DROP DATABASE IF EXISTS test1 +CREATE DATABASE test1 /*!*/; # at # #010909 4:46:40 server id # end_log_pos # GTID 0-1-2 ddl @@ -774,7 +734,7 @@ DROP DATABASE IF EXISTS test1 # at # #010909 4:46:40 server id # end_log_pos # Query thread_id=# exec_time=# error_code=0 SET TIMESTAMP=1000000000/*!*/; -DROP DATABASE IF EXISTS test2 +CREATE DATABASE test2 /*!*/; # at # #010909 4:46:40 server id # end_log_pos # GTID 0-1-3 ddl @@ -782,35 +742,11 @@ DROP DATABASE IF EXISTS test2 # at # #010909 4:46:40 server id # end_log_pos # Query thread_id=# exec_time=# error_code=0 SET TIMESTAMP=1000000000/*!*/; -DROP DATABASE IF EXISTS test3 -/*!*/; -# at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-4 ddl -/*!100001 SET @@session.gtid_seq_no=4*//*!*/; -# at # -#010909 4:46:40 server id # end_log_pos # Query thread_id=# exec_time=# error_code=0 -SET TIMESTAMP=1000000000/*!*/; -CREATE DATABASE test1 -/*!*/; -# at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-5 ddl -/*!100001 SET @@session.gtid_seq_no=5*//*!*/; -# at # -#010909 4:46:40 server id # end_log_pos # Query thread_id=# exec_time=# error_code=0 -SET TIMESTAMP=1000000000/*!*/; -CREATE DATABASE test2 -/*!*/; -# at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-6 ddl -/*!100001 SET @@session.gtid_seq_no=6*//*!*/; -# at # -#010909 4:46:40 server id # end_log_pos # Query thread_id=# exec_time=# error_code=0 -SET TIMESTAMP=1000000000/*!*/; CREATE DATABASE test3 /*!*/; # at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-7 -/*!100001 SET @@session.gtid_seq_no=7*//*!*/; +#010909 4:46:40 server id # end_log_pos # GTID 0-1-4 +/*!100001 SET @@session.gtid_seq_no=4*//*!*/; BEGIN /*!*/; # at # @@ -832,8 +768,8 @@ SET TIMESTAMP=1000000000/*!*/; COMMIT /*!*/; # at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-8 -/*!100001 SET @@session.gtid_seq_no=8*//*!*/; +#010909 4:46:40 server id # end_log_pos # GTID 0-1-5 +/*!100001 SET @@session.gtid_seq_no=5*//*!*/; BEGIN /*!*/; # at # @@ -858,8 +794,8 @@ SET TIMESTAMP=1000000000/*!*/; COMMIT /*!*/; # at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-9 -/*!100001 SET @@session.gtid_seq_no=9*//*!*/; +#010909 4:46:40 server id # end_log_pos # GTID 0-1-6 +/*!100001 SET @@session.gtid_seq_no=6*//*!*/; BEGIN /*!*/; # at # @@ -884,8 +820,8 @@ SET TIMESTAMP=1000000000/*!*/; COMMIT /*!*/; # at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-10 -/*!100001 SET @@session.gtid_seq_no=10*//*!*/; +#010909 4:46:40 server id # end_log_pos # GTID 0-1-7 +/*!100001 SET @@session.gtid_seq_no=7*//*!*/; BEGIN /*!*/; # at # @@ -925,8 +861,8 @@ SET TIMESTAMP=1000000000/*!*/; COMMIT /*!*/; # at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-11 -/*!100001 SET @@session.gtid_seq_no=11*//*!*/; +#010909 4:46:40 server id # end_log_pos # GTID 0-1-8 +/*!100001 SET @@session.gtid_seq_no=8*//*!*/; BEGIN /*!*/; # at # @@ -951,8 +887,8 @@ SET TIMESTAMP=1000000000/*!*/; COMMIT /*!*/; # at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-12 -/*!100001 SET @@session.gtid_seq_no=12*//*!*/; +#010909 4:46:40 server id # end_log_pos # GTID 0-1-9 +/*!100001 SET @@session.gtid_seq_no=9*//*!*/; BEGIN /*!*/; # at # @@ -1019,7 +955,7 @@ SET @@session.auto_increment_increment=1, @@session.auto_increment_offset=1/*!*/ SET @@session.character_set_client=8,@@session.collation_connection=8,@@session.collation_server=8/*!*/; SET @@session.lc_time_names=0/*!*/; SET @@session.collation_database=DEFAULT/*!*/; -DROP DATABASE IF EXISTS test1 +CREATE DATABASE test1 /*!*/; # at # #010909 4:46:40 server id # end_log_pos # GTID 0-1-2 ddl @@ -1030,24 +966,8 @@ DROP DATABASE IF EXISTS test1 /*!100001 SET @@session.gtid_seq_no=3*//*!*/; # at # # at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-4 ddl +#010909 4:46:40 server id # end_log_pos # GTID 0-1-4 /*!100001 SET @@session.gtid_seq_no=4*//*!*/; -# at # -#010909 4:46:40 server id # end_log_pos # Query thread_id=# exec_time=# error_code=0 -SET TIMESTAMP=1000000000/*!*/; -CREATE DATABASE test1 -/*!*/; -# at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-5 ddl -/*!100001 SET @@session.gtid_seq_no=5*//*!*/; -# at # -# at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-6 ddl -/*!100001 SET @@session.gtid_seq_no=6*//*!*/; -# at # -# at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-7 -/*!100001 SET @@session.gtid_seq_no=7*//*!*/; BEGIN /*!*/; # at # @@ -1069,8 +989,8 @@ SET TIMESTAMP=1000000000/*!*/; COMMIT /*!*/; # at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-8 -/*!100001 SET @@session.gtid_seq_no=8*//*!*/; +#010909 4:46:40 server id # end_log_pos # GTID 0-1-5 +/*!100001 SET @@session.gtid_seq_no=5*//*!*/; BEGIN /*!*/; # at # @@ -1082,8 +1002,8 @@ SET TIMESTAMP=1000000000/*!*/; COMMIT /*!*/; # at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-9 -/*!100001 SET @@session.gtid_seq_no=9*//*!*/; +#010909 4:46:40 server id # end_log_pos # GTID 0-1-6 +/*!100001 SET @@session.gtid_seq_no=6*//*!*/; BEGIN /*!*/; # at # @@ -1095,8 +1015,8 @@ SET TIMESTAMP=1000000000/*!*/; COMMIT /*!*/; # at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-10 -/*!100001 SET @@session.gtid_seq_no=10*//*!*/; +#010909 4:46:40 server id # end_log_pos # GTID 0-1-7 +/*!100001 SET @@session.gtid_seq_no=7*//*!*/; BEGIN /*!*/; # at # @@ -1126,8 +1046,8 @@ SET TIMESTAMP=1000000000/*!*/; COMMIT /*!*/; # at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-11 -/*!100001 SET @@session.gtid_seq_no=11*//*!*/; +#010909 4:46:40 server id # end_log_pos # GTID 0-1-8 +/*!100001 SET @@session.gtid_seq_no=8*//*!*/; BEGIN /*!*/; # at # @@ -1139,8 +1059,8 @@ SET TIMESTAMP=1000000000/*!*/; COMMIT /*!*/; # at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-12 -/*!100001 SET @@session.gtid_seq_no=12*//*!*/; +#010909 4:46:40 server id # end_log_pos # GTID 0-1-9 +/*!100001 SET @@session.gtid_seq_no=9*//*!*/; BEGIN /*!*/; # at # @@ -1191,7 +1111,7 @@ SET @@session.auto_increment_increment=1, @@session.auto_increment_offset=1/*!*/ SET @@session.character_set_client=8,@@session.collation_connection=8,@@session.collation_server=8/*!*/; SET @@session.lc_time_names=0/*!*/; SET @@session.collation_database=DEFAULT/*!*/; -DROP DATABASE IF EXISTS test1 +CREATE DATABASE test1 /*!*/; # at # #010909 4:46:40 server id # end_log_pos # GTID 0-1-2 ddl @@ -1199,7 +1119,7 @@ DROP DATABASE IF EXISTS test1 # at # #010909 4:46:40 server id # end_log_pos # Query thread_id=# exec_time=# error_code=0 SET TIMESTAMP=1000000000/*!*/; -DROP DATABASE IF EXISTS test2 +CREATE DATABASE test2 /*!*/; # at # #010909 4:46:40 server id # end_log_pos # GTID 0-1-3 ddl @@ -1207,35 +1127,11 @@ DROP DATABASE IF EXISTS test2 # at # #010909 4:46:40 server id # end_log_pos # Query thread_id=# exec_time=# error_code=0 SET TIMESTAMP=1000000000/*!*/; -DROP DATABASE IF EXISTS test3 -/*!*/; -# at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-4 ddl -/*!100001 SET @@session.gtid_seq_no=4*//*!*/; -# at # -#010909 4:46:40 server id # end_log_pos # Query thread_id=# exec_time=# error_code=0 -SET TIMESTAMP=1000000000/*!*/; -CREATE DATABASE test1 -/*!*/; -# at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-5 ddl -/*!100001 SET @@session.gtid_seq_no=5*//*!*/; -# at # -#010909 4:46:40 server id # end_log_pos # Query thread_id=# exec_time=# error_code=0 -SET TIMESTAMP=1000000000/*!*/; -CREATE DATABASE test2 -/*!*/; -# at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-6 ddl -/*!100001 SET @@session.gtid_seq_no=6*//*!*/; -# at # -#010909 4:46:40 server id # end_log_pos # Query thread_id=# exec_time=# error_code=0 -SET TIMESTAMP=1000000000/*!*/; CREATE DATABASE test3 /*!*/; # at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-7 -/*!100001 SET @@session.gtid_seq_no=7*//*!*/; +#010909 4:46:40 server id # end_log_pos # GTID 0-1-4 +/*!100001 SET @@session.gtid_seq_no=4*//*!*/; BEGIN /*!*/; # at # @@ -1257,8 +1153,8 @@ SET TIMESTAMP=1000000000/*!*/; COMMIT /*!*/; # at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-8 -/*!100001 SET @@session.gtid_seq_no=8*//*!*/; +#010909 4:46:40 server id # end_log_pos # GTID 0-1-5 +/*!100001 SET @@session.gtid_seq_no=5*//*!*/; BEGIN /*!*/; # at # @@ -1280,8 +1176,8 @@ SET TIMESTAMP=1000000000/*!*/; COMMIT /*!*/; # at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-9 -/*!100001 SET @@session.gtid_seq_no=9*//*!*/; +#010909 4:46:40 server id # end_log_pos # GTID 0-1-6 +/*!100001 SET @@session.gtid_seq_no=6*//*!*/; BEGIN /*!*/; # at # @@ -1303,8 +1199,8 @@ SET TIMESTAMP=1000000000/*!*/; COMMIT /*!*/; # at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-10 -/*!100001 SET @@session.gtid_seq_no=10*//*!*/; +#010909 4:46:40 server id # end_log_pos # GTID 0-1-7 +/*!100001 SET @@session.gtid_seq_no=7*//*!*/; BEGIN /*!*/; # at # @@ -1339,8 +1235,8 @@ SET TIMESTAMP=1000000000/*!*/; COMMIT /*!*/; # at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-11 -/*!100001 SET @@session.gtid_seq_no=11*//*!*/; +#010909 4:46:40 server id # end_log_pos # GTID 0-1-8 +/*!100001 SET @@session.gtid_seq_no=8*//*!*/; BEGIN /*!*/; # at # @@ -1362,8 +1258,8 @@ SET TIMESTAMP=1000000000/*!*/; COMMIT /*!*/; # at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-12 -/*!100001 SET @@session.gtid_seq_no=12*//*!*/; +#010909 4:46:40 server id # end_log_pos # GTID 0-1-9 +/*!100001 SET @@session.gtid_seq_no=9*//*!*/; BEGIN /*!*/; # at # @@ -1391,3 +1287,9 @@ DELIMITER ; ROLLBACK /* added by mysqlbinlog */; /*!50003 SET COMPLETION_TYPE=@OLD_COMPLETION_TYPE*/; /*!50530 SET @@SESSION.PSEUDO_SLAVE_MODE=0*/; +set global binlog_checksum=@old_binlog_checksum; +DROP DATABASE test1; +DROP DATABASE test2; +DROP DATABASE test3; +DROP DATABASE xtest1; +DROP DATABASE xtest2; diff --git a/mysql-test/suite/binlog_encryption/binlog_row_annotate.result b/mysql-test/suite/binlog_encryption/binlog_row_annotate.result index d53849b11fd..f4cfc86619d 100644 --- a/mysql-test/suite/binlog_encryption/binlog_row_annotate.result +++ b/mysql-test/suite/binlog_encryption/binlog_row_annotate.result @@ -1,5 +1,37 @@ set @old_binlog_checksum=@@binlog_checksum; set global binlog_checksum=NONE; +set sql_mode=""; +SET timestamp=1000000000; +RESET MASTER; +CREATE DATABASE test1; +CREATE TABLE test1.t1(a int); +CREATE DATABASE test2; +CREATE TABLE test2.t2(a int); +CREATE VIEW test2.v2 AS SELECT * FROM test2.t2; +CREATE DATABASE test3; +CREATE TABLE test3.t3(a int); +CREATE DATABASE xtest1; +CREATE TABLE xtest1.xt1(a int); +CREATE DATABASE xtest2; +CREATE TABLE xtest2.xt2(a int); +INSERT INTO test1.t1 VALUES (1), (2), (3); +SET SESSION binlog_annotate_row_events = ON; +INSERT INTO test2.t2 VALUES (1), (2), (3); +INSERT INTO test3.t3 VALUES (1), (2), (3); +DELETE test1.t1, test2.t2 +FROM test1.t1 INNER JOIN test2.t2 INNER JOIN test3.t3 +WHERE test1.t1.a=test2.t2.a AND test2.t2.a=test3.t3.a; +INSERT INTO xtest1.xt1 VALUES (1), (2), (3); +INSERT INTO test2.v2 VALUES (1), (2), (3); +DELETE xtest1.xt1, test2.t2 +FROM xtest1.xt1 INNER JOIN test2.t2 INNER JOIN test3.t3 +WHERE xtest1.xt1.a=test2.t2.a AND test2.t2.a=test3.t3.a; +INSERT INTO xtest1.xt1 VALUES (1), (2), (3); +INSERT INTO xtest2.xt2 VALUES (1), (2), (3); +DELETE xtest1.xt1, xtest2.xt2 +FROM xtest1.xt1 INNER JOIN xtest2.xt2 INNER JOIN test3.t3 +WHERE xtest1.xt1.a=xtest2.xt2.a AND xtest2.xt2.a=test3.t3.a; +FLUSH LOGS; ##################################################################################### # The following Annotate_rows events should appear below: # - INSERT INTO test2.t2 VALUES (1), (2), (3) @@ -8,58 +40,51 @@ set global binlog_checksum=NONE; # - INSERT INTO test2.t2 VALUES (1), (2), (3) # - DELETE xtest1.xt1, test2.t2 FROM <...> ##################################################################################### -show binlog events in 'master-bin.000001' from <start_pos>; +include/show_binlog_events.inc Log_name Pos Event_type Server_id End_log_pos Info -master-bin.000001 # Gtid_list 1 # [] -master-bin.000001 # Binlog_checkpoint 1 # master-bin.000001 -master-bin.000001 # Gtid 1 # GTID 0-1-1 -master-bin.000001 # Query 1 # DROP DATABASE IF EXISTS test1 -master-bin.000001 # Gtid 1 # GTID 0-1-2 -master-bin.000001 # Query 1 # DROP DATABASE IF EXISTS test2 -master-bin.000001 # Gtid 1 # GTID 0-1-3 -master-bin.000001 # Query 1 # DROP DATABASE IF EXISTS test3 -master-bin.000001 # Gtid 1 # GTID 0-1-4 -master-bin.000001 # Query 1 # CREATE DATABASE test1 -master-bin.000001 # Gtid 1 # GTID 0-1-5 -master-bin.000001 # Query 1 # CREATE DATABASE test2 -master-bin.000001 # Gtid 1 # GTID 0-1-6 -master-bin.000001 # Query 1 # CREATE DATABASE test3 -master-bin.000001 # Gtid 1 # BEGIN GTID 0-1-7 -master-bin.000001 # Table_map 1 # table_id: # (test1.t1) -master-bin.000001 # Write_rows_v1 1 # table_id: # flags: STMT_END_F -master-bin.000001 # Query 1 # COMMIT -master-bin.000001 # Gtid 1 # BEGIN GTID 0-1-8 -master-bin.000001 # Annotate_rows 1 # INSERT INTO test2.t2 VALUES (1), (2), (3) -master-bin.000001 # Table_map 1 # table_id: # (test2.t2) -master-bin.000001 # Write_rows_v1 1 # table_id: # flags: STMT_END_F -master-bin.000001 # Query 1 # COMMIT -master-bin.000001 # Gtid 1 # BEGIN GTID 0-1-9 -master-bin.000001 # Annotate_rows 1 # INSERT INTO test3.t3 VALUES (1), (2), (3) -master-bin.000001 # Table_map 1 # table_id: # (test3.t3) -master-bin.000001 # Write_rows_v1 1 # table_id: # flags: STMT_END_F -master-bin.000001 # Query 1 # COMMIT -master-bin.000001 # Gtid 1 # BEGIN GTID 0-1-10 -master-bin.000001 # Annotate_rows 1 # DELETE test1.t1, test2.t2 +master-bin.000001 # Binlog_checkpoint # # master-bin.000001 +master-bin.000001 # Gtid # # GTID #-#-# +master-bin.000001 # Query # # CREATE DATABASE test1 +master-bin.000001 # Gtid # # GTID #-#-# +master-bin.000001 # Query # # CREATE DATABASE test2 +master-bin.000001 # Gtid # # GTID #-#-# +master-bin.000001 # Query # # CREATE DATABASE test3 +master-bin.000001 # Gtid # # BEGIN GTID #-#-# +master-bin.000001 # Table_map # # table_id: # (test1.t1) +master-bin.000001 # Write_rows_v1 # # table_id: # flags: STMT_END_F +master-bin.000001 # Query # # COMMIT +master-bin.000001 # Gtid # # BEGIN GTID #-#-# +master-bin.000001 # Annotate_rows # # INSERT INTO test2.t2 VALUES (1), (2), (3) +master-bin.000001 # Table_map # # table_id: # (test2.t2) +master-bin.000001 # Write_rows_v1 # # table_id: # flags: STMT_END_F +master-bin.000001 # Query # # COMMIT +master-bin.000001 # Gtid # # BEGIN GTID #-#-# +master-bin.000001 # Annotate_rows # # INSERT INTO test3.t3 VALUES (1), (2), (3) +master-bin.000001 # Table_map # # table_id: # (test3.t3) +master-bin.000001 # Write_rows_v1 # # table_id: # flags: STMT_END_F +master-bin.000001 # Query # # COMMIT +master-bin.000001 # Gtid # # BEGIN GTID #-#-# +master-bin.000001 # Annotate_rows # # DELETE test1.t1, test2.t2 FROM test1.t1 INNER JOIN test2.t2 INNER JOIN test3.t3 WHERE test1.t1.a=test2.t2.a AND test2.t2.a=test3.t3.a -master-bin.000001 # Table_map 1 # table_id: # (test1.t1) -master-bin.000001 # Table_map 1 # table_id: # (test2.t2) -master-bin.000001 # Delete_rows_v1 1 # table_id: # -master-bin.000001 # Delete_rows_v1 1 # table_id: # flags: STMT_END_F -master-bin.000001 # Query 1 # COMMIT -master-bin.000001 # Gtid 1 # BEGIN GTID 0-1-11 -master-bin.000001 # Annotate_rows 1 # INSERT INTO test2.v2 VALUES (1), (2), (3) -master-bin.000001 # Table_map 1 # table_id: # (test2.t2) -master-bin.000001 # Write_rows_v1 1 # table_id: # flags: STMT_END_F -master-bin.000001 # Query 1 # COMMIT -master-bin.000001 # Gtid 1 # BEGIN GTID 0-1-12 -master-bin.000001 # Annotate_rows 1 # DELETE xtest1.xt1, test2.t2 +master-bin.000001 # Table_map # # table_id: # (test1.t1) +master-bin.000001 # Table_map # # table_id: # (test2.t2) +master-bin.000001 # Delete_rows_v1 # # table_id: # +master-bin.000001 # Delete_rows_v1 # # table_id: # flags: STMT_END_F +master-bin.000001 # Query # # COMMIT +master-bin.000001 # Gtid # # BEGIN GTID #-#-# +master-bin.000001 # Annotate_rows # # INSERT INTO test2.v2 VALUES (1), (2), (3) +master-bin.000001 # Table_map # # table_id: # (test2.t2) +master-bin.000001 # Write_rows_v1 # # table_id: # flags: STMT_END_F +master-bin.000001 # Query # # COMMIT +master-bin.000001 # Gtid # # BEGIN GTID #-#-# +master-bin.000001 # Annotate_rows # # DELETE xtest1.xt1, test2.t2 FROM xtest1.xt1 INNER JOIN test2.t2 INNER JOIN test3.t3 WHERE xtest1.xt1.a=test2.t2.a AND test2.t2.a=test3.t3.a -master-bin.000001 # Table_map 1 # table_id: # (test2.t2) -master-bin.000001 # Delete_rows_v1 1 # table_id: # flags: STMT_END_F -master-bin.000001 # Query 1 # COMMIT -master-bin.000001 # Rotate 1 # master-bin.000002;pos=4 +master-bin.000001 # Table_map # # table_id: # (test2.t2) +master-bin.000001 # Delete_rows_v1 # # table_id: # flags: STMT_END_F +master-bin.000001 # Query # # COMMIT +master-bin.000001 # Rotate # # master-bin.000002;pos=POS # ##################################################################################### # mysqlbinlog --read-from-remote-server @@ -98,7 +123,7 @@ SET @@session.auto_increment_increment=1, @@session.auto_increment_offset=1/*!*/ SET @@session.character_set_client=8,@@session.collation_connection=8,@@session.collation_server=8/*!*/; SET @@session.lc_time_names=0/*!*/; SET @@session.collation_database=DEFAULT/*!*/; -DROP DATABASE IF EXISTS test1 +CREATE DATABASE test1 /*!*/; # at # #010909 4:46:40 server id # end_log_pos # GTID 0-1-2 ddl @@ -106,7 +131,7 @@ DROP DATABASE IF EXISTS test1 # at # #010909 4:46:40 server id # end_log_pos # Query thread_id=# exec_time=# error_code=0 SET TIMESTAMP=1000000000/*!*/; -DROP DATABASE IF EXISTS test2 +CREATE DATABASE test2 /*!*/; # at # #010909 4:46:40 server id # end_log_pos # GTID 0-1-3 ddl @@ -114,35 +139,11 @@ DROP DATABASE IF EXISTS test2 # at # #010909 4:46:40 server id # end_log_pos # Query thread_id=# exec_time=# error_code=0 SET TIMESTAMP=1000000000/*!*/; -DROP DATABASE IF EXISTS test3 -/*!*/; -# at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-4 ddl -/*!100001 SET @@session.gtid_seq_no=4*//*!*/; -# at # -#010909 4:46:40 server id # end_log_pos # Query thread_id=# exec_time=# error_code=0 -SET TIMESTAMP=1000000000/*!*/; -CREATE DATABASE test1 -/*!*/; -# at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-5 ddl -/*!100001 SET @@session.gtid_seq_no=5*//*!*/; -# at # -#010909 4:46:40 server id # end_log_pos # Query thread_id=# exec_time=# error_code=0 -SET TIMESTAMP=1000000000/*!*/; -CREATE DATABASE test2 -/*!*/; -# at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-6 ddl -/*!100001 SET @@session.gtid_seq_no=6*//*!*/; -# at # -#010909 4:46:40 server id # end_log_pos # Query thread_id=# exec_time=# error_code=0 -SET TIMESTAMP=1000000000/*!*/; CREATE DATABASE test3 /*!*/; # at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-7 -/*!100001 SET @@session.gtid_seq_no=7*//*!*/; +#010909 4:46:40 server id # end_log_pos # GTID 0-1-4 +/*!100001 SET @@session.gtid_seq_no=4*//*!*/; BEGIN /*!*/; # at # @@ -164,8 +165,8 @@ SET TIMESTAMP=1000000000/*!*/; COMMIT /*!*/; # at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-8 -/*!100001 SET @@session.gtid_seq_no=8*//*!*/; +#010909 4:46:40 server id # end_log_pos # GTID 0-1-5 +/*!100001 SET @@session.gtid_seq_no=5*//*!*/; BEGIN /*!*/; # at # @@ -190,8 +191,8 @@ SET TIMESTAMP=1000000000/*!*/; COMMIT /*!*/; # at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-9 -/*!100001 SET @@session.gtid_seq_no=9*//*!*/; +#010909 4:46:40 server id # end_log_pos # GTID 0-1-6 +/*!100001 SET @@session.gtid_seq_no=6*//*!*/; BEGIN /*!*/; # at # @@ -216,8 +217,8 @@ SET TIMESTAMP=1000000000/*!*/; COMMIT /*!*/; # at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-10 -/*!100001 SET @@session.gtid_seq_no=10*//*!*/; +#010909 4:46:40 server id # end_log_pos # GTID 0-1-7 +/*!100001 SET @@session.gtid_seq_no=7*//*!*/; BEGIN /*!*/; # at # @@ -257,8 +258,8 @@ SET TIMESTAMP=1000000000/*!*/; COMMIT /*!*/; # at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-11 -/*!100001 SET @@session.gtid_seq_no=11*//*!*/; +#010909 4:46:40 server id # end_log_pos # GTID 0-1-8 +/*!100001 SET @@session.gtid_seq_no=8*//*!*/; BEGIN /*!*/; # at # @@ -283,8 +284,8 @@ SET TIMESTAMP=1000000000/*!*/; COMMIT /*!*/; # at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-12 -/*!100001 SET @@session.gtid_seq_no=12*//*!*/; +#010909 4:46:40 server id # end_log_pos # GTID 0-1-9 +/*!100001 SET @@session.gtid_seq_no=9*//*!*/; BEGIN /*!*/; # at # @@ -351,7 +352,7 @@ SET @@session.auto_increment_increment=1, @@session.auto_increment_offset=1/*!*/ SET @@session.character_set_client=8,@@session.collation_connection=8,@@session.collation_server=8/*!*/; SET @@session.lc_time_names=0/*!*/; SET @@session.collation_database=DEFAULT/*!*/; -DROP DATABASE IF EXISTS test1 +CREATE DATABASE test1 /*!*/; # at # #010909 4:46:40 server id # end_log_pos # GTID 0-1-2 ddl @@ -362,24 +363,8 @@ DROP DATABASE IF EXISTS test1 /*!100001 SET @@session.gtid_seq_no=3*//*!*/; # at # # at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-4 ddl +#010909 4:46:40 server id # end_log_pos # GTID 0-1-4 /*!100001 SET @@session.gtid_seq_no=4*//*!*/; -# at # -#010909 4:46:40 server id # end_log_pos # Query thread_id=# exec_time=# error_code=0 -SET TIMESTAMP=1000000000/*!*/; -CREATE DATABASE test1 -/*!*/; -# at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-5 ddl -/*!100001 SET @@session.gtid_seq_no=5*//*!*/; -# at # -# at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-6 ddl -/*!100001 SET @@session.gtid_seq_no=6*//*!*/; -# at # -# at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-7 -/*!100001 SET @@session.gtid_seq_no=7*//*!*/; BEGIN /*!*/; # at # @@ -401,8 +386,8 @@ SET TIMESTAMP=1000000000/*!*/; COMMIT /*!*/; # at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-8 -/*!100001 SET @@session.gtid_seq_no=8*//*!*/; +#010909 4:46:40 server id # end_log_pos # GTID 0-1-5 +/*!100001 SET @@session.gtid_seq_no=5*//*!*/; BEGIN /*!*/; # at # @@ -414,8 +399,8 @@ SET TIMESTAMP=1000000000/*!*/; COMMIT /*!*/; # at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-9 -/*!100001 SET @@session.gtid_seq_no=9*//*!*/; +#010909 4:46:40 server id # end_log_pos # GTID 0-1-6 +/*!100001 SET @@session.gtid_seq_no=6*//*!*/; BEGIN /*!*/; # at # @@ -427,8 +412,8 @@ SET TIMESTAMP=1000000000/*!*/; COMMIT /*!*/; # at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-10 -/*!100001 SET @@session.gtid_seq_no=10*//*!*/; +#010909 4:46:40 server id # end_log_pos # GTID 0-1-7 +/*!100001 SET @@session.gtid_seq_no=7*//*!*/; BEGIN /*!*/; # at # @@ -458,8 +443,8 @@ SET TIMESTAMP=1000000000/*!*/; COMMIT /*!*/; # at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-11 -/*!100001 SET @@session.gtid_seq_no=11*//*!*/; +#010909 4:46:40 server id # end_log_pos # GTID 0-1-8 +/*!100001 SET @@session.gtid_seq_no=8*//*!*/; BEGIN /*!*/; # at # @@ -471,8 +456,8 @@ SET TIMESTAMP=1000000000/*!*/; COMMIT /*!*/; # at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-12 -/*!100001 SET @@session.gtid_seq_no=12*//*!*/; +#010909 4:46:40 server id # end_log_pos # GTID 0-1-9 +/*!100001 SET @@session.gtid_seq_no=9*//*!*/; BEGIN /*!*/; # at # @@ -523,7 +508,7 @@ SET @@session.auto_increment_increment=1, @@session.auto_increment_offset=1/*!*/ SET @@session.character_set_client=8,@@session.collation_connection=8,@@session.collation_server=8/*!*/; SET @@session.lc_time_names=0/*!*/; SET @@session.collation_database=DEFAULT/*!*/; -DROP DATABASE IF EXISTS test1 +CREATE DATABASE test1 /*!*/; # at # #010909 4:46:40 server id # end_log_pos # GTID 0-1-2 ddl @@ -531,7 +516,7 @@ DROP DATABASE IF EXISTS test1 # at # #010909 4:46:40 server id # end_log_pos # Query thread_id=# exec_time=# error_code=0 SET TIMESTAMP=1000000000/*!*/; -DROP DATABASE IF EXISTS test2 +CREATE DATABASE test2 /*!*/; # at # #010909 4:46:40 server id # end_log_pos # GTID 0-1-3 ddl @@ -539,35 +524,11 @@ DROP DATABASE IF EXISTS test2 # at # #010909 4:46:40 server id # end_log_pos # Query thread_id=# exec_time=# error_code=0 SET TIMESTAMP=1000000000/*!*/; -DROP DATABASE IF EXISTS test3 -/*!*/; -# at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-4 ddl -/*!100001 SET @@session.gtid_seq_no=4*//*!*/; -# at # -#010909 4:46:40 server id # end_log_pos # Query thread_id=# exec_time=# error_code=0 -SET TIMESTAMP=1000000000/*!*/; -CREATE DATABASE test1 -/*!*/; -# at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-5 ddl -/*!100001 SET @@session.gtid_seq_no=5*//*!*/; -# at # -#010909 4:46:40 server id # end_log_pos # Query thread_id=# exec_time=# error_code=0 -SET TIMESTAMP=1000000000/*!*/; -CREATE DATABASE test2 -/*!*/; -# at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-6 ddl -/*!100001 SET @@session.gtid_seq_no=6*//*!*/; -# at # -#010909 4:46:40 server id # end_log_pos # Query thread_id=# exec_time=# error_code=0 -SET TIMESTAMP=1000000000/*!*/; CREATE DATABASE test3 /*!*/; # at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-7 -/*!100001 SET @@session.gtid_seq_no=7*//*!*/; +#010909 4:46:40 server id # end_log_pos # GTID 0-1-4 +/*!100001 SET @@session.gtid_seq_no=4*//*!*/; BEGIN /*!*/; # at # @@ -589,8 +550,8 @@ SET TIMESTAMP=1000000000/*!*/; COMMIT /*!*/; # at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-8 -/*!100001 SET @@session.gtid_seq_no=8*//*!*/; +#010909 4:46:40 server id # end_log_pos # GTID 0-1-5 +/*!100001 SET @@session.gtid_seq_no=5*//*!*/; BEGIN /*!*/; # at # @@ -612,8 +573,8 @@ SET TIMESTAMP=1000000000/*!*/; COMMIT /*!*/; # at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-9 -/*!100001 SET @@session.gtid_seq_no=9*//*!*/; +#010909 4:46:40 server id # end_log_pos # GTID 0-1-6 +/*!100001 SET @@session.gtid_seq_no=6*//*!*/; BEGIN /*!*/; # at # @@ -635,8 +596,8 @@ SET TIMESTAMP=1000000000/*!*/; COMMIT /*!*/; # at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-10 -/*!100001 SET @@session.gtid_seq_no=10*//*!*/; +#010909 4:46:40 server id # end_log_pos # GTID 0-1-7 +/*!100001 SET @@session.gtid_seq_no=7*//*!*/; BEGIN /*!*/; # at # @@ -671,8 +632,8 @@ SET TIMESTAMP=1000000000/*!*/; COMMIT /*!*/; # at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-11 -/*!100001 SET @@session.gtid_seq_no=11*//*!*/; +#010909 4:46:40 server id # end_log_pos # GTID 0-1-8 +/*!100001 SET @@session.gtid_seq_no=8*//*!*/; BEGIN /*!*/; # at # @@ -694,8 +655,8 @@ SET TIMESTAMP=1000000000/*!*/; COMMIT /*!*/; # at # -#010909 4:46:40 server id # end_log_pos # GTID 0-1-12 -/*!100001 SET @@session.gtid_seq_no=12*//*!*/; +#010909 4:46:40 server id # end_log_pos # GTID 0-1-9 +/*!100001 SET @@session.gtid_seq_no=9*//*!*/; BEGIN /*!*/; # at # @@ -723,3 +684,9 @@ DELIMITER ; ROLLBACK /* added by mysqlbinlog */; /*!50003 SET COMPLETION_TYPE=@OLD_COMPLETION_TYPE*/; /*!50530 SET @@SESSION.PSEUDO_SLAVE_MODE=0*/; +set global binlog_checksum=@old_binlog_checksum; +DROP DATABASE test1; +DROP DATABASE test2; +DROP DATABASE test3; +DROP DATABASE xtest1; +DROP DATABASE xtest2; |