PS-10098 Configurable Gap Lock Detection for MyRocks

Author: akshaysuryawanshi

mysql-test/include/gap_lock_error_all.inc

@@ -1,3 +1,4 @@
+--let $warning_or_error= ERROR
 --source include/gap_lock_error_init.inc
 
 let $select_lock=for update;
@@ -18,9 +19,5 @@ let $autocommit = 0;
 let $autocommit = 1;
 --source include/gap_lock_error_select.inc
 
-let $autocommit = 0;
---source include/gap_lock_error_update.inc
-let $autocommit = 1;
 --source include/gap_lock_error_update.inc
-
 --source include/gap_lock_error_cleanup.inc

mysql-test/include/gap_lock_error_cleanup.inc

@@ -1,4 +1,6 @@
-drop table gap1, gap2, gap3;
+set global gap_lock_raise_error= off;
+
+drop table gap1, gap2, gap3, gap5, gap6;
 if (!$gap_lock_error_skip_partitioning) {
   drop table gap4;
 }

mysql-test/include/gap_lock_error_init.inc

@@ -1,3 +1,18 @@
+# ==== Usage ====
+#
+# [--let $warning_or_error= WARNING | ERROR ]
+# --source include/assert_no_warnings.inc
+#
+# Parameters:
+#
+#   $warning_or_error
+#     Whether we are expected to raise warning or error.
+#
+
+--disable_warnings
+drop table if exists gap1,gap2,gap3;
+--enable_warnings
+
 eval CREATE TABLE gap1 (id1 INT, id2 INT, id3 INT, c1 INT, value INT,
                       PRIMARY KEY (id1, id2, id3),
                       INDEX i (c1)) ENGINE=$engine;
@@ -23,6 +38,19 @@ while ($i <= $max) {
 --enable_query_log
 
 insert into gap3 values (1,1), (2,2),(3,3),(4,4),(5,5);
+
 if (!$gap_lock_error_skip_partitioning) {
   insert into gap4 values (1,1), (2,2),(3,3),(4,4),(5,5);
 }
+
+eval CREATE TABLE gap5 (
+  pk int primary key,
+  a int,
+  b int,
+  key(a)
+) ENGINE=$engine;
+insert into gap5 values (1,1,1), (2,2,2), (3,3,3), (4,4,4);
+create table gap6 like gap5;
+insert into gap6 values (1,1,1), (2,2,2), (3,3,3), (4,4,4);
+
+eval set session gap_lock_raise_error= $warning_or_error;

mysql-test/include/gap_lock_error_select.inc

@@ -1,5 +1,5 @@
 eval set session autocommit=$autocommit;
-let $is_gaplock_target = `SELECT @@autocommit = 0 && '$select_lock' != '' && '$expect_gap_lock_errors' = 1`;
+let $is_gaplock_target = `SELECT @@autocommit = 0 && '$select_lock' != ''`;
 
 if ($is_gaplock_target)
 {
@@ -49,12 +49,6 @@ eval select * from gap1 where id1=1 and id2=1 and id3 in (1, 2, 3) $select_lock;
 eval select * from gap1 where id1=1 and id2=1 and id3=1 and value=1
   order by c1 $select_lock;
 eval select * from gap3 where id=1 $select_lock;
-eval select * from gap4 where id=1 $select_lock;
-eval select * from gap4 where id in (1, 2, 3) $select_lock;
---error ER_UNKNOWN_ERROR
-eval select * from gap4 $select_lock;
---error ER_UNKNOWN_ERROR
-eval select * from gap4 where id between 3 and 7 $select_lock;
 }
 
 if (!$is_gaplock_target)
@@ -82,8 +76,4 @@ eval select * from gap1 where id1=1 and id2=1 and id3 in (1, 2, 3) $select_lock;
 eval select * from gap1 where id1=1 and id2=1 and id3=1 and value=1
   order by c1 $select_lock;
 eval select * from gap3 where id=1 $select_lock;
-eval select * from gap4 where id=1 $select_lock;
-eval select * from gap4 where id in (1, 2, 3) $select_lock;
-eval select * from gap4 $select_lock;
-eval select * from gap4 where id between 3 and 7 $select_lock;
 }

mysql-test/include/gap_lock_error_update.inc

@@ -63,6 +63,7 @@ eval create table u1(
  primary key (c1, c2, c3),
  unique key (c3, c1)
 ) engine=$engine;
+set session gap_lock_raise_error=error;
 begin;
 insert into u1 values (1,1,1,1);
 commit;

mysql-test/r/all_persisted_variables.result

