Gecko [ www.jdcpatala.org ]

Name	Size	Permission
check_type.inc	2.29 KB	-rw-r--r--
create_recursive_construct.inc	16.61 KB	-rw-r--r--
create_recursive_construct_stm...	16.48 KB	-rw-r--r--
delayed_slave_wait_on_query.in...	1.59 KB	-rw-r--r--
gtid_disconnect_drop_temporary...	3.11 KB	-rw-r--r--
rpl_EE_err.test	1.03 KB	-rw-r--r--
rpl_auto_increment.test	8.63 KB	-rw-r--r--
rpl_auto_increment_insert_view...	1.37 KB	-rw-r--r--
rpl_auto_increment_invoke_trig...	2.47 KB	-rw-r--r--
rpl_autoinc_func_invokes_trigg...	1.78 KB	-rw-r--r--
rpl_binlog_max_cache_size.test	18.23 KB	-rw-r--r--
rpl_blackhole.test	1.03 KB	-rw-r--r--
rpl_change_master.test	10.46 KB	-rw-r--r--
rpl_change_master_bind.inc	2.23 KB	-rw-r--r--
rpl_charset.test	4.45 KB	-rw-r--r--
rpl_check_gtid.inc	4.87 KB	-rw-r--r--
rpl_commit_after_flush.test	272 B	-rw-r--r--
rpl_conflicts.test	5.45 KB	-rw-r--r--
rpl_crash_safe.inc	4.13 KB	-rw-r--r--
rpl_crash_safe.test	7.61 KB	-rw-r--r--
rpl_create_msr_channels.inc	2.53 KB	-rw-r--r--
rpl_db_stmts_ignored.inc	1.7 KB	-rw-r--r--
rpl_ddl.test	21.62 KB	-rw-r--r--
rpl_deadlock.test	6.05 KB	-rw-r--r--
rpl_delete_no_where.test	523 B	-rw-r--r--
rpl_do_table_filter_insensitiv...	492 B	-rw-r--r--
rpl_do_table_filter_sensitive....	491 B	-rw-r--r--
rpl_drop_create_temp_table.inc	29.79 KB	-rw-r--r--
rpl_drop_create_temp_table.tes...	17.8 KB	-rw-r--r--
rpl_drop_multiple_tables.inc	4 KB	-rw-r--r--
rpl_drop_multiple_tables_in_mu...	1.18 KB	-rw-r--r--
rpl_extra_col_master.test	31.93 KB	-rw-r--r--
rpl_extra_col_slave.test	28.76 KB	-rw-r--r--
rpl_failed_optimize.test	666 B	-rw-r--r--
rpl_filters.test	530 B	-rw-r--r--
rpl_flsh_tbls.test	1.86 KB	-rw-r--r--
rpl_foreign_key.test	1.7 KB	-rw-r--r--
rpl_generate_mts_gap.test	1.6 KB	-rw-r--r--
rpl_generate_mts_gap_with_miss...	3.22 KB	-rw-r--r--
rpl_generate_mts_gap_with_miss...	408 B	-rw-r--r--
rpl_get_master_version_and_clo...	2.88 KB	-rw-r--r--
rpl_gtid_drop_table.inc	1.11 KB	-rw-r--r--
rpl_gtid_mixed_rows_and_stmts_...	3.35 KB	-rw-r--r--
rpl_gtid_mts_relay_log_recover...	4.39 KB	-rw-r--r--
rpl_gtid_temp_table_in_func_or...	3.69 KB	-rw-r--r--
rpl_gtids_restart_slave_io_los...	3.48 KB	-rw-r--r--
rpl_heartbeat_2slaves.inc	4.27 KB	-rw-r--r--
rpl_ignore_super_read_only.tes...	6.19 KB	-rw-r--r--
rpl_ignore_table_filter_insens...	508 B	-rw-r--r--
rpl_ignore_table_filter_sensit...	506 B	-rw-r--r--
rpl_implicit_commit_binlog.tes...	17.22 KB	-rw-r--r--
rpl_innodb.test	4.53 KB	-rw-r--r--
rpl_insert_id.test	15.12 KB	-rw-r--r--
rpl_insert_id_pk.test	2.65 KB	-rw-r--r--
rpl_insert_ignore.test	4.9 KB	-rw-r--r--
rpl_kill_query.inc	4.14 KB	-rw-r--r--
rpl_loaddata.test	8.91 KB	-rw-r--r--
rpl_loaddata_s.inc	896 B	-rw-r--r--
rpl_loadfile.test	1.08 KB	-rw-r--r--
rpl_log.test	3.9 KB	-rw-r--r--
rpl_lower_case_table_names.tes...	4.07 KB	-rw-r--r--
rpl_max_relay_size.test	2.58 KB	-rw-r--r--
rpl_mixing_engines.inc	23.15 KB	-rw-r--r--
rpl_mixing_engines.test	54.43 KB	-rw-r--r--
rpl_mts_crash_safe.inc	5.92 KB	-rw-r--r--
rpl_mts_crash_safe.test	6.74 KB	-rw-r--r--
rpl_mts_execute_partial_trx_in...	1.11 KB	-rw-r--r--
rpl_mts_pending_events.inc	4.91 KB	-rw-r--r--
rpl_mts_relay_log_recovery.tes...	2.93 KB	-rw-r--r--
rpl_mts_transaction_retry.inc	7.9 KB	-rw-r--r--
rpl_multi_query.test	782 B	-rw-r--r--
rpl_multi_source_corrupt_repos...	18.31 KB	-rw-r--r--
rpl_multi_source_generate_mts_...	2.11 KB	-rw-r--r--
rpl_multi_update.test	805 B	-rw-r--r--
rpl_multi_update2.test	1.35 KB	-rw-r--r--
rpl_multi_update3.test	4.52 KB	-rw-r--r--
rpl_not_null.test	10.76 KB	-rw-r--r--
rpl_parallel_ddl.test	5.35 KB	-rw-r--r--
rpl_parallel_load.test	6.1 KB	-rw-r--r--
rpl_parallel_load_innodb.test	7 KB	-rw-r--r--
rpl_parallel_recovery_core.tes...	6.74 KB	-rw-r--r--
rpl_partition.test	7.88 KB	-rw-r--r--
rpl_perfschema_applier_xa_stat...	2.96 KB	-rw-r--r--
rpl_perfschema_order_by.test	3.12 KB	-rw-r--r--
rpl_record_compare.test	2.1 KB	-rw-r--r--
rpl_relayrotate.test	2.68 KB	-rw-r--r--
rpl_replication_observers_exam...	2.61 KB	-rw-r--r--
rpl_reset_slave.test	3.82 KB	-rw-r--r--
rpl_reset_slave_all_thread_saf...	1.2 KB	-rw-r--r--
rpl_rollback_to_savepoint.inc	7.54 KB	-rw-r--r--
rpl_row_001.test	2.68 KB	-rw-r--r--
rpl_row_UUID.test	2.61 KB	-rw-r--r--
rpl_row_basic.test	24.58 KB	-rw-r--r--
rpl_row_blob.test	5.57 KB	-rw-r--r--
rpl_row_empty_imgs.test	5.69 KB	-rw-r--r--
rpl_row_event_max_size.inc	4.05 KB	-rw-r--r--
rpl_row_func003.test	3.13 KB	-rw-r--r--
rpl_row_idempotency.test	8.39 KB	-rw-r--r--
rpl_row_img.test	8.23 KB	-rw-r--r--
rpl_row_img_blobs.test	5.82 KB	-rw-r--r--
rpl_row_img_diff_indexes.test	9.11 KB	-rw-r--r--
rpl_row_sp002.test	5.26 KB	-rw-r--r--
rpl_row_sp003.test	2.02 KB	-rw-r--r--
rpl_row_sp006.test	2.78 KB	-rw-r--r--
rpl_row_sp007.test	1.5 KB	-rw-r--r--
rpl_row_tabledefs.test	7.97 KB	-rw-r--r--
rpl_seconds_behind_master_mts_...	12.04 KB	-rw-r--r--
rpl_seconds_behind_master_mts_...	10.2 KB	-rw-r--r--
rpl_semi_sync_ack_thread.inc	676 B	-rw-r--r--
rpl_semi_sync_after_sync.test	4.82 KB	-rw-r--r--
rpl_semi_sync_deadlock.test	1.46 KB	-rw-r--r--
rpl_semi_sync_group_commit_dea...	1.71 KB	-rw-r--r--
rpl_set_null.test	2.85 KB	-rw-r--r--
rpl_sp.test	17.69 KB	-rw-r--r--
rpl_split_statements.test	17.96 KB	-rw-r--r--
rpl_start_stop_slave.test	5.4 KB	-rw-r--r--
rpl_stm_EE_err2.test	1.5 KB	-rw-r--r--
rpl_stm_create_if_not_exists.t...	6.87 KB	-rw-r--r--
rpl_stop_middle_group.test	5.17 KB	-rw-r--r--
rpl_stop_slave.test	1.56 KB	-rw-r--r--
rpl_stress_test.inc	2.21 KB	-rw-r--r--
rpl_sv_relay_space.test	921 B	-rw-r--r--
rpl_sync_relay_log_info.inc	9.02 KB	-rw-r--r--
rpl_sync_relay_log_info_assert...	3.23 KB	-rw-r--r--
rpl_temp_error.test	623 B	-rw-r--r--
rpl_temporary.test	10.6 KB	-rw-r--r--
rpl_test_framework.inc	2.42 KB	-rw-r--r--
rpl_tmp_table_and_DDL.test	4.8 KB	-rw-r--r--
rpl_trig004.test	1.7 KB	-rw-r--r--
rpl_truncate.test	425 B	-rw-r--r--
rpl_truncate_helper.test	976 B	-rw-r--r--
rpl_trx_boundary_parser.inc	1.59 KB	-rw-r--r--
rpl_trx_boundary_parser_all_st...	7.19 KB	-rw-r--r--
rpl_trx_boundary_parser_one_st...	3.69 KB	-rw-r--r--
rpl_trx_boundary_parser_warnin...	4.51 KB	-rw-r--r--
rpl_variables_stm.test	24.26 KB	-rw-r--r--
rpl_xa_gtid_next.inc	2.46 KB	-rw-r--r--
rpl_xa_mixed_engines.inc	1.89 KB	-rw-r--r--
type_conversions.test	23.7 KB	-rw-r--r--

