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
|
#
# Statement specific tests for master_last_event_time
#
--source include/have_binlog_format_statement.inc
--source include/have_innodb.inc
--let $rpl_topology=1->2->3
--source include/rpl_init.inc
# Server_3 state is maintained by master_last_event_time.inc
--connection server_3
--source include/stop_slave.inc
--connection server_1
call mtr.add_suppression("Unsafe statement written to the binary log using statement format since BINLOG_FORMAT = STATEMENT");
alter table mysql.gtid_slave_pos engine=innodb;
create table t1 (a int) engine=aria;
create table t2 (a int) engine=innodb;
--source include/save_master_gtid.inc
--echo # Sleep 1 to ensure setup DDL and test statements have different binlog timestamps
--sleep 1
--connection server_2
set @old_par_thds= @@global.slave_parallel_threads;
--echo #
--echo # Ensure that the slave doesn't overwrite exec_time when binlogging
--echo #
--let $slave_delay= 3
--connection server_2
--source include/sync_with_master_gtid.inc
--source include/stop_slave.inc
--replace_result $slave_delay SLAVE_DELAY
--eval change master to master_delay=$slave_delay
--source include/start_slave.inc
--let $serial_slave_const=2
--let $parallel_slave_const=1
--let $mode_ctr= 2
while ($mode_ctr)
{
--connection server_2
--source include/stop_slave.inc
if ($mode_ctr == $parallel_slave_const)
{
--let $mode_name= parallel
set @@global.slave_parallel_threads= 1;
}
if ($mode_ctr == $serial_slave_const)
{
--let $mode_name= serial
set @@global.slave_parallel_threads= 0;
}
--source include/start_slave.inc
--connection server_2
flush logs;
--connection server_1
--disable_warnings
--echo # Only sleep on master so the real execution time on the slave is less
insert into t1 values (sleep(if(@@global.server_id=1, 2, 0)));
--source include/save_master_gtid.inc
--enable_warnings
--echo # Waiting for slave to delay and commit transaction..
--connection server_2
--source include/sync_with_master_gtid.inc
--let $datadir= `select @@datadir`
--let $filename= query_get_value(SHOW MASTER STATUS, File, 1)
--let $slave_local_binlog=$datadir/$filename
--let $slave_outfile=$MYSQLTEST_VARDIR/tmp/slave_binlog.sql
--echo # MYSQL_BINLOG slave_local_binlog > slave_outfile
--exec $MYSQL_BINLOG $slave_local_binlog > $slave_outfile
--let $assert_count=0
--let $assert_text= Ensure $mode_name slave doesn't overwrite exec_time in the binlog event (0s)
--let $assert_select=exec_time=0
--let $assert_file= $slave_outfile
--source include/assert_grep.inc
# Double-check in the unlikely case execution time could be rounded to 1
--let $assert_text= Ensure $mode_name slave doesn't overwrite exec_time in the binlog event (1s)
--let $assert_select=exec_time=1
--let $assert_file= $slave_outfile
--source include/assert_grep.inc
--source master_last_event_time.inc
--connection server_2
--source include/stop_slave.inc
set @@global.slave_parallel_threads= @old_par_thds;
--source include/start_slave.inc
--dec $mode_ctr
}
--echo #
--echo # Cleanup
--connection server_2
--source include/stop_slave.inc
change master to master_delay=0;
--source include/start_slave.inc
--connection server_3
--source include/start_slave.inc
--connection server_1
drop table t1;
drop table t2;
--source include/rpl_end.inc
--remove_file $slave_outfile
--echo # End of master_last_event_time_stmt
|
