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_binlog_max_cache_size.test

########################################################################################
#    This test does two things. First it verifies if the binlog is not corrupted when
#    the cache buffer is not big enough to accommodate the changes and is divided in
#    five steps:
#
#    1 - Single Statements:
#      1.1 - Single statement on transactional table.
#      1.2 - Single statement on non-transactional table. 
#      1.3 - Single statement on both transactional and non-transactional tables.
#
#    In both 1.2 and 1.3, an incident event is logged to notify the user that the
#    master and slave are diverging.
#
#    2 - Transactions ended by an implicit commit.
#
#    3 - Transactions ended by a COMMIT.
#
#    4 - Transactions ended by a ROLLBACK.
#
#    5 - Transactions with a failing statement that updates a non-transactional
#    table. In this case, a failure means that the statement does not get into
#    the cache and an incident event is logged to notify the user that the master
#    and slave are diverging.
#
#    Then it checks what happens when we try to set BINLOG_CACHE_SIZE to a value that
#    is greater than MAX_BINLOG_CACHE_SIZE and vice-versa. In both cases, We expect
#    that BINLOG_CACHE_SIZE will be set to MAX_BINLOG_CACHE_SIZE. (BUG#55377)
########################################################################################
--source include/have_myisam.inc
call mtr.add_suppression("Unsafe statement written to the binary log using statement format since BINLOG_FORMAT = STATEMENT");
call mtr.add_suppression("Option binlog_cache_size ");
call mtr.add_suppression("Slave SQL for channel '': The incident LOST_EVENTS occured on the master.");
call mtr.add_suppression("The content of the statement cache is corrupted "
                         "while writing a rollback record of the transaction "
                         "to the binary log. An incident event has been "
                         "written to the binary log which will stop the "
                         "slaves.");
call mtr.add_suppression("Error happend while resetting the transaction "
                         "cache for a rolled back transaction or a single "
                         "statement not inside a transaction. An incident "
                         "event has been written to the binary log which "
                         "will stop the slaves.");

let $old_max_binlog_cache_size= query_get_value(SHOW VARIABLES LIKE "max_binlog_cache_size", Value, 1);
let $old_binlog_cache_size= query_get_value(SHOW VARIABLES LIKE "binlog_cache_size", Value, 1);
let $old_max_binlog_stmt_cache_size= query_get_value(SHOW VARIABLES LIKE "max_binlog_stmt_cache_size", Value, 1);
let $old_binlog_stmt_cache_size= query_get_value(SHOW VARIABLES LIKE "binlog_stmt_cache_size", Value, 1);

SET GLOBAL max_binlog_cache_size = 4096;
SET GLOBAL binlog_cache_size = 4096;
SET GLOBAL max_binlog_stmt_cache_size = 4096;
SET GLOBAL binlog_stmt_cache_size = 4096;
disconnect master;
connect (master,127.0.0.1,root,,test,$MASTER_MYPORT,);

CREATE TABLE t1(a INT PRIMARY KEY, data VARCHAR(30000)) ENGINE=Innodb;
CREATE TABLE t2(a INT PRIMARY KEY, data VARCHAR(30000)) ENGINE=MyIsam;
CREATE TABLE t3(a INT PRIMARY KEY, data VARCHAR(30000)) ENGINE=Innodb;

let $data = `select concat('"', repeat('a',2000), '"')`;

--echo ###### 1 - SINGLE STATEMENT  ######

connection master;

--echo *** Single statement on transactional table ***
--disable_query_log
--error ER_TRANS_CACHE_FULL, ER_STMT_CACHE_FULL, ER_ERROR_ON_WRITE
eval INSERT INTO t1 (a, data) VALUES (1,
     CONCAT($data, $data, $data, $data, $data));
--enable_query_log

--echo *** Single statement on non-transactional table ***
--disable_query_log
--error ER_TRANS_CACHE_FULL, ER_STMT_CACHE_FULL, ER_ERROR_ON_WRITE
eval INSERT INTO t2 (a, data) VALUES (2,
       CONCAT($data, $data, $data, $data, $data, $data));
--enable_query_log

# Incident event
# 1590=ER_SLAVE_INCIDENT
--let $slave_sql_errno= 1590
--source include/wait_for_slave_sql_error_and_skip.inc

--disable_query_log
eval INSERT INTO t1 (a, data) VALUES (3, $data);
eval INSERT INTO t1 (a, data) VALUES (4, $data);
eval INSERT INTO t1 (a, data) VALUES (5, $data);
eval INSERT INTO t2 (a, data) VALUES (3, $data);
eval INSERT INTO t2 (a, data) VALUES (4, $data);
eval INSERT INTO t2 (a, data) VALUES (5, $data);
--enable_query_log

