Commit 33d41167 authored by Marko Mäkelä's avatar Marko Mäkelä

MDEV-24224 Gap lock on delete in 10.5 using READ COMMITTED

When MDEV-19544 (commit 1a6f4704)
simplified the initialization of the local variable
set_also_gap_locks, an inadvertent change was included.
Essentially, all code branches that are executed when
set_also_gap_locks hold must also ensure that
trx->isolation_level > TRX_ISO_READ_COMMITTED holds.
This was being violated in a few code paths.

It turns out that there is an even simpler fix: Remove the test
of thd_is_select() completely. In that way, the first part of
UPDATE or DELETE should work exactly like SELECT...FOR UPDATE.

thd_is_select(): Remove.
parent fabdad68
CREATE TABLE t1(a INT PRIMARY KEY, b VARCHAR(40), c INT, INDEX(b,c))
ENGINE=InnoDB;
INSERT INTO t1 VALUES (1,'1',1),(2,'2',1);
SET @save_locks= @@GLOBAL.innodb_status_output_locks;
SET GLOBAL INNODB_STATUS_OUTPUT_LOCKS = 'ON';
SET TRANSACTION ISOLATION LEVEL SERIALIZABLE;
BEGIN;
DELETE FROM t1 WHERE b='2' AND c=2;
SHOW ENGINE INNODB STATUS;
Type Name Status
InnoDB 2 lock struct(s), 1 row lock(s)
ROLLBACK;
SET TRANSACTION ISOLATION LEVEL REPEATABLE READ;
BEGIN;
DELETE FROM t1 WHERE b='2' AND c=2;
SHOW ENGINE INNODB STATUS;
Type Name Status
InnoDB 2 lock struct(s), 1 row lock(s)
ROLLBACK;
SET TRANSACTION ISOLATION LEVEL READ COMMITTED;
BEGIN;
DELETE FROM t1 WHERE b='2' AND c=2;
SHOW ENGINE INNODB STATUS;
Type Name Status
InnoDB 1 lock struct(s), 0 row lock(s)
ROLLBACK;
SET TRANSACTION ISOLATION LEVEL READ UNCOMMITTED;
BEGIN;
DELETE FROM t1 WHERE b='2' AND c=2;
SHOW ENGINE INNODB STATUS;
Type Name Status
InnoDB 1 lock struct(s), 0 row lock(s)
ROLLBACK;
SET GLOBAL INNODB_STATUS_OUTPUT_LOCKS = @save_locks;
DROP TABLE t1;
--source include/have_innodb.inc
CREATE TABLE t1(a INT PRIMARY KEY, b VARCHAR(40), c INT, INDEX(b,c))
ENGINE=InnoDB;
INSERT INTO t1 VALUES (1,'1',1),(2,'2',1);
SET @save_locks= @@GLOBAL.innodb_status_output_locks;
SET GLOBAL INNODB_STATUS_OUTPUT_LOCKS = 'ON';
let $isolation= 4;
while ($isolation) {
let $tx_isolation= `SELECT CASE $isolation
WHEN 1 THEN 'READ UNCOMMITTED'
WHEN 2 THEN 'READ COMMITTED'
WHEN 3 THEN 'REPEATABLE READ'
ELSE 'SERIALIZABLE' END`;
eval SET TRANSACTION ISOLATION LEVEL $tx_isolation;
BEGIN;
DELETE FROM t1 WHERE b='2' AND c=2;
--replace_regex /.*(\d+ lock struct...), heap size \d+(, \d+ row lock...).*/\1\2/
SHOW ENGINE INNODB STATUS;
ROLLBACK;
dec $isolation;
}
SET GLOBAL INNODB_STATUS_OUTPUT_LOCKS = @save_locks;
DROP TABLE t1;
...@@ -1495,7 +1495,7 @@ thd_trx_is_auto_commit( ...@@ -1495,7 +1495,7 @@ thd_trx_is_auto_commit(
&& !thd_test_options( && !thd_test_options(
thd, thd,
OPTION_NOT_AUTOCOMMIT | OPTION_BEGIN) OPTION_NOT_AUTOCOMMIT | OPTION_BEGIN)
&& thd_is_select(thd)); && thd_sql_command(thd) == SQLCOM_SELECT);
} }
/******************************************************************//** /******************************************************************//**
...@@ -1531,17 +1531,6 @@ thd_query_start_micro( ...@@ -1531,17 +1531,6 @@ thd_query_start_micro(
return thd_start_utime(thd); return thd_start_utime(thd);
} }
/******************************************************************//**
Returns true if the thread is executing a SELECT statement.
@return true if thd is executing SELECT */
ibool
thd_is_select(
/*==========*/
const THD* thd) /*!< in: thread handle */
{
return(thd_sql_command(thd) == SQLCOM_SELECT);
}
/******************************************************************//** /******************************************************************//**
Returns the lock wait timeout for the current connection. Returns the lock wait timeout for the current connection.
@return the lock wait timeout, in seconds */ @return the lock wait timeout, in seconds */
......
...@@ -190,14 +190,6 @@ const char* ...@@ -190,14 +190,6 @@ const char*
innobase_basename( innobase_basename(
const char* path_name); const char* path_name);
/******************************************************************//**
Returns true if the thread is executing a SELECT statement.
@return true if thd is executing SELECT */
ibool
thd_is_select(
/*==========*/
const THD* thd); /*!< in: thread handle */
/******************************************************************//** /******************************************************************//**
Converts an identifier to a table name. */ Converts an identifier to a table name. */
void void
......
...@@ -4542,12 +4542,11 @@ row_search_mvcc( ...@@ -4542,12 +4542,11 @@ row_search_mvcc(
|| prebuilt->table->no_rollback() || prebuilt->table->no_rollback()
|| srv_read_only_mode); || srv_read_only_mode);
/* Do not lock gaps for plain SELECT /* Do not lock gaps at READ UNCOMMITTED or READ COMMITTED
at READ UNCOMMITTED or READ COMMITTED isolation level */ isolation level */
const bool set_also_gap_locks = const bool set_also_gap_locks =
prebuilt->select_lock_type != LOCK_NONE prebuilt->select_lock_type != LOCK_NONE
&& (trx->isolation_level > TRX_ISO_READ_COMMITTED && trx->isolation_level > TRX_ISO_READ_COMMITTED
|| !thd_is_select(trx->mysql_thd))
#ifdef WITH_WSREP #ifdef WITH_WSREP
&& !wsrep_thd_skip_locking(trx->mysql_thd) && !wsrep_thd_skip_locking(trx->mysql_thd)
#endif /* WITH_WSREP */ #endif /* WITH_WSREP */
...@@ -4755,7 +4754,6 @@ row_search_mvcc( ...@@ -4755,7 +4754,6 @@ row_search_mvcc(
if (page_rec_is_supremum(rec)) { if (page_rec_is_supremum(rec)) {
if (set_also_gap_locks if (set_also_gap_locks
&& trx->isolation_level > TRX_ISO_READ_COMMITTED
&& !dict_index_is_spatial(index)) { && !dict_index_is_spatial(index)) {
/* Try to place a lock on the index record */ /* Try to place a lock on the index record */
...@@ -5020,8 +5018,16 @@ row_search_mvcc( ...@@ -5020,8 +5018,16 @@ row_search_mvcc(
goto no_gap_lock; goto no_gap_lock;
} }
if (!set_also_gap_locks #ifdef WITH_WSREP
|| (unique_search && !rec_get_deleted_flag(rec, comp)) if (UNIV_UNLIKELY(!set_also_gap_locks)) {
ut_ad(wsrep_thd_skip_locking(trx->mysql_thd));
goto no_gap_lock;
}
#else /* WITH_WSREP */
ut_ad(set_also_gap_locks);
#endif /* WITH_WSREP */
if ((unique_search && !rec_get_deleted_flag(rec, comp))
|| dict_index_is_spatial(index)) { || dict_index_is_spatial(index)) {
goto no_gap_lock; goto no_gap_lock;
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment