mirror of
https://github.com/MariaDB/server.git
synced 2025-10-31 02:46:29 +01:00
178 lines
8.3 KiB
Text
178 lines
8.3 KiB
Text
set binlog_format=mixed;
|
|
RESET MASTER;
|
|
drop database if exists my_replicated_db;
|
|
call mtr.add_suppression("Unsafe statement written to the binary log using statement format since BINLOG_FORMAT = STATEMENT");
|
|
create database my_replicated_db;
|
|
create table my_replicated_db.my_tx_table(a bigint) engine = innodb;
|
|
create table my_replicated_db.my_non_tx_table(a bigint) engine = myisam;
|
|
create table my_replicated_db.my_bh_table(a bigint) engine = blackhole;
|
|
use test;
|
|
drop table if exists marker_start;
|
|
Warnings:
|
|
Note 1051 Unknown table 'test.marker_start'
|
|
use my_replicated_db;
|
|
insert into my_tx_table(a)
|
|
values (1000), (2000), (3000);
|
|
insert into my_non_tx_table(a)
|
|
values (1000), (2000), (3000);
|
|
insert into my_bh_table(a)
|
|
values (1000), (2000), (3000);
|
|
use test;
|
|
drop table if exists marker_insert_select;
|
|
Warnings:
|
|
Note 1051 Unknown table 'test.marker_insert_select'
|
|
use my_replicated_db;
|
|
insert into my_tx_table(a)
|
|
select thread_id from performance_schema.threads;
|
|
insert into my_non_tx_table(a)
|
|
select thread_id from performance_schema.threads;
|
|
insert into my_bh_table(a)
|
|
select thread_id from performance_schema.threads;
|
|
insert into my_tx_table(a)
|
|
select id from information_schema.processlist;
|
|
insert into my_non_tx_table(a)
|
|
select id from information_schema.processlist;
|
|
insert into my_bh_table(a)
|
|
select id from information_schema.processlist;
|
|
insert into my_tx_table(a)
|
|
select thread_id from mysql.general_log;
|
|
insert into my_non_tx_table(a)
|
|
select thread_id from mysql.general_log;
|
|
insert into my_bh_table(a)
|
|
select thread_id from mysql.general_log;
|
|
insert into my_tx_table(a)
|
|
select thread_id from mysql.slow_log;
|
|
insert into my_non_tx_table(a)
|
|
select thread_id from mysql.slow_log;
|
|
insert into my_bh_table(a)
|
|
select thread_id from mysql.slow_log;
|
|
insert into my_tx_table(a)
|
|
select Relay_log_pos from mysql.slave_relay_log_info;
|
|
insert into my_non_tx_table(a)
|
|
select Relay_log_pos from mysql.slave_relay_log_info;
|
|
insert into my_bh_table(a)
|
|
select Relay_log_pos from mysql.slave_relay_log_info;
|
|
insert into my_tx_table(a)
|
|
select Master_log_pos from mysql.slave_master_info;
|
|
insert into my_non_tx_table(a)
|
|
select Master_log_pos from mysql.slave_master_info;
|
|
insert into my_bh_table(a)
|
|
select Master_log_pos from mysql.slave_master_info;
|
|
insert into my_tx_table(a)
|
|
select Relay_log_pos from mysql.slave_worker_info;
|
|
insert into my_non_tx_table(a)
|
|
select Relay_log_pos from mysql.slave_worker_info;
|
|
insert into my_bh_table(a)
|
|
select Relay_log_pos from mysql.slave_worker_info;
|
|
use test;
|
|
drop table if exists marker_multi_update;
|
|
Warnings:
|
|
Note 1051 Unknown table 'test.marker_multi_update'
|
|
use my_replicated_db;
|
|
update my_tx_table, performance_schema.setup_instruments
|
|
set my_tx_table.a = my_tx_table.a + 1,
|
|
performance_schema.setup_instruments.timed= 'NO';
|
|
update my_non_tx_table, performance_schema.setup_instruments
|
|
set my_non_tx_table.a = my_non_tx_table.a + 1,
|
|
performance_schema.setup_instruments.timed= 'NO';
|
|
update my_bh_table, performance_schema.setup_instruments
|
|
set my_bh_table.a = my_bh_table.a + 1,
|
|
performance_schema.setup_instruments.timed= 'NO';
|
|
use test;
|
|
drop table if exists marker_multi_delete;
|
|
Warnings:
|
|
Note 1051 Unknown table 'test.marker_multi_delete'
|
|
use my_replicated_db;
|
|
insert into performance_schema.setup_actors
|
|
values ('FOO', 'FOO', 'FOO', 'YES', 'YES');
|
|
delete my_tx_table.*, performance_schema.setup_actors.*
|
|
from my_tx_table, performance_schema.setup_actors
|
|
where my_tx_table.a != 1000
|
|
or performance_schema.setup_actors.role='FOO';
|
|
insert into performance_schema.setup_actors
|
|
values ('BAR', 'BAR', 'BAR', 'YES', 'YES');
|
|
delete my_non_tx_table.*, performance_schema.setup_actors.*
|
|
from my_non_tx_table, performance_schema.setup_actors
|
|
where my_non_tx_table.a != 1000
|
|
or performance_schema.setup_actors.role='BAR';
|
|
insert into performance_schema.setup_actors
|
|
values ('BAZ', 'BAZ', 'BAZ', 'YES', 'YES');
|
|
delete my_bh_table.*, performance_schema.setup_actors.*
|
|
from my_bh_table, performance_schema.setup_actors
|
|
where my_bh_table.a != 1000
|
|
or performance_schema.setup_actors.role='BAZ';
|
|
use test;
|
|
drop table if exists marker_end;
|
|
Warnings:
|
|
Note 1051 Unknown table 'test.marker_end'
|
|
drop database my_replicated_db;
|
|
include/show_binlog_events.inc
|
|
Log_name Pos Event_type Server_id End_log_pos Info
|
|
master-bin.000001 # Query # # drop database if exists my_replicated_db
|
|
master-bin.000001 # Query # # BEGIN
|
|
master-bin.000001 # Query # # use `mtr`; INSERT INTO test_suppressions (pattern) VALUES ( NAME_CONST('pattern',_latin1'Unsafe statement written to the binary log using statement format since BINLOG_FORMAT = STATEMENT' COLLATE 'latin1_swedish_ci'))
|
|
master-bin.000001 # Query # # COMMIT
|
|
master-bin.000001 # Query # # create database my_replicated_db
|
|
master-bin.000001 # Query # # use `test`; create table my_replicated_db.my_tx_table(a bigint) engine = innodb
|
|
master-bin.000001 # Query # # use `test`; create table my_replicated_db.my_non_tx_table(a bigint) engine = myisam
|
|
master-bin.000001 # Query # # use `test`; create table my_replicated_db.my_bh_table(a bigint) engine = blackhole
|
|
master-bin.000001 # Query # # use `test`; DROP TABLE IF EXISTS `marker_start` /* generated by server */
|
|
master-bin.000001 # Query # # BEGIN
|
|
master-bin.000001 # Query # # use `my_replicated_db`; insert into my_tx_table(a)
|
|
values (1000), (2000), (3000)
|
|
master-bin.000001 # Xid # # COMMIT /* XID */
|
|
master-bin.000001 # Query # # BEGIN
|
|
master-bin.000001 # Query # # use `my_replicated_db`; insert into my_non_tx_table(a)
|
|
values (1000), (2000), (3000)
|
|
master-bin.000001 # Query # # COMMIT
|
|
master-bin.000001 # Query # # BEGIN
|
|
master-bin.000001 # Query # # use `my_replicated_db`; insert into my_bh_table(a)
|
|
values (1000), (2000), (3000)
|
|
master-bin.000001 # Query # # COMMIT
|
|
master-bin.000001 # Query # # use `test`; DROP TABLE IF EXISTS `marker_insert_select` /* generated by server */
|
|
master-bin.000001 # Query # # BEGIN
|
|
master-bin.000001 # Table_map # # table_id: # (my_replicated_db.my_tx_table)
|
|
master-bin.000001 # Write_rows # # table_id: # flags: STMT_END_F
|
|
master-bin.000001 # Xid # # COMMIT /* XID */
|
|
master-bin.000001 # Query # # BEGIN
|
|
master-bin.000001 # Table_map # # table_id: # (my_replicated_db.my_non_tx_table)
|
|
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: # (my_replicated_db.my_bh_table)
|
|
master-bin.000001 # Write_rows # # table_id: # flags: STMT_END_F
|
|
master-bin.000001 # Query # # COMMIT
|
|
master-bin.000001 # Query # # BEGIN
|
|
master-bin.000001 # Query # # use `my_replicated_db`; insert into my_tx_table(a)
|
|
select id from information_schema.processlist
|
|
master-bin.000001 # Xid # # COMMIT /* XID */
|
|
master-bin.000001 # Query # # BEGIN
|
|
master-bin.000001 # Query # # use `my_replicated_db`; insert into my_non_tx_table(a)
|
|
select id from information_schema.processlist
|
|
master-bin.000001 # Query # # COMMIT
|
|
master-bin.000001 # Query # # BEGIN
|
|
master-bin.000001 # Query # # use `my_replicated_db`; insert into my_bh_table(a)
|
|
select id from information_schema.processlist
|
|
master-bin.000001 # Query # # COMMIT
|
|
master-bin.000001 # Query # # use `test`; DROP TABLE IF EXISTS `marker_multi_update` /* generated by server */
|
|
master-bin.000001 # Query # # BEGIN
|
|
master-bin.000001 # Table_map # # table_id: # (my_replicated_db.my_tx_table)
|
|
master-bin.000001 # Update_rows # # table_id: # flags: STMT_END_F
|
|
master-bin.000001 # Xid # # COMMIT /* XID */
|
|
master-bin.000001 # Query # # BEGIN
|
|
master-bin.000001 # Table_map # # table_id: # (my_replicated_db.my_non_tx_table)
|
|
master-bin.000001 # Update_rows # # table_id: # flags: STMT_END_F
|
|
master-bin.000001 # Query # # COMMIT
|
|
master-bin.000001 # Query # # use `test`; DROP TABLE IF EXISTS `marker_multi_delete` /* generated by server */
|
|
master-bin.000001 # Query # # BEGIN
|
|
master-bin.000001 # Table_map # # table_id: # (my_replicated_db.my_tx_table)
|
|
master-bin.000001 # Delete_rows # # table_id: # flags: STMT_END_F
|
|
master-bin.000001 # Xid # # COMMIT /* XID */
|
|
master-bin.000001 # Query # # BEGIN
|
|
master-bin.000001 # Table_map # # table_id: # (my_replicated_db.my_non_tx_table)
|
|
master-bin.000001 # Delete_rows # # table_id: # flags: STMT_END_F
|
|
master-bin.000001 # Query # # COMMIT
|
|
master-bin.000001 # Query # # use `test`; DROP TABLE IF EXISTS `marker_end` /* generated by server */
|
|
master-bin.000001 # Query # # drop database my_replicated_db
|
|
truncate table performance_schema.setup_actors;
|
|
insert into performance_schema.setup_actors values ('%', '%', '%', 'YES', 'YES');
|