mirror of
				https://github.com/MariaDB/server.git
				synced 2025-11-03 20:36:16 +01:00 
			
		
		
		
	
		
			
				
	
	
		
			207 lines
		
	
	
	
		
			7.3 KiB
		
	
	
	
		
			Text
		
	
	
	
	
	
			
		
		
	
	
			207 lines
		
	
	
	
		
			7.3 KiB
		
	
	
	
		
			Text
		
	
	
	
	
	
SET GLOBAL log_bin_compress=on;
 | 
						|
SET GLOBAL log_bin_compress_min_len=10;
 | 
						|
CREATE TABLE t1 (pk INT PRIMARY KEY, f1 INT, f2 INT, f3 TINYINT, f4 MEDIUMINT, f5 BIGINT, f6 INT, f7 INT, f8 char(1));
 | 
						|
CREATE TABLE t2 (pk INT PRIMARY KEY, f1 INT, f2 INT, f3 INT, f4 INT, f5 MEDIUMINT, f6 INT, f7 INT, f8 char(1));
 | 
						|
INSERT INTO t1 VALUES (10, 1, 2, 3, 4, 5, 6, 7, "");
 | 
						|
INSERT INTO t1 VALUES (11, 1, 2, 3, 4, 5, 6, 7, NULL);
 | 
						|
INSERT INTO t1 VALUES (12, 1, 2, 3, NULL, 5, 6, 7, "A");
 | 
						|
INSERT INTO t1 VALUES (13, 1, 2, 3, 0, 5, 6, 7, "A");
 | 
						|
INSERT INTO t2 SELECT * FROM t1;
 | 
						|
UPDATE t2 SET f4=5 WHERE f4>0 or f4 is NULL;
 | 
						|
DELETE FROM t1;
 | 
						|
DELETE FROM t2;
 | 
						|
FLUSH BINARY LOGS;
 | 
						|
/*!50530 SET @@SESSION.PSEUDO_SLAVE_MODE=1*/;
 | 
						|
/*!40019 SET @@session.max_insert_delayed_threads=0*/;
 | 
						|
/*!50003 SET @OLD_COMPLETION_TYPE=@@COMPLETION_TYPE,COMPLETION_TYPE=0*/;
 | 
						|
DELIMITER /*!*/;
 | 
						|
# at <pos>
 | 
						|
#<date> server id 1  end_log_pos <pos> CRC32 XXX 	Start: xxx
 | 
						|
ROLLBACK/*!*/;
 | 
						|
# at <pos>
 | 
						|
#<date> server id 1  end_log_pos <pos> CRC32 XXX 	Gtid list []
 | 
						|
# at <pos>
 | 
						|
#<date> server id 1  end_log_pos <pos> CRC32 XXX 	Binlog checkpoint master-bin.000001
 | 
						|
# at <pos>
 | 
						|
#<date> server id 1  end_log_pos <pos> CRC32 XXX 	GTID 0-1-1 ddl
 | 
						|
/*M!100101 SET @@session.skip_parallel_replication=0*//*!*/;
 | 
						|
/*M!100001 SET @@session.gtid_domain_id=0*//*!*/;
 | 
						|
/*M!100001 SET @@session.server_id=1*//*!*/;
 | 
						|
/*M!100001 SET @@session.gtid_seq_no=1*//*!*/;
 | 
						|
# at <pos>
 | 
						|
#<date> server id 1  end_log_pos <pos> CRC32 XXX 	Query_compressed	thread_id=5	exec_time=x	error_code=0	xid=<xid>
 | 
						|
use `test`/*!*/;
 | 
						|
SET TIMESTAMP=X/*!*/;
 | 
						|
SET @@session.pseudo_thread_id=5/*!*/;
 | 
						|
SET @@session.foreign_key_checks=1, @@session.sql_auto_is_null=0, @@session.unique_checks=1, @@session.autocommit=1, @@session.check_constraint_checks=1, @@session.sql_if_exists=0, @@session.explicit_defaults_for_timestamp=0/*!*/;
 | 
						|
