###############################################################################
# This include file is created to test local transaction's behaviour
# (conflict/success) against a transaction that is ordered first
# on a remote server and broadcasted to local server.
#
# 1. Set a debug sync before broadcast message to group on local server.
# 2. Commit a transaction (called local transaction) that will be blocked
#    before broadcast.
# 3. Wait until local server reaches the debug sync point.
# 4. Execute a transaction on remote server (called remote transaction), that
#    will reach first certification, since local transaction is blocked before
#    broadcast.
# 5. Signal the waiting thread on local server to resume.
# 6. Wait for remote transaction to be executed succesfully on local server.
# 7. Check the local transaction behaviour (depends on the scenario, it should be
#    rolled back (conflict scenario) or it should succesfully commit(success scenario).
# 8. Sync everything.
# 9. Assert that number of certified transactions are the expected ones.
#10. Assert that GTID is increased as expected.
#11. Cleanup (restore the connection back to original)
#
# ##### Usage #######
#
# --let $local_server_connection1=server1
# --let $local_server_connection2=server_1
# --let $remote_server_connection=server2
# --let $local_transaction= INSERT INTO t2 VALUES (5); INSERT INTO t1 VALUES (5);
# --let $remote_transaction=UPDATE t1 SET c1=6 WHERE c1=2
# --let $conflict_test=1
# --source include/gr_parallel_local_and_remote_transactions.inc
#
# ##### Parameters #####
#
#  $local_server_connection1
#      Connection name on which the $local_transaction needs to be executed.
#      show_rpl_debug_info uses 'server_.*' connections, they need to be
#      avoided for this parameter due to use of --send command, that dissalows
#      the execution of queries
#
#  $local_server_connection2
#      Connection name on which debug sync commands can be executed to block
#      local transaction before broadcasting.
#
#  $remote_server_connection
#      Connection name on which the $remote_transaction needs to be executed.
#
#  $local_transaction
#       The transaction statements that needs to be executed on local server.
#       If there are more than one statement, they should be specified in the same
#       line with semicolon(;) as delimiter.
#       Eg: --let $local_transaction= INSERT INTO t2 VALUES (5); INSERT INTO t1 VALUES (5);
#
#  $remote_transaction
#       The transaction statements that needs to be executed on remote server.
#       If there are more than one statement, they should be specified in the same
#       line with semicolon(;) as delimiter.
#       Eg: --let $remote_transaction= INSERT INTO t2 VALUES (5); INSERT INTO t1 VALUES (5);
#
#  $conflict_test
#       0 or 1 depends on the testing scenario.
#       If the test case is conflict scenario(1), local transaction
#       should end up in an error stating that it was aborted,
#       since transactions are conflicting and transaction on
#       remote server was ordered first.
#       If the test case is is positive scenario(0),
#       no error will be seen while executing local transaction and
#       should be committed succesfully.
#
#  P.S: This .inc will restore the original connection back.
#
--echo
--echo ############################################################
--echo # 0. Initial setup and checks.

--let $old_conn= $CURRENT_CONNECTION
if (!$local_server_connection1)
{
  --die !!!ERROR IN TEST: you must set $local_server_connection1 on which the local_transaction needs to be executed.
}
if (`SELECT '$local_server_connection1' REGEXP '.*_.*'`)
{
  --die !!!ERROR IN TEST: $local_server_connection1 can't be a 'server_.*' connection, as it maybe be used by rpl_debug_info on error cases.
}
if (!$local_server_connection2)
{
  --die !!!ERROR IN TEST: you must set $local_server_connection2 on which debug sync needs to be set to block the broadcast.
}
if (!$remote_server_connection)
{
  --die !!!ERROR IN TEST: you must set $remote_server_connection on which the remote_transaction needs to be executed.
}
if (!$local_transaction)
{
  --die !!!ERROR IN TEST: you must set $local_transaction which will be executed on local_server_connection1.
}
if (!$remote_transaction)
{
  --die !!!ERROR IN TEST: you must set $remote_transaction which will be executed on remote_server_connection.
}

--let $rpl_connection_name= $local_server_connection1
--source include/rpl_connection.inc

# Include gtid_utils if it is not included already
if (!$gtid_util_included)
{
  SET SESSION sql_log_bin= 0;
  --source include/gtid_utils.inc
  SET SESSION sql_log_bin= 1;
  --let $gtid_utils_installed= 1;
}
# Remember the gtid position
--source include/gtid_step_reset.inc
--let $prev_certified_transactions= query_get_value(SELECT Count_Transactions_Checked from performance_schema.replication_group_member_stats where member_id in (select @@server_uuid), Count_Transactions_Checked, 1)
--let $prev_negatively_certified= query_get_value(SELECT Count_Conflicts_Detected from performance_schema.replication_group_member_stats where member_id in (select @@server_uuid), Count_Conflicts_Detected, 1)

