Commitf495fd6

committed

bugfix: check that variable is the partitioning key (Ildar)

1 parent4b25335 commitf495fd6Copy full SHA for f495fd6

File tree

-5

lines changed

-5

lines changed

Lines changed: 4 additions & 5 deletions

Original file line number	Diff line number	Diff line change
`@@ -1409,11 +1409,9 @@ handle_arrexpr(const ScalarArrayOpExpr expr, WalkerContext context)`
`1409`	`1409`	`result->args=NIL;`
`1410`	`1410`	`result->paramsel=1.0;`
`1411`	`1411`
`1412`		`-if (varnode==NULL\|\| !IsA(varnode,Var))`
`1413`		`-{`
`1414`		`-result->rangeset=list_make1_irange(make_irange(0,prel->children_count-1, true));`
`1415`		`-returnresult;`
`1416`		`-}`
	`1412`	`+/* If variable is not the partition key then skip it */`
	`1413`	`+if (!varnode\|\| !IsA(varnode,Var)\|\| ((Var*)varnode)->varattno!=prel->attnum)`
	`1414`	`+gotohandle_arrexpr_return;`
`1417`	`1415`
`1418`	`1416`	`if (arraynode&&IsA(arraynode,Const)&&`
`1419`	`1417`	`!((Const*)arraynode)->constisnull)`
`@@ -1458,6 +1456,7 @@ handle_arrexpr(const ScalarArrayOpExpr expr, WalkerContext context)`
`1458`	`1456`	`result->paramsel=DEFAULT_INEQ_SEL;`
`1459`	`1457`	`}`
`1460`	`1458`
	`1459`	`+handle_arrexpr_return:`
`1461`	`1460`	`result->rangeset=list_make1_irange(make_irange(0,prel->children_count-1, true));`
`1462`	`1461`	`returnresult;`
`1463`	`1462`	`}`

Comments

(0)