SET @@session.sql_mode=#/*!*/;
 | 
						|
SET @@session.auto_increment_increment=1, @@session.auto_increment_offset=1/*!*/;
 | 
						|
/*!\C latin1 *//*!*/;
 | 
						|
SET @@session.character_set_client=latin1,@@session.collation_connection=8,@@session.collation_server=#/*!*/;
 | 
						|
SET @@session.lc_time_names=0/*!*/;
 | 
						|
SET @@session.collation_database=DEFAULT/*!*/;
 | 
						|
CREATE TABLE t1 (pk INT PRIMARY KEY, f1 INT, f2 INT, f3 TINYINT, f4 MEDIUMINT, f5 BIGINT, f6 INT, f7 INT, f8 char(1))
 | 
						|
/*!*/;
 | 
						|
# at <pos>
 | 
						|
#<date> server id 1  end_log_pos <pos> CRC32 XXX 	GTID 0-1-2 ddl
 | 
						|
/*M!100001 SET @@session.gtid_seq_no=2*//*!*/;
 | 
						|
# at <pos>
 | 
						|
#<date> server id 1  end_log_pos <pos> CRC32 XXX 	Query_compressed	thread_id=5	exec_time=x	error_code=0	xid=<xid>
 | 
						|
SET TIMESTAMP=X/*!*/;
 | 
						|
CREATE TABLE t2 (pk INT PRIMARY KEY, f1 INT, f2 INT, f3 INT, f4 INT, f5 MEDIUMINT, f6 INT, f7 INT, f8 char(1))
 | 
						|
/*!*/;
 | 
						|
# at <pos>
 | 
						|
#<date> server id 1  end_log_pos <pos> CRC32 XXX 	GTID 0-1-3
 | 
						|
/*M!100001 SET @@session.gtid_seq_no=3*//*!*/;
 | 
						|
START TRANSACTION
 | 
						|
/*!*/;
 | 
						|
# at <pos>
 | 
						|
#<date> server id 1  end_log_pos <pos> CRC32 XXX 	Query_compressed	thread_id=5	exec_time=x	error_code=0	xid=<xid>
 | 
						|
SET TIMESTAMP=X/*!*/;
 | 
						|
INSERT INTO t1 VALUES (10, 1, 2, 3, 4, 5, 6, 7, "")
 | 
						|
/*!*/;
 | 
						|
# at <pos>
 | 
						|
#<date> server id 1  end_log_pos <pos> CRC32 XXX 	Query	thread_id=5	exec_time=x	error_code=0	xid=<xid>
 | 
						|
SET TIMESTAMP=X/*!*/;
 | 
						|
COMMIT
 | 
						|
/*!*/;
 | 
						|
# at <pos>
 | 
						|
#<date> server id 1  end_log_pos <pos> CRC32 XXX 	GTID 0-1-4
 | 
						|
/*M!100001 SET @@session.gtid_seq_no=4*//*!*/;
 | 
						|
START TRANSACTION
 | 
						|
/*!*/;
 | 
						|
# at <pos>
 | 
						|
#<date> server id 1  end_log_pos <pos> CRC32 XXX 	Query_compressed	thread_id=5	exec_time=x	error_code=0	xid=<xid>
 | 
						|
SET TIMESTAMP=X/*!*/;
 | 
						|
INSERT INTO t1 VALUES (11, 1, 2, 3, 4, 5, 6, 7, NULL)
 | 
						|
/*!*/;
 | 
						|
# at <pos>
 | 
						|
#<date> server id 1  end_log_pos <pos> CRC32 XXX 	Query	thread_id=5	exec_time=x	error_code=0	xid=<xid>
 | 
						|
SET TIMESTAMP=X/*!*/;
 | 
						|
COMMIT
 | 
						|
/*!*/;
 | 
						|
# at <pos>
 | 
						|
#<date> server id 1  end_log_pos <pos> CRC32 XXX 	GTID 0-1-5
 | 
						|
/*M!100001 SET @@session.gtid_seq_no=5*//*!*/;
 | 
						|
START TRANSACTION
 | 
						|
