Skip to content

Commit 78144ef

Browse files
committed
*
Signed-off-by: Weizhen Wang <[email protected]>
1 parent e949bd4 commit 78144ef

File tree

1 file changed

+11
-10
lines changed

1 file changed

+11
-10
lines changed

pkg/executor/prepared_test.go

Lines changed: 11 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -802,7 +802,8 @@ func TestIssue29101(t *testing.T) {
802802
` ├─Point_Get_27(Build) 1.00 root table:customer, index:PRIMARY(c_w_id, c_d_id, c_id) `,
803803
` └─TableReader_30(Probe) 0.00 root data:Selection_29`,
804804
` └─Selection_29 0.00 cop[tikv] eq(test.warehouse.w_id, 936)`,
805-
` └─TableRangeScan_28 1.00 cop[tikv] table:warehouse range: decided by [test.customer.c_w_id], keep order:false, stats:pseudo`))
805+
` └─TableRangeScan_28 1.00 cop[tikv] table:warehouse range: decided by [test.customer.c_w_id], keep order:false, stats:pseudo`,
806+
))
806807
tk.MustQuery(`execute s1 using @a,@b,@c`).Check(testkit.Rows())
807808
tk.MustQuery(`select @@last_plan_from_cache`).Check(testkit.Rows("1")) // can use the plan-cache
808809

@@ -825,15 +826,15 @@ func TestIssue29101(t *testing.T) {
825826
ps = []*sessmgr.ProcessInfo{tkProcess}
826827
tk.Session().SetSessionManager(&testkit.MockSessionManager{PS: ps})
827828
tk.MustQuery(fmt.Sprintf("explain for connection %d", tkProcess.ID)).Check(testkit.Rows( // can use index-join
828-
`StreamAgg_14 1.00 root funcs:count(distinct test.stock.s_i_id)->Column#11`,
829-
`└─IndexJoin_43 1.25 root inner join, inner:IndexLookUp_36, outer key:test.order_line.ol_i_id, inner key:test.stock.s_i_id, equal cond:eq(test.order_line.ol_i_id, test.stock.s_i_id)`,
830-
` ├─IndexLookUp_32(Build) 1.25 root `,
831-
` │ ├─IndexRangeScan_30(Build) 1.25 cop[tikv] table:order_line, index:PRIMARY(ol_w_id, ol_d_id, ol_o_id, ol_number) range:[391 1 3038,391 1 3058), keep order:false, stats:pseudo`,
832-
` │ └─TableRowIDScan_31(Probe) 1.25 cop[tikv] table:order_line keep order:false, stats:pseudo`,
833-
` └─IndexLookUp_36(Probe) 1.25 root `,
834-
` ├─IndexRangeScan_33(Build) 1.25 cop[tikv] table:stock, index:PRIMARY(s_w_id, s_i_id) range: decided by [eq(test.stock.s_i_id, test.order_line.ol_i_id) eq(test.stock.s_w_id, 391)], keep order:false, stats:pseudo`,
835-
` └─Selection_35(Probe) 1.25 cop[tikv] lt(test.stock.s_quantity, 18)`,
836-
` └─TableRowIDScan_34 1.25 cop[tikv] table:stock keep order:false, stats:pseudo`))
829+
`StreamAgg_13 1.00 root funcs:count(distinct test.stock.s_i_id)->Column#11`,
830+
`└─IndexJoin_42 1.25 root inner join, inner:IndexLookUp_35, outer key:test.order_line.ol_i_id, inner key:test.stock.s_i_id, equal cond:eq(test.order_line.ol_i_id, test.stock.s_i_id)`,
831+
` ├─IndexLookUp_31(Build) 1.25 root `,
832+
` │ ├─IndexRangeScan_29(Build) 1.25 cop[tikv] table:order_line, index:PRIMARY(ol_w_id, ol_d_id, ol_o_id, ol_number) range:[391 1 3038,391 1 3058), keep order:false, stats:pseudo`,
833+
` │ └─TableRowIDScan_30(Probe) 1.25 cop[tikv] table:order_line keep order:false, stats:pseudo`,
834+
` └─IndexLookUp_35(Probe) 1.25 root `,
835+
` ├─IndexRangeScan_32(Build) 1.25 cop[tikv] table:stock, index:PRIMARY(s_w_id, s_i_id) range: decided by [eq(test.stock.s_i_id, test.order_line.ol_i_id) eq(test.stock.s_w_id, 391)], keep order:false, stats:pseudo`,
836+
` └─Selection_34(Probe) 1.25 cop[tikv] lt(test.stock.s_quantity, 18)`,
837+
` └─TableRowIDScan_33 1.25 cop[tikv] table:stock keep order:false, stats:pseudo`))
837838
tk.MustExec(`execute s1 using @a,@b,@c,@c,@a,@d`)
838839
tk.MustQuery(`select @@last_plan_from_cache`).Check(testkit.Rows("1")) // can use the plan-cache
839840
}

0 commit comments

Comments
 (0)