--echo *** Single statement on both transactional and non-transactional tables. ***
--disable_query_log
--error ER_TRANS_CACHE_FULL, ER_STMT_CACHE_FULL, ER_ERROR_ON_WRITE
eval UPDATE t2, t1 SET t2.data = CONCAT($data, $data, $data, $data),
                       t1.data = CONCAT($data, $data, $data, $data);
--enable_query_log

# 1590=ER_SLAVE_INCIDENT
--let $slave_sql_errno= 1590
--let $slave_skip_counter= `SELECT IF(@@binlog_format = 'ROW', 2, 1)`
--source include/wait_for_slave_sql_error_and_skip.inc

--let $diff_tables= master:t1,slave:t1
--source include/diff_tables.inc

--echo #########  2 - BEGIN - IMPLICIT COMMIT by DDL #########

connection master;
TRUNCATE TABLE t1;
TRUNCATE TABLE t2;
TRUNCATE TABLE t3;

BEGIN;
--disable_query_log
--eval INSERT INTO t1 (a, data) VALUES (1, $data);
--eval INSERT INTO t1 (a, data) VALUES (2, $data);
--eval INSERT INTO t1 (a, data) VALUES (3, $data);
--error ER_TRANS_CACHE_FULL, ER_STMT_CACHE_FULL, ER_ERROR_ON_WRITE
--eval INSERT INTO t1 (a, data) VALUES (4, $data);
--error ER_TRANS_CACHE_FULL, ER_STMT_CACHE_FULL, ER_ERROR_ON_WRITE
--eval INSERT INTO t1 (a, data) VALUES (5, $data);
--error ER_TRANS_CACHE_FULL, ER_STMT_CACHE_FULL, ER_ERROR_ON_WRITE
--eval INSERT INTO t1 (a, data) VALUES (6, $data);
--eval INSERT INTO t1 (a, data) VALUES (7, 's');
--eval INSERT INTO t2 (a, data) VALUES (8, 's');
--eval INSERT INTO t1 (a, data) VALUES (9, 's');
--enable_query_log

--disable_query_log
ALTER TABLE t3 ADD COLUMN d int;
--enable_query_log

--disable_query_log
--eval INSERT INTO t2 (a, data) VALUES (10, $data);
--eval INSERT INTO t2 (a, data) VALUES (11, $data);
--eval INSERT INTO t2 (a, data) VALUES (12, $data);
--eval INSERT INTO t2 (a, data) VALUES (13, $data);
--enable_query_log

BEGIN;
--disable_query_log
--eval INSERT INTO t1 (a, data) VALUES (14, $data);
--eval INSERT INTO t1 (a, data) VALUES (15, $data);
--eval INSERT INTO t1 (a, data) VALUES (16, $data);
--error ER_TRANS_CACHE_FULL, ER_STMT_CACHE_FULL, ER_ERROR_ON_WRITE
--eval INSERT INTO t1 (a, data) VALUES (17, $data);
--error ER_TRANS_CACHE_FULL, ER_STMT_CACHE_FULL, ER_ERROR_ON_WRITE
--eval INSERT INTO t1 (a, data) VALUES (18, $data);
--eval INSERT INTO t1 (a, data) VALUES (19, 's');
--eval INSERT INTO t2 (a, data) VALUES (20, 's');
--eval INSERT INTO t1 (a, data) VALUES (21, 's');
--enable_query_log

if (`SELECT @@binlog_format = 'STATEMENT' || @@binlog_format = 'MIXED'`)
{
  --disable_query_log
  CREATE TABLE t4 SELECT * FROM t1;
  --enable_query_log
}
if (`SELECT @@binlog_format = 'ROW'`)
{
  --disable_query_log
  --error ER_TRANS_CACHE_FULL, ER_STMT_CACHE_FULL, ER_ERROR_ON_WRITE
  CREATE TABLE t4 SELECT * FROM t1;
  --enable_query_log
}

--disable_query_log
--eval INSERT INTO t2 (a, data) VALUES (15, $data);
--enable_query_log

