Commit175b0c8

committed

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

1 parent7345c79 commit175b0c8Copy full SHA for 175b0c8

File tree

-5

lines changed

-5

lines changed

Lines changed: 4 additions & 5 deletions

Original file line number	Diff line number	Diff line change
`@@ -1340,11 +1340,9 @@ handle_arrexpr(const ScalarArrayOpExpr expr, const PartRelationInfo prel)`
`1340`	`1340`	`result->orig= (constNode*)expr;`
`1341`	`1341`	`result->args=NIL;`
`1342`	`1342`
`1343`		`-if (varnode==NULL\|\| !IsA(varnode,Var))`
`1344`		`-{`
`1345`		`-result->rangeset=list_make1_irange(make_irange(0,prel->children_count-1, true));`
`1346`		`-returnresult;`
`1347`		`-}`
	`1343`	`+/* If variable is not the partition key then skip it */`
	`1344`	`+if (!varnode\|\| !IsA(varnode,Var)\|\| ((Var*)varnode)->varattno!=prel->attnum)`
	`1345`	`+gotohandle_arrexpr_return;`
`1348`	`1346`
`1349`	`1347`	`if (arraynode&&IsA(arraynode,Const)&&`
`1350`	`1348`	`!((Const*)arraynode)->constisnull)`
`@@ -1384,6 +1382,7 @@ handle_arrexpr(const ScalarArrayOpExpr expr, const PartRelationInfo prel)`
`1384`	`1382`	`returnresult;`
`1385`	`1383`	`}`
`1386`	`1384`
	`1385`	`+handle_arrexpr_return:`
`1387`	`1386`	`result->rangeset=list_make1_irange(make_irange(0,prel->children_count-1, true));`
`1388`	`1387`	`returnresult;`
`1389`	`1388`	`}`

Comments

(0)