mirror of
https://github.com/MariaDB/server.git
synced 2025-01-16 12:02:42 +01:00
ab4bfad206
* Log rows in online_alter_binlog. * Table online data is replicated within dedicated binlog file * Cached data is written on commit. * Versioning is fully supported. * Works both wit and without binlog enabled. * For now savepoints setup is forbidden while ONLINE ALTER goes on. Extra support is required. We can simply log the SAVEPOINT query events and replicate them together with row events. But it's not implemented for now. * Cache flipping: We want to care for the possible bottleneck in the online alter binlog reading/writing in advance. IO_CACHE does not provide anything better that sequential access, besides, only a single write is mutex-protected, which is not suitable, since we should write a transaction atomically. To solve this, a special layer on top Event_log is implemented. There are two IO_CACHE files underneath: one for reading, and one for writing. Once the read cache is empty, an exclusive lock is acquired (we can wait for a currently active transaction finish writing), and flip() is emitted, i.e. the write cache is reopened for read, and the read cache is emptied, and reopened for writing. This reminds a buffer flip that happens in accelerated graphics (DirectX/OpenGL/etc). Cache_flip_event_log is considered non-blocking for a single reader and a single writer in this sense, with the only lock held by reader during flip. An alternative approach by implementing a fair concurrent circular buffer is described in MDEV-24676. * Cache managers: We have two cache sinks: statement and transactional. It is important that the changes are first cached per-statement and per-transaction. If a statement fails, then only statement data is rolled back. The transaction moves along, however. Turns out, there's no guarantee that TABLE well persist in thd->open_tables to the transaction commit moment. If an error occurs, tables from statement are purged. Therefore, we can't store te caches in TABLE. Ideally, it should be handlerton, but we cut the corner and store it in THD in a list.
231 lines
4.8 KiB
Text
231 lines
4.8 KiB
Text
# Bug38499 flush tables and multitable table update with derived table cause crash
|
|
# MySQL >= 5.0
|
|
#
|
|
|
|
# The test can take hours with valgrind
|
|
--source include/not_valgrind.inc
|
|
|
|
# Save the initial number of concurrent sessions
|
|
--source include/count_sessions.inc
|
|
|
|
SET @odl_sync_frm = @@global.sync_frm;
|
|
SET @@global.sync_frm = OFF;
|
|
|
|
connect (locker,localhost,root,,);
|
|
connect (writer,localhost,root,,);
|
|
|
|
--connection default
|
|
--disable_warnings
|
|
DROP TABLE IF EXISTS t1;
|
|
--enable_warnings
|
|
CREATE TABLE t1( a INT, b INT );
|
|
CREATE TABLE t2( a INT, b INT );
|
|
INSERT INTO t1 VALUES (1, 1), (2, 2), (3, 3), (4, 4);
|
|
INSERT INTO t2 VALUES (1, 1), (2, 2), (3, 3), (4, 4);
|
|
|
|
--echo # 1. test regular tables
|
|
--echo # 1.1. test altering of columns that multiupdate doesn't use
|
|
--echo # 1.1.1. normal mode
|
|
|
|
--disable_query_log
|
|
let $i = 100;
|
|
while ($i) {
|
|
--dec $i
|
|
|
|
--connection writer
|
|
send UPDATE t1, (SELECT 1 FROM t2 t1i) d SET a = 0 WHERE 1=0;
|
|
|
|
--connection locker
|
|
ALTER TABLE t1 ADD COLUMN (c INT), LOCK=SHARED;
|
|
ALTER TABLE t1 DROP COLUMN c, LOCK=SHARED;
|
|
|
|
--connection writer
|
|
--reap
|
|
}
|
|
|
|
--echo # 1.1.2. PS mode
|
|
|
|
--connection writer
|
|
PREPARE stmt FROM 'UPDATE t1, (SELECT 1 FROM t2 t1i) d SET a = 0 WHERE 1=0';
|
|
|
|
let $i = 100;
|
|
while ($i) {
|
|
--dec $i
|
|
|
|
--connection writer
|
|
--send EXECUTE stmt
|
|
|
|
--connection locker
|
|
ALTER TABLE t1 ADD COLUMN (c INT), LOCK=SHARED;
|
|
ALTER TABLE t1 DROP COLUMN c, LOCK=SHARED;
|
|
|
|
--connection writer
|
|
--reap
|
|
}
|
|
--enable_query_log
|
|
|
|
--echo # 1.2. test altering of columns that multiupdate uses
|
|
--echo # 1.2.1. normal mode
|
|
|
|
--connection default
|
|
|
|
--disable_query_log
|
|
let $i = 100;
|
|
while ($i) {
|
|
dec $i;
|
|
|
|
--connection locker
|
|
--error 0,ER_DUP_FIELDNAME
|
|
ALTER TABLE t1 ADD COLUMN a int(11) unsigned default NULL, LOCK=SHARED;
|
|
UPDATE t1 SET a=b;
|
|
|
|
--connection writer
|
|
--send UPDATE t1, (SELECT 1 FROM t2 t1i) d SET a = 0 WHERE 1=0;
|
|
|
|
--connection locker
|
|
--error 0,ER_CANT_DROP_FIELD_OR_KEY
|
|
ALTER TABLE t1 DROP COLUMN a, LOCK=SHARED;
|
|
|
|
--connection writer
|
|
--error 0,ER_BAD_FIELD_ERROR # unknown column error
|
|
--reap
|
|
}
|
|
--enable_query_log
|
|
|
|
--echo # 1.2.2. PS mode
|
|
|
|
--disable_query_log
|
|
let $i = 100;
|
|
while ($i) {
|
|
dec $i;
|
|
|
|
--connection locker
|
|
--error 0,ER_DUP_FIELDNAME
|
|
ALTER TABLE t1 ADD COLUMN a INT, LOCK=SHARED;
|
|
UPDATE t1 SET a=b;
|
|
|
|
--connection writer
|
|
PREPARE stmt FROM 'UPDATE t1, (SELECT 1 FROM t2 t1i) d SET a = 0 WHERE 1=0';
|
|
--send EXECUTE stmt
|
|
|
|
--connection locker
|
|
--error 0,ER_CANT_DROP_FIELD_OR_KEY
|
|
ALTER TABLE t1 DROP COLUMN a, LOCK=SHARED;
|
|
|
|
--connection writer
|
|
--error 0,ER_BAD_FIELD_ERROR # Unknown column 'a' in 'field list'
|
|
--reap
|
|
}
|
|
--enable_query_log
|
|
--connection default
|
|
ALTER TABLE t1 ADD COLUMN a INT, LOCK=SHARED;
|
|
|
|
--echo # 2. test UNIONs
|
|
--echo # 2.1. test altering of columns that multiupdate doesn't use
|
|
--echo # 2.1.1. normal mode
|
|
|
|
--disable_query_log
|
|
let $i = 100;
|
|
while ($i) {
|
|
--dec $i
|
|
|
|
--connection writer
|
|
send UPDATE t1, ((SELECT 1 FROM t1 t1i) UNION (SELECT 2 FROM t1 t1ii)) e SET a = 0 WHERE 1=0;
|
|
|
|
--connection locker
|
|
ALTER TABLE t1 ADD COLUMN (c INT), LOCK=SHARED;
|
|
ALTER TABLE t1 DROP COLUMN c, LOCK=SHARED;
|
|
|
|
--connection writer
|
|
--reap
|
|
}
|
|
|
|
--echo # 2.1.2. PS mode
|
|
|
|
--connection writer
|
|
PREPARE stmt FROM 'UPDATE t1, ((SELECT 1 FROM t1 t1i) UNION (SELECT 2 FROM t1 t1ii)) e SET a = 0 WHERE 1=0';
|
|
|
|
let $i = 100;
|
|
while ($i) {
|
|
--dec $i
|
|
|
|
--connection writer
|
|
--send EXECUTE stmt
|
|
|
|
--connection locker
|
|
ALTER TABLE t1 ADD COLUMN (c INT), LOCK=SHARED;
|
|
ALTER TABLE t1 DROP COLUMN c, LOCK=SHARED;
|
|
|
|
--connection writer
|
|
--reap
|
|
}
|
|
--enable_query_log
|
|
|
|
--echo # 2.2. test altering of columns that multiupdate uses
|
|
--echo # 2.2.1. normal mode
|
|
|
|
--connection default
|
|
|
|
--disable_query_log
|
|
let $i = 100;
|
|
while ($i) {
|
|
dec $i;
|
|
|
|
--connection locker
|
|
--error 0,ER_DUP_FIELDNAME
|
|
ALTER TABLE t1 ADD COLUMN a int(11) unsigned default NULL, LOCK=SHARED;
|
|
UPDATE t1 SET a=b;
|
|
|
|
--connection writer
|
|
--send UPDATE t1, ((SELECT 1 FROM t1 t1i) UNION (SELECT 2 FROM t1 t1ii)) e SET a = 0 WHERE 1=0;
|
|
|
|
--connection locker
|
|
--error 0,ER_CANT_DROP_FIELD_OR_KEY
|
|
ALTER TABLE t1 DROP COLUMN a, LOCK=SHARED;
|
|
|
|
--connection writer
|
|
--error 0,ER_BAD_FIELD_ERROR # Unknown column 'a' in 'field list'
|
|
--reap
|
|
}
|
|
--enable_query_log
|
|
|
|
--echo # 2.2.2. PS mode
|
|
|
|
--disable_query_log
|
|
let $i = 100;
|
|
while ($i) {
|
|
dec $i;
|
|
|
|
--connection locker
|
|
--error 0,ER_DUP_FIELDNAME
|
|
ALTER TABLE t1 ADD COLUMN a INT, LOCK=SHARED;
|
|
UPDATE t1 SET a=b;
|
|
|
|
--connection writer
|
|
PREPARE stmt FROM 'UPDATE t1, ((SELECT 1 FROM t1 t1i) UNION (SELECT 2 FROM t1 t1ii)) e SET a = 0 WHERE 1=0';
|
|
--send EXECUTE stmt
|
|
|
|
--connection locker
|
|
--error 0,ER_CANT_DROP_FIELD_OR_KEY
|
|
ALTER TABLE t1 DROP COLUMN a, LOCK=SHARED;
|
|
|
|
--connection writer
|
|
--error 0,ER_BAD_FIELD_ERROR # Unknown column 'a' in 'field list'
|
|
--reap
|
|
}
|
|
--enable_query_log
|
|
--connection default
|
|
DROP TABLE t1,t2;
|
|
|
|
|
|
# Close connections
|
|
--disconnect locker
|
|
--disconnect writer
|
|
|
|
SET @@global.sync_frm = @odl_sync_frm;
|
|
|
|
# End of 5.0 tests
|
|
|
|
# Wait till all disconnects are completed
|
|
--source include/wait_until_count_sessions.inc
|
|
|