Code Editor : rpl_mixing_engines.inc

# ==== Purpose ====
#
# This is an auxiliary file used by rpl_mixing_engines.test. It
# executes SQL statements according to a format string, as specified in
# rpl_mixing_engines.test. In addition, it accepts the special format
# strings 'configure' and 'clean', used before and after everything else.
#
# ==== Usage ====
#
# --let $commands= command1 command2 ...
# --let $database_name= name
# [--let $verbose= 1]
# --source include/rpl_mixing_engines.inc
#
#   Parameters:
#
#     $commands
#       Space-separated list of commands. See rpl_mixing_engines.test
#       for a list of all commands.
#
#     $database_name
#       Name of database to use. If $commands is 'configure' or
#       'clean', and the database name is not 'test', then the
#       database is created or dropped, respectively.
#
#     $verbose
#       By default, the query show binlog events is executed after all
#       commands have been processed, showing the result of all
#       commands. If this flag is set, then the query show binlog events
#       is also executed once after each command, showing only the result
#       of that command.
--echo rpl_mixing_engines.inc [commands=$commands]

--let $rme_initial_commands= $commands

if ($commands == 'configure')
{
  let $binlog_filter=
  /Anonymous_Gtid/Gtid/
  /GTID_NEXT= '([0-9a-f:\-]+|ANONYMOUS)'/GTID_NEXT= Gtid_set/
  /xid=[0-9]+/XID/
  /table_id: [0-9]+/table_id: #/;
  connection master;
  --disable_query_log
  if ($database_name != 'test')
  {
    --eval CREATE DATABASE $database_name
  }
  --eval use $database_name
  --enable_query_log

eval CREATE TABLE nt_1 (trans_id INT, stmt_id INT, info VARCHAR(64), PRIMARY KEY(trans_id, stmt_id)) ENGINE = MyISAM;
  eval CREATE TABLE nt_2 (trans_id INT, stmt_id INT, info VARCHAR(64), PRIMARY KEY(trans_id, stmt_id)) ENGINE = MyISAM;
  eval CREATE TABLE nt_3 (trans_id INT, stmt_id INT, info VARCHAR(64), PRIMARY KEY(trans_id, stmt_id)) ENGINE = MyISAM;
  eval CREATE TABLE nt_4 (trans_id INT, stmt_id INT, info VARCHAR(64), PRIMARY KEY(trans_id, stmt_id)) ENGINE = MyISAM;
  eval CREATE TABLE nt_5 (trans_id INT, stmt_id INT, info VARCHAR(64), PRIMARY KEY(trans_id, stmt_id)) ENGINE = MyISAM;
  eval CREATE TABLE nt_6 (trans_id INT, stmt_id INT, info VARCHAR(64), PRIMARY KEY(trans_id, stmt_id)) ENGINE = MyISAM;
  eval CREATE TABLE tt_1 (trans_id INT, stmt_id INT, info VARCHAR(64), PRIMARY KEY(trans_id, stmt_id)) ENGINE = $engine_type;
  eval CREATE TABLE tt_2 (trans_id INT, stmt_id INT, info VARCHAR(64), PRIMARY KEY(trans_id, stmt_id)) ENGINE = $engine_type;
  eval CREATE TABLE tt_3 (trans_id INT, stmt_id INT, info VARCHAR(64), PRIMARY KEY(trans_id, stmt_id)) ENGINE = $engine_type;
  eval CREATE TABLE tt_4 (trans_id INT, stmt_id INT, info VARCHAR(64), PRIMARY KEY(trans_id, stmt_id)) ENGINE = $engine_type;
  eval CREATE TABLE tt_5 (trans_id INT, stmt_id INT, info VARCHAR(64), PRIMARY KEY(trans_id, stmt_id)) ENGINE = $engine_type;
  eval CREATE TABLE tt_6 (trans_id INT, stmt_id INT, info VARCHAR(64), PRIMARY KEY(trans_id, stmt_id)) ENGINE = $engine_type;

INSERT INTO nt_1(trans_id, stmt_id) VALUES(1,1);
  INSERT INTO nt_2(trans_id, stmt_id) VALUES(1,1);
  INSERT INTO nt_3(trans_id, stmt_id) VALUES(1,1);
  INSERT INTO nt_4(trans_id, stmt_id) VALUES(1,1);
  INSERT INTO nt_5(trans_id, stmt_id) VALUES(1,1);
  INSERT INTO nt_6(trans_id, stmt_id) VALUES(1,1);

INSERT INTO tt_1(trans_id, stmt_id) VALUES(1,1);
  INSERT INTO tt_2(trans_id, stmt_id) VALUES(1,1);
  INSERT INTO tt_3(trans_id, stmt_id) VALUES(1,1);
  INSERT INTO tt_4(trans_id, stmt_id) VALUES(1,1);
  INSERT INTO tt_5(trans_id, stmt_id) VALUES(1,1);
  INSERT INTO tt_6(trans_id, stmt_id) VALUES(1,1);

DELIMITER |;

CREATE PROCEDURE pc_i_tt_5_suc (IN p_trans_id INTEGER, IN p_stmt_id INTEGER)
  BEGIN
    DECLARE in_stmt_id INTEGER;
    SELECT max(stmt_id) INTO in_stmt_id FROM tt_5 WHERE trans_id= p_trans_id;
    SELECT COALESCE(greatest(in_stmt_id + 1, p_stmt_id), 1) INTO in_stmt_id;
    INSERT INTO tt_5(trans_id, stmt_id) VALUES (p_trans_id, in_stmt_id);
    INSERT INTO tt_5(trans_id, stmt_id) VALUES (p_trans_id, in_stmt_id + 1);
  END|

CREATE PROCEDURE pc_i_nt_5_suc (IN p_trans_id INTEGER, IN p_stmt_id INTEGER)
  BEGIN
    DECLARE in_stmt_id INTEGER;
    SELECT max(stmt_id) INTO in_stmt_id FROM nt_5 WHERE trans_id= p_trans_id;
    SELECT COALESCE(greatest(in_stmt_id + 1, p_stmt_id), 1) INTO in_stmt_id;
    INSERT INTO nt_5(trans_id, stmt_id) VALUES (p_trans_id, in_stmt_id);
    INSERT INTO nt_5(trans_id, stmt_id) VALUES (p_trans_id, in_stmt_id + 1);
  END|

CREATE FUNCTION fc_i_tt_5_suc (p_trans_id INTEGER, p_stmt_id INTEGER) RETURNS VARCHAR(64)
  BEGIN
    DECLARE in_stmt_id INTEGER;
    SELECT max(stmt_id) INTO in_stmt_id FROM tt_5 WHERE trans_id= p_trans_id;
    SELECT COALESCE(greatest(in_stmt_id + 1, p_stmt_id), 1) INTO in_stmt_id;
    INSERT INTO tt_5(trans_id, stmt_id) VALUES (p_trans_id, in_stmt_id);
    INSERT INTO tt_5(trans_id, stmt_id) VALUES (p_trans_id, in_stmt_id + 1);
    RETURN "fc_i_tt_5_suc";
  END|

CREATE FUNCTION fc_i_nt_5_suc (p_trans_id INTEGER, p_stmt_id INTEGER) RETURNS VARCHAR(64)
  BEGIN
    DECLARE in_stmt_id INTEGER;
    SELECT max(stmt_id) INTO in_stmt_id FROM nt_5 WHERE trans_id= p_trans_id;
    SELECT COALESCE(greatest(in_stmt_id + 1, p_stmt_id), 1) INTO in_stmt_id;
    INSERT INTO nt_5(trans_id, stmt_id) VALUES (p_trans_id, in_stmt_id);
    INSERT INTO nt_5(trans_id, stmt_id) VALUES (p_trans_id, in_stmt_id + 1);
    RETURN "fc_i_nt_5_suc";
  END|

CREATE FUNCTION fc_i_nt_3_tt_3_suc (p_trans_id INTEGER, p_stmt_id INTEGER) RETURNS VARCHAR(64)
  BEGIN
    DECLARE in_stmt_id INTEGER;
    SELECT max(stmt_id) INTO in_stmt_id FROM nt_3 WHERE trans_id= p_trans_id;
    SELECT COALESCE(greatest(in_stmt_id + 1, p_stmt_id), 1) INTO in_stmt_id;
    INSERT INTO nt_3(trans_id, stmt_id) VALUES (p_trans_id, in_stmt_id);

SELECT max(stmt_id) INTO in_stmt_id FROM tt_3 WHERE trans_id= p_trans_id;
    SELECT COALESCE(greatest(in_stmt_id + 1, p_stmt_id), 1) INTO in_stmt_id;
    INSERT INTO tt_3(trans_id, stmt_id) VALUES (p_trans_id, in_stmt_id);
    RETURN "fc_i_nt_3_tt_3_suc";
  END|

CREATE TRIGGER tr_i_tt_3_to_nt_3 AFTER INSERT ON tt_3 FOR EACH ROW
  BEGIN
    DECLARE in_stmt_id INTEGER;
    SELECT max(stmt_id) INTO in_stmt_id FROM nt_3 WHERE trans_id= NEW.trans_id;
    SELECT COALESCE(greatest(in_stmt_id + 1, NEW.stmt_id), 1) INTO in_stmt_id;
    INSERT INTO nt_3(trans_id, stmt_id) VALUES (NEW.trans_id, in_stmt_id);
    INSERT INTO nt_3(trans_id, stmt_id) VALUES (NEW.trans_id, in_stmt_id + 1);
  END|

CREATE TRIGGER tr_i_nt_4_to_tt_4 AFTER INSERT ON nt_4 FOR EACH ROW
  BEGIN
    DECLARE in_stmt_id INTEGER;
    SELECT max(stmt_id) INTO in_stmt_id FROM tt_4 WHERE trans_id= NEW.trans_id;
    SELECT COALESCE(greatest(in_stmt_id + 1, NEW.stmt_id), 1) INTO in_stmt_id;
    INSERT INTO tt_4(trans_id, stmt_id) VALUES (NEW.trans_id, in_stmt_id);
    INSERT INTO tt_4(trans_id, stmt_id) VALUES (NEW.trans_id, in_stmt_id + 1);
  END|

CREATE TRIGGER tr_i_tt_5_to_tt_6 AFTER INSERT ON tt_5 FOR EACH ROW
  BEGIN
    DECLARE in_stmt_id INTEGER;
    SELECT max(stmt_id) INTO in_stmt_id FROM tt_6 WHERE trans_id= NEW.trans_id;
    SELECT COALESCE(greatest(in_stmt_id + 1, NEW.stmt_id, 1), 1) INTO in_stmt_id;
    INSERT INTO tt_6(trans_id, stmt_id) VALUES (NEW.trans_id, in_stmt_id);
    INSERT INTO tt_6(trans_id, stmt_id) VALUES (NEW.trans_id, in_stmt_id + 1);
  END|

CREATE TRIGGER tr_i_nt_5_to_nt_6 AFTER INSERT ON nt_5 FOR EACH ROW
  BEGIN
    DECLARE in_stmt_id INTEGER;
    SELECT max(stmt_id) INTO in_stmt_id FROM nt_6 WHERE trans_id= NEW.trans_id;
    SELECT COALESCE(greatest(in_stmt_id + 1, NEW.stmt_id), 1) INTO in_stmt_id;
    INSERT INTO nt_6(trans_id, stmt_id) VALUES (NEW.trans_id, in_stmt_id);
    INSERT INTO nt_6(trans_id, stmt_id) VALUES (NEW.trans_id, in_stmt_id + 1);
  END|

DELIMITER ;|

let $pos_trans_command= query_get_value("SHOW MASTER STATUS", Position, 1);

let $trans_id= 7;
  let $tb_id= 1;
  let $stmt_id= 1;
  --let $commands=
  let $sn= 0;
}