@@ -47,17 +47,17 @@ include/assert.inc [Expect 500+ variables in the table. Due to open Bugs, we are
 
 # Test SET PERSIST
 
-include/assert.inc [Expect 489 persisted variables in the table.]
+include/assert.inc [Expect 490 persisted variables in the table.]
 
 ************************************************************
 * 3. Restart server, it must preserve the persisted variable
 *    settings. Verify persisted configuration.
 ************************************************************
 # restart
 
-include/assert.inc [Expect 489 persisted variables in persisted_variables table.]
-include/assert.inc [Expect 489 persisted variables shown as PERSISTED in variables_info table.]
-include/assert.inc [Expect 489 persisted variables with matching peristed and global values.]
+include/assert.inc [Expect 490 persisted variables in persisted_variables table.]
+include/assert.inc [Expect 490 persisted variables shown as PERSISTED in variables_info table.]
+include/assert.inc [Expect 490 persisted variables with matching peristed and global values.]
 
 ************************************************************
 * 4. Test RESET PERSIST IF EXISTS. Verify persisted variable

mysql-test/r/mysqld--help-notwin.result

@@ -423,6 +423,11 @@ The following options may be given as the first argument:
  word symbols for full text search queries
  --ft-stopword-file=name 
  Use stopwords from this file instead of built-in list
+ --gap-lock-raise-error[=name]
+ Controls raising a warning or an error when executing
+ queries that rely on Gap Lock. It can take the following
+ values: OFF: no error is raised WARNING: a warning is
+ raised ERROR: an error is raised. Default is OFF
  --gdb               Set up signals usable for debugging.
  --general-log       Log connections and queries to a table or log file.
  Defaults to logging to a file hostname.log, or if
@@ -1847,6 +1852,7 @@ ft-min-word-len 4
 ft-query-expansion-limit 20
 ft-query-extra-word-chars FALSE
 ft-stopword-file (No default value)
+gap-lock-raise-error OFF
 gdb FALSE
 general-log FALSE
 generated-random-password-length 20

mysql-test/suite/percona/r/gap_lock_error_memory.result

@@ -1,3 +1,4 @@
+drop table if exists gap1,gap2,gap3;
 CREATE TABLE gap1 (id1 INT, id2 INT, id3 INT, c1 INT, value INT,
 PRIMARY KEY (id1, id2, id3),
 INDEX i (c1)) ENGINE=memory;
@@ -6,11 +7,22 @@ CREATE TABLE gap3 (id INT, value INT,
 PRIMARY KEY (id),
 UNIQUE KEY ui(value)) ENGINE=memory;
 insert into gap3 values (1,1), (2,2),(3,3),(4,4),(5,5);
+CREATE TABLE gap5 (
+pk int primary key,
+a int,
+b int,
+key(a)
+) ENGINE=memory;
+insert into gap5 values (1,1,1), (2,2,2), (3,3,3), (4,4,4);
+create table gap6 like gap5;
+insert into gap6 values (1,1,1), (2,2,2), (3,3,3), (4,4,4);
+set session gap_lock_raise_error= WARNING;
 select sum(value) from gap1;
 sum(value)
 500500
 update gap1 set gap1.value= (select count(*) from gap2);
 select sum(value) from gap1;
 sum(value)
 1000000
-drop table gap1, gap2, gap3;
+set global gap_lock_raise_error= off;
+drop table gap1, gap2, gap3, gap5, gap6;

mysql-test/suite/percona/r/gap_lock_error_myisam.result

@@ -1,3 +1,4 @@
+drop table if exists gap1,gap2,gap3;
 CREATE TABLE gap1 (id1 INT, id2 INT, id3 INT, c1 INT, value INT,
 PRIMARY KEY (id1, id2, id3),
 INDEX i (c1)) ENGINE=myisam;
@@ -6,11 +7,22 @@ CREATE TABLE gap3 (id INT, value INT,
 PRIMARY KEY (id),
 UNIQUE KEY ui(value)) ENGINE=myisam;
 insert into gap3 values (1,1), (2,2),(3,3),(4,4),(5,5);
+CREATE TABLE gap5 (
+pk int primary key,
+a int,
+b int,
+key(a)
+) ENGINE=myisam;
+insert into gap5 values (1,1,1), (2,2,2), (3,3,3), (4,4,4);
+create table gap6 like gap5;
+insert into gap6 values (1,1,1), (2,2,2), (3,3,3), (4,4,4);
+set session gap_lock_raise_error= WARNING;
 select sum(value) from gap1;
 sum(value)
 500500
 update gap1 set gap1.value= (select count(*) from gap2);
 select sum(value) from gap1;
 sum(value)
 1000000
-drop table gap1, gap2, gap3;
+set global gap_lock_raise_error= off;
+drop table gap1, gap2, gap3, gap5, gap6;

mysql-test/suite/percona/t/gap_lock_error_memory.test

@@ -3,6 +3,7 @@
 let $engine=memory;
 let $expect_gap_lock_errors=0;
 let $gap_lock_error_skip_partitioning=1;
+--let $warning_or_error=WARNING
 --source include/gap_lock_error_init.inc
 select sum(value) from gap1;
 update gap1 set gap1.value= (select count(*) from gap2);