mirror of
https://github.com/MariaDB/server.git
synced 2025-08-07 00:04:31 +03:00
585785c7bc
When updating non-transactional tables inside a multi-statement transaction, and binlog_direct_non_transactional_updates=1, then the non-transactional updates are binlogged directly through the statement cache while the transaction cache is still being added to in the main transaction. Thus, move the engine_binlog_info out from binlog_cache_mngr and into the individual stmt/trx binlog_cache_data, so that we can have separate engine_binlog_info active for the statement and the transaction cache. Signed-off-by: Kristian Nielsen <knielsen@knielsen-hq.org>
126 lines
3.5 KiB
Plaintext
126 lines
3.5 KiB
Plaintext
--source include/have_binlog_format_row.inc
|
|
--source include/master-slave.inc
|
|
--source include/have_innodb_binlog.inc
|
|
|
|
CREATE TABLE t1 (i INT, a INT, b TEXT, PRIMARY KEY(i, a)) ENGINE=InnoDB;
|
|
CREATE TABLE t2 (i INT, a INT, b TEXT, PRIMARY KEY(i, a)) ENGINE=MyISAM;
|
|
|
|
# Add different amounts of data, to test various cases where event
|
|
# groups fit or do not fit in case, are binlogged / not binlogged as
|
|
# oob data.
|
|
--let $i = 0
|
|
while ($i <= 6) {
|
|
if ($i == 0) {
|
|
SET @b= REPEAT('$', 0);
|
|
}
|
|
if ($i == 1) {
|
|
SET @b= REPEAT('$', 10);
|
|
}
|
|
if ($i == 2) {
|
|
SET @b= REPEAT('$', 100);
|
|
}
|
|
if ($i == 3) {
|
|
SET @b= REPEAT('$', 642);
|
|
}
|
|
if ($i == 4) {
|
|
SET @b= REPEAT('$', 3930);
|
|
}
|
|
if ($i == 5) {
|
|
SET @b= REPEAT('$', 16000);
|
|
}
|
|
if ($i == 6) {
|
|
SET @b= REPEAT('$', 40000);
|
|
}
|
|
BEGIN;
|
|
eval INSERT INTO t1 VALUES ($i, 1, @b);
|
|
SAVEPOINT s1;
|
|
eval INSERT INTO t1 VALUES ($i, 2, @b);
|
|
SAVEPOINT s2;
|
|
eval INSERT INTO t1 VALUES ($i, 3, @b);
|
|
SAVEPOINT s3;
|
|
eval INSERT INTO t1 VALUES ($i, 4, @b);
|
|
ROLLBACK TO s2;
|
|
eval INSERT INTO t1 VALUES ($i, 5, @b);
|
|
ROLLBACK TO s2;
|
|
eval INSERT INTO t1 VALUES ($i, 6, @b);
|
|
SAVEPOINT s4;
|
|
eval INSERT INTO t1 VALUES ($i, 7, @b);
|
|
SAVEPOINT s5;
|
|
ROLLBACK TO s5;
|
|
eval INSERT INTO t1 VALUES ($i, 8, @b);
|
|
COMMIT;
|
|
eval SELECT a, length(b) FROM t1 WHERE i=$i ORDER BY a;
|
|
|
|
BEGIN;
|
|
eval INSERT INTO t1 VALUES ($i, 10, @b);
|
|
SAVEPOINT s10;
|
|
eval INSERT INTO t1 VALUES ($i, 11, @b);
|
|
eval INSERT INTO t2 VALUES ($i, 12, @b);
|
|
ROLLBACK TO s10;
|
|
COMMIT;
|
|
|
|
eval SELECT a, length(b) FROM t1 WHERE i=$i AND a>=10 ORDER BY a;
|
|
eval SELECT a, length(b) FROM t2 WHERE i=$i ORDER BY a;
|
|
|
|
# Test a full rollback.
|
|
BEGIN;
|
|
eval UPDATE t1 SET a=a+1000 WHERE i=$i;
|
|
eval UPDATE t1 SET b='x' WHERE i=$i;
|
|
ROLLBACK;
|
|
|
|
# Test a statement that fails and is rolled back but the remaining
|
|
# transaction is committed.
|
|
BEGIN;
|
|
eval INSERT INTO t1
|
|
VALUES ($i, 101, @b), ($i, 102, @b), ($i, 103, @b), ($i, 104, @b), ($i, 105, @b);
|
|
--error ER_DUP_ENTRY
|
|
eval UPDATE t1 SET a=a-104 WHERE i=$i AND a > 100;
|
|
eval UPDATE t1 SET a=a+10 WHERE i=$i AND a > 100;
|
|
COMMIT;
|
|
eval SELECT a, length(b) FROM t1 WHERE i=$i AND a >= 100 ORDER BY a;
|
|
|
|
inc $i;
|
|
}
|
|
|
|
# Seeing the events generated useful for debugging, but hard to maintain the
|
|
# .result file over time, better to check slave data vs. master.
|
|
#--let $binlog_file= binlog-000000.ibb
|
|
#--let $binlog_start= 4096
|
|
#--source include/show_binlog_events.inc
|
|
|
|
--let $master_checksum1= query_get_value(CHECKSUM TABLE t1, Checksum, 1)
|
|
--let $master_checksum2= query_get_value(CHECKSUM TABLE t2, Checksum, 1)
|
|
|
|
--source include/save_master_gtid.inc
|
|
--connection slave
|
|
--source include/sync_with_master_gtid.inc
|
|
|
|
--let $slave_checksum1= query_get_value(CHECKSUM TABLE t1, Checksum, 1)
|
|
--let slave_checksum2= query_get_value(CHECKSUM TABLE t2, Checksum, 1)
|
|
|
|
--let $ok= 1
|
|
if ($master_checksum1 != $slave_checksum1) {
|
|
--let $ok= 0
|
|
}
|
|
if ($master_checksum2 != $slave_checksum2) {
|
|
--let $ok= 0
|
|
}
|
|
if (!$ok) {
|
|
--connection master
|
|
--echo *** Data on master: ***
|
|
SELECT i, a, length(b) FROM t1 ORDER BY i, a;
|
|
SELECT i, a, length(b) FROM t2 ORDER BY i, a;
|
|
--connection slave
|
|
--echo *** Data on slave: ***
|
|
SELECT i, a, length(b) FROM t1 ORDER BY i, a;
|
|
SELECT i, a, length(b) FROM t2 ORDER BY i, a;
|
|
--die Slave data differs from master. Master checksums $master_checksum1 $master_checksum2, but slave $slave_checksum1 $slave_checksum2
|
|
}
|
|
if ($ok) {
|
|
--echo *** Slave data checksums with master, all ok. ***
|
|
}
|
|
|
|
--connection master
|
|
DROP TABLE t1, t2;
|
|
--source include/rpl_end.inc
|