if ($commands == 'clean')
{
  connection master;

--disable_query_log
  --eval use $database_name
  --enable_query_log

DROP TABLE tt_1;
  DROP TABLE tt_2;
  DROP TABLE tt_3;
  DROP TABLE tt_4;
  DROP TABLE tt_5;
  DROP TABLE tt_6;

DROP TABLE nt_1;
  DROP TABLE nt_2;
  DROP TABLE nt_3;
  DROP TABLE nt_4;
  DROP TABLE nt_5;
  DROP TABLE nt_6;

DROP PROCEDURE pc_i_tt_5_suc;
  DROP PROCEDURE pc_i_nt_5_suc;
  DROP FUNCTION fc_i_tt_5_suc;
  DROP FUNCTION fc_i_nt_5_suc;
  DROP FUNCTION fc_i_nt_3_tt_3_suc;

--disable_query_log
  if ($database_name != 'test')
  {
    --eval DROP DATABASE $database_name
  }
  --enable_query_log

sync_slave_with_master;

--let $commands=
}

while ($commands != '')
{
  --disable_query_log
  --eval use $database_name
  --enable_query_log

--disable_query_log
  --let $command= `SELECT SUBSTRING_INDEX('$commands', ' ', 1)`
  if ($verbose)
  {
    --echo -b-b-b-b-b-b-b-b-b-b-b- >> $command << -b-b-b-b-b-b-b-b-b-b-b-
    let $pos_command= query_get_value("SHOW MASTER STATUS", Position, 1);
  }
  --enable_query_log
  if ($command == 'B')
  {
    eval BEGIN;
  }
  if ($command == 'T')
  {
    #--echo DEBUG-- (trans_id, stmt_id) --> ($trans_id, $stmt_id)
    eval INSERT INTO tt_1(trans_id, stmt_id) VALUES ($trans_id, $stmt_id);
    inc $stmt_id;
  }
  if ($command == 'T-trig')
  {
    #--echo DEBUG-- (trans_id, stmt_id) --> ($trans_id, $stmt_id)
    eval INSERT INTO tt_5(trans_id, stmt_id) VALUES ($trans_id, $stmt_id);
    inc $stmt_id;
  }
  if ($command == 'T-func')
  {
    #--echo DEBUG-- (trans_id, stmt_id) --> ($trans_id, $stmt_id)
    eval SELECT fc_i_tt_5_suc ($trans_id, $stmt_id);
    inc $stmt_id;
  }
  if ($command == 'T-proc')
  {
    #--echo DEBUG-- (trans_id, stmt_id) --> ($trans_id, $stmt_id)
    eval CALL pc_i_tt_5_suc ($trans_id, $stmt_id);
    inc $stmt_id;
  }
  if ($command == 'eT')
  {
    #--echo DEBUG-- (trans_id, stmt_id) --> ($trans_id, $stmt_id)
    let $old_trans_id= `SELECT max(trans_id) from tt_1`;
    let $old_stmt_id= `SELECT max(stmt_id) from tt_1 where trans_id= $old_trans_id`;
    --error ER_DUP_ENTRY, ER_DUP_KEY
    eval INSERT INTO tt_1(trans_id, stmt_id) VALUES ($old_trans_id, $old_stmt_id);
    inc $stmt_id;
  }
  if ($command == 'Te')
  {
    #--echo DEBUG-- (trans_id, stmt_id) --> ($trans_id, $stmt_id)
    let $old_trans_id= `SELECT max(trans_id) from tt_1`;
    let $old_stmt_id= `SELECT max(stmt_id) from tt_1 where trans_id= $old_trans_id`;
    --error ER_DUP_ENTRY, ER_DUP_KEY
    eval INSERT INTO tt_1(trans_id, stmt_id) VALUES ($trans_id, $stmt_id), ($old_trans_id, $old_stmt_id);
    inc $stmt_id;
  }
  if ($command == 'Te-trig')
  {
    #--echo DEBUG-- (trans_id, stmt_id) --> ($trans_id, $stmt_id)
    let $old_trans_id= `SELECT max(trans_id) from tt_5`;
    let $old_stmt_id= `SELECT max(stmt_id) from tt_5 where trans_id= $old_trans_id`;
    --error ER_DUP_ENTRY, ER_DUP_KEY
    eval INSERT INTO tt_5(trans_id, stmt_id) VALUES ($trans_id, $stmt_id), ($old_trans_id, $old_stmt_id);
    inc $stmt_id;
  }
  if ($command == 'Te-func')
  {
    #--echo DEBUG-- (trans_id, stmt_id) --> ($trans_id, $stmt_id)
    let $old_trans_id= `SELECT max(trans_id) from tt_1`;
    let $old_stmt_id= `SELECT max(stmt_id) from tt_1 where trans_id= $old_trans_id`;
    --error ER_DUP_ENTRY, ER_DUP_KEY
    eval INSERT INTO tt_1(trans_id, stmt_id, info) VALUES ($trans_id, $stmt_id, ''), ($old_trans_id, $old_stmt_id, fc_i_tt_5_suc ($trans_id, $stmt_id));
    inc $stmt_id;
  }
  if ($command == 'N')
  {
    #--echo DEBUG-- (trans_id, stmt_id) --> ($trans_id, $stmt_id)
    eval INSERT INTO nt_1(trans_id, stmt_id) VALUES ($trans_id, $stmt_id);
    inc $stmt_id;
  }
  if ($command == 'N-trig')
  {
    #--echo DEBUG-- (trans_id, stmt_id) --> ($trans_id, $stmt_id)
    eval INSERT INTO nt_5(trans_id, stmt_id) VALUES ($trans_id, $stmt_id);
    inc $stmt_id;
  }
  if ($command == 'N-func')
  {
    #--echo DEBUG-- (trans_id, stmt_id) --> ($trans_id, $stmt_id)
    eval SELECT fc_i_nt_5_suc ($trans_id, $stmt_id);
    inc $stmt_id;
  }
  if ($command == 'N-proc')
  {
    #--echo DEBUG-- (trans_id, stmt_id) --> ($trans_id, $stmt_id)
    eval CALL pc_i_nt_5_suc ($trans_id, $stmt_id);
    inc $stmt_id;
  }
  if ($command == 'eN')
  {
    #--echo DEBUG-- (trans_id, stmt_id) --> ($trans_id, $stmt_id)
    let $old_trans_id= `SELECT max(trans_id) from nt_1`;
    let $old_stmt_id= `SELECT max(stmt_id) from nt_1 where trans_id= $old_trans_id`;
    --error ER_DUP_ENTRY, ER_DUP_KEY
    eval INSERT INTO nt_1(trans_id, stmt_id) VALUES ($old_trans_id, $old_stmt_id);
    inc $stmt_id;
  }
  if ($command == 'Ne')
  {
    #--echo DEBUG-- (trans_id, stmt_id) --> ($trans_id, $stmt_id)
    let $old_trans_id= `SELECT max(trans_id) from nt_1`;
    let $old_stmt_id= `SELECT max(stmt_id) from nt_1 where trans_id= $old_trans_id`;
    --error ER_DUP_ENTRY, ER_DUP_KEY
    eval INSERT INTO nt_1(trans_id, stmt_id) VALUES ($trans_id, $stmt_id), ($old_trans_id, $old_stmt_id);
    inc $stmt_id;
  }
  if ($command == 'Ne-trig')
  {
    #--echo DEBUG-- (trans_id, stmt_id) --> ($trans_id, $stmt_id)
    let $old_trans_id= `SELECT max(trans_id) from nt_5`;
    let $old_stmt_id= `SELECT max(stmt_id) from nt_5 where trans_id= $old_trans_id`;
    --error ER_DUP_ENTRY, ER_DUP_KEY
    eval INSERT INTO nt_5(trans_id, stmt_id) VALUES ($trans_id, $stmt_id), ($old_trans_id, $old_stmt_id);
    inc $stmt_id;
  }
  if ($command == 'Ne-func')
  {
    #--echo DEBUG-- (trans_id, stmt_id) --> ($trans_id, $stmt_id)
    let $old_trans_id= `SELECT max(trans_id) from nt_1`;
    let $old_stmt_id= `SELECT max(stmt_id) from nt_1 where trans_id= $old_trans_id`;
    --error ER_DUP_ENTRY, ER_DUP_KEY
    eval INSERT INTO nt_1(trans_id, stmt_id, info) VALUES ($trans_id, $stmt_id, ''), ($old_trans_id, $old_stmt_id, fc_i_nt_5_suc ($trans_id, $stmt_id));
    inc $stmt_id;
  }
  if ($command == 'tN')
  {
    #--echo DEBUG-- (trans_id, stmt_id) --> ($trans_id, $stmt_id)
    eval INSERT INTO nt_1(trans_id, stmt_id, info) SELECT $trans_id, $stmt_id, COUNT(*) FROM tt_1;
    inc $stmt_id;
  }
  if ($command == 'tNe')
  {
    #--echo DEBUG-- (trans_id, stmt_id) --> ($trans_id, $stmt_id)
    let $old_trans_id= `SELECT max(trans_id) from nt_1`;
    let $old_stmt_id= `SELECT max(stmt_id) from nt_1 where trans_id= $old_trans_id`;
    --error ER_DUP_ENTRY, ER_DUP_KEY
    eval INSERT INTO nt_1(trans_id, stmt_id, info) SELECT $trans_id, $stmt_id, COUNT(*) FROM tt_1 UNION SELECT $old_trans_id, $old_stmt_id, COUNT(*) FROM tt_1;
    inc $stmt_id;
  }
  if ($command == 'nT')
  {
    #--echo DEBUG-- (trans_id, stmt_id) --> ($trans_id, $stmt_id)
    eval INSERT INTO tt_1(trans_id, stmt_id, info) SELECT $trans_id, $stmt_id, COUNT(*) FROM nt_1;
    inc $stmt_id;
  }
  if ($command == 'nTe')
  {
    #--echo DEBUG-- (trans_id, stmt_id) --> ($trans_id, $stmt_id)
    let $old_trans_id= `SELECT max(trans_id) from tt_1`;
    let $old_stmt_id= `SELECT max(stmt_id) from tt_1 where trans_id= $old_trans_id`;
    --error ER_DUP_ENTRY, ER_DUP_KEY
    eval INSERT INTO tt_1(trans_id, stmt_id, info) SELECT $trans_id, $stmt_id, COUNT(*) FROM nt_1 UNION SELECT $old_trans_id, $old_stmt_id, COUNT(*) FROM nt_1;
    inc $stmt_id;
  }
  if ($command == 'NT')
  {
    #--echo DEBUG-- (trans_id, stmt_id) --> ($trans_id, $stmt_id)
    eval UPDATE nt_3, tt_3 SET nt_3.info= "new text $trans_id --> $stmt_id", tt_3.info= "new text $trans_id --> $stmt_id" where nt_3.trans_id = tt_3.trans_id and tt_3.trans_id = 1;
    inc $stmt_id;
  }
  if ($command == 'NT-trig')
  {
    #--echo DEBUG-- (trans_id, stmt_id) --> ($trans_id, $stmt_id)
    eval INSERT INTO nt_4(trans_id, stmt_id) VALUES ($trans_id, $stmt_id);
    inc $stmt_id;
  }
  if ($command == 'NT-func')
  {
    #--echo DEBUG-- (trans_id, stmt_id) --> ($trans_id, $stmt_id)
    eval INSERT INTO nt_5(trans_id, stmt_id, info) VALUES ($trans_id, $stmt_id, fc_i_tt_5_suc($trans_id, $stmt_id));
    inc $stmt_id;
  }
  if ($command == 'NeT-trig')
  {
    #--echo DEBUG-- (trans_id, stmt_id) --> ($trans_id, $stmt_id)
    let $old_trans_id= `SELECT max(trans_id) from nt_4`;
    let $old_stmt_id= `SELECT max(stmt_id) from nt_4 where trans_id= $old_trans_id`;
    --error ER_DUP_ENTRY, ER_DUP_KEY
    eval INSERT INTO nt_4(trans_id, stmt_id) VALUES ($trans_id, $stmt_id), ($old_trans_id, $old_stmt_id);
    inc $stmt_id;
  }
  if ($command == 'NeT-func')
  {
    #--echo DEBUG-- (trans_id, stmt_id) --> ($trans_id, $stmt_id)
    let $old_trans_id= `SELECT max(trans_id) from nt_5`;
    let $old_stmt_id= `SELECT max(stmt_id) from nt_5 where trans_id= $old_trans_id`;
    --error ER_DUP_ENTRY, ER_DUP_KEY
    eval INSERT INTO nt_5(trans_id, stmt_id, info) VALUES ($trans_id, $stmt_id, ''), ($old_trans_id, $old_stmt_id, fc_i_tt_5_suc ($trans_id, $stmt_id));
    inc $stmt_id;
  }
  if ($command == 'TN')
  {
    #--echo DEBUG-- (trans_id, stmt_id) --> ($trans_id, $stmt_id)
    eval UPDATE tt_4, nt_4 SET tt_4.info= "new text $trans_id --> $stmt_id", nt_4.info= "new text $trans_id --> $stmt_id" where nt_4.trans_id = tt_4.trans_id and tt_4.trans_id = 1;
    inc $stmt_id;
  }
  if ($command == 'TN-trig')
  {
    #--echo DEBUG-- (trans_id, stmt_id) --> ($trans_id, $stmt_id)
    eval INSERT INTO tt_3(trans_id, stmt_id) VALUES ($trans_id, $stmt_id);
    inc $stmt_id;
  }
  if ($command == 'TN-func')
  {
    #--echo DEBUG-- (trans_id, stmt_id) --> ($trans_id, $stmt_id)
    eval INSERT INTO tt_5(trans_id, stmt_id, info) VALUES ($trans_id, $stmt_id, fc_i_nt_5_suc($trans_id, $stmt_id));
    inc $stmt_id;
  }
  if ($command == 'TeN-trig')
  {
    #--echo DEBUG-- (trans_id, stmt_id) --> ($trans_id, $stmt_id)
    let $old_trans_id= `SELECT max(trans_id) from tt_3`;
    let $old_stmt_id= `SELECT max(stmt_id) from tt_3 where trans_id= $old_trans_id`;
    --error ER_DUP_ENTRY, ER_DUP_KEY
    eval INSERT INTO tt_3(trans_id, stmt_id) VALUES ($trans_id, $stmt_id), ($old_trans_id, $old_stmt_id);
    inc $stmt_id;
  }
  if ($command == 'TeN-func')
  {
    #--echo DEBUG-- (trans_id, stmt_id) --> ($trans_id, $stmt_id)
    let $old_trans_id= `SELECT max(trans_id) from tt_5`;
    let $old_stmt_id= `SELECT max(stmt_id) from tt_5 where trans_id= $old_trans_id`;
    --error ER_DUP_ENTRY, ER_DUP_KEY
    eval INSERT INTO tt_5(trans_id, stmt_id, info) VALUES ($trans_id, $stmt_id, ''), ($old_trans_id, $old_stmt_id, fc_i_nt_5_suc ($trans_id, $stmt_id));
    inc $stmt_id;
  }
  if ($command == 'set-T')
  {
    --eval SET @var= fc_i_tt_5_suc($trans_id, $stmt_id)
    inc $stmt_id;
  }
  if ($command == 'set-N')
  {
    --eval SET @var= fc_i_nt_5_suc($trans_id, $stmt_id)
    inc $stmt_id;
  }
  if ($command == 'set-NT')
  {
    --eval SET @var= fc_i_nt_3_tt_3_suc($trans_id, $stmt_id)
    inc $stmt_id;
  }
  if ($command == 'CS-T->T')
  {
    --eval CREATE TABLE tt_xx_$tb_id (PRIMARY KEY(trans_id, stmt_id)) engine=$engine_type SELECT * FROM tt_1;
  }
  if ($command == 'CS-N->N')
  {
    --eval CREATE TABLE nt_xx_$tb_id (PRIMARY KEY(trans_id, stmt_id)) engine=MyIsam SELECT * FROM nt_1;
  }
  if ($command == 'CS-T->N')
  {
    --eval CREATE TABLE tt_xx_$tb_id (PRIMARY KEY(trans_id, stmt_id)) engine=$engine_type SELECT * FROM nt_1;
  }
  if ($command == 'CS-N->T')
  {
    --eval CREATE TABLE nt_xx_$tb_id (PRIMARY KEY(trans_id, stmt_id)) engine=MyIsam SELECT * FROM tt_1;
  }
  if ($command == 'CSe-T->T')
  {
    --error ER_DUP_ENTRY, ER_DUP_KEY
    --eval CREATE TABLE tt_xx_$tb_id (PRIMARY KEY (stmt_id)) engine=$engine_type SELECT stmt_id FROM tt_1;
  }
  if ($command == 'CSe-N->N')
  {
    --error ER_DUP_ENTRY, ER_DUP_KEY
    --eval CREATE TABLE nt_xx_$tb_id (PRIMARY KEY (stmt_id)) engine=MyIsam SELECT stmt_id FROM nt_1;
  }
  if ($command == 'CSe-T->N')
  {
    --error ER_DUP_ENTRY, ER_DUP_KEY
    --eval CREATE TABLE tt_xx_$tb_id (PRIMARY KEY (stmt_id)) engine=$engine_type SELECT stmt_id FROM nt_1;
  }
  if ($command == 'CSe-N->T')
  {
    --error ER_DUP_ENTRY, ER_DUP_KEY
    --eval CREATE TABLE nt_xx_$tb_id (PRIMARY KEY (stmt_id)) engine=MyIsam SELECT stmt_id FROM tt_1;
  }
  if ($command == 'CT')
  {
    --eval CREATE TEMPORARY TABLE tt_xx_$tb_id (a int) engine=$engine_type;
  }
  if ($command == 'IS-T<-N')
  {
    --eval INSERT INTO tt_xx_$tb_id(trans_id, stmt_id, info) SELECT trans_id, stmt_id, USER() FROM nt_1;
  }
  if ($command == 'ISe-T<-N')
  {
    --error ER_DUP_ENTRY, ER_DUP_KEY
    --eval INSERT INTO tt_xx_$tb_id(trans_id, stmt_id, info) SELECT trans_id, trans_id, USER() FROM nt_1;
  }
  if ($command == 'IS-N<-T')
  {
    --eval INSERT INTO nt_xx_$tb_id(trans_id, stmt_id, info) SELECT trans_id, stmt_id, USER() FROM tt_1;
  }
  if ($command == 'ISe-N<-T')
  {
    --error ER_DUP_ENTRY, ER_DUP_KEY
    --eval INSERT INTO nt_xx_$tb_id(trans_id, stmt_id, info) SELECT trans_id, trans_id, USER() FROM tt_1;
  }
  if ($command == 'IS-T<-T')
  {
    --eval INSERT INTO tt_xx_$tb_id(trans_id, stmt_id, info) SELECT trans_id, stmt_id, USER() FROM tt_1;
  }
  if ($command == 'ISe-T<-T')
  {
    --error ER_DUP_ENTRY, ER_DUP_KEY
    --eval INSERT INTO tt_xx_$tb_id(trans_id, stmt_id, info) SELECT trans_id, trans_id, USER() FROM tt_1;
  }
  if ($command == 'IS-N<-N')
  {
    --eval INSERT INTO nt_xx_$tb_id(trans_id, stmt_id, info) SELECT trans_id, stmt_id, USER() FROM nt_1;
  }
  if ($command == 'ISe-N<-N')
  {
    --error ER_DUP_ENTRY, ER_DUP_KEY
    --eval INSERT INTO nt_xx_$tb_id(trans_id, stmt_id, info) SELECT trans_id, trans_id, USER() FROM nt_1;
  }
  if ($command == 'trunc-CS-T')
  {
    eval TRUNCATE TABLE tt_xx_$tb_id;
  }
  if ($command == 'trunc-CS-N')
  {
    eval TRUNCATE TABLE nt_xx_$tb_id;
  }
  if ($command == 'trunc-CT')
  {
    eval TRUNCATE TABLE tt_xx_$tb_id;
  }
  if ($command == 'drop-CS')
  {
    --disable_warnings
    eval DROP TABLE IF EXISTS tt_xx_$tb_id, nt_xx_$tb_id;
    inc $tb_id;
    --enable_warnings
  }
  if ($command == 'drop-CT')
  {
    --disable_warnings
    eval DROP TEMPORARY TABLE IF EXISTS tt_xx_$tb_id;
    inc $tb_id;
    --enable_warnings
  }
  if ($command == 'C')
  {
    --error 0, ER_GET_ERRMSG
    eval COMMIT;
  }
  if ($command == 'R')
  {
    --replace_column 2 #
    --error 0, ER_GET_ERRMSG
    eval ROLLBACK;
  }
  if ($command == 'Sn')
  {
    eval SAVEPOINT S_$sn;
    --inc $sn 
  }
  if ($command == 'Rn')
  {
    if ($sn)
    {
      --dec $sn
    }
    --replace_column 2 #
    eval ROLLBACK TO S_$sn;
  }
  if ($command == 'Cn')
  {
    if ($sn)
    {
      --dec $sn
    }
    eval RELEASE SAVEPOINT S_$sn;
  }
  --disable_query_log
  --let $commands= `SELECT LTRIM(SUBSTRING('$commands', LENGTH('$command') + 1))`
  inc $stmt_id;

let $binlog_start= $pos_command;
  if ($verbose)
  {
    # Use other connection because query show binlog events
    # executes SELECT UUID(), which switches to row-logging when
    # binlog_format=mixed, if there are open temporary tables. This is
    # due to BUG#13692513.
    --connection server_1
    replace_column 2 # 4 # 5 #;
    --replace_regex $binlog_filter
    eval show binlog events from $binlog_start;
    --connection master
    --echo -e-e-e-e-e-e-e-e-e-e-e- >> $command << -e-e-e-e-e-e-e-e-e-e-e-
  }
  if ($commands == '')
  {
    let $binlog_start= $pos_trans_command;
    --echo -b-b-b-b-b-b-b-b-b-b-b- >> $rme_initial_commands << -b-b-b-b-b-b-b-b-b-b-b-
    --connection server_1
    replace_column 2 # 4 # 5 #;
    --replace_regex $binlog_filter
    eval show binlog events from $binlog_start;
    --connection master
    --echo -e-e-e-e-e-e-e-e-e-e-e- >> $rme_initial_commands << -e-e-e-e-e-e-e-e-e-e-e-
    --echo
    let $pos_trans_command= query_get_value("SHOW MASTER STATUS", Position, 1);
    let $stmt_id= 1;
    inc $trans_id;
  }
}

--let $commands= $rme_initial_commands

${this.title}

Code Editor : rpl_mixing_engines.inc