Commit77ee808

committed

bugfix: check that variable is the partitioning key

1 parentd874c6b commit77ee808Copy full SHA for 77ee808

File tree

-5

lines changed

-5

lines changed

Lines changed: 4 additions & 5 deletions

Original file line number	Diff line number	Diff line change
`@@ -1447,11 +1447,9 @@ handle_arrexpr(const ScalarArrayOpExpr expr, WalkerContext context)`
`1447`	`1447`	`result->orig= (constNode*)expr;`
`1448`	`1448`	`result->args=NIL;`
`1449`	`1449`
`1450`		`-if (varnode==NULL\|\| !IsA(varnode,Var))`
`1451`		`-{`
`1452`		`-result->rangeset=list_make1_irange(make_irange(0,prel->children_count-1, true));`
`1453`		`-returnresult;`
`1454`		`-}`
	`1450`	`+/* If variable is not the partition key then skip it */`
	`1451`	`+if (!varnode\|\| !IsA(varnode,Var)\|\| ((Var*)varnode)->varattno!=prel->attnum)`
	`1452`	`+gotohandle_arrexpr_return;`
`1455`	`1453`
`1456`	`1454`	`if (arraynode&&IsA(arraynode,Const)&&`
`1457`	`1455`	`!((Const*)arraynode)->constisnull)`
`@@ -1491,6 +1489,7 @@ handle_arrexpr(const ScalarArrayOpExpr expr, WalkerContext context)`
`1491`	`1489`	`returnresult;`
`1492`	`1490`	`}`
`1493`	`1491`
	`1492`	`+handle_arrexpr_return:`
`1494`	`1493`	`result->rangeset=list_make1_irange(make_irange(0,prel->children_count-1, true));`
`1495`	`1494`	`returnresult;`
`1496`	`1495`	`}`

Comments

(0)