mirror of
https://github.com/MariaDB/server.git
synced 2025-08-01 03:47:19 +03:00
Bug#32435:
DROP DATABASE statement writes changes to mysql.proc table under RBR When replicating a DROP DATABASE statement with a database holding stored procedures, the changes to the mysql.proc table was recorded in the binary log under row-based replication. With this patch, the thread uses statement-logging format for the duration of the DROP DATABASE statement. The logging format is (already) reset at the end of the statement, so no additional code for resetting the logging format is necessary. sql/sql_db.cc: Clearing the row-based statement flag for the DROP DATABASE statement since it should always be replicated as a statement. mysql-test/extra/binlog_tests/database.test: New BitKeeper file ``mysql-test/extra/binlog_tests/database.test'' mysql-test/suite/binlog/r/binlog_database.result: New BitKeeper file ``mysql-test/suite/binlog/r/binlog_database.result'' mysql-test/suite/binlog/t/binlog_database.test: New BitKeeper file ``mysql-test/suite/binlog/t/binlog_database.test''
This commit is contained in:
15
mysql-test/extra/binlog_tests/database.test
Normal file
15
mysql-test/extra/binlog_tests/database.test
Normal file
@ -0,0 +1,15 @@
|
||||
source include/have_log_bin.inc;
|
||||
source include/not_embedded.inc;
|
||||
|
||||
# Checking that the drop of a database does not replicate anything in
|
||||
# addition to the drop of the database
|
||||
|
||||
reset master;
|
||||
create database testing_1;
|
||||
use testing_1;
|
||||
create table t1 (a int);
|
||||
create function sf1 (a int) returns int return a+1;
|
||||
create trigger tr1 before insert on t1 for each row insert into t2 values (2*new.a);
|
||||
create procedure sp1 (a int) insert into t1 values(a);
|
||||
drop database testing_1;
|
||||
source include/show_binlog_events.inc;
|
56
mysql-test/suite/binlog/r/binlog_database.result
Normal file
56
mysql-test/suite/binlog/r/binlog_database.result
Normal file
@ -0,0 +1,56 @@
|
||||
set binlog_format=statement;
|
||||
reset master;
|
||||
create database testing_1;
|
||||
use testing_1;
|
||||
create table t1 (a int);
|
||||
create function sf1 (a int) returns int return a+1;
|
||||
create trigger tr1 before insert on t1 for each row insert into t2 values (2*new.a);
|
||||
create procedure sp1 (a int) insert into t1 values(a);
|
||||
drop database testing_1;
|
||||
show binlog events from <binlog_start>;
|
||||
Log_name Pos Event_type Server_id End_log_pos Info
|
||||
master-bin.000001 # Query # # create database testing_1
|
||||
master-bin.000001 # Query # # use `testing_1`; create table t1 (a int)
|
||||
master-bin.000001 # Query # # use `testing_1`; CREATE DEFINER=`root`@`localhost` function sf1 (a int) returns int return a+1
|
||||
master-bin.000001 # Query # # use `testing_1`; CREATE DEFINER=`root`@`localhost` trigger tr1 before insert on t1 for each row insert into t2 values (2*new.a)
|
||||
master-bin.000001 # Query # # use `testing_1`; CREATE DEFINER=`root`@`localhost` procedure sp1 (a int) insert into t1 values(a)
|
||||
master-bin.000001 # Query # # drop database testing_1
|
||||
set binlog_format=mixed;
|
||||
reset master;
|
||||
create database testing_1;
|
||||
use testing_1;
|
||||
create table t1 (a int);
|
||||
create function sf1 (a int) returns int return a+1;
|
||||
create trigger tr1 before insert on t1 for each row insert into t2 values (2*new.a);
|
||||
create procedure sp1 (a int) insert into t1 values(a);
|
||||
drop database testing_1;
|
||||
show binlog events from <binlog_start>;
|
||||
Log_name Pos Event_type Server_id End_log_pos Info
|
||||
master-bin.000001 # Query # # create database testing_1
|
||||
master-bin.000001 # Query # # use `testing_1`; create table t1 (a int)
|
||||
master-bin.000001 # Query # # use `testing_1`; CREATE DEFINER=`root`@`localhost` function sf1 (a int) returns int return a+1
|
||||
master-bin.000001 # Query # # use `testing_1`; CREATE DEFINER=`root`@`localhost` trigger tr1 before insert on t1 for each row insert into t2 values (2*new.a)
|
||||
master-bin.000001 # Query # # use `testing_1`; CREATE DEFINER=`root`@`localhost` procedure sp1 (a int) insert into t1 values(a)
|
||||
master-bin.000001 # Query # # drop database testing_1
|
||||
set binlog_format=row;
|
||||
reset master;
|
||||
create database testing_1;
|
||||
use testing_1;
|
||||
create table t1 (a int);
|
||||
create function sf1 (a int) returns int return a+1;
|
||||
create trigger tr1 before insert on t1 for each row insert into t2 values (2*new.a);
|
||||
create procedure sp1 (a int) insert into t1 values(a);
|
||||
drop database testing_1;
|
||||
show binlog events from <binlog_start>;
|
||||
Log_name Pos Event_type Server_id End_log_pos Info
|
||||
master-bin.000001 # Query # # create database testing_1
|
||||
master-bin.000001 # Query # # use `testing_1`; create table t1 (a int)
|
||||
master-bin.000001 # Query # # use `testing_1`; CREATE DEFINER=`root`@`localhost` function sf1 (a int) returns int return a+1
|
||||
master-bin.000001 # Query # # use `testing_1`; CREATE DEFINER=`root`@`localhost` trigger tr1 before insert on t1 for each row insert into t2 values (2*new.a)
|
||||
master-bin.000001 # Query # # use `testing_1`; CREATE DEFINER=`root`@`localhost` procedure sp1 (a int) insert into t1 values(a)
|
||||
master-bin.000001 # Query # # drop database testing_1
|
||||
show databases;
|
||||
Database
|
||||
information_schema
|
||||
mysql
|
||||
test
|
12
mysql-test/suite/binlog/t/binlog_database.test
Normal file
12
mysql-test/suite/binlog/t/binlog_database.test
Normal file
@ -0,0 +1,12 @@
|
||||
# A wrapper to test that dropping a database is binlogged
|
||||
# correctly. We test all three modes in the same file to avoid
|
||||
# unecessary server restarts.
|
||||
|
||||
set binlog_format=statement;
|
||||
source extra/binlog_tests/database.test;
|
||||
set binlog_format=mixed;
|
||||
source extra/binlog_tests/database.test;
|
||||
set binlog_format=row;
|
||||
source extra/binlog_tests/database.test;
|
||||
|
||||
show databases;
|
@ -883,6 +883,13 @@ bool mysql_rm_db(THD *thd,char *db,bool if_exists, bool silent)
|
||||
|
||||
VOID(pthread_mutex_lock(&LOCK_mysql_create_db));
|
||||
|
||||
/*
|
||||
This statement will be replicated as a statement, even when using
|
||||
row-based replication. The flag will be reset at the end of the
|
||||
statement.
|
||||
*/
|
||||
thd->clear_current_stmt_binlog_row_based();
|
||||
|
||||
length= build_table_filename(path, sizeof(path), db, "", "", 0);
|
||||
strmov(path+length, MY_DB_OPT_FILE); // Append db option file name
|
||||
del_dbopt(path); // Remove dboption hash entry
|
||||
|
Reference in New Issue
Block a user