--echo
--echo ############################################################
--echo # 1. Set a debug sync before broadcast message to group on
--echo #    connection local_server_connection1.
--let $rpl_connection_name= $local_server_connection1
--source include/rpl_connection.inc
SET @debug_save= @@GLOBAL.DEBUG;
SET @@GLOBAL.DEBUG='d,group_replication_before_message_broadcast';

--echo
--echo #####################################################################
--echo # 2. Commit local_transaction that will be blocked before broadcast.
BEGIN;
--eval $local_transaction
--send COMMIT

--echo
--echo ############################################################
--echo # 3. Wait until local transaction reaches the
--echo # group_replication_before_message_broadcast debug sync point.
--let $rpl_connection_name= $local_server_connection2
--source include/rpl_connection.inc
--let $wait_condition=SELECT COUNT(*)=1 FROM INFORMATION_SCHEMA.PROCESSLIST WHERE State = 'debug sync point: now'
--source include/wait_condition.inc

--echo
--echo ############################################################
--echo # 4. Execute a transaction on remote server, that will reach first
--echo #    certification, since transaction on the local server
--echo #    is blocked before broadcast.
--let $rpl_connection_name= $remote_server_connection
--source include/rpl_connection.inc
BEGIN;
--eval $remote_transaction
COMMIT;

--echo
--echo ############################################################
--echo # 5. Signal the waiting thread on local server to resume the
--echo #    transaction.
--let $rpl_connection_name= $local_server_connection2
--source include/rpl_connection.inc
SET DEBUG_SYNC='now SIGNAL waiting';
SET @@GLOBAL.DEBUG= @debug_save;


--echo
--echo ############################################################
--echo # 6. Wait for remote transaction to be executed succesfully
--echo      on local server.
--let $rpl_connection_name= $remote_server_connection
--source include/rpl_connection.inc
--let $sync_slave_connection= $local_server_connection2
--source include/sync_slave_sql_with_master.inc

--echo ############################################################
--echo # 7. If the test case is conflict scenario, local transaction
--echo #    will end up in an error stating that it was aborted,
--echo #    since transactions are conflicting and transaction on
--echo #    remote server was ordered first. If the test case is
--echo #    is positive scenario, no error will be seen here.
--let $rpl_connection_name= $local_server_connection1
--source include/rpl_connection.inc
if ($conflict_test)
{
  --error ER_TRANSACTION_ROLLBACK_DURING_COMMIT
}
--reap

--let $rpl_connection_name= $local_server_connection1
--source include/rpl_connection.inc
SET @@GLOBAL.DEBUG=@debug_save;

--echo ############################################################
--echo # 8. Sync everything
--source include/rpl_sync.inc

--echo ############################################################
--echo # 9. Assert that number of certified transactions are the
--echo #    expected ones.
--let $expected_certified_transactions= `SELECT $prev_certified_transactions + 2`
--let $certified_transactions= query_get_value(SELECT Count_Transactions_Checked from performance_schema.replication_group_member_stats where member_id in (select @@server_uuid), Count_Transactions_Checked, 1)
--let $assert_text= The value of Count_Transactions_Checked should be $expected_certified_transactions after starting group replication
--let $assert_cond= "$certified_transactions" = $expected_certified_transactions
--source include/assert.inc

--let $expected_negatively_certified_transactions= `SELECT $prev_negatively_certified + $conflict_test`
--let $negatively_certified= query_get_value(SELECT Count_Conflicts_Detected from performance_schema.replication_group_member_stats where member_id in (select @@server_uuid), Count_Conflicts_Detected, 1)
--let $assert_text= The value of Count_Conflicts_Detected should be $expected_negatively_certified_transactions after starting group replication
--let $assert_cond= "$negatively_certified" = $expected_negatively_certified_transactions
--source include/assert.inc

--echo ############################################################
--echo # 10. Assert that GTID is increased as expected
--let $gtid_step_count= `SELECT 2 - $conflict_test`
--let $gtid_step_uuid=`SELECT @@global.group_replication_group_name`
--let $gtid_step_only_count= 1
--source include/gtid_step_assert.inc

# uninstall gtid_utils if it is installed by this file.
if ($gtid_utils_installed)
{
  --let $rpl_connection_name= $local_server_connection1
  --source include/rpl_connection.inc
  SET SESSION sql_log_bin= 0;
  --source include/gtid_utils_end.inc
  SET SESSION sql_log_bin= 1;
}

--echo ############################################################
--echo # 11. Cleanup (restore the connection back to original)
--let $rpl_connection_name= $old_conn
--source include/rpl_connection.inc