database/openGauss-server
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

bugfix: fix NOT_EXISTS_SUBLINK logic while scan subplan for spq

Browse Source
This commit is contained in:
SetnameWang
2024-10-29 19:53:37 +08:00
parent 4924028cb9
commit 9ddbc67e62
1 changed files with 25 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
src/gausskernel/runtime/executor/nodeSubplan.cpp
View File

@ -294,6 +294,13 @@ static Datum ExecScanSubPlan(SubPlanState* node, ExprContext* econtext, bool* is
result = BoolGetDatum(true);
break;
}
#ifdef USE_SPQ
if (sub_link_type == NOT_EXISTS_SUBLINK) {
found = true;
result = BoolGetDatum(false);
break;
}
#endif
if (sub_link_type == EXPR_SUBLINK) {
/* cannot allow multiple input tuples for EXPR sublink */
@ -1008,13 +1015,22 @@ void ExecSetParamPlan(SubPlanState* node, ExprContext* econtext)
Assert(slot->tts_tupleDescriptor != NULL);
int i = 1;
#ifdef USE_SPQ
if (sub_link_type == EXISTS_SUBLINK || sub_link_type == NOT_EXISTS_SUBLINK) {
#else
if (sub_link_type == EXISTS_SUBLINK) {
#endif
/* There can be only one setParam... */
int paramid = linitial_int(subplan->setParam);
ParamExecData* prm = &(econtext->ecxt_param_exec_vals[paramid]);
prm->execPlan = NULL;
prm->value = BoolGetDatum(true);
#ifdef USE_SPQ
if (sub_link_type == NOT_EXISTS_SUBLINK) {
prm->value = BoolGetDatum(false);
}
#endif
prm->isnull = false;
found = true;
break;
@ -1091,13 +1107,22 @@ void ExecSetParamPlan(SubPlanState* node, ExprContext* econtext)
prm->value = node->curArray;
prm->isnull = false;
} else if (!found) {
#ifdef USE_SPQ
if (sub_link_type == EXISTS_SUBLINK || sub_link_type == NOT_EXISTS_SUBLINK) {
#else
if (sub_link_type == EXISTS_SUBLINK) {
#endif
/* There can be only one setParam... */
int paramid = linitial_int(subplan->setParam);
ParamExecData* prm = &(econtext->ecxt_param_exec_vals[paramid]);
prm->execPlan = NULL;
prm->value = BoolGetDatum(false);
#ifdef USE_SPQ
if (sub_link_type == NOT_EXISTS_SUBLINK) {
prm->value = BoolGetDatum(true);
}
#endif
prm->isnull = false;
} else {
foreach (l, subplan->setParam) {