/*!*/;
 | 
						|
# at <pos>
 | 
						|
#<date> server id 1  end_log_pos <pos> CRC32 XXX 	Query_compressed	thread_id=5	exec_time=x	error_code=0	xid=<xid>
 | 
						|
SET TIMESTAMP=X/*!*/;
 | 
						|
INSERT INTO t1 VALUES (12, 1, 2, 3, NULL, 5, 6, 7, "A")
 | 
						|
/*!*/;
 | 
						|
# at <pos>
 | 
						|
#<date> server id 1  end_log_pos <pos> CRC32 XXX 	Query	thread_id=5	exec_time=x	error_code=0	xid=<xid>
 | 
						|
SET TIMESTAMP=X/*!*/;
 | 
						|
COMMIT
 | 
						|
/*!*/;
 | 
						|
# at <pos>
 | 
						|
#<date> server id 1  end_log_pos <pos> CRC32 XXX 	GTID 0-1-6
 | 
						|
/*M!100001 SET @@session.gtid_seq_no=6*//*!*/;
 | 
						|
START TRANSACTION
 | 
						|
/*!*/;
 | 
						|
# at <pos>
 | 
						|
#<date> server id 1  end_log_pos <pos> CRC32 XXX 	Query_compressed	thread_id=5	exec_time=x	error_code=0	xid=<xid>
 | 
						|
SET TIMESTAMP=X/*!*/;
 | 
						|
INSERT INTO t1 VALUES (13, 1, 2, 3, 0, 5, 6, 7, "A")
 | 
						|
/*!*/;
 | 
						|
# at <pos>
 | 
						|
#<date> server id 1  end_log_pos <pos> CRC32 XXX 	Query	thread_id=5	exec_time=x	error_code=0	xid=<xid>
 | 
						|
SET TIMESTAMP=X/*!*/;
 | 
						|
COMMIT
 | 
						|
/*!*/;
 | 
						|
# at <pos>
 | 
						|
#<date> server id 1  end_log_pos <pos> CRC32 XXX 	GTID 0-1-7
 | 
						|
/*M!100001 SET @@session.gtid_seq_no=7*//*!*/;
 | 
						|
START TRANSACTION
 | 
						|
/*!*/;
 | 
						|
# at <pos>
 | 
						|
#<date> server id 1  end_log_pos <pos> CRC32 XXX 	Query_compressed	thread_id=5	exec_time=x	error_code=0	xid=<xid>
 | 
						|
SET TIMESTAMP=X/*!*/;
 | 
						|
INSERT INTO t2 SELECT * FROM t1
 | 
						|
/*!*/;
 | 
						|
# at <pos>
 | 
						|
#<date> server id 1  end_log_pos <pos> CRC32 XXX 	Query	thread_id=5	exec_time=x	error_code=0	xid=<xid>
 | 
						|
SET TIMESTAMP=X/*!*/;
 | 
						|
COMMIT
 | 
						|
/*!*/;
 | 
						|
# at <pos>
 | 
						|
#<date> server id 1  end_log_pos <pos> CRC32 XXX 	GTID 0-1-8
 | 
						|
/*M!100001 SET @@session.gtid_seq_no=8*//*!*/;
 | 
						|
START TRANSACTION
 | 
						|
/*!*/;
 | 
						|
# at <pos>
 | 
						|
#<date> server id 1  end_log_pos <pos> CRC32 XXX 	Query_compressed	thread_id=5	exec_time=x	error_code=0	xid=<xid>
 | 
						|
SET TIMESTAMP=X/*!*/;
 | 
						|
UPDATE t2 SET f4=5 WHERE f4>0 or f4 is NULL
 | 
						|
/*!*/;
 | 
						|
# at <pos>
 | 
						|
#<date> server id 1  end_log_pos <pos> CRC32 XXX 	Query	thread_id=5	exec_time=x	error_code=0	xid=<xid>
 | 
						|
SET TIMESTAMP=X/*!*/;
 | 
						|
COMMIT
 | 
						|
/*!*/;
 | 
						|
# at <pos>
 | 
						|
