-
Notifications
You must be signed in to change notification settings - Fork 5.9k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
planner: fix nulleq condition to calcalate index range (#56769)
close #56745
- Loading branch information
1 parent
4eac701
commit c066620
Showing
6 changed files
with
217 additions
and
127 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,16 @@ | ||
| load("@io_bazel_rules_go//go:def.bzl", "go_test") | ||
|
|
||
| go_test( | ||
| name = "null_test", | ||
| timeout = "short", | ||
| srcs = [ | ||
| "main_test.go", | ||
| "null_test.go", | ||
| ], | ||
| flaky = True, | ||
| deps = [ | ||
| "//pkg/testkit", | ||
| "//pkg/testkit/testsetup", | ||
| "@org_uber_go_goleak//:goleak", | ||
| ], | ||
| ) |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,34 @@ | ||
| // Copyright 2024 PingCAP, Inc. | ||
| // | ||
| // Licensed under the Apache License, Version 2.0 (the "License"); | ||
| // you may not use this file except in compliance with the License. | ||
| // You may obtain a copy of the License at | ||
| // | ||
| // http://www.apache.org/licenses/LICENSE-2.0 | ||
| // | ||
| // Unless required by applicable law or agreed to in writing, software | ||
| // distributed under the License is distributed on an "AS IS" BASIS, | ||
| // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | ||
| // See the License for the specific language governing permissions and | ||
| // limitations under the License. | ||
|
|
||
| package null | ||
|
|
||
| import ( | ||
| "flag" | ||
| "testing" | ||
|
|
||
| "github.com/pingcap/tidb/pkg/testkit/testsetup" | ||
| "go.uber.org/goleak" | ||
| ) | ||
|
|
||
| func TestMain(m *testing.M) { | ||
| testsetup.SetupForCommonTest() | ||
| flag.Parse() | ||
| opts := []goleak.Option{ | ||
| goleak.IgnoreTopFunction("github.com/golang/glog.(*fileSink).flushDaemon"), | ||
| goleak.IgnoreTopFunction("github.com/bazelbuild/rules_go/go/tools/bzltestutil.RegisterTimeoutHandler.func1"), | ||
| goleak.IgnoreTopFunction("github.com/lestrrat-go/httprc.runFetchWorker"), | ||
| } | ||
| goleak.VerifyTestMain(m, opts...) | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,159 @@ | ||
| // Copyright 2024 PingCAP, Inc. | ||
| // | ||
| // Licensed under the Apache License, Version 2.0 (the "License"); | ||
| // you may not use this file except in compliance with the License. | ||
| // You may obtain a copy of the License at | ||
| // | ||
| // http://www.apache.org/licenses/LICENSE-2.0 | ||
| // | ||
| // Unless required by applicable law or agreed to in writing, software | ||
| // distributed under the License is distributed on an "AS IS" BASIS, | ||
| // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | ||
| // See the License for the specific language governing permissions and | ||
| // limitations under the License. | ||
|
|
||
| package null | ||
|
|
||
| import ( | ||
| "testing" | ||
|
|
||
| "github.com/pingcap/tidb/pkg/testkit" | ||
| ) | ||
|
|
||
| func TestIssue54803(t *testing.T) { | ||
| store := testkit.CreateMockStore(t) | ||
| tk := testkit.NewTestKit(t, store) | ||
| tk.MustExec("use test") | ||
| tk.MustExec(` | ||
| CREATE TABLE t1db47fc1 ( | ||
| col_67 time NOT NULL DEFAULT '16:58:45', | ||
| col_68 tinyint(3) unsigned DEFAULT NULL, | ||
| col_69 bit(6) NOT NULL DEFAULT b'11110', | ||
| col_72 double NOT NULL | ||
| ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci | ||
| PARTITION BY HASH (col_68) PARTITIONS 5; | ||
| `) | ||
| tk.MustQuery(`EXPLAIN SELECT TRIM(t1db47fc1.col_68) AS r0 | ||
| FROM t1db47fc1 | ||
| WHERE ISNULL(t1db47fc1.col_68) | ||
| GROUP BY t1db47fc1.col_68 | ||
| HAVING ISNULL(t1db47fc1.col_68) OR t1db47fc1.col_68 IN (62, 200, 196, 99) | ||
| LIMIT 106149535; | ||
| `).Check(testkit.Rows("Projection_11 8.00 root trim(cast(test.t1db47fc1.col_68, var_string(20)))->Column#7", | ||
| "└─Limit_14 8.00 root offset:0, count:106149535", | ||
| " └─HashAgg_17 8.00 root group by:test.t1db47fc1.col_68, funcs:firstrow(test.t1db47fc1.col_68)->test.t1db47fc1.col_68", | ||
| " └─TableReader_24 10.00 root partition:p0 data:Selection_23", | ||
| " └─Selection_23 10.00 cop[tikv] isnull(test.t1db47fc1.col_68), or(isnull(test.t1db47fc1.col_68), in(test.t1db47fc1.col_68, 62, 200, 196, 99))", | ||
| " └─TableFullScan_22 10000.00 cop[tikv] table:t1db47fc1 keep order:false, stats:pseudo")) | ||
| // Issue55299 | ||
| tk.MustExec(` | ||
| CREATE TABLE tcd8c2aac ( | ||
| col_21 char(87) COLLATE utf8mb4_general_ci DEFAULT NULL, | ||
| KEY idx_12 (col_21(1)) | ||
| ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci; | ||
| `) | ||
| tk.MustExec(` | ||
| CREATE TABLE tle50fd846 ( | ||
| col_42 date DEFAULT '1989-10-30', | ||
| col_43 varbinary(122) NOT NULL DEFAULT 'Vz!3_P0LOdG', | ||
| col_44 json DEFAULT NULL, | ||
| col_45 binary(129) DEFAULT NULL, | ||
| col_46 double NOT NULL DEFAULT '4264.32300782421', | ||
| col_47 char(251) NOT NULL DEFAULT 'g7uo-dlBEY22!fx3@&', | ||
| col_48 char(229) NOT NULL, | ||
| col_49 blob NOT NULL, | ||
| col_50 blob DEFAULT NULL, | ||
| col_51 json DEFAULT NULL, | ||
| PRIMARY KEY (col_48) /*T![clustered_index] NONCLUSTERED */ | ||
| ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin; | ||
| `) | ||
| tk.MustExec("INSERT INTO `tcd8c2aac` VALUES(NULL),(NULL),('u!Vk+9B-3bn@'),('&PpQ*z!kQwj4g*ag#');") | ||
| tk.MustExec(`INSERT INTO tle50fd846 | ||
| VALUES | ||
| ('2029-05-09', x'757640736a42316c384162793124246b', '["YXt8UJAnVMWeMEZj1CzhNUzTMDJfzsmTWQkyOvVCsciA3eobvH8heH8gtr6ogxXa"]', x'577340000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000', 526.0218366710487, '%gMk', '58reJ%D&54', x'39254c48242556737474', x'6c66762b303567236f4068', '[2984188985038968170, 2580328438245089106, 4624130652422829118]');`) | ||
| tk.MustQuery(` | ||
| EXPLAIN SELECT GROUP_CONCAT(tcd8c2aac.col_21 ORDER BY tcd8c2aac.col_21 SEPARATOR ',') AS r0 | ||
| FROM tcd8c2aac | ||
| JOIN tle50fd846 | ||
| WHERE ISNULL(tcd8c2aac.col_21) OR tcd8c2aac.col_21='yJTkLeL5^yJ' | ||
| GROUP BY tcd8c2aac.col_21 | ||
| HAVING ISNULL(tcd8c2aac.col_21) | ||
| LIMIT 48579914;`).Check(testkit.Rows( | ||
| "Limit_16 6.40 root offset:0, count:48579914", | ||
| "└─HashAgg_17 6.40 root group by:test.tcd8c2aac.col_21, funcs:group_concat(test.tcd8c2aac.col_21 order by test.tcd8c2aac.col_21 separator \",\")->Column#14", | ||
| " └─HashJoin_20 80000.00 root CARTESIAN inner join", | ||
| " ├─IndexLookUp_24(Build) 8.00 root ", | ||
| " │ ├─Selection_23(Build) 8.00 cop[tikv] isnull(test.tcd8c2aac.col_21)", | ||
| " │ │ └─IndexRangeScan_21 10.00 cop[tikv] table:tcd8c2aac, index:idx_12(col_21) range:[NULL,NULL], keep order:false, stats:pseudo", | ||
| " │ └─TableRowIDScan_22(Probe) 8.00 cop[tikv] table:tcd8c2aac keep order:false, stats:pseudo", | ||
| " └─IndexReader_28(Probe) 10000.00 root index:IndexFullScan_27", | ||
| " └─IndexFullScan_27 10000.00 cop[tikv] table:tle50fd846, index:PRIMARY(col_48) keep order:false, stats:pseudo")) | ||
| tk.MustQuery(`SELECT GROUP_CONCAT(tcd8c2aac.col_21 ORDER BY tcd8c2aac.col_21 SEPARATOR ',') AS r0 | ||
| FROM tcd8c2aac | ||
| JOIN tle50fd846 | ||
| WHERE ISNULL(tcd8c2aac.col_21) OR tcd8c2aac.col_21='yJTkLeL5^yJ' | ||
| GROUP BY tcd8c2aac.col_21 | ||
| HAVING ISNULL(tcd8c2aac.col_21) | ||
| LIMIT 48579914;`).Check(testkit.Rows("<nil>")) | ||
|
|
||
| tk.MustExec(`CREATE TABLE ta31c32a7 ( | ||
| col_63 double DEFAULT '9963.92512636973', | ||
| KEY idx_24 (col_63), | ||
| KEY idx_25 (col_63), | ||
| KEY idx_26 (col_63) | ||
| ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci;`) | ||
| tk.MustExec(`INSERT INTO ta31c32a7 VALUES | ||
| (5496.073863178138), (4027.8475888445246), (2995.154396178381), (3045.228783606007), (3618.0432407275603), (1156.6077897338241), | ||
| (348.56448524702813), (2138.361831358777), (5904.959667345741), (2815.6976889801267), (6455.25717613724), | ||
| (9721.34540217101), (6793.035010125108), (6080.120357332818), (NULL), (1780.7418079754723), | ||
| (1222.1954607008702), (3576.2079432921923), (2187.4672702135276), (9129.689249510902), | ||
| (1065.3222700463314), (7509.347382423184), (7413.331945779306), (986.9882817569359), | ||
| (747.4145098692578), (4850.840161745998), (2607.5009231086797), (6499.136742855925), | ||
| (2501.691252762187), (6138.096783185339);`) | ||
| tk.MustQuery(`explain SELECT BIT_XOR(ta31c32a7.col_63) AS r0 | ||
| FROM ta31c32a7 | ||
| WHERE ISNULL(ta31c32a7.col_63) | ||
| OR ta31c32a7.col_63 IN (1780.7418079754723, 5904.959667345741, 1531.4023068774668) | ||
| GROUP BY ta31c32a7.col_63 | ||
| HAVING ISNULL(ta31c32a7.col_63) | ||
| LIMIT 65122436;`).Check(testkit.Rows( | ||
| "Limit_13 6.40 root offset:0, count:65122436", | ||
| "└─StreamAgg_37 6.40 root group by:test.ta31c32a7.col_63, funcs:bit_xor(Column#6)->Column#3", | ||
| " └─IndexReader_38 6.40 root index:StreamAgg_17", | ||
| " └─StreamAgg_17 6.40 cop[tikv] group by:test.ta31c32a7.col_63, funcs:bit_xor(cast(test.ta31c32a7.col_63, bigint(22) BINARY))->Column#6", | ||
| " └─IndexRangeScan_34 10.00 cop[tikv] table:ta31c32a7, index:idx_24(col_63) range:[NULL,NULL], keep order:true, stats:pseudo")) | ||
| tk.MustQuery(`explain SELECT BIT_XOR(ta31c32a7.col_63) AS r0 | ||
| FROM ta31c32a7 | ||
| WHERE ISNULL(ta31c32a7.col_63) | ||
| OR ta31c32a7.col_63 IN (1780.7418079754723, 5904.959667345741, 1531.4023068774668) | ||
| GROUP BY ta31c32a7.col_63 | ||
| LIMIT 65122436;`).Check(testkit.Rows( | ||
| "Limit_11 32.00 root offset:0, count:65122436", | ||
| "└─StreamAgg_35 32.00 root group by:test.ta31c32a7.col_63, funcs:bit_xor(Column#5)->Column#3", | ||
| " └─IndexReader_36 32.00 root index:StreamAgg_15", | ||
| " └─StreamAgg_15 32.00 cop[tikv] group by:test.ta31c32a7.col_63, funcs:bit_xor(cast(test.ta31c32a7.col_63, bigint(22) BINARY))->Column#5", | ||
| " └─IndexRangeScan_32 40.00 cop[tikv] table:ta31c32a7, index:idx_24(col_63) range:[NULL,NULL], [1531.4023068774668,1531.4023068774668], [1780.7418079754723,1780.7418079754723], [5904.959667345741,5904.959667345741], keep order:true, stats:pseudo")) | ||
| tk.MustExec(`CREATE TABLE tl75eff7ba ( | ||
| col_1 tinyint(1) DEFAULT '0', | ||
| KEY idx_1 (col_1), | ||
| UNIQUE KEY idx_2 (col_1), | ||
| UNIQUE KEY idx_3 (col_1), | ||
| KEY idx_4 (col_1) /*!80000 INVISIBLE */, | ||
| UNIQUE KEY idx_5 (col_1) | ||
| ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_general_ci;`) | ||
| tk.MustExec(`INSERT INTO tl75eff7ba VALUES(1),(0);`) | ||
| tk.MustQuery(`SELECT tl75eff7ba.col_1 AS r0 FROM tl75eff7ba WHERE ISNULL(tl75eff7ba.col_1) OR tl75eff7ba.col_1 IN (0, 0, 1, 1) GROUP BY tl75eff7ba.col_1 HAVING ISNULL(tl75eff7ba.col_1) OR tl75eff7ba.col_1 IN (0, 1, 1, 0) LIMIT 58651509;`).Check(testkit.Rows("0", "1")) | ||
| } | ||
|
|
||
| func TestIssue56745(t *testing.T) { | ||
| // c1 <=> null | ||
| store := testkit.CreateMockStore(t) | ||
| tk := testkit.NewTestKit(t, store) | ||
| tk.MustExec("use test") | ||
| tk.MustExec("create table lrr( `COL1` varchar(10) NOT NULL,`COL2` char(10) NOT NULL,PRIMARY KEY (`COL1`(5),`COL2`) /*T![clustered_index] CLUSTERED */);") | ||
| tk.MustExec("insert into lrr values('','a');") | ||
| tk.MustExec("insert into lrr values('test','b');") | ||
| tk.MustExec("prepare stmt from 'SELECT * FROM lrr t1 JOIN lrr t2 ON t1.col1 <=> t2.col1 WHERE t1.col1 <=> NULL AND t2.col1 = ?;';") | ||
| tk.MustExec("set @a=NULL;") | ||
| tk.MustExec("execute stmt using @a;") | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters