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 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168
|
# ==== Purpose ====
#
# Used by scripts testing XA crash recovery, it sets up the scenario
# requirements, for instance, creates table and inserts records, sets up
# GR, initializes constants used in the tests, etc.
#
# ==== Parameters ====
#
# $xid
# The XID of the XA transaction that is going to be used in the test.
#
# ==== References ====
#
# Related tests:
#
# - mysql-test/t/xa_commit_failure_before_commit_engines.test
# - mysql-test/t/xa_commit_failure_before_commit_tc.test
# - mysql-test/t/xa_commit_failure_before_gtid_externalization.test
# - mysql-test/t/xa_commit_one_phase_failure_before_commit_engines.test
# - mysql-test/t/xa_commit_one_phase_failure_before_commit_tc.test
# - mysql-test/t/xa_commit_one_phase_failure_before_gtid_externalization.test
# - mysql-test/t/xa_prepare_failure_before_gtid_externalization.test
# - mysql-test/t/xa_prepare_failure_before_prepare_2nd_phase.test
# - mysql-test/t/xa_prepare_failure_before_prepare_in_engines.test
# - mysql-test/t/xa_prepare_failure_before_prepare_tc.test
# - mysql-test/t/xa_rollback_failure_before_gtid_externalization.test
# - mysql-test/t/xa_rollback_failure_before_rollback_engines.test
# - mysql-test/t/xa_rollback_failure_before_rollback_tc.test
#
# - mysql-test/suite/binlog/t/binlog_xa_recovery_errors.test
#
# - mysql-test/suite/binlog_gtid/t/binlog_gtid_xa_multiple_failures.test
# - mysql-test/suite/binlog_gtid/t/binlog_gtid_binlog_recovery_errors.test
# - mysql-test/suite/binlog_gtid/t/binlog_gtid_xa_commit_failure_after_rotate.test
# - mysql-test/suite/binlog_gtid/t/binlog_gtid_xa_commit_failure_before_commit_engines.test
# - mysql-test/suite/binlog_gtid/t/binlog_gtid_xa_commit_failure_before_gtid_externalization.test
# - mysql-test/suite/binlog_gtid/t/binlog_gtid_xa_commit_failure_before_write_binlog.test
# - mysql-test/suite/binlog_gtid/t/binlog_gtid_xa_commit_one_phase_failure_before_commit_engines.test
# - mysql-test/suite/binlog_gtid/t/binlog_gtid_xa_commit_one_phase_failure_before_gtid_externalizatio .test
# - mysql-test/suite/binlog_gtid/t/binlog_gtid_xa_commit_one_phase_failure_before_prepare_in_engines.test
# - mysql-test/suite/binlog_gtid/t/binlog_gtid_xa_commit_one_phase_failure_before_write_binlog.test
# - mysql-test/suite/binlog_gtid/t/binlog_gtid_xa_prepare_failure_before_gtid_externalization.test
# - mysql-test/suite/binlog_gtid/t/binlog_gtid_xa_prepare_failure_before_prepare_2nd_phase.test
# - mysql-test/suite/binlog_gtid/t/binlog_gtid_xa_prepare_failure_before_prepare_in_engines.test
# - mysql-test/suite/binlog_gtid/t/binlog_gtid_xa_prepare_failure_before_write_binlog.test
# - mysql-test/suite/binlog_gtid/t/binlog_gtid_xa_rollback_failure_after_rotate.test
# - mysql-test/suite/binlog_gtid/t/binlog_gtid_xa_rollback_failure_before_gtid_externalization.test
# - mysql-test/suite/binlog_gtid/t/binlog_gtid_xa_rollback_failure_before_rollback_engines.test
# - mysql-test/suite/binlog_gtid/t/binlog_gtid_xa_rollback_failure_before_write_binlog.test
#
# - mysql-test/suite/group_replication/t/gr_xa_commit_failure_after_rotate.test
# - mysql-test/suite/group_replication/t/gr_xa_commit_failure_before_broadcast.test
# - mysql-test/suite/group_replication/t/gr_xa_commit_failure_before_commit_engines.test
# - mysql-test/suite/group_replication/t/gr_xa_commit_failure_before_gtid_externalization.test
# - mysql-test/suite/group_replication/t/gr_xa_commit_failure_before_write_binlog.test
# - mysql-test/suite/group_replication/t/gr_xa_commit_one_phase_failure_before_broadcast.test
# - mysql-test/suite/group_replication/t/gr_xa_commit_one_phase_failure_before_commit_engines.test
# - mysql-test/suite/group_replication/t/gr_xa_commit_one_phase_failure_before_gtid_externalization.test
# - mysql-test/suite/group_replication/t/gr_xa_commit_one_phase_failure_before_prepare_in_engines.tes
# - mysql-test/suite/group_replication/t/gr_xa_commit_one_phase_failure_before_write_binlog.test
# - mysql-test/suite/group_replication/t/gr_xa_prepare_failure_before_broadcast.test
# - mysql-test/suite/group_replication/t/gr_xa_prepare_failure_before_gtid_externalization.test
# - mysql-test/suite/group_replication/t/gr_xa_prepare_failure_before_prepare_2nd_phase.test
# - mysql-test/suite/group_replication/t/gr_xa_prepare_failure_before_prepare_in_engines.test
# - mysql-test/suite/group_replication/t/gr_xa_prepare_failure_before_write_binlog.test
# - mysql-test/suite/group_replication/t/gr_xa_rollback_failure_after_rotate.test
# - mysql-test/suite/group_replication/t/gr_xa_rollback_failure_before_broadcast.test
# - mysql-test/suite/group_replication/t/gr_xa_rollback_failure_before_gtid_externalization.test
# - mysql-test/suite/group_replication/t/gr_xa_rollback_failure_before_rollback_engines.test
# - mysql-test/suite/group_replication/t/gr_xa_rollback_failure_before_write_binlog.test
#
# - mysql-test/suite/rpl_gtid/t/rpl_gtid_xa_multiple_failures.test
# - mysql-test/suite/rpl_gtid/t/rpl_gtid_xa_commit_failure_after_rotate.test
# - mysql-test/suite/rpl_gtid/t/rpl_gtid_xa_commit_failure_before_commit_engines.test
# - mysql-test/suite/rpl_gtid/t/rpl_gtid_xa_commit_failure_before_gtid_externalization.test
# - mysql-test/suite/rpl_gtid/t/rpl_gtid_xa_commit_failure_before_write_binlog.test
# - mysql-test/suite/rpl_gtid/t/rpl_gtid_xa_commit_one_phase_failure_before_commit_engines.test
# - mysql-test/suite/rpl_gtid/t/rpl_gtid_xa_commit_one_phase_failure_before_gtid_externalization.test
# - mysql-test/suite/rpl_gtid/t/rpl_gtid_xa_commit_one_phase_failure_before_prepare_in_engines.test
# - mysql-test/suite/rpl_gtid/t/rpl_gtid_xa_commit_one_phase_failure_before_write_binlog.test
# - mysql-test/suite/rpl_gtid/t/rpl_gtid_xa_prepare_failure_before_gtid_externalization.test
# - mysql-test/suite/rpl_gtid/t/rpl_gtid_xa_prepare_failure_before_prepare_2nd_phase.test
# - mysql-test/suite/rpl_gtid/t/rpl_gtid_xa_prepare_failure_before_prepare_in_engines.test
# - mysql-test/suite/rpl_gtid/t/rpl_gtid_xa_prepare_failure_before_write_binlog.test
# - mysql-test/suite/rpl_gtid/t/rpl_gtid_xa_rollback_failure_after_rotate.test
# - mysql-test/suite/rpl_gtid/t/rpl_gtid_xa_rollback_failure_before_gtid_externalization.test
# - mysql-test/suite/rpl_gtid/t/rpl_gtid_xa_rollback_failure_before_rollback_engines.test
# - mysql-test/suite/rpl_gtid/t/rpl_gtid_xa_rollback_failure_before_write_binlog.test
#
if ($xid == '') {
--die ERROR IN TEST: You must set $xid before sourcing xa_crash_safe_testing_setup.inc
}
# Add suppression for XA transaction related warning
let $messages = Found .* prepared XA transactions
.*Checksum mismatch in datafile.*;
--source include/suppress_messages.inc
# If in the GR setup
if ($rpl_group_replication == 1) {
--let $rpl_connection_name = server1
--source include/rpl_connection.inc
--source include/start_and_bootstrap_group_replication.inc
--let $_group_replication_local_address = `SELECT @@GLOBAL.group_replication_local_address`
--let $_group_replication_group_seeds = `SELECT @@GLOBAL.group_replication_group_seeds`
--let $_group_replication_group_name = `SELECT @@GLOBAL.group_replication_group_name`
}
# Create the table and insert records
CREATE TABLE t1 (c1 INT PRIMARY KEY);
--eval XA START $xid
INSERT INTO t1 VALUES (2);
--eval XA END $xid
--eval XA PREPARE $xid
--eval XA COMMIT $xid
# Allow for `save_binlog_position.inc` to save the binlog info in the
# connection session in order for the tests to be able to use
# `assert_binlog_events.inc` for more than one server.
--let $save_binlog_position_in_sql = 1
if ($rpl_group_replication == 1) {
# Bootstrap server 2
--let $rpl_connection_name = server2
--source include/rpl_connection.inc
--let $sysvars_to_save = [ "GLOBAL.group_replication_member_expel_timeout" ]
--source include/save_sysvars.inc
SET GLOBAL group_replication_member_expel_timeout = 0;
--source include/start_group_replication.inc
# Save binlog position for server 2
--source include/save_binlog_position.inc
# Bootstrap server 2
--let $rpl_connection_name = server3
--source include/rpl_connection.inc
--let $sysvars_to_save = [ "GLOBAL.group_replication_member_expel_timeout" ]
--source include/save_sysvars.inc
SET GLOBAL group_replication_member_expel_timeout = 0;
--source include/start_group_replication.inc
# Save binlog position for server 1
--let $rpl_connection_name = server1
--source include/rpl_connection.inc
--source include/save_binlog_position.inc
}
# If not in GR mode
if ($rpl_group_replication != 1) {
# If not in source->replica mode
if ($rpl_inited) {
--source include/sync_slave_sql_with_master.inc
}
if (`SELECT @@GLOBAL.log_bin != 0`) {
# Save binlog position for the current server
--source include/save_binlog_position.inc
}
if ($rpl_inited) {
--source include/rpl_connection_master.inc
}
}
# Initialize constants to be used with `assert_binlog_events.inc`
--let $empty_event_sequence = ()
--let $view_change = Gtid # Query/BEGIN # View_change # Query/COMMIT
--let $xa_start_end = Query/XA START $xid # Table_map # Write_rows # Query/XA END $xid
|