1include/master-slave.inc 2[connection master] 3call mtr.add_suppression("Recovery from master pos .*"); 4call mtr.add_suppression("Error in Log_event::read_log_event()"); 5call mtr.add_suppression("Failed to read information on Previous GTIDs."); 6call mtr.add_suppression("Error reading GTIDs from binary log"); 7include/rpl_set_gtid_mode.inc 8CREATE TABLE t1(id INTEGER) ENGINE= Innodb; 9==== Part 1 ==== 10include/rpl_reset.inc 11---- i=1 ---- 12BEGIN; 13INSERT INTO t1 VALUES(1); 14INSERT INTO t1 VALUES(2); 15COMMIT; 16extra/rpl_tests/rpl_check_gtid.inc 17include/sync_slave_sql_with_master.inc 18extra/rpl_tests/rpl_check_gtid.inc 19extra/rpl_tests/rpl_check_gtid.inc 20BEGIN; 21INSERT INTO t1 VALUES(1); 22INSERT INTO t1 VALUES(2); 23COMMIT; 24extra/rpl_tests/rpl_check_gtid.inc 25FLUSH LOGS; 26FLUSH LOGS; 27---- i=2 ---- 28BEGIN; 29INSERT INTO t1 VALUES(1); 30INSERT INTO t1 VALUES(2); 31COMMIT; 32extra/rpl_tests/rpl_check_gtid.inc 33include/sync_slave_sql_with_master.inc 34extra/rpl_tests/rpl_check_gtid.inc 35extra/rpl_tests/rpl_check_gtid.inc 36BEGIN; 37INSERT INTO t1 VALUES(1); 38INSERT INTO t1 VALUES(2); 39COMMIT; 40extra/rpl_tests/rpl_check_gtid.inc 41FLUSH LOGS; 42FLUSH LOGS; 43---- i=3 ---- 44BEGIN; 45INSERT INTO t1 VALUES(1); 46INSERT INTO t1 VALUES(2); 47COMMIT; 48extra/rpl_tests/rpl_check_gtid.inc 49include/sync_slave_sql_with_master.inc 50extra/rpl_tests/rpl_check_gtid.inc 51extra/rpl_tests/rpl_check_gtid.inc 52BEGIN; 53INSERT INTO t1 VALUES(1); 54INSERT INTO t1 VALUES(2); 55COMMIT; 56extra/rpl_tests/rpl_check_gtid.inc 57FLUSH LOGS; 58FLUSH LOGS; 59---- i=4 ---- 60BEGIN; 61INSERT INTO t1 VALUES(1); 62INSERT INTO t1 VALUES(2); 63COMMIT; 64extra/rpl_tests/rpl_check_gtid.inc 65include/sync_slave_sql_with_master.inc 66extra/rpl_tests/rpl_check_gtid.inc 67extra/rpl_tests/rpl_check_gtid.inc 68BEGIN; 69INSERT INTO t1 VALUES(1); 70INSERT INTO t1 VALUES(2); 71COMMIT; 72extra/rpl_tests/rpl_check_gtid.inc 73FLUSH LOGS; 74FLUSH LOGS; 75==== Part 2 ==== 76include/rpl_reset.inc 77include/stop_slave.inc 78SET GLOBAL debug="d,rotate_slave_debug_group"; 79include/start_slave.inc 80---- i=1 ---- 81BEGIN; 82INSERT INTO t1 VALUES(1); 83INSERT INTO t1 VALUES(2); 84COMMIT; 85include/sync_slave_sql_with_master.inc 86extra/rpl_tests/rpl_check_gtid.inc 87FLUSH LOGS; 88---- i=2 ---- 89BEGIN; 90INSERT INTO t1 VALUES(1); 91INSERT INTO t1 VALUES(2); 92COMMIT; 93include/sync_slave_sql_with_master.inc 94extra/rpl_tests/rpl_check_gtid.inc 95FLUSH LOGS; 96---- i=3 ---- 97BEGIN; 98INSERT INTO t1 VALUES(1); 99INSERT INTO t1 VALUES(2); 100COMMIT; 101include/sync_slave_sql_with_master.inc 102extra/rpl_tests/rpl_check_gtid.inc 103FLUSH LOGS; 104---- i=4 ---- 105BEGIN; 106INSERT INTO t1 VALUES(1); 107INSERT INTO t1 VALUES(2); 108COMMIT; 109include/sync_slave_sql_with_master.inc 110extra/rpl_tests/rpl_check_gtid.inc 111FLUSH LOGS; 112==== Part 3 ==== 113include/rpl_reset.inc 114include/stop_slave.inc 115SET GLOBAL debug=""; 116include/start_slave.inc 117---- i=1 ---- 118BEGIN; 119INSERT INTO t1 VALUES(1); 120INSERT INTO t1 VALUES(2); 121COMMIT; 122include/sync_slave_sql_with_master.inc 123extra/rpl_tests/rpl_check_gtid.inc 124extra/rpl_tests/rpl_check_gtid.inc 125include/stop_slave.inc 126include/rpl_restart_server.inc [server_number=2 gtids=on] 127include/start_slave.inc 128FLUSH LOGS; 129FLUSH LOGS; 130---- i=2 ---- 131BEGIN; 132INSERT INTO t1 VALUES(1); 133INSERT INTO t1 VALUES(2); 134COMMIT; 135include/sync_slave_sql_with_master.inc 136extra/rpl_tests/rpl_check_gtid.inc 137extra/rpl_tests/rpl_check_gtid.inc 138include/stop_slave.inc 139include/rpl_restart_server.inc [server_number=2 gtids=on] 140include/start_slave.inc 141FLUSH LOGS; 142FLUSH LOGS; 143---- i=3 ---- 144BEGIN; 145INSERT INTO t1 VALUES(1); 146INSERT INTO t1 VALUES(2); 147COMMIT; 148include/sync_slave_sql_with_master.inc 149extra/rpl_tests/rpl_check_gtid.inc 150extra/rpl_tests/rpl_check_gtid.inc 151include/stop_slave.inc 152include/rpl_restart_server.inc [server_number=2 gtids=on] 153include/start_slave.inc 154FLUSH LOGS; 155FLUSH LOGS; 156---- i=4 ---- 157BEGIN; 158INSERT INTO t1 VALUES(1); 159INSERT INTO t1 VALUES(2); 160COMMIT; 161include/sync_slave_sql_with_master.inc 162extra/rpl_tests/rpl_check_gtid.inc 163extra/rpl_tests/rpl_check_gtid.inc 164include/stop_slave.inc 165include/rpl_restart_server.inc [server_number=2 gtids=on] 166include/start_slave.inc 167FLUSH LOGS; 168FLUSH LOGS; 169==== Part 4 ==== 170include/rpl_reset.inc 171---- i=1 ---- 172BEGIN; 173INSERT INTO t1 VALUES(1); 174INSERT INTO t1 VALUES(2); 175COMMIT; 176extra/rpl_tests/rpl_check_gtid.inc 177include/sync_slave_sql_with_master.inc 178extra/rpl_tests/rpl_check_gtid.inc 179extra/rpl_tests/rpl_check_gtid.inc 180include/stop_slave.inc 181include/rpl_restart_server.inc [server_number=1 gtids=on] 182include/start_slave.inc 183FLUSH LOGS; 184FLUSH LOGS; 185---- i=2 ---- 186BEGIN; 187INSERT INTO t1 VALUES(1); 188INSERT INTO t1 VALUES(2); 189COMMIT; 190extra/rpl_tests/rpl_check_gtid.inc 191include/sync_slave_sql_with_master.inc 192extra/rpl_tests/rpl_check_gtid.inc 193extra/rpl_tests/rpl_check_gtid.inc 194include/stop_slave.inc 195include/rpl_restart_server.inc [server_number=1 gtids=on] 196include/start_slave.inc 197FLUSH LOGS; 198FLUSH LOGS; 199---- i=3 ---- 200BEGIN; 201INSERT INTO t1 VALUES(1); 202INSERT INTO t1 VALUES(2); 203COMMIT; 204extra/rpl_tests/rpl_check_gtid.inc 205include/sync_slave_sql_with_master.inc 206extra/rpl_tests/rpl_check_gtid.inc 207extra/rpl_tests/rpl_check_gtid.inc 208include/stop_slave.inc 209include/rpl_restart_server.inc [server_number=1 gtids=on] 210include/start_slave.inc 211FLUSH LOGS; 212FLUSH LOGS; 213---- i=4 ---- 214BEGIN; 215INSERT INTO t1 VALUES(1); 216INSERT INTO t1 VALUES(2); 217COMMIT; 218extra/rpl_tests/rpl_check_gtid.inc 219include/sync_slave_sql_with_master.inc 220extra/rpl_tests/rpl_check_gtid.inc 221extra/rpl_tests/rpl_check_gtid.inc 222include/stop_slave.inc 223include/rpl_restart_server.inc [server_number=1 gtids=on] 224include/start_slave.inc 225FLUSH LOGS; 226FLUSH LOGS; 227==== Part 5 ==== 228---- i=1 ---- 229include/stop_slave.inc 230RESET SLAVE; 231RESET MASTER; 232RESET MASTER; 233include/start_slave.inc 234BEGIN; 235INSERT INTO t1 VALUES(1); 236INSERT INTO t1 VALUES(2); 237COMMIT; 238BEGIN; 239INSERT INTO t1 VALUES(1); 240INSERT INTO t1 VALUES(2); 241COMMIT; 242include/sync_slave_sql_with_master.inc 243extra/rpl_tests/rpl_check_gtid.inc 244FLUSH LOGS; 245FLUSH LOGS; 246---- i=2 ---- 247include/stop_slave.inc 248RESET SLAVE; 249RESET MASTER; 250RESET MASTER; 251include/start_slave.inc 252BEGIN; 253INSERT INTO t1 VALUES(1); 254INSERT INTO t1 VALUES(2); 255COMMIT; 256BEGIN; 257INSERT INTO t1 VALUES(1); 258INSERT INTO t1 VALUES(2); 259COMMIT; 260include/sync_slave_sql_with_master.inc 261extra/rpl_tests/rpl_check_gtid.inc 262FLUSH LOGS; 263FLUSH LOGS; 264---- i=3 ---- 265include/stop_slave.inc 266RESET SLAVE; 267RESET MASTER; 268RESET MASTER; 269include/start_slave.inc 270BEGIN; 271INSERT INTO t1 VALUES(1); 272INSERT INTO t1 VALUES(2); 273COMMIT; 274BEGIN; 275INSERT INTO t1 VALUES(1); 276INSERT INTO t1 VALUES(2); 277COMMIT; 278include/sync_slave_sql_with_master.inc 279extra/rpl_tests/rpl_check_gtid.inc 280FLUSH LOGS; 281FLUSH LOGS; 282---- i=4 ---- 283include/stop_slave.inc 284RESET SLAVE; 285RESET MASTER; 286RESET MASTER; 287include/start_slave.inc 288BEGIN; 289INSERT INTO t1 VALUES(1); 290INSERT INTO t1 VALUES(2); 291COMMIT; 292BEGIN; 293INSERT INTO t1 VALUES(1); 294INSERT INTO t1 VALUES(2); 295COMMIT; 296include/sync_slave_sql_with_master.inc 297extra/rpl_tests/rpl_check_gtid.inc 298FLUSH LOGS; 299FLUSH LOGS; 300==== Part 6 ==== 301include/stop_slave.inc 302RESET SLAVE; 303RESET MASTER; 304RESET MASTER; 305CHANGE MASTER TO MASTER_AUTO_POSITION= 1, MASTER_LOG_FILE= 'master-bin.000001', MASTER_LOG_POS= 4; 306ERROR HY000: Parameters MASTER_LOG_FILE, MASTER_LOG_POS, RELAY_LOG_FILE and RELAY_LOG_POS cannot be set when MASTER_AUTO_POSITION is active. 307include/start_slave.inc 308---- i=1 ---- 309BEGIN; 310INSERT INTO t1 VALUES(1); 311INSERT INTO t1 VALUES(2); 312COMMIT; 313BEGIN; 314INSERT INTO t1 VALUES(1); 315INSERT INTO t1 VALUES(2); 316COMMIT; 317SELECT WAIT_UNTIL_SQL_THREAD_AFTER_GTIDS('MASTER_UUID:1'); 318SELECT WAIT_UNTIL_SQL_THREAD_AFTER_GTIDS('MASTER_UUID:1-2'); 319extra/rpl_tests/rpl_check_gtid.inc 320include/stop_slave.inc 321CHANGE MASTER TO MASTER_HOST= 'SLAVE_MASTER_HOST', MASTER_AUTO_POSITION= 1; 322include/start_slave.inc 323FLUSH LOGS; 324---- i=2 ---- 325BEGIN; 326INSERT INTO t1 VALUES(1); 327INSERT INTO t1 VALUES(2); 328COMMIT; 329BEGIN; 330INSERT INTO t1 VALUES(1); 331INSERT INTO t1 VALUES(2); 332COMMIT; 333SELECT WAIT_UNTIL_SQL_THREAD_AFTER_GTIDS('MASTER_UUID:1-3', 300); 334SELECT WAIT_UNTIL_SQL_THREAD_AFTER_GTIDS('MASTER_UUID:1-4', 300); 335extra/rpl_tests/rpl_check_gtid.inc 336include/stop_slave.inc 337CHANGE MASTER TO MASTER_HOST= 'SLAVE_MASTER_HOST', MASTER_AUTO_POSITION= 1; 338include/start_slave.inc 339FLUSH LOGS; 340---- i=3 ---- 341BEGIN; 342INSERT INTO t1 VALUES(1); 343INSERT INTO t1 VALUES(2); 344COMMIT; 345BEGIN; 346INSERT INTO t1 VALUES(1); 347INSERT INTO t1 VALUES(2); 348COMMIT; 349SELECT WAIT_UNTIL_SQL_THREAD_AFTER_GTIDS('MASTER_UUID:1-5'); 350SELECT WAIT_UNTIL_SQL_THREAD_AFTER_GTIDS('MASTER_UUID:1-6'); 351extra/rpl_tests/rpl_check_gtid.inc 352include/stop_slave.inc 353CHANGE MASTER TO MASTER_HOST= 'SLAVE_MASTER_HOST', MASTER_AUTO_POSITION= 1; 354include/start_slave.inc 355FLUSH LOGS; 356---- i=4 ---- 357BEGIN; 358INSERT INTO t1 VALUES(1); 359INSERT INTO t1 VALUES(2); 360COMMIT; 361BEGIN; 362INSERT INTO t1 VALUES(1); 363INSERT INTO t1 VALUES(2); 364COMMIT; 365SELECT WAIT_UNTIL_SQL_THREAD_AFTER_GTIDS('MASTER_UUID:1-7', 300); 366SELECT WAIT_UNTIL_SQL_THREAD_AFTER_GTIDS('MASTER_UUID:1-8', 300); 367extra/rpl_tests/rpl_check_gtid.inc 368include/stop_slave.inc 369CHANGE MASTER TO MASTER_HOST= 'SLAVE_MASTER_HOST', MASTER_AUTO_POSITION= 1; 370include/start_slave.inc 371FLUSH LOGS; 372==== Part 7 ==== 373include/stop_slave.inc 374RESET SLAVE; 375RESET MASTER; 376RESET MASTER; 377CHANGE MASTER TO MASTER_HOST= 'SLAVE_MASTER_HOST', MASTER_AUTO_POSITION= 1; 378---- i=1 ---- 379BEGIN; 380INSERT INTO t1 VALUES(1); 381INSERT INTO t1 VALUES(2); 382COMMIT; 383BEGIN; 384INSERT INTO t1 VALUES(1); 385INSERT INTO t1 VALUES(2); 386COMMIT; 387START SLAVE UNTIL SQL_BEFORE_GTIDS= "MASTER_UUID:2"; 388include/wait_for_slave_sql_to_stop.inc 389include/stop_slave.inc 390extra/rpl_tests/rpl_check_gtid.inc 391FLUSH LOGS; 392---- i=2 ---- 393BEGIN; 394INSERT INTO t1 VALUES(1); 395INSERT INTO t1 VALUES(2); 396COMMIT; 397BEGIN; 398INSERT INTO t1 VALUES(1); 399INSERT INTO t1 VALUES(2); 400COMMIT; 401START SLAVE UNTIL SQL_BEFORE_GTIDS= "MASTER_UUID:4"; 402include/wait_for_slave_sql_to_stop.inc 403include/stop_slave.inc 404extra/rpl_tests/rpl_check_gtid.inc 405FLUSH LOGS; 406---- i=3 ---- 407BEGIN; 408INSERT INTO t1 VALUES(1); 409INSERT INTO t1 VALUES(2); 410COMMIT; 411BEGIN; 412INSERT INTO t1 VALUES(1); 413INSERT INTO t1 VALUES(2); 414COMMIT; 415START SLAVE UNTIL SQL_BEFORE_GTIDS= "MASTER_UUID:6"; 416include/wait_for_slave_sql_to_stop.inc 417include/stop_slave.inc 418extra/rpl_tests/rpl_check_gtid.inc 419FLUSH LOGS; 420---- i=4 ---- 421BEGIN; 422INSERT INTO t1 VALUES(1); 423INSERT INTO t1 VALUES(2); 424COMMIT; 425BEGIN; 426INSERT INTO t1 VALUES(1); 427INSERT INTO t1 VALUES(2); 428COMMIT; 429START SLAVE UNTIL SQL_BEFORE_GTIDS= "MASTER_UUID:8"; 430include/wait_for_slave_sql_to_stop.inc 431include/stop_slave.inc 432extra/rpl_tests/rpl_check_gtid.inc 433FLUSH LOGS; 434==== Part 8 ==== 435include/stop_slave.inc 436Warnings: 437Note 1255 Slave already has been stopped 438RESET MASTER; 439RESET SLAVE; 440CHANGE MASTER TO MASTER_HOST= '127.0.0.1', MASTER_AUTO_POSITION= 0; 441RESET MASTER; 442include/start_slave.inc 443---- i=1 ---- 444BEGIN; 445INSERT INTO t1 VALUES(1); 446INSERT INTO t1 VALUES(2); 447COMMIT; 448include/sync_slave_sql_with_master.inc 449extra/rpl_tests/rpl_check_gtid.inc 450extra/rpl_tests/rpl_check_gtid.inc 451include/stop_slave.inc 452include/rpl_restart_server.inc [server_number=2 gtids=on parameters: --relay-log-recovery=1 --debug=d,skip_writing_previous_gtids_log_event] 453include/rpl_restart_server.inc [server_number=2 gtids=on parameters: --relay-log-recovery=1] 454include/start_slave.inc 455FLUSH LOGS; 456FLUSH LOGS; 457---- i=2 ---- 458BEGIN; 459INSERT INTO t1 VALUES(1); 460INSERT INTO t1 VALUES(2); 461COMMIT; 462include/sync_slave_sql_with_master.inc 463extra/rpl_tests/rpl_check_gtid.inc 464extra/rpl_tests/rpl_check_gtid.inc 465include/stop_slave.inc 466include/rpl_restart_server.inc [server_number=2 gtids=on parameters: --relay-log-recovery=1 --debug=d,skip_writing_previous_gtids_log_event] 467include/rpl_restart_server.inc [server_number=2 gtids=on parameters: --relay-log-recovery=1] 468include/start_slave.inc 469FLUSH LOGS; 470FLUSH LOGS; 471---- i=3 ---- 472BEGIN; 473INSERT INTO t1 VALUES(1); 474INSERT INTO t1 VALUES(2); 475COMMIT; 476include/sync_slave_sql_with_master.inc 477extra/rpl_tests/rpl_check_gtid.inc 478extra/rpl_tests/rpl_check_gtid.inc 479include/stop_slave.inc 480include/rpl_restart_server.inc [server_number=2 gtids=on parameters: --relay-log-recovery=1 --debug=d,skip_writing_previous_gtids_log_event] 481include/rpl_restart_server.inc [server_number=2 gtids=on parameters: --relay-log-recovery=1] 482include/start_slave.inc 483FLUSH LOGS; 484FLUSH LOGS; 485---- i=4 ---- 486BEGIN; 487INSERT INTO t1 VALUES(1); 488INSERT INTO t1 VALUES(2); 489COMMIT; 490include/sync_slave_sql_with_master.inc 491extra/rpl_tests/rpl_check_gtid.inc 492extra/rpl_tests/rpl_check_gtid.inc 493include/stop_slave.inc 494include/rpl_restart_server.inc [server_number=2 gtids=on parameters: --relay-log-recovery=1 --debug=d,skip_writing_previous_gtids_log_event] 495include/rpl_restart_server.inc [server_number=2 gtids=on parameters: --relay-log-recovery=1] 496include/start_slave.inc 497FLUSH LOGS; 498FLUSH LOGS; 499==== Part 9 ==== 500include/rpl_reset.inc 501---- i=1 ---- 502BEGIN; 503INSERT INTO t1 VALUES(1); 504INSERT INTO t1 VALUES(2); 505COMMIT; 506include/sync_slave_sql_with_master.inc 507extra/rpl_tests/rpl_check_gtid.inc 508extra/rpl_tests/rpl_check_gtid.inc 509include/stop_slave.inc 510include/rpl_restart_server.inc [server_number=2 gtids=on parameters: --relay-log-recovery=1 --debug=d,write_partial_previous_gtids_log_event] 511include/rpl_restart_server.inc [server_number=2 gtids=on parameters: --relay-log-recovery=1] 512include/start_slave.inc 513FLUSH LOGS; 514FLUSH LOGS; 515---- i=2 ---- 516BEGIN; 517INSERT INTO t1 VALUES(1); 518INSERT INTO t1 VALUES(2); 519COMMIT; 520include/sync_slave_sql_with_master.inc 521extra/rpl_tests/rpl_check_gtid.inc 522extra/rpl_tests/rpl_check_gtid.inc 523include/stop_slave.inc 524include/rpl_restart_server.inc [server_number=2 gtids=on parameters: --relay-log-recovery=1 --debug=d,write_partial_previous_gtids_log_event] 525include/rpl_restart_server.inc [server_number=2 gtids=on parameters: --relay-log-recovery=1] 526include/start_slave.inc 527FLUSH LOGS; 528FLUSH LOGS; 529---- i=3 ---- 530BEGIN; 531INSERT INTO t1 VALUES(1); 532INSERT INTO t1 VALUES(2); 533COMMIT; 534include/sync_slave_sql_with_master.inc 535extra/rpl_tests/rpl_check_gtid.inc 536extra/rpl_tests/rpl_check_gtid.inc 537include/stop_slave.inc 538include/rpl_restart_server.inc [server_number=2 gtids=on parameters: --relay-log-recovery=1 --debug=d,write_partial_previous_gtids_log_event] 539include/rpl_restart_server.inc [server_number=2 gtids=on parameters: --relay-log-recovery=1] 540include/start_slave.inc 541FLUSH LOGS; 542FLUSH LOGS; 543---- i=4 ---- 544BEGIN; 545INSERT INTO t1 VALUES(1); 546INSERT INTO t1 VALUES(2); 547COMMIT; 548include/sync_slave_sql_with_master.inc 549extra/rpl_tests/rpl_check_gtid.inc 550extra/rpl_tests/rpl_check_gtid.inc 551include/stop_slave.inc 552include/rpl_restart_server.inc [server_number=2 gtids=on parameters: --relay-log-recovery=1 --debug=d,write_partial_previous_gtids_log_event] 553include/rpl_restart_server.inc [server_number=2 gtids=on parameters: --relay-log-recovery=1] 554include/start_slave.inc 555FLUSH LOGS; 556FLUSH LOGS; 557include/rpl_reset.inc 558DROP TABLE t1; 559include/rpl_end.inc 560