external
/
citus
mirror of https://github.com/citusdata/citus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Adds support for MERGE in ruleutils_15.c 

Relevant PG commit:
7103ebb7aae8ab8076b7e85f335ceb8fe799097c
version-15-socket
naisila 2022-07-25 16:08:18 +03:00
parent a23111b972
commit 4a3948f8ac
1 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/backend/distributed/deparser/ruleutils_15.c
View File

@ -1792,6 +1792,8 @@ set_deparse_plan(deparse_namespace *dpns, Plan *plan)
* For a WorkTableScan, locate the parent RecursiveUnion plan node and use * For a WorkTableScan, locate the parent RecursiveUnion plan node and use
* that as INNER referent. * that as INNER referent.
* *
* For MERGE, make the inner tlist point to the merge source tlist, which
* is same as the targetlist that the ModifyTable's source plan provides.
* For ON CONFLICT .. UPDATE we just need the inner tlist to point to the * For ON CONFLICT .. UPDATE we just need the inner tlist to point to the
* excluded expression's tlist. (Similar to the SubqueryScan we don't want * excluded expression's tlist. (Similar to the SubqueryScan we don't want
* to reuse OUTER, it's used for RETURNING in some modify table cases, * to reuse OUTER, it's used for RETURNING in some modify table cases,
@ -1811,7 +1813,12 @@ set_deparse_plan(deparse_namespace *dpns, Plan *plan)
dpns->inner_plan = innerPlan(plan); dpns->inner_plan = innerPlan(plan);
if (IsA(plan, ModifyTable)) if (IsA(plan, ModifyTable))
dpns->inner_tlist = ((ModifyTable *) plan)->exclRelTlist; {
if (((ModifyTable *) plan)->operation == CMD_MERGE)
dpns->inner_tlist = dpns->outer_plan->targetlist;
else
dpns->inner_tlist = ((ModifyTable *) plan)->exclRelTlist;
}
else if (dpns->inner_plan) else if (dpns->inner_plan)
dpns->inner_tlist = dpns->inner_plan->targetlist; dpns->inner_tlist = dpns->inner_plan->targetlist;
else else