#<date> server id 1  end_log_pos <pos> CRC32 XXX 	GTID 0-1-9
 | 
						|
/*M!100001 SET @@session.gtid_seq_no=9*//*!*/;
 | 
						|
START TRANSACTION
 | 
						|
/*!*/;
 | 
						|
# at <pos>
 | 
						|
#<date> server id 1  end_log_pos <pos> CRC32 XXX 	Query_compressed	thread_id=5	exec_time=x	error_code=0	xid=<xid>
 | 
						|
SET TIMESTAMP=X/*!*/;
 | 
						|
DELETE FROM t1
 | 
						|
/*!*/;
 | 
						|
# at <pos>
 | 
						|
#<date> server id 1  end_log_pos <pos> CRC32 XXX 	Query	thread_id=5	exec_time=x	error_code=0	xid=<xid>
 | 
						|
SET TIMESTAMP=X/*!*/;
 | 
						|
COMMIT
 | 
						|
/*!*/;
 | 
						|
# at <pos>
 | 
						|
#<date> server id 1  end_log_pos <pos> CRC32 XXX 	GTID 0-1-10
 | 
						|
/*M!100001 SET @@session.gtid_seq_no=10*//*!*/;
 | 
						|
START TRANSACTION
 | 
						|
/*!*/;
 | 
						|
# at <pos>
 | 
						|
#<date> server id 1  end_log_pos <pos> CRC32 XXX 	Query_compressed	thread_id=5	exec_time=x	error_code=0	xid=<xid>
 | 
						|
SET TIMESTAMP=X/*!*/;
 | 
						|
DELETE FROM t2
 | 
						|
/*!*/;
 | 
						|
# at <pos>
 | 
						|
#<date> server id 1  end_log_pos <pos> CRC32 XXX 	Query	thread_id=5	exec_time=x	error_code=0	xid=<xid>
 | 
						|
SET TIMESTAMP=X/*!*/;
 | 
						|
COMMIT
 | 
						|
/*!*/;
 | 
						|
# at <pos>
 | 
						|
#<date> server id 1  end_log_pos <pos> CRC32 XXX 	Rotate to master-bin.000002  pos: 4
 | 
						|
DELIMITER ;
 | 
						|
# End of log file
 | 
						|
ROLLBACK /* added by mysqlbinlog */;
 | 
						|
/*!50003 SET COMPLETION_TYPE=@OLD_COMPLETION_TYPE*/;
 | 
						|
/*!50530 SET @@SESSION.PSEUDO_SLAVE_MODE=0*/;
 | 
						|
 | 
						|
Test mysqlbinlog | mysql type point-in-time recovery with compressed events.
 | 
						|
 | 
						|
FLUSH BINARY LOGS;
 | 
						|
CREATE TABLE t3 (a INT PRIMARY KEY, b INT, c VARCHAR(100));
 | 
						|
INSERT INTO t3 VALUES (0, 10, "hello");
 | 
						|
BEGIN;
 | 
						|
INSERT INTO t3 VALUES (1, 10, "cat"), (2, 10, "mouse"), (3, 10, "dog");
 | 
						|
INSERT INTO t3 VALUES (4, 10, "goodbye");
 | 
						|
COMMIT;
 | 
						|
DELETE FROM t3 WHERE a=2;
 | 
						|
SELECT * FROM t3 ORDER BY a;
 | 
						|
a	b	c
 | 
						|
0	10	hello
 | 
						|
1	10	cat
 | 
						|
3	10	dog
 | 
						|
4	10	goodbye
 | 
						|
FLUSH LOGS;
 | 
						|
DROP TABLE t3;
 | 
						|
SELECT * FROM t3 ORDER BY a;
 | 
						|
a	b	c
 | 
						|
0	10	hello
 | 
						|
1	10	cat
 | 
						|
3	10	dog
 | 
						|
4	10	goodbye
 | 
						|
DROP TABLE t1,t2,t3;
 | 
						|
SET GLOBAL log_bin_compress=off;
 | 
						|
SET GLOBAL log_bin_compress_min_len=256;
 |