mirror of
https://github.com/MariaDB/server.git
synced 2025-04-18 21:25:32 +02:00
MDEV-35304: Add Connects_Tried and Master_Retry_Count to SSS
When the IO thread (re)connect to a primary, no updates are available besides unique errors that cause the failure. These new `Master_info` numbers supplement SHOW SLAVE STATUS’s (most- recent) ‘Connecting’ state with statistics on (re)connect attempts: * `Connects_Tried`: how many retries have been attempted so far This was previously a local variable that only counted re-attempts; it’s now meaningful even after the “Connecting” state concludes. * `Master_Retry_Count` (from MDEV-25674): out of how many configured Side-note: Some of the tests updated by this commit dump the entire SHOW SLAVE STATUS, which might include non-deterministic entries. Reviewed-by: Kristian Nielsen <knielsen@knielsen-hq.org> Reviewed-by: Brandon Nesterenko <brandon.nesterenko@mariadb.com>
This commit is contained in:
ParadoxV5
parent
7094a75596
commit
e2dbd9b6ac
19 changed files with 374 additions and 79 deletions
mysql-test
include
main
suite
sql
tests
|
|
@ -74,10 +74,12 @@ if ($tmp)
|
|||
--echo Slave_Non_Transactional_Groups #
|
||||
--echo Slave_Transactional_Groups #
|
||||
--echo Replicate_Rewrite_DB #
|
||||
--echo Connects_Tried #
|
||||
--echo Master_Retry_Count #
|
||||
}
|
||||
if (!$tmp) {
|
||||
# Note: after WL#5177, fields 13-18 shall not be filtered-out.
|
||||
--replace_column 4 # 5 # 6 # 7 # 8 # 9 # 10 # 13 # 14 # 15 # 16 # 17 # 18 # 22 # 23 # 24 # 25 # 26 # 40 # 41 # 42 # 44 # 51 # 52 # 53 # 54 #
|
||||
--replace_column 4 # 5 # 6 # 7 # 8 # 9 # 10 # 13 # 14 # 15 # 16 # 17 # 18 # 22 # 23 # 24 # 25 # 26 # 40 # 41 # 42 # 44 # 51 # 52 # 53 # 54 # 55 # 56 #
|
||||
query_vertical
|
||||
SHOW SLAVE STATUS;
|
||||
}
|
||||
|
|
|
|||
|
|
@ -1,14 +1,26 @@
|
|||
# Use `--master-retry-count` when not specified
|
||||
CHANGE MASTER 'named' TO master_host='example.com';
|
||||
CHANGE MASTER TO master_host='127.0.0.1', master_ssl_verify_server_cert=0;
|
||||
SELECT CHANNEL_NAME, CONNECTION_RETRY_COUNT
|
||||
FROM performance_schema.replication_connection_configuration;
|
||||
CHANNEL_NAME CONNECTION_RETRY_COUNT
|
||||
named 1
|
||||
SELECT Connection_name, Master_Retry_Count
|
||||
FROM information_schema.SLAVE_STATUS;
|
||||
Connection_name Master_Retry_Count
|
||||
1
|
||||
named 1
|
||||
# Replace when specified
|
||||
CHANGE MASTER 'named' TO master_retry_count=11;
|
||||
CHANGE MASTER TO master_retry_count=10;
|
||||
SELECT Connection_name, Master_Retry_Count
|
||||
FROM information_schema.SLAVE_STATUS;
|
||||
Connection_name Master_Retry_Count
|
||||
10
|
||||
named 11
|
||||
# Conventional views also show the configuations
|
||||
Connection_name = ''
|
||||
Connection_name = 'named'
|
||||
Master_Retry_Count = '10'
|
||||
Master_Retry_Count = '11'
|
||||
Master_Retry_Count = '10'
|
||||
Master_Retry_Count = '11'
|
||||
SELECT CHANNEL_NAME, CONNECTION_RETRY_COUNT
|
||||
FROM performance_schema.replication_connection_configuration;
|
||||
CHANNEL_NAME CONNECTION_RETRY_COUNT
|
||||
|
|
@ -16,52 +28,52 @@ named 11
|
|||
10
|
||||
# Restore specified config on restart
|
||||
# restart: --skip-slave-start
|
||||
SELECT CHANNEL_NAME, CONNECTION_RETRY_COUNT
|
||||
FROM performance_schema.replication_connection_configuration;
|
||||
CHANNEL_NAME CONNECTION_RETRY_COUNT
|
||||
named 11
|
||||
SELECT Connection_name, Master_Retry_Count
|
||||
FROM information_schema.SLAVE_STATUS;
|
||||
Connection_name Master_Retry_Count
|
||||
10
|
||||
named 11
|
||||
# Keep specified config on RESET REPLICA
|
||||
RESET REPLICA 'named';
|
||||
RESET REPLICA;
|
||||
SELECT CHANNEL_NAME, CONNECTION_RETRY_COUNT
|
||||
FROM performance_schema.replication_connection_configuration;
|
||||
CHANNEL_NAME CONNECTION_RETRY_COUNT
|
||||
named 11
|
||||
SELECT Connection_name, Master_Retry_Count
|
||||
FROM information_schema.SLAVE_STATUS;
|
||||
Connection_name Master_Retry_Count
|
||||
10
|
||||
named 11
|
||||
# Don't replace when not specified
|
||||
CHANGE MASTER TO master_user='root';
|
||||
CHANGE MASTER 'named' TO master_user='root';
|
||||
SELECT CHANNEL_NAME, CONNECTION_RETRY_COUNT
|
||||
FROM performance_schema.replication_connection_configuration;
|
||||
CHANNEL_NAME CONNECTION_RETRY_COUNT
|
||||
named 11
|
||||
SELECT Connection_name, Master_Retry_Count
|
||||
FROM information_schema.SLAVE_STATUS;
|
||||
Connection_name Master_Retry_Count
|
||||
10
|
||||
named 11
|
||||
# 0 internally means "not specified"
|
||||
CHANGE MASTER TO master_retry_count=0;
|
||||
CHANGE MASTER 'named' TO master_retry_count=0;
|
||||
SELECT CHANNEL_NAME, CONNECTION_RETRY_COUNT
|
||||
FROM performance_schema.replication_connection_configuration;
|
||||
CHANNEL_NAME CONNECTION_RETRY_COUNT
|
||||
named 11
|
||||
SELECT Connection_name, Master_Retry_Count
|
||||
FROM information_schema.SLAVE_STATUS;
|
||||
Connection_name Master_Retry_Count
|
||||
10
|
||||
named 11
|
||||
# Truncates decimals
|
||||
CHANGE MASTER TO master_retry_count=0.5;
|
||||
CHANGE MASTER 'named' TO master_retry_count=0.5;
|
||||
SELECT CHANNEL_NAME, CONNECTION_RETRY_COUNT
|
||||
FROM performance_schema.replication_connection_configuration;
|
||||
CHANNEL_NAME CONNECTION_RETRY_COUNT
|
||||
named 11
|
||||
SELECT Connection_name, Master_Retry_Count
|
||||
FROM information_schema.SLAVE_STATUS;
|
||||
Connection_name Master_Retry_Count
|
||||
10
|
||||
named 11
|
||||
# Caps values (such as UINT64_MAX + 1) to `--master-retry-count`'s max
|
||||
CHANGE MASTER TO master_retry_count=18446744073709551616;
|
||||
CHANGE MASTER 'named' TO master_retry_count=18446744073709551616;
|
||||
SELECT CHANNEL_NAME
|
||||
FROM performance_schema.replication_connection_configuration
|
||||
WHERE CONNECTION_RETRY_COUNT IN (4294967295, 18446744073709551615);
|
||||
CHANNEL_NAME
|
||||
named
|
||||
SELECT Connection_name
|
||||
FROM information_schema.SLAVE_STATUS
|
||||
WHERE Master_Retry_Count IN (4294967295, 18446744073709551615);
|
||||
Connection_name
|
||||
|
||||
named
|
||||
# Negative
|
||||
CHANGE MASTER TO master_retry_count=-1;
|
||||
ERROR 42000: You have an error in your SQL syntax; check the manual that corresponds to your MariaDB server version for the right syntax to use near '-1' at line 1
|
||||
|
|
|
|||
|
|
@ -1,57 +1,69 @@
|
|||
# MDEV-25674: Test the `Master_Retry_Count` field of
|
||||
# CHANGE MASTER [name] TO (no feature testing)
|
||||
# CHANGE MASTER [name] TO and SHOW SLAVE [name] STATUS & co. (no feature testing)
|
||||
# Two connections tests that the field is now per-connection.
|
||||
--source include/have_perfschema.inc
|
||||
|
||||
--echo # Use `--master-retry-count` when not specified
|
||||
CHANGE MASTER 'named' TO master_host='example.com';
|
||||
CHANGE MASTER TO master_host='127.0.0.1', master_ssl_verify_server_cert=0;
|
||||
SELECT CHANNEL_NAME, CONNECTION_RETRY_COUNT
|
||||
FROM performance_schema.replication_connection_configuration;
|
||||
SELECT Connection_name, Master_Retry_Count
|
||||
FROM information_schema.SLAVE_STATUS;
|
||||
|
||||
--echo # Replace when specified
|
||||
CHANGE MASTER 'named' TO master_retry_count=11;
|
||||
# Default master does not replace named master
|
||||
CHANGE MASTER TO master_retry_count=10;
|
||||
SELECT Connection_name, Master_Retry_Count
|
||||
FROM information_schema.SLAVE_STATUS;
|
||||
|
||||
--echo # Conventional views also show the configuations
|
||||
--let $all_slaves_status= 1
|
||||
--let $status_items= Connection_name, Master_Retry_Count
|
||||
--source include/show_slave_status.inc
|
||||
--let $all_slaves_status= 0
|
||||
--let $status_items= Master_Retry_Count
|
||||
--source include/show_slave_status.inc
|
||||
--let $slave_name= 'named'
|
||||
--source include/show_slave_status.inc
|
||||
SELECT CHANNEL_NAME, CONNECTION_RETRY_COUNT
|
||||
FROM performance_schema.replication_connection_configuration;
|
||||
|
||||
--echo # Restore specified config on restart
|
||||
--let $restart_parameters= --skip-slave-start
|
||||
--source include/restart_mysqld.inc # not_embedded
|
||||
SELECT CHANNEL_NAME, CONNECTION_RETRY_COUNT
|
||||
FROM performance_schema.replication_connection_configuration;
|
||||
SELECT Connection_name, Master_Retry_Count
|
||||
FROM information_schema.SLAVE_STATUS;
|
||||
|
||||
--echo # Keep specified config on RESET REPLICA
|
||||
RESET REPLICA 'named';
|
||||
RESET REPLICA;
|
||||
SELECT CHANNEL_NAME, CONNECTION_RETRY_COUNT
|
||||
FROM performance_schema.replication_connection_configuration;
|
||||
SELECT Connection_name, Master_Retry_Count
|
||||
FROM information_schema.SLAVE_STATUS;
|
||||
|
||||
--echo # Don't replace when not specified
|
||||
CHANGE MASTER TO master_user='root';
|
||||
CHANGE MASTER 'named' TO master_user='root';
|
||||
SELECT CHANNEL_NAME, CONNECTION_RETRY_COUNT
|
||||
FROM performance_schema.replication_connection_configuration;
|
||||
SELECT Connection_name, Master_Retry_Count
|
||||
FROM information_schema.SLAVE_STATUS;
|
||||
|
||||
--echo # 0 internally means "not specified"
|
||||
CHANGE MASTER TO master_retry_count=0;
|
||||
CHANGE MASTER 'named' TO master_retry_count=0;
|
||||
SELECT CHANNEL_NAME, CONNECTION_RETRY_COUNT
|
||||
FROM performance_schema.replication_connection_configuration;
|
||||
SELECT Connection_name, Master_Retry_Count
|
||||
FROM information_schema.SLAVE_STATUS;
|
||||
|
||||
--echo # Truncates decimals
|
||||
CHANGE MASTER TO master_retry_count=0.5;
|
||||
CHANGE MASTER 'named' TO master_retry_count=0.5;
|
||||
SELECT CHANNEL_NAME, CONNECTION_RETRY_COUNT
|
||||
FROM performance_schema.replication_connection_configuration;
|
||||
SELECT Connection_name, Master_Retry_Count
|
||||
FROM information_schema.SLAVE_STATUS;
|
||||
|
||||
--echo # Caps values (such as UINT64_MAX + 1) to `--master-retry-count`'s max
|
||||
CHANGE MASTER TO master_retry_count=18446744073709551616;
|
||||
CHANGE MASTER 'named' TO master_retry_count=18446744073709551616;
|
||||
SELECT CHANNEL_NAME
|
||||
FROM performance_schema.replication_connection_configuration
|
||||
WHERE CONNECTION_RETRY_COUNT IN (4294967295, 18446744073709551615);
|
||||
SELECT Connection_name
|
||||
FROM information_schema.SLAVE_STATUS
|
||||
WHERE Master_Retry_Count IN (4294967295, 18446744073709551615);
|
||||
|
||||
--echo # Negative
|
||||
--error ER_PARSE_ERROR
|
||||
|
|
|
|||
|
|
@ -390,11 +390,12 @@ def information_schema SESSION_STATUS VARIABLE_VALUE 2 NULL NO varchar 4096 1228
|
|||
def information_schema SESSION_VARIABLES VARIABLE_NAME 1 NULL NO varchar 64 192 NULL NULL NULL utf8mb3 utf8mb3_general_ci varchar(64) select NEVER NULL NO NO
|
||||
def information_schema SESSION_VARIABLES VARIABLE_VALUE 2 NULL NO varchar 4096 12288 NULL NULL NULL utf8mb3 utf8mb3_general_ci varchar(4096) select NEVER NULL NO NO
|
||||
def information_schema SLAVE_STATUS Connection_name 1 NULL NO varchar 64 192 NULL NULL NULL utf8mb3 utf8mb3_general_ci varchar(64) select NEVER NULL NO NO
|
||||
def information_schema SLAVE_STATUS Connects_Tried 57 NULL NO bigint NULL NULL 20 0 NULL NULL NULL bigint(20) unsigned select NEVER NULL NO NO
|
||||
def information_schema SLAVE_STATUS Connect_Retry 7 NULL NO int NULL NULL 10 0 NULL NULL NULL int(10) unsigned select NEVER NULL NO NO
|
||||
def information_schema SLAVE_STATUS Executed_log_entries 59 NULL NO int NULL NULL 10 0 NULL NULL NULL int(10) unsigned select NEVER NULL NO NO
|
||||
def information_schema SLAVE_STATUS Executed_log_entries 61 NULL NO int NULL NULL 10 0 NULL NULL NULL int(10) unsigned select NEVER NULL NO NO
|
||||
def information_schema SLAVE_STATUS Exec_Master_Log_Pos 24 NULL NO bigint NULL NULL 20 0 NULL NULL NULL bigint(20) unsigned select NEVER NULL NO NO
|
||||
def information_schema SLAVE_STATUS Gtid_IO_Pos 46 NULL NO varchar 21844 65532 NULL NULL NULL utf8mb3 utf8mb3_general_ci varchar(21844) select NEVER NULL NO NO
|
||||
def information_schema SLAVE_STATUS Gtid_Slave_Pos 62 NULL NO varchar 21844 65532 NULL NULL NULL utf8mb3 utf8mb3_general_ci varchar(21844) select NEVER NULL NO NO
|
||||
def information_schema SLAVE_STATUS Gtid_Slave_Pos 64 NULL NO varchar 21844 65532 NULL NULL NULL utf8mb3 utf8mb3_general_ci varchar(21844) select NEVER NULL NO NO
|
||||
def information_schema SLAVE_STATUS Last_Errno 21 NULL NO smallint NULL NULL 5 0 NULL NULL NULL smallint(4) unsigned select NEVER NULL NO NO
|
||||
def information_schema SLAVE_STATUS Last_Error 22 NULL YES varchar 1024 3072 NULL NULL NULL utf8mb3 utf8mb3_general_ci varchar(1024) select NEVER NULL NO NO
|
||||
def information_schema SLAVE_STATUS Last_IO_Errno 37 NULL NO smallint NULL NULL 5 0 NULL NULL NULL smallint(4) unsigned select NEVER NULL NO NO
|
||||
|
|
@ -402,11 +403,12 @@ def information_schema SLAVE_STATUS Last_IO_Error 38 NULL YES varchar 1024 3072
|
|||
def information_schema SLAVE_STATUS Last_SQL_Errno 39 NULL NO smallint NULL NULL 5 0 NULL NULL NULL smallint(4) unsigned select NEVER NULL NO NO
|
||||
def information_schema SLAVE_STATUS Last_SQL_Error 40 NULL YES varchar 1024 3072 NULL NULL NULL utf8mb3 utf8mb3_general_ci varchar(1024) select NEVER NULL NO NO
|
||||
def information_schema SLAVE_STATUS Master_Host 4 NULL YES varchar 255 765 NULL NULL NULL utf8mb3 utf8mb3_general_ci varchar(255) select NEVER NULL NO NO
|
||||
def information_schema SLAVE_STATUS Master_last_event_time 63 NULL YES datetime NULL NULL NULL NULL 0 NULL NULL datetime select NEVER NULL NO NO
|
||||
def information_schema SLAVE_STATUS Master_last_event_time 65 NULL YES datetime NULL NULL NULL NULL 0 NULL NULL datetime select NEVER NULL NO NO
|
||||
def information_schema SLAVE_STATUS Master_Log_File 8 NULL NO varchar 512 1536 NULL NULL NULL utf8mb3 utf8mb3_general_ci varchar(512) select NEVER NULL NO NO
|
||||
def information_schema SLAVE_STATUS Master_Port 6 NULL NO smallint NULL NULL 5 0 NULL NULL NULL smallint(5) unsigned select NEVER NULL NO NO
|
||||
def information_schema SLAVE_STATUS Master_Retry_Count 58 NULL NO bigint NULL NULL 20 0 NULL NULL NULL bigint(20) unsigned select NEVER NULL NO NO
|
||||
def information_schema SLAVE_STATUS Master_Server_Id 42 NULL NO int NULL NULL 10 0 NULL NULL NULL int(10) unsigned select NEVER NULL NO NO
|
||||
def information_schema SLAVE_STATUS Master_Slave_time_diff 65 NULL YES int NULL NULL 10 0 NULL NULL NULL int(10) unsigned select NEVER NULL NO NO
|
||||
def information_schema SLAVE_STATUS Master_Slave_time_diff 67 NULL YES int NULL NULL 10 0 NULL NULL NULL int(10) unsigned select NEVER NULL NO NO
|
||||
def information_schema SLAVE_STATUS Master_SSL_Allowed 29 NULL YES varchar 7 21 NULL NULL NULL utf8mb3 utf8mb3_general_ci varchar(7) select NEVER NULL NO NO
|
||||
def information_schema SLAVE_STATUS Master_SSL_CA_File 30 NULL YES varchar 512 1536 NULL NULL NULL utf8mb3 utf8mb3_general_ci varchar(512) select NEVER NULL NO NO
|
||||
def information_schema SLAVE_STATUS Master_SSL_CA_Path 31 NULL YES varchar 512 1536 NULL NULL NULL utf8mb3 utf8mb3_general_ci varchar(512) select NEVER NULL NO NO
|
||||
|
|
@ -417,7 +419,7 @@ def information_schema SLAVE_STATUS Master_SSL_Crlpath 44 NULL YES varchar 512 1
|
|||
def information_schema SLAVE_STATUS Master_SSL_Key 34 NULL YES varchar 512 1536 NULL NULL NULL utf8mb3 utf8mb3_general_ci varchar(512) select NEVER NULL NO NO
|
||||
def information_schema SLAVE_STATUS Master_SSL_Verify_Server_Cert 36 NULL NO varchar 3 9 NULL NULL NULL utf8mb3 utf8mb3_general_ci varchar(3) select NEVER NULL NO NO
|
||||
def information_schema SLAVE_STATUS Master_User 5 NULL YES varchar 384 1152 NULL NULL NULL utf8mb3 utf8mb3_general_ci varchar(384) select NEVER NULL NO NO
|
||||
def information_schema SLAVE_STATUS Max_relay_log_size 58 NULL NO int NULL NULL 10 0 NULL NULL NULL int(10) unsigned select NEVER NULL NO NO
|
||||
def information_schema SLAVE_STATUS Max_relay_log_size 60 NULL NO int NULL NULL 10 0 NULL NULL NULL int(10) unsigned select NEVER NULL NO NO
|
||||
def information_schema SLAVE_STATUS Parallel_Mode 49 NULL NO varchar 12 36 NULL NULL NULL utf8mb3 utf8mb3_general_ci varchar(12) select NEVER NULL NO NO
|
||||
def information_schema SLAVE_STATUS Read_Master_Log_Pos 9 NULL NO bigint NULL NULL 20 0 NULL NULL NULL bigint(20) unsigned select NEVER NULL NO NO
|
||||
def information_schema SLAVE_STATUS Relay_Log_File 10 NULL NO varchar 512 1536 NULL NULL NULL utf8mb3 utf8mb3_general_ci varchar(512) select NEVER NULL NO NO
|
||||
|
|
@ -434,16 +436,16 @@ def information_schema SLAVE_STATUS Replicate_Ignore_Table 18 NULL NO varchar 21
|
|||
def information_schema SLAVE_STATUS Replicate_Rewrite_DB 56 NULL NO varchar 21844 65532 NULL NULL NULL utf8mb3 utf8mb3_general_ci varchar(21844) select NEVER NULL NO NO
|
||||
def information_schema SLAVE_STATUS Replicate_Wild_Do_Table 19 NULL NO varchar 21844 65532 NULL NULL NULL utf8mb3 utf8mb3_general_ci varchar(21844) select NEVER NULL NO NO
|
||||
def information_schema SLAVE_STATUS Replicate_Wild_Ignore_Table 20 NULL NO varchar 21844 65532 NULL NULL NULL utf8mb3 utf8mb3_general_ci varchar(21844) select NEVER NULL NO NO
|
||||
def information_schema SLAVE_STATUS Retried_transactions 57 NULL NO int NULL NULL 10 0 NULL NULL NULL int(10) unsigned select NEVER NULL NO NO
|
||||
def information_schema SLAVE_STATUS Retried_transactions 59 NULL NO int NULL NULL 10 0 NULL NULL NULL int(10) unsigned select NEVER NULL NO NO
|
||||
def information_schema SLAVE_STATUS Seconds_Behind_Master 35 NULL YES bigint NULL NULL 20 0 NULL NULL NULL bigint(20) unsigned select NEVER NULL NO NO
|
||||
def information_schema SLAVE_STATUS Skip_Counter 23 NULL NO int NULL NULL 10 0 NULL NULL NULL int(10) unsigned select NEVER NULL NO NO
|
||||
def information_schema SLAVE_STATUS Slave_DDL_Groups 53 NULL NO bigint NULL NULL 20 0 NULL NULL NULL bigint(20) unsigned select NEVER NULL NO NO
|
||||
def information_schema SLAVE_STATUS Slave_heartbeat_period 61 NULL NO float NULL NULL 9 3 NULL NULL NULL float(9,3) select NEVER NULL NO NO
|
||||
def information_schema SLAVE_STATUS Slave_heartbeat_period 63 NULL NO float NULL NULL 9 3 NULL NULL NULL float(9,3) select NEVER NULL NO NO
|
||||
def information_schema SLAVE_STATUS Slave_IO_Running 13 NULL NO varchar 10 30 NULL NULL NULL utf8mb3 utf8mb3_general_ci varchar(10) select NEVER NULL NO NO
|
||||
def information_schema SLAVE_STATUS Slave_IO_State 3 NULL YES varchar 64 192 NULL NULL NULL utf8mb3 utf8mb3_general_ci varchar(64) select NEVER NULL NO NO
|
||||
def information_schema SLAVE_STATUS Slave_last_event_time 64 NULL YES datetime NULL NULL NULL NULL 0 NULL NULL datetime select NEVER NULL NO NO
|
||||
def information_schema SLAVE_STATUS Slave_last_event_time 66 NULL YES datetime NULL NULL NULL NULL 0 NULL NULL datetime select NEVER NULL NO NO
|
||||
def information_schema SLAVE_STATUS Slave_Non_Transactional_Groups 54 NULL NO bigint NULL NULL 20 0 NULL NULL NULL bigint(20) unsigned select NEVER NULL NO NO
|
||||
def information_schema SLAVE_STATUS Slave_received_heartbeats 60 NULL NO int NULL NULL 10 0 NULL NULL NULL int(10) unsigned select NEVER NULL NO NO
|
||||
def information_schema SLAVE_STATUS Slave_received_heartbeats 62 NULL NO int NULL NULL 10 0 NULL NULL NULL int(10) unsigned select NEVER NULL NO NO
|
||||
def information_schema SLAVE_STATUS Slave_SQL_Running 14 NULL NO varchar 3 9 NULL NULL NULL utf8mb3 utf8mb3_general_ci varchar(3) select NEVER NULL NO NO
|
||||
def information_schema SLAVE_STATUS Slave_SQL_Running_State 52 NULL YES varchar 21844 65532 NULL NULL NULL utf8mb3 utf8mb3_general_ci varchar(21844) select NEVER NULL NO NO
|
||||
def information_schema SLAVE_STATUS Slave_SQL_State 2 NULL YES varchar 64 192 NULL NULL NULL utf8mb3 utf8mb3_general_ci varchar(64) select NEVER NULL NO NO
|
||||
|
|
@ -1120,6 +1122,8 @@ NULL information_schema SLAVE_STATUS Slave_DDL_Groups bigint NULL NULL NULL NULL
|
|||
NULL information_schema SLAVE_STATUS Slave_Non_Transactional_Groups bigint NULL NULL NULL NULL bigint(20) unsigned
|
||||
NULL information_schema SLAVE_STATUS Slave_Transactional_Groups bigint NULL NULL NULL NULL bigint(20) unsigned
|
||||
3.0000 information_schema SLAVE_STATUS Replicate_Rewrite_DB varchar 21844 65532 utf8mb3 utf8mb3_general_ci varchar(21844)
|
||||
NULL information_schema SLAVE_STATUS Connects_Tried bigint NULL NULL NULL NULL bigint(20) unsigned
|
||||
NULL information_schema SLAVE_STATUS Master_Retry_Count bigint NULL NULL NULL NULL bigint(20) unsigned
|
||||
NULL information_schema SLAVE_STATUS Retried_transactions int NULL NULL NULL NULL int(10) unsigned
|
||||
NULL information_schema SLAVE_STATUS Max_relay_log_size int NULL NULL NULL NULL int(10) unsigned
|
||||
NULL information_schema SLAVE_STATUS Executed_log_entries int NULL NULL NULL NULL int(10) unsigned
|
||||
|
|
|
|||
102
mysql-test/suite/multi_source/connects_tried.result
Normal file
102
mysql-test/suite/multi_source/connects_tried.result
Normal file
|
|
@ -0,0 +1,102 @@
|
|||
include/master-slave.inc [rpl_server_count=3]
|
||||
[connection master]
|
||||
include/rpl_stop_server.inc [server_number=1]
|
||||
include/rpl_stop_server.inc [server_number=3]
|
||||
connection slave;
|
||||
CHANGE MASTER TO master_connect_retry=1;
|
||||
CHANGE MASTER 'named' TO master_host='127.0.0.1', master_port=SERVER_MYPORT_3, master_user='root', master_ssl_verify_server_cert=0, master_connect_retry=2;
|
||||
# `Connects_Tried` is 0 before connections begin.
|
||||
SELECT Connection_name, Connects_Tried FROM information_schema.SLAVE_STATUS;
|
||||
Connection_name Connects_Tried
|
||||
0
|
||||
named 0
|
||||
START ALL SLAVES;
|
||||
SET @@SESSION.default_master_connection= 'named';
|
||||
include/wait_for_slave_io_error.inc [errno=2003]
|
||||
SET @@SESSION.default_master_connection= '';
|
||||
include/wait_for_slave_io_error.inc [errno=2003]
|
||||
CREATE TEMPORARY TABLE status_begin AS
|
||||
SELECT Connection_name, Connects_Tried FROM information_schema.SLAVE_STATUS;
|
||||
# `Connects_Tried` is 1 immediately after connections begin.
|
||||
SELECT Connection_name, Connects_Tried
|
||||
FROM status_begin
|
||||
WHERE Connects_Tried <= 0;
|
||||
Connection_name Connects_Tried
|
||||
DO SLEEP(3);
|
||||
# `Connects_Tried` increments (at least) 3 for connection '' and 1 for 'named'.
|
||||
CREATE TEMPORARY TABLE status_sleep AS
|
||||
SELECT Connection_name, Connects_Tried FROM information_schema.SLAVE_STATUS;
|
||||
SELECT *
|
||||
FROM status_begin JOIN status_sleep USING(Connection_name)
|
||||
WHERE status_sleep.Connects_Tried - status_begin.Connects_Tried <
|
||||
IF(LENGTH(Connection_name), 1, 3);
|
||||
Connection_name Connects_Tried Connects_Tried
|
||||
# Boot replication up and assert final count
|
||||
include/rpl_start_server.inc [server_number=1]
|
||||
include/rpl_start_server.inc [server_number=3]
|
||||
connection slave;
|
||||
SET @@SESSION.default_master_connection= 'named';
|
||||
include/wait_for_slave_param.inc [Slave_IO_Running]
|
||||
SET @@SESSION.default_master_connection= '';
|
||||
include/wait_for_slave_param.inc [Slave_IO_Running]
|
||||
CREATE TEMPORARY TABLE status_end AS
|
||||
SELECT Connection_name, Connects_Tried FROM information_schema.SLAVE_STATUS;
|
||||
# `Connects_Tried` increments (at least) 1 for each connection.
|
||||
SELECT *
|
||||
FROM status_sleep JOIN status_end USING(Connection_name)
|
||||
WHERE status_end.Connects_Tried <= status_sleep.Connects_Tried;
|
||||
Connection_name Connects_Tried Connects_Tried
|
||||
DO SLEEP(2);
|
||||
# `Connects_Tried` does not increment after connection establishes.
|
||||
CREATE TEMPORARY TABLE status_after AS
|
||||
SELECT Connection_name, Connects_Tried FROM information_schema.SLAVE_STATUS;
|
||||
SELECT *
|
||||
FROM status_end JOIN status_after USING(Connection_name)
|
||||
WHERE status_after.Connects_Tried <> status_end.Connects_Tried;
|
||||
Connection_name Connects_Tried Connects_Tried
|
||||
# Conventional views
|
||||
SELECT * FROM status_end;
|
||||
Connection_name Connects_Tried
|
||||
connects_tried
|
||||
named connects_tried_named
|
||||
SELECT * FROM status_end;
|
||||
Connection_name Connects_Tried
|
||||
connects_tried
|
||||
named connects_tried_named
|
||||
STOP ALL SLAVES;
|
||||
SET @@SESSION.default_master_connection= 'named';
|
||||
include/wait_for_slave_to_stop.inc
|
||||
SET @@SESSION.default_master_connection= '';
|
||||
include/wait_for_slave_to_stop.inc
|
||||
# STOP SLAVE does not reset `Connects_Tried`.
|
||||
CREATE TEMPORARY TABLE status_stop AS
|
||||
SELECT Connection_name, Connects_Tried FROM information_schema.SLAVE_STATUS;
|
||||
SELECT *
|
||||
FROM status_after JOIN status_stop USING(Connection_name)
|
||||
WHERE status_stop.Connects_Tried <> status_after.Connects_Tried;
|
||||
Connection_name Connects_Tried Connects_Tried
|
||||
START SLAVE;
|
||||
include/wait_for_slave_to_start.inc
|
||||
# START SLAVE recounts `Connects_Tried` from 1 (for the restarted connection only).
|
||||
CREATE TEMPORARY TABLE status_restart AS
|
||||
SELECT Connection_name, Connects_Tried FROM information_schema.SLAVE_STATUS;
|
||||
SELECT *
|
||||
FROM status_restart JOIN status_stop USING(Connection_name)
|
||||
WHERE status_restart.Connects_Tried NOT BETWEEN IF(
|
||||
LENGTH(Connection_name), status_stop.Connects_Tried, 1
|
||||
) AND status_stop.Connects_Tried;
|
||||
Connection_name Connects_Tried Connects_Tried
|
||||
STOP SLAVE;
|
||||
include/wait_for_slave_to_stop.inc
|
||||
RESET SLAVE;
|
||||
# RESET SLAVE resets `Connects_Tried` to 0 (for the resetted connection only).
|
||||
CREATE TEMPORARY TABLE status_reset AS
|
||||
SELECT Connection_name, Connects_Tried FROM information_schema.SLAVE_STATUS;
|
||||
SELECT *
|
||||
FROM status_reset JOIN status_restart USING(Connection_name)
|
||||
WHERE status_reset.Connects_Tried <>
|
||||
IF(LENGTH(Connection_name), status_restart.Connects_Tried, 0);
|
||||
Connection_name Connects_Tried Connects_Tried
|
||||
# Cleanup
|
||||
RESET SLAVE 'named' ALL;
|
||||
include/rpl_end.inc
|
||||
133
mysql-test/suite/multi_source/connects_tried.test
Normal file
133
mysql-test/suite/multi_source/connects_tried.test
Normal file
|
|
@ -0,0 +1,133 @@
|
|||
# MDEV-35304: Test the `Connects_Tried` feature
|
||||
#
|
||||
# Two connections with different retry frequencies tests their
|
||||
# separate counters in parallel multi-source (SHOW SLAVE [name] STATUS).
|
||||
#
|
||||
# Note: nearly all SELECT results are timing-sensitive,
|
||||
# they therefore list unexpected rows because.
|
||||
|
||||
--source include/have_binlog_format_mixed.inc # The test is agnostic of binlog formats.
|
||||
# `rpl_*.inc` (still) expects `server_1` be `master` and `server_2` be `slave`.
|
||||
--let $rpl_server_count= 3
|
||||
--let $rpl_skip_start_slave= 1
|
||||
--source include/master-slave.inc
|
||||
--let $rpl_server_number= 1
|
||||
--source include/rpl_stop_server.inc
|
||||
--let $rpl_server_number= 3
|
||||
--source include/rpl_stop_server.inc
|
||||
|
||||
--connection slave
|
||||
CHANGE MASTER TO master_connect_retry=1;
|
||||
--replace_result $SERVER_MYPORT_3 SERVER_MYPORT_3
|
||||
--eval CHANGE MASTER 'named' TO master_host='127.0.0.1', master_port=$SERVER_MYPORT_3, master_user='root', master_ssl_verify_server_cert=0, master_connect_retry=2
|
||||
--echo # `Connects_Tried` is 0 before connections begin.
|
||||
SELECT Connection_name, Connects_Tried FROM information_schema.SLAVE_STATUS;
|
||||
|
||||
--disable_warnings
|
||||
START ALL SLAVES; # will fail because the masters are down
|
||||
# CR_CONN_HOST_ERROR
|
||||
--let $slave_io_errno= 2003
|
||||
--let $slave_io_error_is_nonfatal= 1
|
||||
SET @@SESSION.default_master_connection= 'named';
|
||||
--source include/wait_for_slave_io_error.inc
|
||||
--let $slave_io_error_is_nonfatal= 1
|
||||
SET @@SESSION.default_master_connection= '';
|
||||
--source include/wait_for_slave_io_error.inc
|
||||
--enable_warnings
|
||||
|
||||
CREATE TEMPORARY TABLE status_begin AS
|
||||
SELECT Connection_name, Connects_Tried FROM information_schema.SLAVE_STATUS;
|
||||
--echo # `Connects_Tried` is 1 immediately after connections begin.
|
||||
SELECT Connection_name, Connects_Tried
|
||||
FROM status_begin
|
||||
WHERE Connects_Tried <= 0;
|
||||
|
||||
DO SLEEP(3);
|
||||
--echo # `Connects_Tried` increments (at least) 3 for connection '' and 1 for 'named'.
|
||||
CREATE TEMPORARY TABLE status_sleep AS
|
||||
SELECT Connection_name, Connects_Tried FROM information_schema.SLAVE_STATUS;
|
||||
SELECT *
|
||||
FROM status_begin JOIN status_sleep USING(Connection_name)
|
||||
WHERE status_sleep.Connects_Tried - status_begin.Connects_Tried <
|
||||
IF(LENGTH(Connection_name), 1, 3);
|
||||
|
||||
--echo # Boot replication up and assert final count
|
||||
--let $rpl_server_number= 1
|
||||
--source include/rpl_start_server.inc
|
||||
--let $rpl_server_number= 3
|
||||
--source include/rpl_start_server.inc
|
||||
--connection slave
|
||||
# `wait_for_slave_io_to_start.inc` fails if the IO thread has an error.
|
||||
--let $slave_param= Slave_IO_Running
|
||||
--let $slave_param_value= Yes
|
||||
SET @@SESSION.default_master_connection= 'named';
|
||||
--source include/wait_for_slave_param.inc
|
||||
SET @@SESSION.default_master_connection= '';
|
||||
--source include/wait_for_slave_param.inc
|
||||
|
||||
CREATE TEMPORARY TABLE status_end AS
|
||||
SELECT Connection_name, Connects_Tried FROM information_schema.SLAVE_STATUS;
|
||||
--echo # `Connects_Tried` increments (at least) 1 for each connection.
|
||||
SELECT *
|
||||
FROM status_sleep JOIN status_end USING(Connection_name)
|
||||
WHERE status_end.Connects_Tried <= status_sleep.Connects_Tried;
|
||||
|
||||
DO SLEEP(2);
|
||||
--echo # `Connects_Tried` does not increment after connection establishes.
|
||||
CREATE TEMPORARY TABLE status_after AS
|
||||
SELECT Connection_name, Connects_Tried FROM information_schema.SLAVE_STATUS;
|
||||
SELECT *
|
||||
FROM status_end JOIN status_after USING(Connection_name)
|
||||
WHERE status_after.Connects_Tried <> status_end.Connects_Tried;
|
||||
|
||||
--echo # Conventional views
|
||||
--let $connects_tried= query_get_value("SHOW SLAVE STATUS", Connects_Tried, 1)
|
||||
--let $connects_tried_named= query_get_value("SHOW SLAVE 'named' STATUS", Connects_Tried, 1)
|
||||
--replace_result $connects_tried connects_tried $connects_tried_named connects_tried_named
|
||||
SELECT * FROM status_end;
|
||||
--let $connects_tried= query_get_value("SHOW ALL SLAVES STATUS", Connects_Tried, 1)
|
||||
--let $connects_tried_named= query_get_value("SHOW ALL SLAVES STATUS", Connects_Tried, 2)
|
||||
--replace_result $connects_tried connects_tried $connects_tried_named connects_tried_named
|
||||
SELECT * FROM status_end;
|
||||
|
||||
--disable_warnings
|
||||
STOP ALL SLAVES;
|
||||
SET @@SESSION.default_master_connection= 'named';
|
||||
--source include/wait_for_slave_to_stop.inc
|
||||
SET @@SESSION.default_master_connection= '';
|
||||
--source include/wait_for_slave_to_stop.inc
|
||||
--enable_warnings
|
||||
--echo # STOP SLAVE does not reset `Connects_Tried`.
|
||||
# That is, so the user can check this stat without leaving the slave spinning.
|
||||
CREATE TEMPORARY TABLE status_stop AS
|
||||
SELECT Connection_name, Connects_Tried FROM information_schema.SLAVE_STATUS;
|
||||
SELECT *
|
||||
FROM status_after JOIN status_stop USING(Connection_name)
|
||||
WHERE status_stop.Connects_Tried <> status_after.Connects_Tried;
|
||||
|
||||
START SLAVE;
|
||||
--source include/wait_for_slave_to_start.inc
|
||||
--echo # START SLAVE recounts `Connects_Tried` from 1 (for the restarted connection only).
|
||||
CREATE TEMPORARY TABLE status_restart AS
|
||||
SELECT Connection_name, Connects_Tried FROM information_schema.SLAVE_STATUS;
|
||||
SELECT *
|
||||
FROM status_restart JOIN status_stop USING(Connection_name)
|
||||
WHERE status_restart.Connects_Tried NOT BETWEEN IF(
|
||||
LENGTH(Connection_name), status_stop.Connects_Tried, 1
|
||||
) AND status_stop.Connects_Tried;
|
||||
|
||||
STOP SLAVE;
|
||||
--source include/wait_for_slave_to_stop.inc
|
||||
RESET SLAVE;
|
||||
--echo # RESET SLAVE resets `Connects_Tried` to 0 (for the resetted connection only).
|
||||
CREATE TEMPORARY TABLE status_reset AS
|
||||
SELECT Connection_name, Connects_Tried FROM information_schema.SLAVE_STATUS;
|
||||
SELECT *
|
||||
FROM status_reset JOIN status_restart USING(Connection_name)
|
||||
WHERE status_reset.Connects_Tried <>
|
||||
IF(LENGTH(Connection_name), status_restart.Connects_Tried, 0);
|
||||
|
||||
--echo # Cleanup
|
||||
RESET SLAVE 'named' ALL;
|
||||
--let $rpl_only_running_threads= 1
|
||||
--source include/rpl_end.inc
|
||||
|
|
@ -94,17 +94,17 @@ MASTER 2.2
|
|||
# EOF
|
||||
#
|
||||
show all slaves status;
|
||||
Connection_name Slave_SQL_State Slave_IO_State Master_Host Master_User Master_Port Connect_Retry Master_Log_File Read_Master_Log_Pos Relay_Log_File Relay_Log_Pos Relay_Master_Log_File Slave_IO_Running Slave_SQL_Running Replicate_Do_DB Replicate_Ignore_DB Replicate_Do_Table Replicate_Ignore_Table Replicate_Wild_Do_Table Replicate_Wild_Ignore_Table Last_Errno Last_Error Skip_Counter Exec_Master_Log_Pos Relay_Log_Space Until_Condition Until_Log_File Until_Log_Pos Master_SSL_Allowed Master_SSL_CA_File Master_SSL_CA_Path Master_SSL_Cert Master_SSL_Cipher Master_SSL_Key Seconds_Behind_Master Master_SSL_Verify_Server_Cert Last_IO_Errno Last_IO_Error Last_SQL_Errno Last_SQL_Error Replicate_Ignore_Server_Ids Master_Server_Id Master_SSL_Crl Master_SSL_Crlpath Using_Gtid Gtid_IO_Pos Replicate_Do_Domain_Ids Replicate_Ignore_Domain_Ids Parallel_Mode SQL_Delay SQL_Remaining_Delay Slave_SQL_Running_State Slave_DDL_Groups Slave_Non_Transactional_Groups Slave_Transactional_Groups Replicate_Rewrite_DB Retried_transactions Max_relay_log_size Executed_log_entries Slave_received_heartbeats Slave_heartbeat_period Gtid_Slave_Pos Master_last_event_time Slave_last_event_time Master_Slave_time_diff
|
||||
Slave has read all relay log; waiting for more updates Waiting for master to send event 127.0.0.1 root MYPORT_1 60 master-bin.000001 <read_master_log_pos> relay.000002 <relay_log_pos> master-bin.000001 Yes Yes 0 0 <read_master_log_pos> <relay_log_space1> None 0 Yes 0 No 0 0 1 No optimistic 0 NULL Slave has read all relay log; waiting for more updates 0 0 0 0 1073741824 7 0 60.000 NULL NULL NULL
|
||||
MASTER 2.2 Slave has read all relay log; waiting for more updates Waiting for master to send event 127.0.0.1 root MYPORT_2 60 master-bin.000001 <read_master_log_pos> relay-master@00202@002e2.000002 <relay_log_pos> master-bin.000001 Yes Yes 0 0 <read_master_log_pos> <relay_log_space2> None 0 Yes 0 No 0 0 2 No optimistic 0 NULL Slave has read all relay log; waiting for more updates 0 0 0 0 1073741824 7 0 60.000 NULL NULL NULL
|
||||
Connection_name Slave_SQL_State Slave_IO_State Master_Host Master_User Master_Port Connect_Retry Master_Log_File Read_Master_Log_Pos Relay_Log_File Relay_Log_Pos Relay_Master_Log_File Slave_IO_Running Slave_SQL_Running Replicate_Do_DB Replicate_Ignore_DB Replicate_Do_Table Replicate_Ignore_Table Replicate_Wild_Do_Table Replicate_Wild_Ignore_Table Last_Errno Last_Error Skip_Counter Exec_Master_Log_Pos Relay_Log_Space Until_Condition Until_Log_File Until_Log_Pos Master_SSL_Allowed Master_SSL_CA_File Master_SSL_CA_Path Master_SSL_Cert Master_SSL_Cipher Master_SSL_Key Seconds_Behind_Master Master_SSL_Verify_Server_Cert Last_IO_Errno Last_IO_Error Last_SQL_Errno Last_SQL_Error Replicate_Ignore_Server_Ids Master_Server_Id Master_SSL_Crl Master_SSL_Crlpath Using_Gtid Gtid_IO_Pos Replicate_Do_Domain_Ids Replicate_Ignore_Domain_Ids Parallel_Mode SQL_Delay SQL_Remaining_Delay Slave_SQL_Running_State Slave_DDL_Groups Slave_Non_Transactional_Groups Slave_Transactional_Groups Replicate_Rewrite_DB Connects_Tried Master_Retry_Count Retried_transactions Max_relay_log_size Executed_log_entries Slave_received_heartbeats Slave_heartbeat_period Gtid_Slave_Pos Master_last_event_time Slave_last_event_time Master_Slave_time_diff
|
||||
Slave has read all relay log; waiting for more updates Waiting for master to send event 127.0.0.1 root MYPORT_1 60 master-bin.000001 <read_master_log_pos> relay.000002 <relay_log_pos> master-bin.000001 Yes Yes 0 0 <read_master_log_pos> <relay_log_space1> None 0 Yes 0 No 0 0 1 No optimistic 0 NULL Slave has read all relay log; waiting for more updates 0 0 0 1 100000 0 1073741824 7 0 60.000 NULL NULL NULL
|
||||
MASTER 2.2 Slave has read all relay log; waiting for more updates Waiting for master to send event 127.0.0.1 root MYPORT_2 60 master-bin.000001 <read_master_log_pos> relay-master@00202@002e2.000002 <relay_log_pos> master-bin.000001 Yes Yes 0 0 <read_master_log_pos> <relay_log_space2> None 0 Yes 0 No 0 0 2 No optimistic 0 NULL Slave has read all relay log; waiting for more updates 0 0 0 1 100000 0 1073741824 7 0 60.000 NULL NULL NULL
|
||||
include/wait_for_slave_to_start.inc
|
||||
set default_master_connection = 'MASTER 2.2';
|
||||
include/wait_for_slave_to_start.inc
|
||||
set default_master_connection = '';
|
||||
show all slaves status;
|
||||
Connection_name Slave_SQL_State Slave_IO_State Master_Host Master_User Master_Port Connect_Retry Master_Log_File Read_Master_Log_Pos Relay_Log_File Relay_Log_Pos Relay_Master_Log_File Slave_IO_Running Slave_SQL_Running Replicate_Do_DB Replicate_Ignore_DB Replicate_Do_Table Replicate_Ignore_Table Replicate_Wild_Do_Table Replicate_Wild_Ignore_Table Last_Errno Last_Error Skip_Counter Exec_Master_Log_Pos Relay_Log_Space Until_Condition Until_Log_File Until_Log_Pos Master_SSL_Allowed Master_SSL_CA_File Master_SSL_CA_Path Master_SSL_Cert Master_SSL_Cipher Master_SSL_Key Seconds_Behind_Master Master_SSL_Verify_Server_Cert Last_IO_Errno Last_IO_Error Last_SQL_Errno Last_SQL_Error Replicate_Ignore_Server_Ids Master_Server_Id Master_SSL_Crl Master_SSL_Crlpath Using_Gtid Gtid_IO_Pos Replicate_Do_Domain_Ids Replicate_Ignore_Domain_Ids Parallel_Mode SQL_Delay SQL_Remaining_Delay Slave_SQL_Running_State Slave_DDL_Groups Slave_Non_Transactional_Groups Slave_Transactional_Groups Replicate_Rewrite_DB Retried_transactions Max_relay_log_size Executed_log_entries Slave_received_heartbeats Slave_heartbeat_period Gtid_Slave_Pos Master_last_event_time Slave_last_event_time Master_Slave_time_diff
|
||||
Slave has read all relay log; waiting for more updates Waiting for master to send event 127.0.0.1 root MYPORT_1 60 master-bin.000001 <read_master_log_pos> relay.000004 <relay_log_pos> master-bin.000001 Yes Yes 0 0 <read_master_log_pos> <relay_log_space1> None 0 Yes 0 No 0 0 1 No optimistic 0 NULL Slave has read all relay log; waiting for more updates 0 0 0 0 1073741824 6 0 60.000 NULL NULL NULL
|
||||
MASTER 2.2 Slave has read all relay log; waiting for more updates Waiting for master to send event 127.0.0.1 root MYPORT_2 60 master-bin.000001 <read_master_log_pos> relay-master@00202@002e2.000004 <relay_log_pos> master-bin.000001 Yes Yes 0 0 <read_master_log_pos> <relay_log_space2> None 0 Yes 0 No 0 0 2 No optimistic 0 NULL Slave has read all relay log; waiting for more updates 0 0 0 0 1073741824 6 0 60.000 NULL NULL NULL
|
||||
Connection_name Slave_SQL_State Slave_IO_State Master_Host Master_User Master_Port Connect_Retry Master_Log_File Read_Master_Log_Pos Relay_Log_File Relay_Log_Pos Relay_Master_Log_File Slave_IO_Running Slave_SQL_Running Replicate_Do_DB Replicate_Ignore_DB Replicate_Do_Table Replicate_Ignore_Table Replicate_Wild_Do_Table Replicate_Wild_Ignore_Table Last_Errno Last_Error Skip_Counter Exec_Master_Log_Pos Relay_Log_Space Until_Condition Until_Log_File Until_Log_Pos Master_SSL_Allowed Master_SSL_CA_File Master_SSL_CA_Path Master_SSL_Cert Master_SSL_Cipher Master_SSL_Key Seconds_Behind_Master Master_SSL_Verify_Server_Cert Last_IO_Errno Last_IO_Error Last_SQL_Errno Last_SQL_Error Replicate_Ignore_Server_Ids Master_Server_Id Master_SSL_Crl Master_SSL_Crlpath Using_Gtid Gtid_IO_Pos Replicate_Do_Domain_Ids Replicate_Ignore_Domain_Ids Parallel_Mode SQL_Delay SQL_Remaining_Delay Slave_SQL_Running_State Slave_DDL_Groups Slave_Non_Transactional_Groups Slave_Transactional_Groups Replicate_Rewrite_DB Connects_Tried Master_Retry_Count Retried_transactions Max_relay_log_size Executed_log_entries Slave_received_heartbeats Slave_heartbeat_period Gtid_Slave_Pos Master_last_event_time Slave_last_event_time Master_Slave_time_diff
|
||||
Slave has read all relay log; waiting for more updates Waiting for master to send event 127.0.0.1 root MYPORT_1 60 master-bin.000001 <read_master_log_pos> relay.000004 <relay_log_pos> master-bin.000001 Yes Yes 0 0 <read_master_log_pos> <relay_log_space1> None 0 Yes 0 No 0 0 1 No optimistic 0 NULL Slave has read all relay log; waiting for more updates 0 0 0 1 100000 0 1073741824 6 0 60.000 NULL NULL NULL
|
||||
MASTER 2.2 Slave has read all relay log; waiting for more updates Waiting for master to send event 127.0.0.1 root MYPORT_2 60 master-bin.000001 <read_master_log_pos> relay-master@00202@002e2.000004 <relay_log_pos> master-bin.000001 Yes Yes 0 0 <read_master_log_pos> <relay_log_space2> None 0 Yes 0 No 0 0 2 No optimistic 0 NULL Slave has read all relay log; waiting for more updates 0 0 0 1 100000 0 1073741824 6 0 60.000 NULL NULL NULL
|
||||
#
|
||||
# List of files matching '*info*' pattern
|
||||
# after slave server restart
|
||||
|
|
|
|||
|
|
@ -76,6 +76,8 @@ Slave_DDL_Groups 0
|
|||
Slave_Non_Transactional_Groups 0
|
||||
Slave_Transactional_Groups 0
|
||||
Replicate_Rewrite_DB
|
||||
Connects_Tried 1
|
||||
Master_Retry_Count 100000
|
||||
Retried_transactions 0
|
||||
Max_relay_log_size 1073741824
|
||||
Executed_log_entries 7
|
||||
|
|
@ -141,6 +143,8 @@ Slave_DDL_Groups 0
|
|||
Slave_Non_Transactional_Groups 0
|
||||
Slave_Transactional_Groups 0
|
||||
Replicate_Rewrite_DB
|
||||
Connects_Tried 1
|
||||
Master_Retry_Count 100000
|
||||
Retried_transactions 0
|
||||
Max_relay_log_size 1073741824
|
||||
Executed_log_entries 7
|
||||
|
|
|
|||
|
|
@ -13,15 +13,15 @@ insert into t1 values (1),(2);
|
|||
connection slave;
|
||||
stop slave 'master1';
|
||||
show slave 'master1' status;
|
||||
Slave_IO_State Master_Host Master_User Master_Port Connect_Retry Master_Log_File Read_Master_Log_Pos Relay_Log_File Relay_Log_Pos Relay_Master_Log_File Slave_IO_Running Slave_SQL_Running Replicate_Do_DB Replicate_Ignore_DB Replicate_Do_Table Replicate_Ignore_Table Replicate_Wild_Do_Table Replicate_Wild_Ignore_Table Last_Errno Last_Error Skip_Counter Exec_Master_Log_Pos Relay_Log_Space Until_Condition Until_Log_File Until_Log_Pos Master_SSL_Allowed Master_SSL_CA_File Master_SSL_CA_Path Master_SSL_Cert Master_SSL_Cipher Master_SSL_Key Seconds_Behind_Master Master_SSL_Verify_Server_Cert Last_IO_Errno Last_IO_Error Last_SQL_Errno Last_SQL_Error Replicate_Ignore_Server_Ids Master_Server_Id Master_SSL_Crl Master_SSL_Crlpath Using_Gtid Gtid_IO_Pos Replicate_Do_Domain_Ids Replicate_Ignore_Domain_Ids Parallel_Mode SQL_Delay SQL_Remaining_Delay Slave_SQL_Running_State Slave_DDL_Groups Slave_Non_Transactional_Groups Slave_Transactional_Groups Replicate_Rewrite_DB
|
||||
127.0.0.1 root MYPORT_1 60 master-bin.000001 <read_master_log_pos> mysqld-relay-bin-master1.000002 <relay_log_pos> master-bin.000001 No No 0 0 <read_master_log_pos> <relay_log_space> None 0 Yes NULL No 0 0 1 Slave_Pos 0-1-3 optimistic 0 NULL 2 1 0
|
||||
Slave_IO_State Master_Host Master_User Master_Port Connect_Retry Master_Log_File Read_Master_Log_Pos Relay_Log_File Relay_Log_Pos Relay_Master_Log_File Slave_IO_Running Slave_SQL_Running Replicate_Do_DB Replicate_Ignore_DB Replicate_Do_Table Replicate_Ignore_Table Replicate_Wild_Do_Table Replicate_Wild_Ignore_Table Last_Errno Last_Error Skip_Counter Exec_Master_Log_Pos Relay_Log_Space Until_Condition Until_Log_File Until_Log_Pos Master_SSL_Allowed Master_SSL_CA_File Master_SSL_CA_Path Master_SSL_Cert Master_SSL_Cipher Master_SSL_Key Seconds_Behind_Master Master_SSL_Verify_Server_Cert Last_IO_Errno Last_IO_Error Last_SQL_Errno Last_SQL_Error Replicate_Ignore_Server_Ids Master_Server_Id Master_SSL_Crl Master_SSL_Crlpath Using_Gtid Gtid_IO_Pos Replicate_Do_Domain_Ids Replicate_Ignore_Domain_Ids Parallel_Mode SQL_Delay SQL_Remaining_Delay Slave_SQL_Running_State Slave_DDL_Groups Slave_Non_Transactional_Groups Slave_Transactional_Groups Replicate_Rewrite_DB Connects_Tried Master_Retry_Count
|
||||
127.0.0.1 root MYPORT_1 60 master-bin.000001 <read_master_log_pos> mysqld-relay-bin-master1.000002 <relay_log_pos> master-bin.000001 No No 0 0 <read_master_log_pos> <relay_log_space> None 0 Yes NULL No 0 0 1 Slave_Pos 0-1-3 optimistic 0 NULL 2 1 0 1 100000
|
||||
mysqld-relay-bin-master1.000001
|
||||
mysqld-relay-bin-master1.000002
|
||||
mysqld-relay-bin-master1.index
|
||||
reset slave 'master1';
|
||||
show slave 'master1' status;
|
||||
Slave_IO_State Master_Host Master_User Master_Port Connect_Retry Master_Log_File Read_Master_Log_Pos Relay_Log_File Relay_Log_Pos Relay_Master_Log_File Slave_IO_Running Slave_SQL_Running Replicate_Do_DB Replicate_Ignore_DB Replicate_Do_Table Replicate_Ignore_Table Replicate_Wild_Do_Table Replicate_Wild_Ignore_Table Last_Errno Last_Error Skip_Counter Exec_Master_Log_Pos Relay_Log_Space Until_Condition Until_Log_File Until_Log_Pos Master_SSL_Allowed Master_SSL_CA_File Master_SSL_CA_Path Master_SSL_Cert Master_SSL_Cipher Master_SSL_Key Seconds_Behind_Master Master_SSL_Verify_Server_Cert Last_IO_Errno Last_IO_Error Last_SQL_Errno Last_SQL_Error Replicate_Ignore_Server_Ids Master_Server_Id Master_SSL_Crl Master_SSL_Crlpath Using_Gtid Gtid_IO_Pos Replicate_Do_Domain_Ids Replicate_Ignore_Domain_Ids Parallel_Mode SQL_Delay SQL_Remaining_Delay Slave_SQL_Running_State Slave_DDL_Groups Slave_Non_Transactional_Groups Slave_Transactional_Groups Replicate_Rewrite_DB
|
||||
127.0.0.1 root MYPORT_1 60 4 <relay_log_pos> No No 0 0 0 <relay_log_space> None 0 Yes NULL No 0 0 1 Slave_Pos optimistic 0 NULL 2 1 0
|
||||
Slave_IO_State Master_Host Master_User Master_Port Connect_Retry Master_Log_File Read_Master_Log_Pos Relay_Log_File Relay_Log_Pos Relay_Master_Log_File Slave_IO_Running Slave_SQL_Running Replicate_Do_DB Replicate_Ignore_DB Replicate_Do_Table Replicate_Ignore_Table Replicate_Wild_Do_Table Replicate_Wild_Ignore_Table Last_Errno Last_Error Skip_Counter Exec_Master_Log_Pos Relay_Log_Space Until_Condition Until_Log_File Until_Log_Pos Master_SSL_Allowed Master_SSL_CA_File Master_SSL_CA_Path Master_SSL_Cert Master_SSL_Cipher Master_SSL_Key Seconds_Behind_Master Master_SSL_Verify_Server_Cert Last_IO_Errno Last_IO_Error Last_SQL_Errno Last_SQL_Error Replicate_Ignore_Server_Ids Master_Server_Id Master_SSL_Crl Master_SSL_Crlpath Using_Gtid Gtid_IO_Pos Replicate_Do_Domain_Ids Replicate_Ignore_Domain_Ids Parallel_Mode SQL_Delay SQL_Remaining_Delay Slave_SQL_Running_State Slave_DDL_Groups Slave_Non_Transactional_Groups Slave_Transactional_Groups Replicate_Rewrite_DB Connects_Tried Master_Retry_Count
|
||||
127.0.0.1 root MYPORT_1 60 4 <relay_log_pos> No No 0 0 0 <relay_log_space> None 0 Yes NULL No 0 0 1 Slave_Pos optimistic 0 NULL 2 1 0 0 100000
|
||||
reset slave 'master1' all;
|
||||
show slave 'master1' status;
|
||||
ERROR HY000: There is no master connection 'master1'
|
||||
|
|
|
|||
|
|
@ -74,6 +74,8 @@ Slave_DDL_Groups 0
|
|||
Slave_Non_Transactional_Groups 0
|
||||
Slave_Transactional_Groups 0
|
||||
Replicate_Rewrite_DB
|
||||
Connects_Tried 1
|
||||
Master_Retry_Count 100000
|
||||
Retried_transactions 0
|
||||
Max_relay_log_size 1073741824
|
||||
Executed_log_entries 7
|
||||
|
|
@ -139,6 +141,8 @@ Slave_DDL_Groups 0
|
|||
Slave_Non_Transactional_Groups 0
|
||||
Slave_Transactional_Groups 0
|
||||
Replicate_Rewrite_DB
|
||||
Connects_Tried 1
|
||||
Master_Retry_Count 100000
|
||||
Retried_transactions 0
|
||||
Max_relay_log_size 1073741824
|
||||
Executed_log_entries 7
|
||||
|
|
@ -269,6 +273,8 @@ Slave_DDL_Groups 0
|
|||
Slave_Non_Transactional_Groups 0
|
||||
Slave_Transactional_Groups 0
|
||||
Replicate_Rewrite_DB
|
||||
Connects_Tried 1
|
||||
Master_Retry_Count 100000
|
||||
reset slave 'slave1';
|
||||
show all slaves status;
|
||||
Connection_name slave1
|
||||
|
|
@ -327,6 +333,8 @@ Slave_DDL_Groups 0
|
|||
Slave_Non_Transactional_Groups 0
|
||||
Slave_Transactional_Groups 0
|
||||
Replicate_Rewrite_DB
|
||||
Connects_Tried 0
|
||||
Master_Retry_Count 100000
|
||||
Retried_transactions 0
|
||||
Max_relay_log_size 1073741824
|
||||
Executed_log_entries 7
|
||||
|
|
@ -392,6 +400,8 @@ Slave_DDL_Groups 0
|
|||
Slave_Non_Transactional_Groups 0
|
||||
Slave_Transactional_Groups 0
|
||||
Replicate_Rewrite_DB
|
||||
Connects_Tried 1
|
||||
Master_Retry_Count 100000
|
||||
Retried_transactions 0
|
||||
Max_relay_log_size 1073741824
|
||||
Executed_log_entries 7
|
||||
|
|
@ -459,6 +469,8 @@ Slave_DDL_Groups 0
|
|||
Slave_Non_Transactional_Groups 0
|
||||
Slave_Transactional_Groups 0
|
||||
Replicate_Rewrite_DB
|
||||
Connects_Tried 1
|
||||
Master_Retry_Count 100000
|
||||
Retried_transactions 0
|
||||
Max_relay_log_size 1073741824
|
||||
Executed_log_entries 7
|
||||
|
|
@ -528,6 +540,8 @@ Slave_DDL_Groups 0
|
|||
Slave_Non_Transactional_Groups 0
|
||||
Slave_Transactional_Groups 0
|
||||
Replicate_Rewrite_DB
|
||||
Connects_Tried 1
|
||||
Master_Retry_Count 100000
|
||||
Retried_transactions 0
|
||||
Max_relay_log_size 1073741824
|
||||
Executed_log_entries 7
|
||||
|
|
|
|||
|
|
@ -1,11 +1,11 @@
|
|||
include/master-slave.inc
|
||||
[connection master]
|
||||
show slave status;
|
||||
Slave_IO_State Master_Host Master_User Master_Port Connect_Retry Master_Log_File Read_Master_Log_Pos Relay_Log_File Relay_Log_Pos Relay_Master_Log_File Slave_IO_Running Slave_SQL_Running Replicate_Do_DB Replicate_Ignore_DB Replicate_Do_Table Replicate_Ignore_Table Replicate_Wild_Do_Table Replicate_Wild_Ignore_Table Last_Errno Last_Error Skip_Counter Exec_Master_Log_Pos Relay_Log_Space Until_Condition Until_Log_File Until_Log_Pos Master_SSL_Allowed Master_SSL_CA_File Master_SSL_CA_Path Master_SSL_Cert Master_SSL_Cipher Master_SSL_Key Seconds_Behind_Master Master_SSL_Verify_Server_Cert Last_IO_Errno Last_IO_Error Last_SQL_Errno Last_SQL_Error Replicate_Ignore_Server_Ids Master_Server_Id Master_SSL_Crl Master_SSL_Crlpath Using_Gtid Gtid_IO_Pos Replicate_Do_Domain_Ids Replicate_Ignore_Domain_Ids Parallel_Mode SQL_Delay SQL_Remaining_Delay Slave_SQL_Running_State Slave_DDL_Groups Slave_Non_Transactional_Groups Slave_Transactional_Groups Replicate_Rewrite_DB
|
||||
Slave_IO_State Master_Host Master_User Master_Port Connect_Retry Master_Log_File Read_Master_Log_Pos Relay_Log_File Relay_Log_Pos Relay_Master_Log_File Slave_IO_Running Slave_SQL_Running Replicate_Do_DB Replicate_Ignore_DB Replicate_Do_Table Replicate_Ignore_Table Replicate_Wild_Do_Table Replicate_Wild_Ignore_Table Last_Errno Last_Error Skip_Counter Exec_Master_Log_Pos Relay_Log_Space Until_Condition Until_Log_File Until_Log_Pos Master_SSL_Allowed Master_SSL_CA_File Master_SSL_CA_Path Master_SSL_Cert Master_SSL_Cipher Master_SSL_Key Seconds_Behind_Master Master_SSL_Verify_Server_Cert Last_IO_Errno Last_IO_Error Last_SQL_Errno Last_SQL_Error Replicate_Ignore_Server_Ids Master_Server_Id Master_SSL_Crl Master_SSL_Crlpath Using_Gtid Gtid_IO_Pos Replicate_Do_Domain_Ids Replicate_Ignore_Domain_Ids Parallel_Mode SQL_Delay SQL_Remaining_Delay Slave_SQL_Running_State Slave_DDL_Groups Slave_Non_Transactional_Groups Slave_Transactional_Groups Replicate_Rewrite_DB Connects_Tried Master_Retry_Count
|
||||
show slave '' status;
|
||||
Slave_IO_State Master_Host Master_User Master_Port Connect_Retry Master_Log_File Read_Master_Log_Pos Relay_Log_File Relay_Log_Pos Relay_Master_Log_File Slave_IO_Running Slave_SQL_Running Replicate_Do_DB Replicate_Ignore_DB Replicate_Do_Table Replicate_Ignore_Table Replicate_Wild_Do_Table Replicate_Wild_Ignore_Table Last_Errno Last_Error Skip_Counter Exec_Master_Log_Pos Relay_Log_Space Until_Condition Until_Log_File Until_Log_Pos Master_SSL_Allowed Master_SSL_CA_File Master_SSL_CA_Path Master_SSL_Cert Master_SSL_Cipher Master_SSL_Key Seconds_Behind_Master Master_SSL_Verify_Server_Cert Last_IO_Errno Last_IO_Error Last_SQL_Errno Last_SQL_Error Replicate_Ignore_Server_Ids Master_Server_Id Master_SSL_Crl Master_SSL_Crlpath Using_Gtid Gtid_IO_Pos Replicate_Do_Domain_Ids Replicate_Ignore_Domain_Ids Parallel_Mode SQL_Delay SQL_Remaining_Delay Slave_SQL_Running_State Slave_DDL_Groups Slave_Non_Transactional_Groups Slave_Transactional_Groups Replicate_Rewrite_DB
|
||||
Slave_IO_State Master_Host Master_User Master_Port Connect_Retry Master_Log_File Read_Master_Log_Pos Relay_Log_File Relay_Log_Pos Relay_Master_Log_File Slave_IO_Running Slave_SQL_Running Replicate_Do_DB Replicate_Ignore_DB Replicate_Do_Table Replicate_Ignore_Table Replicate_Wild_Do_Table Replicate_Wild_Ignore_Table Last_Errno Last_Error Skip_Counter Exec_Master_Log_Pos Relay_Log_Space Until_Condition Until_Log_File Until_Log_Pos Master_SSL_Allowed Master_SSL_CA_File Master_SSL_CA_Path Master_SSL_Cert Master_SSL_Cipher Master_SSL_Key Seconds_Behind_Master Master_SSL_Verify_Server_Cert Last_IO_Errno Last_IO_Error Last_SQL_Errno Last_SQL_Error Replicate_Ignore_Server_Ids Master_Server_Id Master_SSL_Crl Master_SSL_Crlpath Using_Gtid Gtid_IO_Pos Replicate_Do_Domain_Ids Replicate_Ignore_Domain_Ids Parallel_Mode SQL_Delay SQL_Remaining_Delay Slave_SQL_Running_State Slave_DDL_Groups Slave_Non_Transactional_Groups Slave_Transactional_Groups Replicate_Rewrite_DB Connects_Tried Master_Retry_Count
|
||||
show all slaves status;
|
||||
Connection_name Slave_SQL_State Slave_IO_State Master_Host Master_User Master_Port Connect_Retry Master_Log_File Read_Master_Log_Pos Relay_Log_File Relay_Log_Pos Relay_Master_Log_File Slave_IO_Running Slave_SQL_Running Replicate_Do_DB Replicate_Ignore_DB Replicate_Do_Table Replicate_Ignore_Table Replicate_Wild_Do_Table Replicate_Wild_Ignore_Table Last_Errno Last_Error Skip_Counter Exec_Master_Log_Pos Relay_Log_Space Until_Condition Until_Log_File Until_Log_Pos Master_SSL_Allowed Master_SSL_CA_File Master_SSL_CA_Path Master_SSL_Cert Master_SSL_Cipher Master_SSL_Key Seconds_Behind_Master Master_SSL_Verify_Server_Cert Last_IO_Errno Last_IO_Error Last_SQL_Errno Last_SQL_Error Replicate_Ignore_Server_Ids Master_Server_Id Master_SSL_Crl Master_SSL_Crlpath Using_Gtid Gtid_IO_Pos Replicate_Do_Domain_Ids Replicate_Ignore_Domain_Ids Parallel_Mode SQL_Delay SQL_Remaining_Delay Slave_SQL_Running_State Slave_DDL_Groups Slave_Non_Transactional_Groups Slave_Transactional_Groups Replicate_Rewrite_DB Retried_transactions Max_relay_log_size Executed_log_entries Slave_received_heartbeats Slave_heartbeat_period Gtid_Slave_Pos Master_last_event_time Slave_last_event_time Master_Slave_time_diff
|
||||
Connection_name Slave_SQL_State Slave_IO_State Master_Host Master_User Master_Port Connect_Retry Master_Log_File Read_Master_Log_Pos Relay_Log_File Relay_Log_Pos Relay_Master_Log_File Slave_IO_Running Slave_SQL_Running Replicate_Do_DB Replicate_Ignore_DB Replicate_Do_Table Replicate_Ignore_Table Replicate_Wild_Do_Table Replicate_Wild_Ignore_Table Last_Errno Last_Error Skip_Counter Exec_Master_Log_Pos Relay_Log_Space Until_Condition Until_Log_File Until_Log_Pos Master_SSL_Allowed Master_SSL_CA_File Master_SSL_CA_Path Master_SSL_Cert Master_SSL_Cipher Master_SSL_Key Seconds_Behind_Master Master_SSL_Verify_Server_Cert Last_IO_Errno Last_IO_Error Last_SQL_Errno Last_SQL_Error Replicate_Ignore_Server_Ids Master_Server_Id Master_SSL_Crl Master_SSL_Crlpath Using_Gtid Gtid_IO_Pos Replicate_Do_Domain_Ids Replicate_Ignore_Domain_Ids Parallel_Mode SQL_Delay SQL_Remaining_Delay Slave_SQL_Running_State Slave_DDL_Groups Slave_Non_Transactional_Groups Slave_Transactional_Groups Replicate_Rewrite_DB Connects_Tried Master_Retry_Count Retried_transactions Max_relay_log_size Executed_log_entries Slave_received_heartbeats Slave_heartbeat_period Gtid_Slave_Pos Master_last_event_time Slave_last_event_time Master_Slave_time_diff
|
||||
#
|
||||
# Check error handling
|
||||
#
|
||||
|
|
|
|||
|
|
@ -67,6 +67,8 @@ Slave_DDL_Groups #
|
|||
Slave_Non_Transactional_Groups #
|
||||
Slave_Transactional_Groups #
|
||||
Replicate_Rewrite_DB #
|
||||
Connects_Tried #
|
||||
Master_Retry_Count #
|
||||
*
|
||||
* When modifying this test after adding a column to SHOW SLAVE STATUS,
|
||||
* _only_ additions at the end are allowed, the column number of existing
|
||||
|
|
|
|||
|
|
@ -14,7 +14,7 @@
|
|||
--echo *
|
||||
|
||||
--connection slave
|
||||
--replace_column 1 # 2 # 3 # 4 # 5 # 6 # 7 # 8 # 9 # 10 # 11 # 12 # 13 # 14 # 15 # 16 # 17 # 18 # 19 # 20 # 21 # 22 # 23 # 24 # 25 # 26 # 27 # 28 # 29 # 30 # 31 # 32 # 33 # 34 # 35 # 36 # 37 # 38 # 39 # 40 # 41 # 42 # 43 # 44 # 45 # 46 # 47 # 48 # 49 # 50 # 51 # 52 # 53 # 54 #
|
||||
--replace_column 1 # 2 # 3 # 4 # 5 # 6 # 7 # 8 # 9 # 10 # 11 # 12 # 13 # 14 # 15 # 16 # 17 # 18 # 19 # 20 # 21 # 22 # 23 # 24 # 25 # 26 # 27 # 28 # 29 # 30 # 31 # 32 # 33 # 34 # 35 # 36 # 37 # 38 # 39 # 40 # 41 # 42 # 43 # 44 # 45 # 46 # 47 # 48 # 49 # 50 # 51 # 52 # 53 # 54 # 55 # 56 #
|
||||
query_vertical
|
||||
SHOW SLAVE STATUS;
|
||||
|
||||
|
|
|
|||
|
|
@ -36,7 +36,7 @@ Master_info::Master_info(LEX_CSTRING *connection_name_arg,
|
|||
rli(is_slave_recovery), port(MYSQL_PORT),
|
||||
checksum_alg_before_fd(BINLOG_CHECKSUM_ALG_UNDEF),
|
||||
connect_retry(DEFAULT_CONNECT_RETRY), retry_count(master_retry_count),
|
||||
inited(0), abort_slave(0),
|
||||
connects_tried(0), inited(0), abort_slave(0),
|
||||
slave_running(MYSQL_SLAVE_NOT_RUN), slave_run_id(0),
|
||||
clock_diff_with_master(0),
|
||||
sync_counter(0), heartbeat_period(0), received_heartbeats(0),
|
||||
|
|
|
|||
|
|
@ -257,6 +257,8 @@ class Master_info : public Slave_reporting_capability
|
|||
uint connect_retry;
|
||||
/** per-slave @ref master_retry_count */
|
||||
ulong retry_count;
|
||||
/** count of connects the most-recent (or the current) connection has tried */
|
||||
ulong connects_tried;
|
||||
#ifndef DBUG_OFF
|
||||
int events_till_disconnect;
|
||||
|
||||
|
|
|
|||
15
sql/slave.cc
15
sql/slave.cc
|
|
@ -3117,6 +3117,10 @@ void store_master_info(THD *thd, Master_info *mi, TABLE *table,
|
|||
rpl_filter->get_rewrite_db(&tmp);
|
||||
(*field++)->store(tmp.ptr(), tmp.length(), &my_charset_bin);
|
||||
|
||||
(*field++)->store(static_cast<long long>(mi->connects_tried), true);
|
||||
(*field++)->store(static_cast<long long>(mi->retry_count), true);
|
||||
|
||||
// SHOW ALL SLAVE STATUS additional entries commences-
|
||||
(*field++)->store((uint32) mi->rli.retried_trans, true);
|
||||
(*field++)->store((ulonglong) mi->rli.max_relay_log_size, true);
|
||||
(*field++)->store(mi->rli.executed_entries, true);
|
||||
|
|
@ -4389,9 +4393,9 @@ static bool check_io_slave_killed(Master_info *mi, const char *info)
|
|||
|
||||
@details Terminates current connection to master
|
||||
and initiates new connection with safe_reconnect(), which sleeps for
|
||||
@c mi->connect_retry msecs and increases @c mi->TODO for each attempt -
|
||||
if it exceeds @c mi->retry_count then connection is not re-established
|
||||
and function signals error.
|
||||
@c mi->connect_retry msecs and increases @c mi->connects_tried for each
|
||||
attempt - if it exceeds @c mi->retry_count then connection is not
|
||||
re-established and function signals error.
|
||||
Unless @c suppres_warnings is TRUE, a warning is put in the server error log
|
||||
when reconnecting. The warning message and messages used to report errors
|
||||
are taken from @c messages array.
|
||||
|
|
@ -6941,7 +6945,7 @@ static int connect_to_master(THD* thd, MYSQL* mysql, Master_info* mi,
|
|||
{
|
||||
int slave_was_killed;
|
||||
int last_errno= -2; // impossible error
|
||||
ulong err_count=0;
|
||||
mi->connects_tried= 0; // reset retry counter
|
||||
my_bool my_true= 1;
|
||||
DBUG_ENTER("connect_to_master");
|
||||
set_slave_max_allowed_packet(thd, mysql);
|
||||
|
|
@ -7019,7 +7023,7 @@ static int connect_to_master(THD* thd, MYSQL* mysql, Master_info* mi,
|
|||
mi->connect_retry, mi->retry_count,
|
||||
mysql_error(mysql));
|
||||
}
|
||||
if (++err_count == mi->retry_count)
|
||||
if (++(mi->connects_tried) == mi->retry_count)
|
||||
{
|
||||
slave_was_killed=1;
|
||||
if (reconnect)
|
||||
|
|
@ -7046,6 +7050,7 @@ static int connect_to_master(THD* thd, MYSQL* mysql, Master_info* mi,
|
|||
general_log_print(thd, COM_CONNECT_OUT, "%s@%s:%d",
|
||||
mi->user, mi->host, mi->port);
|
||||
}
|
||||
++(mi->connects_tried); // count the final success in addition to failures
|
||||
#ifdef SIGNAL_WITH_VIO_CLOSE
|
||||
thd->set_active_vio(mysql->net.vio);
|
||||
#endif
|
||||
|
|
|
|||
|
|
@ -3707,6 +3707,7 @@ int reset_slave(THD *thd, Master_info* mi)
|
|||
mi->rli.clear_until_condition();
|
||||
mi->rli.clear_sql_delay();
|
||||
mi->rli.slave_skip_counter= 0;
|
||||
mi->connects_tried= 0;
|
||||
mi->rli.newest_master_timestamp= 0;
|
||||
mi->rli.slave_timestamp= 0;
|
||||
|
||||
|
|
|
|||
|
|
@ -9207,14 +9207,14 @@ int make_proc_old_format(THD *thd, ST_SCHEMA_TABLE *schema_table)
|
|||
Constants for columns that are present in
|
||||
SHOW ALL SLAVES STATUS
|
||||
that are not in SHOW SLAVE STATUS. Specifically, columns 0 and 1, and
|
||||
everything at and above 56.
|
||||
everything at and above 58.
|
||||
0: Connection_name
|
||||
1: Slave_SQL_State
|
||||
56: Retried_transactions
|
||||
58: Retried_transactions
|
||||
*/
|
||||
#define SLAVE_STATUS_COL_CONNECTION_NAME 0
|
||||
#define SLAVE_STATUS_COL_SLAVE_SQL_STATE 1
|
||||
#define SLAVE_STATUS_COL_RETRIED_TRANSACTIONS 56
|
||||
#define SLAVE_STATUS_COL_RETRIED_TRANSACTIONS 58
|
||||
|
||||
static int make_slave_status_old_format(THD *thd, ST_SCHEMA_TABLE *schema_table)
|
||||
{
|
||||
|
|
@ -10708,6 +10708,8 @@ ST_FIELD_INFO slave_status_info[]=
|
|||
Column("Slave_Non_Transactional_Groups", ULonglong(20), NOT_NULL),
|
||||
Column("Slave_Transactional_Groups", ULonglong(20), NOT_NULL),
|
||||
Column("Replicate_Rewrite_DB", Varchar(), NOT_NULL),
|
||||
Column("Connects_Tried", ULonglong(20), NOT_NULL),
|
||||
Column("Master_Retry_Count", ULonglong(20), NOT_NULL),
|
||||
Column("Retried_transactions", ULong(10), NOT_NULL),
|
||||
Column("Max_relay_log_size", ULong(10), NOT_NULL),
|
||||
Column("Executed_log_entries", ULong(10), NOT_NULL),
|
||||
|
|
|
|||
|
|
@ -469,7 +469,7 @@ static void test_prepare_simple()
|
|||
strmov(query, "SHOW SLAVE STATUS");
|
||||
stmt= mysql_simple_prepare(mysql, query);
|
||||
check_stmt(stmt);
|
||||
DIE_UNLESS(mysql_stmt_field_count(stmt) == 54);
|
||||
DIE_UNLESS(mysql_stmt_field_count(stmt) == 56);
|
||||
mysql_stmt_close(stmt);
|
||||
|
||||
/* show master status */
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue