|
| 1 | +#==== Purpose ==== |
| 2 | +# |
| 3 | +# This test script purpose is to check semisync replication |
| 4 | +# behaviour when there are semisync slaves getting added and |
| 5 | +# removed while dml changes are happening. |
| 6 | +# |
| 7 | +#==== Implementation ==== |
| 8 | +# |
| 9 | +# 1) Install semisync on one Master and 8 Slaves. |
| 10 | +# 2) Using mysqlslap, keep inserting data in background on Master. |
| 11 | +# 3) While the DMLs are going on, keep adding/removing semisync slaves. |
| 12 | +# 4) At the end of the step-3, check that the data is synced without any |
| 13 | +# issues. |
| 14 | +# 5) Check semisync is still enabled on Master and all slaves. |
| 15 | +# |
| 16 | +#==== References ==== |
| 17 | +# |
| 18 | +# Bug#27610678 SEMI-SYNC REPLICATION DOESN'T WORK FOR MINUTES AFTER RESTART |
| 19 | +# REPLICATION |
| 20 | +# |
| 21 | +#======== |
| 22 | +# |
| 23 | +# 9 servers + 5000 inserts involved in test. Hence marking it as big-test. |
| 24 | +# |
| 25 | +--source include/big_test.inc |
| 26 | +--source include/not_group_replication_plugin.inc |
| 27 | +--source include/have_binlog_format_statement.inc |
| 28 | +--source include/have_debug.inc |
| 29 | + |
| 30 | +# |
| 31 | +# One Master and 8 Slaves in the semi sync topology. |
| 32 | +# |
| 33 | +--let rpl_topology=1->2, 1->3, 1->4, 1->5, 1->6, 1->7, 1->8, 1->9 |
| 34 | +--source include/rpl_init.inc |
| 35 | + |
| 36 | +--echo # |
| 37 | +--echo # 1. Initial data. |
| 38 | +--echo # |
| 39 | +CREATE TABLE t1(c1 INT); |
| 40 | +--source include/rpl_sync.inc |
| 41 | + |
| 42 | +--echo # |
| 43 | +--echo # 2. Install semisync on all the 9 servers. |
| 44 | +--echo # |
| 45 | +--let $i= 1 |
| 46 | +while ($i < 10) |
| 47 | +{ |
| 48 | + --let $rpl_connection_name= server_$i |
| 49 | + --source include/rpl_connection.inc |
| 50 | + if ( $i == 1) |
| 51 | + { |
| 52 | + --connect(server1_1, localhost,root,,,$MASTER_MYPORT) |
| 53 | + CALL mtr.add_suppression("Semi-sync master failed on net_flush.*"); |
| 54 | + --source include/install_semisync_master.inc |
| 55 | + } |
| 56 | + if ( $i != 1 ) |
| 57 | + { |
| 58 | + CALL mtr.add_suppression("Semi-sync slave net_flush.*"); |
| 59 | + --source include/install_semisync_slave.inc |
| 60 | + } |
| 61 | + --inc $i |
| 62 | +} |
| 63 | + |
| 64 | +--echo # |
| 65 | +--echo # 3. Make Master aware of 8 semisync slaves. |
| 66 | +--echo # |
| 67 | +--let $rpl_connection_name= server1_1 |
| 68 | +--source include/rpl_connection.inc |
| 69 | +--let $slaves = 8 |
| 70 | +--eval SET GLOBAL rpl_semi_sync_master_wait_for_slave_count = $slaves |
| 71 | + |
| 72 | +--echo # |
| 73 | +--echo # 4. Insert 5000 tuples in background using 10 parallel connections. |
| 74 | +--echo # |
| 75 | +--exec_in_background $MYSQL_SLAP --create-schema=test --delimiter=";" --iterations=500 --query="INSERT INTO t1 values (1)" --concurrency=10 --silent 2>&1 |
| 76 | + |
| 77 | +--echo # |
| 78 | +--echo # 5. While the insert operations are going in the background, keep |
| 79 | +--echo # adding/removing semisync slaves randomly. |
| 80 | +--echo # |
| 81 | +--let $rpl_connection_silent = 1 |
| 82 | +--let $include_silent= 1 |
| 83 | +--disable_result_log |
| 84 | +--disable_query_log |
| 85 | +--let $rpl_debug= 0 |
| 86 | +--let $iter= 1 |
| 87 | +while ( $iter < 50 ) |
| 88 | +{ |
| 89 | + # Random server_id generator ( server_id will between [2-9] |
| 90 | + --let $server_id=`SELECT FLOOR(2 + ((RAND() * 100) % 8))` |
| 91 | + --let $rpl_connection_name= server_$server_id |
| 92 | + --source include/rpl_connection.inc |
| 93 | + --let $service_state= `SELECT service_state FROM performance_schema.replication_connection_status` |
| 94 | + if ($service_state == 'ON') |
| 95 | + { |
| 96 | + # If the replication state is ON, bring it down. |
| 97 | + --source include/stop_slave.inc |
| 98 | + --let $rpl_connection_name= server1_1 |
| 99 | + --source include/rpl_connection.inc |
| 100 | + # Adjust rpl_semi_sync_master_wait_for_slave_count variable. |
| 101 | + --dec $slaves |
| 102 | + --eval SET GLOBAL rpl_semi_sync_master_wait_for_slave_count = $slaves |
| 103 | + } |
| 104 | + if ($service_state == 'OFF') |
| 105 | + { |
| 106 | + # If the replication state is OFF, bring it up. |
| 107 | + --source include/start_slave.inc |
| 108 | + --let $rpl_connection_name= server1_1 |
| 109 | + --source include/rpl_connection.inc |
| 110 | + # Adjust rpl_semi_sync_master_wait_for_slave_count variable. |
| 111 | + --inc $slaves |
| 112 | + --eval SET GLOBAL rpl_semi_sync_master_wait_for_slave_count = $slaves |
| 113 | + } |
| 114 | + --inc $iter |
| 115 | + # Do it slowly while insertions on the master are happening in the background. |
| 116 | + sleep 1; |
| 117 | +} |
| 118 | + |
| 119 | +--echo # |
| 120 | +--echo # 6. Add all 8 semisync slaves back to Master |
| 121 | +--echo # (if they were disconnected, in above step). |
| 122 | +--echo # |
| 123 | +--let $iter = 2 |
| 124 | +while ($iter <= 9) |
| 125 | +{ |
| 126 | + --let $rpl_connection_name= server_$iter |
| 127 | + --source include/rpl_connection.inc |
| 128 | + --let $service_state= `SELECT service_state FROM performance_schema.replication_connection_status` |
| 129 | + if ($service_state == 'OFF') |
| 130 | + { |
| 131 | + --source include/start_slave.inc |
| 132 | + --let $rpl_connection_name= server1_1 |
| 133 | + --source include/rpl_connection.inc |
| 134 | + # Adjust rpl_semi_sync_master_wait_for_slave_count variable. |
| 135 | + --inc $slaves |
| 136 | + --eval SET GLOBAL rpl_semi_sync_master_wait_for_slave_count = $slaves |
| 137 | + } |
| 138 | + --inc $iter |
| 139 | +} |
| 140 | +--enable_result_log |
| 141 | +--enable_query_log |
| 142 | +--let $rpl_connection_silent = 0 |
| 143 | +--let $include_silent= 0 |
| 144 | + |
| 145 | + |
| 146 | +--echo # |
| 147 | +--echo # 7. Make sure the data is synced on Master without any issues. |
| 148 | +--echo # |
| 149 | +--let $rpl_connection_name= server_1 |
| 150 | +--source include/rpl_connection.inc |
| 151 | +--let $wait_timeout= 60 |
| 152 | +--let $wait_condition= SELECT count(*) = 5000 FROM t1 |
| 153 | +--source include/wait_condition.inc |
| 154 | +--let $slave_timeout=600 |
| 155 | +--source include/rpl_sync.inc |
| 156 | + |
| 157 | +--echo # |
| 158 | +--echo # 8. Check on all servers semisync is enabled after the |
| 159 | +--echo # the experiment and then uninstall semisync pluging |
| 160 | +--echo # from it. |
| 161 | +--echo # |
| 162 | +--let $i= 9 |
| 163 | +while ($i >= 1) |
| 164 | +{ |
| 165 | + --let $rpl_connection_name= server_$i |
| 166 | + --source include/rpl_connection.inc |
| 167 | + if ( $i == 1) |
| 168 | + { |
| 169 | + --let $assert_variable_name= rpl_semi_sync_master_enabled |
| 170 | + --let $assert_variable_value= 1 |
| 171 | + --source include/assert_variable.inc |
| 172 | + --source include/uninstall_semisync_master.inc |
| 173 | + } |
| 174 | + if ( $i != 1 ) |
| 175 | + { |
| 176 | + --let $assert_variable_name= rpl_semi_sync_slave_enabled |
| 177 | + --let $assert_variable_value= 1 |
| 178 | + --source include/assert_variable.inc |
| 179 | + --source include/uninstall_semisync_slave.inc |
| 180 | + } |
| 181 | + --dec $i |
| 182 | +} |
| 183 | + |
| 184 | +--echo # |
| 185 | +--echo # 9. Cleanup time. |
| 186 | +--echo # |
| 187 | +--let $rpl_connection_name= server_1 |
| 188 | +--source include/rpl_connection.inc |
| 189 | +DROP TABLE t1; |
| 190 | +--source include/rpl_end.inc |
0 commit comments