@@ -62,7 +62,8 @@ eval INSERT INTO t2 (a, data) VALUES (2,
62
62
--enable_query_log
63
63
64
64
# Incident event
65
- --let $slave_sql_errno=1590
65
+ # 1590=ER_SLAVE_INCIDENT
66
+ --let $slave_sql_errno= 1590
66
67
--source include/wait_for_slave_sql_error_and_skip.inc
67
68
68
69
--disable_query_log
@@ -81,15 +82,13 @@ eval UPDATE t2, t1 SET t2.data = CONCAT($data, $data, $data, $data),
81
82
t1.data = CONCAT($data, $data, $data, $data);
82
83
--enable_query_log
83
84
84
- # Incident event
85
- --let $slave_skip_counter=1
86
- if (`SELECT @@binlog_format = 'ROW'`)
87
- {
88
- --inc $slave_skip_counter
89
- }
90
- --let $slave_sql_errno=1590
85
+ # 1590=ER_SLAVE_INCIDENT
86
+ --let $slave_sql_errno= 1590
87
+ --let $slave_skip_counter= `SELECT IF(@@binlog_format = 'ROW', 2, 1)`
91
88
--source include/wait_for_slave_sql_error_and_skip.inc
92
- --let $slave_skip_counter=
89
+
90
+ --let $diff_tables= master:t1,slave:t1
91
+ --source include/diff_tables.inc
93
92
94
93
--echo ########################################################################################
95
94
--echo # 2 - BEGIN - IMPLICIT COMMIT by DDL
@@ -177,8 +176,9 @@ BEGIN;
177
176
CREATE TABLE t5 (a int);
178
177
--enable_query_log
179
178
180
- let $diff_statement= SELECT * FROM t1;
181
- --source include/diff_master_slave.inc
179
+ --sync_slave_with_master
180
+ --let $diff_tables= master:t1,slave:t1
181
+ --source include/diff_tables.inc
182
182
183
183
--echo ########################################################################################
184
184
--echo # 3 - BEGIN - COMMIT
@@ -206,8 +206,9 @@ BEGIN;
206
206
--enable_query_log
207
207
COMMIT;
208
208
209
- let $diff_statement= SELECT * FROM t1;
210
- --source include/diff_master_slave.inc
209
+ --sync_slave_with_master
210
+ --let $diff_tables= master:t1,slave:t1
211
+ --source include/diff_tables.inc
211
212
212
213
--echo ########################################################################################
213
214
--echo # 4 - BEGIN - ROLLBACK
@@ -235,8 +236,9 @@ BEGIN;
235
236
--enable_query_log
236
237
ROLLBACK;
237
238
238
- let $diff_statement= SELECT * FROM t1;
239
- --source include/diff_master_slave.inc
239
+ --sync_slave_with_master
240
+ --let $diff_tables= master:t1,slave:t1
241
+ --source include/diff_tables.inc
240
242
241
243
--echo ########################################################################################
242
244
--echo # 5 - PROCEDURE
@@ -284,8 +286,9 @@ eval CALL p1($data);
284
286
--enable_query_log
285
287
ROLLBACK;
286
288
287
- let $diff_statement= SELECT * FROM t1;
288
- --source include/diff_master_slave.inc
289
+ --sync_slave_with_master
290
+ --let $diff_tables= master:t1,slave:t1
291
+ --source include/diff_tables.inc
289
292
290
293
--echo ########################################################################################
291
294
--echo # 6 - XID
@@ -315,8 +318,9 @@ SAVEPOINT sv;
315
318
ROLLBACK TO sv;
316
319
COMMIT;
317
320
318
- let $diff_statement= SELECT * FROM t1;
319
- --source include/diff_master_slave.inc
321
+ --sync_slave_with_master
322
+ --let $diff_tables= master:t1,slave:t1
323
+ --source include/diff_tables.inc
320
324
321
325
--echo ########################################################################################
322
326
--echo # 7 - NON-TRANS TABLE
@@ -358,8 +362,9 @@ BEGIN;
358
362
--enable_query_log
359
363
COMMIT;
360
364
361
- let $diff_statement= SELECT * FROM t1;
362
- --source include/diff_master_slave.inc
365
+ --sync_slave_with_master
366
+ --let $diff_tables= master:t1,slave:t1
367
+ --source include/diff_tables.inc
363
368
364
369
--echo ########################################################################
365
370
--echo # 8 - Bug#55375(Regression Bug) Transaction bigger than
@@ -409,7 +414,7 @@ while ($n)
409
414
--enable_query_log
410
415
COMMIT;
411
416
412
- connection slave;
417
+ -- connection slave
413
418
--let $slave_sql_errno= 1197
414
419
if (`SELECT @@binlog_format = 'ROW'`)
415
420
{
@@ -444,8 +449,10 @@ connection master;
444
449
DROP TABLE t1;
445
450
DROP TABLE t2;
446
451
DROP TABLE t3;
452
+ # t4 exists only if binlog_format!=row, so so a warning is generated
453
+ # if binog_format=row
454
+ --disable_warnings
447
455
DROP TABLE IF EXISTS t4;
448
- DROP TABLE IF EXISTS t5;
449
- DROP TABLE IF EXISTS t6 ;
456
+ --enable_warnings
457
+ DROP TABLE t5 ;
450
458
DROP PROCEDURE p1;
451
- source include/master-slave-end.inc;
0 commit comments