BEGIN;
--disable_query_log
--eval INSERT INTO t1 (a, data) VALUES (22, $data);
--eval INSERT INTO t1 (a, data) VALUES (23, $data);
--eval INSERT INTO t1 (a, data) VALUES (24, $data);
--error ER_TRANS_CACHE_FULL, ER_STMT_CACHE_FULL, ER_ERROR_ON_WRITE
--eval INSERT INTO t1 (a, data) VALUES (25, $data);
--error ER_TRANS_CACHE_FULL, ER_STMT_CACHE_FULL, ER_ERROR_ON_WRITE
--eval INSERT INTO t1 (a, data) VALUES (26, $data);
--eval INSERT INTO t1 (a, data) VALUES (27, 's');
--eval INSERT INTO t2 (a, data) VALUES (28, 's');
--eval INSERT INTO t1 (a, data) VALUES (29, 's');
--enable_query_log

--disable_query_log
CREATE TABLE t5 (a int);
--enable_query_log

--sync_slave_with_master
--let $diff_tables= master:t1,slave:t1
--source include/diff_tables.inc

--echo ###### 3 - BEGIN - COMMIT ######

connection master;
TRUNCATE TABLE t1;
TRUNCATE TABLE t2;
TRUNCATE TABLE t3;

--sync_slave_with_master
--let $diff_tables= master:t1,slave:t1
--source include/diff_tables.inc

--echo ####### 4 - BEGIN - ROLLBACK  #######

connection master;
TRUNCATE TABLE t1;
TRUNCATE TABLE t2;
TRUNCATE TABLE t3;

--sync_slave_with_master
--let $diff_tables= master:t1,slave:t1
--source include/diff_tables.inc

--echo ###### 5 - PROCEDURE  #######

connection master;
TRUNCATE TABLE t1;
TRUNCATE TABLE t2;
TRUNCATE TABLE t3;

DELIMITER //;

CREATE PROCEDURE p1(pd VARCHAR(30000))
BEGIN
  INSERT INTO t1 (a, data) VALUES (1, pd);
  INSERT INTO t1 (a, data) VALUES (2, pd);
  INSERT INTO t1 (a, data) VALUES (3, pd);
  INSERT INTO t1 (a, data) VALUES (4, pd);
  INSERT INTO t1 (a, data) VALUES (5, 's');
END//

DELIMITER ;//

TRUNCATE TABLE t1;

--disable_query_log
eval CALL p1($data);
--enable_query_log

TRUNCATE TABLE t1;

BEGIN;
--disable_query_log
--error ER_TRANS_CACHE_FULL, ER_STMT_CACHE_FULL, ER_ERROR_ON_WRITE
eval CALL p1($data);
--enable_query_log
COMMIT;

TRUNCATE TABLE t1;

BEGIN;
--disable_query_log
--error ER_TRANS_CACHE_FULL, ER_STMT_CACHE_FULL, ER_ERROR_ON_WRITE
eval CALL p1($data);
--enable_query_log
ROLLBACK;

--sync_slave_with_master
--let $diff_tables= master:t1,slave:t1
--source include/diff_tables.inc

--echo ####### 6 - XID ######

connection master;
TRUNCATE TABLE t1;
TRUNCATE TABLE t2;
TRUNCATE TABLE t3;

BEGIN;
--disable_query_log
--eval INSERT INTO t1 (a, data) VALUES (1, $data);
--eval INSERT INTO t1 (a, data) VALUES (2, $data);
--eval INSERT INTO t1 (a, data) VALUES (3, $data);
--error ER_TRANS_CACHE_FULL, ER_STMT_CACHE_FULL, ER_ERROR_ON_WRITE
--eval INSERT INTO t1 (a, data) VALUES (4, $data);
SAVEPOINT sv;
--error ER_TRANS_CACHE_FULL, ER_STMT_CACHE_FULL, ER_ERROR_ON_WRITE
--eval INSERT INTO t1 (a, data) VALUES (5, $data);
--error ER_TRANS_CACHE_FULL, ER_STMT_CACHE_FULL, ER_ERROR_ON_WRITE
--eval INSERT INTO t1 (a, data) VALUES (6, $data);
--eval INSERT INTO t1 (a, data) VALUES (7, 's');
--eval INSERT INTO t2 (a, data) VALUES (8, 's');
--eval INSERT INTO t1 (a, data) VALUES (9, 's');
--enable_query_log
ROLLBACK TO sv;
COMMIT;

--sync_slave_with_master
--let $diff_tables= master:t1,slave:t1
--source include/diff_tables.inc

--echo ####### 7 - NON-TRANS TABLE #######

connection master;
TRUNCATE TABLE t1;
TRUNCATE TABLE t2;
TRUNCATE TABLE t3;

