tests: move IT in executor to tests/integrationtest (PART 11)

pkg/executor/test/indexmergereadtest/BUILD.bazel

@@ -9,7 +9,7 @@ go_test(
     ],
     flaky = True,
     race = "on",
-    shard_count = 37,
+    shard_count = 20,
     deps = [
         "//pkg/config",
         "//pkg/executor",

pkg/executor/test/passwordtest/BUILD.bazel

@@ -8,7 +8,7 @@ go_test(
         "password_management_test.go",
     ],
     flaky = True,
-    shard_count = 16,
+    shard_count = 8,
     deps = [
         "//pkg/domain",
         "//pkg/errno",

pkg/executor/test/seqtest/BUILD.bazel

@@ -10,7 +10,7 @@ go_test(
     ],
     flaky = True,
     race = "on",
-    shard_count = 33,
+    shard_count = 31,
     deps = [
         "//pkg/config",
         "//pkg/ddl/testutil",

pkg/executor/test/seqtest/prepared_test.go

@@ -656,42 +656,3 @@ func TestPreparedIssue17419(t *testing.T) {
 	// _, ok := tk1.Session().ShowProcess().Plan.(*plannercore.Execute)
 	// require.True(t, ok)
 }
-
-func TestLimitUnsupportedCase(t *testing.T) {
-	store := testkit.CreateMockStore(t)
-	tk := testkit.NewTestKit(t, store)
-	tk.MustExec("use test")
-	tk.MustExec("drop table if exists t")
-	tk.MustExec("create table t(a int, key(a))")
-	tk.MustExec("prepare stmt from 'select * from t limit ?'")
-
-	tk.MustExec("set @a = 1.2")
-	tk.MustGetErrMsg("execute stmt using @a", "[planner:1210]Incorrect arguments to LIMIT")
-	tk.MustExec("set @a = 1.")
-	tk.MustGetErrMsg("execute stmt using @a", "[planner:1210]Incorrect arguments to LIMIT")
-	tk.MustExec("set @a = '0'")
-	tk.MustGetErrMsg("execute stmt using @a", "[planner:1210]Incorrect arguments to LIMIT")
-	tk.MustExec("set @a = '1'")
-	tk.MustGetErrMsg("execute stmt using @a", "[planner:1210]Incorrect arguments to LIMIT")
-	tk.MustExec("set @a = 1_2")
-	tk.MustGetErrMsg("execute stmt using @a", "[planner:1210]Incorrect arguments to LIMIT")
-}
-
-func TestIssue38323(t *testing.T) {
-	store := testkit.CreateMockStore(t)
-	tk := testkit.NewTestKit(t, store)
-	tk.MustExec("use test")
-	tk.MustExec("drop table if exists t")
-	tk.MustExec("create table t(id int, k int);")
-
-	tk.MustExec("prepare stmt from 'explain select * from t where id = ? and k = ? group by id, k';")
-	tk.MustQuery("show warnings").Check(testkit.Rows("Warning 1105 skip prepared plan-cache: not a SELECT/UPDATE/INSERT/DELETE/SET statement"))
-	tk.MustExec("set @a = 1;")
-	tk.MustExec("execute stmt using @a, @a")
-	tk.MustQuery("execute stmt using @a, @a").Check(tk.MustQuery("explain select * from t where id = 1 and k = 1 group by id, k").Rows())
-
-	tk.MustExec("prepare stmt from 'explain select * from t where ? = id and ? = k group by id, k';")
-	tk.MustQuery("show warnings").Check(testkit.Rows("Warning 1105 skip prepared plan-cache: not a SELECT/UPDATE/INSERT/DELETE/SET statement"))
-	tk.MustExec("set @a = 1;")
-	tk.MustQuery("execute stmt using @a, @a").Check(tk.MustQuery("explain select * from t where 1 = id and 1 = k group by id, k").Rows())
-}

tests/integrationtest/r/black_list.result

@@ -57,3 +57,106 @@ TableReader	3323.33	root		data:Selection
 delete from mysql.expr_pushdown_blacklist;
 admin reload expr_pushdown_blacklist;
 
+drop table if exists t;
+create table t(a enum('a','b','c'), b enum('a','b','c'), c int, index idx(b,a));
+insert into t values(1,1,1),(2,2,2),(3,3,3);
+insert into mysql.expr_pushdown_blacklist(name) values('enum');
+admin reload expr_pushdown_blacklist;
+
+desc format='brief' select /*+ HASH_AGG() */ max(a) from t;
+id	estRows	task	access object	operator info
+HashAgg	1.00	root		funcs:max(black_list.t.a)->Column#5
+└─IndexReader	10000.00	root		index:IndexFullScan
+  └─IndexFullScan	10000.00	cop[tikv]	table:t, index:idx(b, a)	keep order:false, stats:pseudo
+desc format='brief' select /*+ STREAM_AGG() */ max(a) from t;
+id	estRows	task	access object	operator info
+StreamAgg	1.00	root		funcs:max(black_list.t.a)->Column#5
+└─IndexReader	10000.00	root		index:IndexFullScan
+  └─IndexFullScan	10000.00	cop[tikv]	table:t, index:idx(b, a)	keep order:false, stats:pseudo
+delete from mysql.expr_pushdown_blacklist;
+admin reload expr_pushdown_blacklist;
+
+desc format='brief' select /*+ HASH_AGG() */ max(a) from t;
+id	estRows	task	access object	operator info
+HashAgg	1.00	root		funcs:max(Column#7)->Column#5
+└─IndexReader	1.00	root		index:HashAgg
+  └─HashAgg	1.00	cop[tikv]		funcs:max(black_list.t.a)->Column#7
+    └─IndexFullScan	10000.00	cop[tikv]	table:t, index:idx(b, a)	keep order:false, stats:pseudo
+desc format='brief' select /*+ STREAM_AGG() */ max(a) from t;
+id	estRows	task	access object	operator info
+StreamAgg	1.00	root		funcs:max(Column#7)->Column#5
+└─IndexReader	1.00	root		index:StreamAgg
+  └─StreamAgg	1.00	cop[tikv]		funcs:max(black_list.t.a)->Column#7
+    └─IndexFullScan	10000.00	cop[tikv]	table:t, index:idx(b, a)	keep order:false, stats:pseudo
+insert into mysql.expr_pushdown_blacklist(name) values('enum');
+admin reload expr_pushdown_blacklist;
+
+desc format='brief' select * from t where a + b;
+id	estRows	task	access object	operator info
+Selection	8000.00	root		plus(cast(black_list.t.a, double BINARY), cast(black_list.t.b, double BINARY))
+└─TableReader	10000.00	root		data:TableFullScan
+  └─TableFullScan	10000.00	cop[tikv]	table:t	keep order:false, stats:pseudo
+desc format='brief' select * from t where a + b;
+id	estRows	task	access object	operator info
+Selection	8000.00	root		plus(cast(black_list.t.a, double BINARY), cast(black_list.t.b, double BINARY))
+└─TableReader	10000.00	root		data:TableFullScan
+  └─TableFullScan	10000.00	cop[tikv]	table:t	keep order:false, stats:pseudo
+delete from mysql.expr_pushdown_blacklist;
+admin reload expr_pushdown_blacklist;
+
+desc format='brief' select * from t where a + b;
+id	estRows	task	access object	operator info
+TableReader	8000.00	root		data:Selection
+└─Selection	8000.00	cop[tikv]		plus(cast(black_list.t.a, double BINARY), cast(black_list.t.b, double BINARY))
+  └─TableFullScan	10000.00	cop[tikv]	table:t	keep order:false, stats:pseudo
+desc format='brief' select * from t where a + b;
+id	estRows	task	access object	operator info
+TableReader	8000.00	root		data:Selection
+└─Selection	8000.00	cop[tikv]		plus(cast(black_list.t.a, double BINARY), cast(black_list.t.b, double BINARY))
+  └─TableFullScan	10000.00	cop[tikv]	table:t	keep order:false, stats:pseudo
+insert into mysql.expr_pushdown_blacklist(name) values('enum');
+admin reload expr_pushdown_blacklist;
+
+desc format='brief' select * from t where b = 1;
+id	estRows	task	access object	operator info
+Selection	8000.00	root		eq(black_list.t.b, 1)
+└─TableReader	10000.00	root		data:TableFullScan
+  └─TableFullScan	10000.00	cop[tikv]	table:t	keep order:false, stats:pseudo
+desc format='brief' select * from t where b = 'a';
+id	estRows	task	access object	operator info
+Selection	8000.00	root		eq(black_list.t.b, "a")
+└─TableReader	10000.00	root		data:TableFullScan
+  └─TableFullScan	10000.00	cop[tikv]	table:t	keep order:false, stats:pseudo
+desc format='brief' select * from t where b > 1;
+id	estRows	task	access object	operator info
+Selection	8000.00	root		gt(black_list.t.b, 1)
+└─TableReader	10000.00	root		data:TableFullScan
+  └─TableFullScan	10000.00	cop[tikv]	table:t	keep order:false, stats:pseudo
+desc format='brief' select * from t where b > 'a';
+id	estRows	task	access object	operator info
+Selection	8000.00	root		gt(black_list.t.b, "a")
+└─TableReader	10000.00	root		data:TableFullScan
+  └─TableFullScan	10000.00	cop[tikv]	table:t	keep order:false, stats:pseudo
+delete from mysql.expr_pushdown_blacklist;
+admin reload expr_pushdown_blacklist;
+
+desc format='brief' select * from t where b = 1 and a = 1;
+id	estRows	task	access object	operator info
+IndexLookUp	0.10	root		
+├─IndexRangeScan(Build)	0.10	cop[tikv]	table:t, index:idx(b, a)	range:["a" "a","a" "a"], keep order:false, stats:pseudo
+└─TableRowIDScan(Probe)	0.10	cop[tikv]	table:t	keep order:false, stats:pseudo
+desc format='brief' select * from t where b = 'a' and a = 'a';
+id	estRows	task	access object	operator info
+IndexLookUp	0.10	root		
+├─IndexRangeScan(Build)	0.10	cop[tikv]	table:t, index:idx(b, a)	range:["a" "a","a" "a"], keep order:false, stats:pseudo
+└─TableRowIDScan(Probe)	0.10	cop[tikv]	table:t	keep order:false, stats:pseudo
+desc format='brief' select * from t where b = 1 and a > 1;
+id	estRows	task	access object	operator info
+IndexLookUp	33.33	root		
+├─IndexRangeScan(Build)	33.33	cop[tikv]	table:t, index:idx(b, a)	range:("a" "a","a" +inf], keep order:false, stats:pseudo
+└─TableRowIDScan(Probe)	33.33	cop[tikv]	table:t	keep order:false, stats:pseudo
+desc format='brief' select * from t where b = 1 and a > 'a';
+id	estRows	task	access object	operator info
+IndexLookUp	0.20	root		
+├─IndexRangeScan(Build)	0.20	cop[tikv]	table:t, index:idx(b, a)	range:["a" "b","a" "b"], ["a" "c","a" "c"], keep order:false, stats:pseudo
+└─TableRowIDScan(Probe)	0.20	cop[tikv]	table:t	keep order:false, stats:pseudo