mirror of
https://github.com/MariaDB/server.git
synced 2025-10-19 21:09:40 +03:00
1864d9596d
Documentation of the feature can be found at: http://kb.askmonty.org/en/multi-source-replication/ This code is based on code from Taobao, developed by Plinux BUILD/SETUP.sh: Added -Wno-invalid-offsetof to get rid of warning of offsetof() on C++ class (safe in the contex we use it) client/mysqltest.cc: Added support for error names starting with 'W' Added connection_name support to --sync_with_master cmake/maintainer.cmake: Added -Wno-invalid-offsetof to get rid of warning of offsetof() on C++ class (safe in the contex we use it) mysql-test/r/mysqltest.result: Updated results mysql-test/r/parser.result: Updated results mysql-test/suite/multi_source/my.cnf: Setup of multi-master tests mysql-test/suite/multi_source/simple.result: Simple basic test of multi-source functionality mysql-test/suite/multi_source/simple.test: Simple basic test of multi-source functionality mysql-test/suite/multi_source/syntax.result: Test of multi-source syntax mysql-test/suite/multi_source/syntax.test: Test of multi-source syntax mysql-test/suite/rpl/r/rpl_rotate_logs.result: Updated results because of new error messages mysql-test/t/parser.test: Updated test as master_pos_wait() now takes more arguments than before sql/event_scheduler.cc: No reason to initialize slave_thread (it's guaranteed to be zero here) sql/item_create.cc: Added connection_name argument to master_pos_wait() Simplified code sql/item_func.cc: Added connection_name argument to master_pos_wait() sql/item_func.h: Added connection_name argument to master_pos_wait() sql/log.cc: Added tag "Master 'connection_name'" to slave errors that has a connection name. sql/mysqld.cc: Added variable mysqld_server_initialized so that other functions can test if server is fully initialized. Free all slave data in one place (fewer ifdef's) Removed not needed call to close_active_mi() Initialize slaves() later in startup to ensure that everthing is really initialized when slaves start. Made status variable slave_running multi-source safe sql/mysqld.h: Added mysqld_server_initialized sql/rpl_mi.cc: Store connection name and cmp_connection_name (only used for show full slave status) in Master_info Added code for Master_info_index, which handles storage of multi-master information Don't write the empty "" connection_name to multi-master.info file. This is handled by the original code. sql/rpl_mi.h: Added connection_name and Master_info_index sql/rpl_rli.cc: Added connection_name to relay log files. sql/rpl_rli.h: Fixed type of slave_skip_counter as we now access it directly in sys_vars.cc, so it must be uint sql/share/errmsg-utf8.txt: Added new error messages needed for multi-source Added multi-source name to error ER_MASTER_INFO and WARN_NO_MASTER_INFO sql/slave.cc: Moved things a bit around to make it easier to handle error conditions. Create a global master_info_index and add the "" connection to it Ensure that new Master_info doesn't fail. Don't call terminate_slave_threads(active_mi..) on end_slave() as this is now done automaticly when deleting master_info_index. Delete not needed function close_active_mi(). One can achive same thing by calling end_slave(). Added support for SHOW FULL SLAVE STATUS (show status for all master connections with connection_name as first column) sql/slave.h: Added new prototypes sql/sql_base.cc: More DBUG_PRINT sql/sql_class.cc: Reset thd->connection_name and thd-->default_master_connection sql/sql_class.h: Added thd->connection_name and thd-->default_master_connection Added slave_skip_count to variables to make changing the @@sql_slave_skip_count variable thread safe sql/sql_const.h: Added MAX_CONNECTION_NAME sql/sql_lex.cc: Reset 'lex->verbose' (to simplify some sql_yacc.yy code) sql/sql_lex.h: Added connection_name sql/sql_parse.cc: Added support for connection_name to all SLAVE commands. - Instead of using active_mi, we now get the current Master_info from master_info_index. - Create new replication threads with CHANGE MASTER - Added support for show_all_master_info() sql/sql_reload.cc: Made reset/full slave use master_info_index->get_master_info() instead of active_mi. If one uses 'RESET SLAVE "connection_name" all' the connection is removed from master_info_index. sql/sql_repl.cc: sql_slave_skip_counter is moved to thd->variables to make it thread safe and fix some bugs with it Add connection name to relay log files. Added connection name to errors. Added some logging for multi-master if log_warnings > 1 stop_slave(): - Don't check if thd is set. It's guaranteed to always be set. change_master(): - Check for duplicate connection names in change_master() - Check for wrong arguments first in file (to simplify error handling) - Register new connections in master_info_index sql/sql_yacc.yy: Added optional connection_name to a all relevant master/slave commands sql/strfunc.cc: my_global.h shoud always be included first. sql/sys_vars.cc: Added variable default_master_connection Made variable sql_slave_skip_counter multi-source safe sql/sys_vars.h: Added Sys_var_session_lexstring (needed for default_master_connection) Added Sys_var_multi_source_uint (needed for sql_slave_skip_counter).
110 lines
3.4 KiB
Plaintext
110 lines
3.4 KiB
Plaintext
CALL mtr.add_suppression("Unsafe statement written to the binary log using statement format since BINLOG_FORMAT = STATEMENT.");
|
|
start slave;
|
|
Got one of the listed errors
|
|
start slave;
|
|
ERROR HY000: Could not initialize master info structure for ''; more error messages can be found in the MariaDB error log
|
|
change master to master_host='127.0.0.1',master_port=MASTER_PORT, master_user='root';
|
|
ERROR HY000: Could not initialize master info structure for ''; more error messages can be found in the MariaDB error log
|
|
reset slave;
|
|
change master to master_host='127.0.0.1',master_port=MASTER_PORT, master_user='root';
|
|
reset master;
|
|
start slave;
|
|
include/wait_for_slave_to_start.inc
|
|
create temporary table temp_table (a char(80) not null);
|
|
insert into temp_table values ("testing temporary tables");
|
|
create table t1 (s text);
|
|
insert into t1 values('Could not break slave'),('Tried hard');
|
|
Master_Log_File = 'master-bin.000001'
|
|
Relay_Master_Log_File = 'master-bin.000001'
|
|
include/check_slave_is_running.inc
|
|
select * from t1;
|
|
s
|
|
Could not break slave
|
|
Tried hard
|
|
flush logs;
|
|
create table t2(m int not null auto_increment primary key);
|
|
insert into t2 values (34),(67),(123);
|
|
flush logs;
|
|
show binary logs;
|
|
Log_name File_size
|
|
master-bin.000001 #
|
|
master-bin.000002 #
|
|
master-bin.000003 #
|
|
create table t3 select * from temp_table;
|
|
select * from t3;
|
|
a
|
|
testing temporary tables
|
|
drop table temp_table, t3;
|
|
insert into t2 values(1234);
|
|
set insert_id=1234;
|
|
insert into t2 values(NULL);
|
|
call mtr.add_suppression("Slave SQL.*Error .Duplicate entry .1234. for key .PRIMARY.. on query.* Error_code: 1062");
|
|
include/wait_for_slave_sql_error_and_skip.inc [errno=1062]
|
|
purge master logs to 'master-bin.000002';
|
|
show master logs;
|
|
Log_name master-bin.000002
|
|
File_size #
|
|
Log_name master-bin.000003
|
|
File_size #
|
|
purge binary logs to 'master-bin.000002';
|
|
show binary logs;
|
|
Log_name File_size
|
|
master-bin.000002 #
|
|
master-bin.000003 #
|
|
SELECT @time_for_purge:=DATE_ADD('tmpval', INTERVAL 1 SECOND);
|
|
purge master logs before (@time_for_purge);
|
|
show binary logs;
|
|
Log_name File_size
|
|
master-bin.000003 #
|
|
insert into t2 values (65);
|
|
Master_Log_File = 'master-bin.000003'
|
|
Relay_Master_Log_File = 'master-bin.000003'
|
|
include/check_slave_is_running.inc
|
|
select * from t2;
|
|
m
|
|
34
|
|
65
|
|
67
|
|
123
|
|
1234
|
|
create temporary table temp_table (a char(80) not null);
|
|
insert into temp_table values ("testing temporary tables part 2");
|
|
create table t3 (n int);
|
|
select count(*) from t3 where n >= 4;
|
|
count(*)
|
|
91
|
|
create table t4 select * from temp_table;
|
|
show binary logs;
|
|
Log_name File_size
|
|
master-bin.000003 #
|
|
master-bin.000004 #
|
|
master-bin.000005 #
|
|
master-bin.000006 #
|
|
master-bin.000007 #
|
|
master-bin.000008 #
|
|
master-bin.000009 #
|
|
show master status;
|
|
File Position Binlog_Do_DB Binlog_Ignore_DB
|
|
master-bin.000009 # <Binlog_Do_DB> <Binlog_Ignore_DB>
|
|
select * from t4;
|
|
a
|
|
testing temporary tables part 2
|
|
Master_Log_File = 'master-bin.000009'
|
|
Relay_Master_Log_File = 'master-bin.000009'
|
|
include/check_slave_is_running.inc
|
|
lock tables t3 read;
|
|
select count(*) from t3 where n >= 4;
|
|
count(*)
|
|
91
|
|
unlock tables;
|
|
drop table if exists t1,t2,t3,t4;
|
|
End of 4.1 tests
|
|
show binlog events in 'non existing_binlog_file';
|
|
ERROR HY000: Error when executing command SHOW BINLOG EVENTS: Could not find target log
|
|
purge master logs before now();
|
|
show binlog events in '';
|
|
ERROR HY000: Error when executing command SHOW BINLOG EVENTS: Could not find target log
|
|
purge master logs before now();
|
|
End of 5.0 tests
|
|
include/stop_slave.inc
|