BEGIN;
--disable_query_log
--eval INSERT INTO t1 (a, data) VALUES (1, $data);
--eval INSERT INTO t1 (a, data) VALUES (2, $data);
--eval INSERT INTO t2 (a, data) VALUES (3, $data);
--eval INSERT INTO t1 (a, data) VALUES (4, $data);
--error ER_TRANS_CACHE_FULL, ER_STMT_CACHE_FULL, ER_ERROR_ON_WRITE
--eval INSERT INTO t1 (a, data) VALUES (5, $data);
--error ER_TRANS_CACHE_FULL, ER_STMT_CACHE_FULL, ER_ERROR_ON_WRITE
--eval INSERT INTO t1 (a, data) VALUES (6, $data);
--error ER_TRANS_CACHE_FULL, ER_STMT_CACHE_FULL, ER_ERROR_ON_WRITE
--eval INSERT INTO t1 (a, data) VALUES (7, $data);
--eval UPDATE t2 SET data= CONCAT($data, $data);
--eval INSERT INTO t1 (a, data) VALUES (8, 's');
--eval INSERT INTO t1 (a, data) VALUES (9, 's');
--eval INSERT INTO t2 (a, data) VALUES (10, 's');
--eval INSERT INTO t1 (a, data) VALUES (11, 's');
--enable_query_log
COMMIT;

BEGIN;
--disable_query_log
--eval INSERT INTO t1 (a, data) VALUES (15, $data);
--eval INSERT INTO t1 (a, data) VALUES (16, $data);
--eval INSERT INTO t2 (a, data) VALUES (17, $data);
--eval INSERT INTO t1 (a, data) VALUES (18, $data);
--error ER_TRANS_CACHE_FULL, ER_STMT_CACHE_FULL, ER_ERROR_ON_WRITE
--eval INSERT INTO t1 (a, data) VALUES (19, $data);
--enable_query_log
COMMIT;

--sync_slave_with_master
--let $diff_tables= master:t1,slave:t1
--source include/diff_tables.inc

--echo ####### 8 - LOAD DATA INFILE INTO TABLE #######

#
# This scenario verifies that load data infile fails when
# binlog cache exceeds max_binlog_cache_size
#
--source include/rpl_connection_master.inc
CREATE TABLE t6 (a varchar(20)) ENGINE=Innodb;

# Save the current binary log position
--let $pos_before= query_get_value(show master status,Position,1)

--disable_query_log
--let $write_var =`SELECT REPEAT('Testing\n', 1000)`
--let $write_to_file = GENERATE
--source include/write_var_to_file.inc
--enable_query_log

# Below transaction generates transaction cache more than
# the max_binlog_cache_size i.e 4096. Hence results in error.
--replace_result $write_to_file temp_file
--error ER_TRANS_CACHE_FULL
eval LOAD DATA INFILE '$write_to_file' INTO TABLE t6;

--exec rm $write_to_file

# Check that the above transaction has not been logged in the binary log
--let $assert_text= assert that the above Event has not been added to binlog
--let $assert_cond= [SHOW MASTER STATUS, Position,1] = $pos_before
--source include/assert.inc

# Check that the table is empty on master
--let $assert_text = Check that the LOAD DATA didn't add any data into the table
--let $assert_cond = [SELECT COUNT(*) FROM t6] = 0
--source include/assert.inc

--source include/sync_slave_sql_with_master.inc

# Check that the table is empty on slave
--let $assert_text = Check that the LOAD DATA didn't add any data into the table
--let $assert_cond = [SELECT COUNT(*) FROM t6] = 0
--source include/assert.inc

--source include/rpl_connection_master.inc
DROP TABLE t6;
--source include/sync_slave_sql_with_master.inc

--echo ######### 9 - Bug#55375(Regression Bug) Transaction bigger than  ##########
--echo #########     max_binlog_cache_size crashes slave                ##########

--echo # [ On Slave ]
SET GLOBAL max_binlog_cache_size = 4096;
SET GLOBAL binlog_cache_size = 4096;
SET GLOBAL max_binlog_stmt_cache_size = 4096;
SET GLOBAL binlog_stmt_cache_size = 4096;

source include/stop_slave.inc;
source include/start_slave.inc;
CALL mtr.add_suppression("Multi-statement transaction required more than 'max_binlog_cache_size' bytes of storage.*");
CALL mtr.add_suppression("Multi-statement transaction required more than 'max_binlog_stmt_cache_size' bytes of storage.*");
CALL mtr.add_suppression("Writing one row to the row-based binary log failed.*");
CALL mtr.add_suppression("Slave SQL.*The incident LOST_EVENTS occured on the master. Message: error writing to the binary log");
call mtr.add_suppression("The slave coordinator and worker threads are stopped, possibly leaving data in inconsistent state");

connection master;
TRUNCATE t1;

sync_slave_with_master;
--let binlog_start= query_get_value(SHOW MASTER STATUS, Position, 1)
--let binlog_file= query_get_value(SHOW MASTER STATUS, File, 1)

connection master;
--replace_result $old_max_binlog_cache_size ORIGINAL_VALUE
--eval SET GLOBAL max_binlog_cache_size= $old_max_binlog_cache_size
--replace_result $old_binlog_cache_size ORIGINAL_VALUE
--eval SET GLOBAL binlog_cache_size= $old_binlog_cache_size
--replace_result $old_max_binlog_stmt_cache_size ORIGINAL_VALUE
--eval SET GLOBAL max_binlog_stmt_cache_size= $old_max_binlog_stmt_cache_size
--replace_result $old_binlog_stmt_cache_size ORIGINAL_VALUE
--eval SET GLOBAL binlog_stmt_cache_size= $old_binlog_stmt_cache_size
disconnect master;
connect (master,127.0.0.1,root,,test,$MASTER_MYPORT,);

--let $n=128
BEGIN;
--disable_query_log
--echo Repeat statement 'INSERT INTO t1 VALUES(\$n, repeat("a", 32))' $n times
while ($n)
{
  --eval INSERT INTO t1 VALUES ($n, repeat("a", 32))
  --dec $n
}
--enable_query_log
COMMIT;

--connection slave
--let $slave_sql_errno= 1534,1197
source include/wait_for_slave_sql_error.inc;

SELECT count(*) FROM t1;
source include/show_binlog_events.inc;

--replace_result $old_max_binlog_cache_size ORIGINAL_VALUE
--eval SET GLOBAL max_binlog_cache_size= $old_max_binlog_cache_size
--replace_result $old_binlog_cache_size ORIGINAL_VALUE
--eval SET GLOBAL binlog_cache_size= $old_binlog_cache_size
--replace_result $old_max_binlog_stmt_cache_size ORIGINAL_VALUE
--eval SET GLOBAL max_binlog_stmt_cache_size= $old_max_binlog_stmt_cache_size
--replace_result $old_binlog_stmt_cache_size ORIGINAL_VALUE
--eval SET GLOBAL binlog_stmt_cache_size= $old_binlog_stmt_cache_size

source include/stop_slave.inc;
source include/start_slave.inc;

connection master;
sync_slave_with_master;
SELECT count(*) FROM t1;

--echo ######## CHECK MAX_BINLOG_CACHE_SIZE and BINLOG_CACHE_SIZE #########
#
# Checking what happens when we try to set BINLOG_CACHE_SIZE to a value that is
# greater than MAX_BINLOG_CACHE_SIZE and vice-versa. In both cases, We expect
# that BINLOG_CACHE_SIZE will be set to MAX_BINLOG_CACHE_SIZE. (BUG#55377)
# 
connection master;

SET @@GLOBAL.MAX_BINLOG_CACHE_SIZE= 8192;
SHOW VARIABLES LIKE 'MAX_BINLOG_CACHE_SIZE';
SHOW VARIABLES LIKE 'BINLOG_CACHE_SIZE';
SET @@GLOBAL.BINLOG_CACHE_SIZE= 16384;
SHOW VARIABLES LIKE 'MAX_BINLOG_CACHE_SIZE';
SHOW VARIABLES LIKE 'BINLOG_CACHE_SIZE';
SET @@GLOBAL.MAX_BINLOG_CACHE_SIZE= 4096;
SHOW VARIABLES LIKE 'MAX_BINLOG_CACHE_SIZE';
SHOW VARIABLES LIKE 'BINLOG_CACHE_SIZE';

--echo ######### CLEAN #########

--disable_query_log
--eval SET GLOBAL max_binlog_cache_size= $old_max_binlog_cache_size
--eval SET GLOBAL binlog_cache_size= $old_binlog_cache_size
--enable_query_log

DROP TABLE t1;
DROP TABLE t2;
DROP TABLE t3;
# t4 exists only if binlog_format!=row, so so a warning is generated
# if binog_format=row
--disable_warnings
DROP TABLE IF EXISTS t4;
--enable_warnings
DROP TABLE t5;
DROP PROCEDURE p1;

${this.title}

Code Editor : rpl_binlog_max_cache_size.test