PostgreSQL Source Code  git master
nodeResult.c File Reference
#include "postgres.h"
#include "executor/executor.h"
#include "executor/nodeResult.h"
#include "miscadmin.h"
Include dependency graph for nodeResult.c:

Go to the source code of this file.

Functions

static TupleTableSlotExecResult (PlanState *pstate)
 
void ExecResultMarkPos (ResultState *node)
 
void ExecResultRestrPos (ResultState *node)
 
ResultStateExecInitResult (Result *node, EState *estate, int eflags)
 
void ExecEndResult (ResultState *node)
 
void ExecReScanResult (ResultState *node)
 

Function Documentation

◆ ExecEndResult()

void ExecEndResult ( ResultState node)

Definition at line 240 of file nodeResult.c.

241 {
242  /*
243  * shut down subplans
244  */
246 }
void ExecEndNode(PlanState *node)
Definition: execProcnode.c:557
#define outerPlanState(node)
Definition: execnodes.h:1214

References ExecEndNode(), and outerPlanState.

Referenced by ExecEndNode().

◆ ExecInitResult()

ResultState* ExecInitResult ( Result node,
EState estate,
int  eflags 
)

Definition at line 180 of file nodeResult.c.

181 {
182  ResultState *resstate;
183 
184  /* check for unsupported flags */
185  Assert(!(eflags & (EXEC_FLAG_MARK | EXEC_FLAG_BACKWARD)) ||
186  outerPlan(node) != NULL);
187 
188  /*
189  * create state structure
190  */
191  resstate = makeNode(ResultState);
192  resstate->ps.plan = (Plan *) node;
193  resstate->ps.state = estate;
194  resstate->ps.ExecProcNode = ExecResult;
195 
196  resstate->rs_done = false;
197  resstate->rs_checkqual = (node->resconstantqual != NULL);
198 
199  /*
200  * Miscellaneous initialization
201  *
202  * create expression context for node
203  */
204  ExecAssignExprContext(estate, &resstate->ps);
205 
206  /*
207  * initialize child nodes
208  */
209  outerPlanState(resstate) = ExecInitNode(outerPlan(node), estate, eflags);
210 
211  /*
212  * we don't use inner plan
213  */
214  Assert(innerPlan(node) == NULL);
215 
216  /*
217  * Initialize result slot, type and projection.
218  */
220  ExecAssignProjectionInfo(&resstate->ps, NULL);
221 
222  /*
223  * initialize child expressions
224  */
225  resstate->ps.qual =
226  ExecInitQual(node->plan.qual, (PlanState *) resstate);
227  resstate->resconstantqual =
228  ExecInitQual((List *) node->resconstantqual, (PlanState *) resstate);
229 
230  return resstate;
231 }
#define Assert(condition)
Definition: c.h:858
ExprState * ExecInitQual(List *qual, PlanState *parent)
Definition: execExpr.c:220
PlanState * ExecInitNode(Plan *node, EState *estate, int eflags)
Definition: execProcnode.c:142
const TupleTableSlotOps TTSOpsVirtual
Definition: execTuples.c:84
void ExecInitResultTupleSlotTL(PlanState *planstate, const TupleTableSlotOps *tts_ops)
Definition: execTuples.c:1886
void ExecAssignExprContext(EState *estate, PlanState *planstate)
Definition: execUtils.c:483
void ExecAssignProjectionInfo(PlanState *planstate, TupleDesc inputDesc)
Definition: execUtils.c:538
#define EXEC_FLAG_BACKWARD
Definition: executor.h:68
#define EXEC_FLAG_MARK
Definition: executor.h:69
static TupleTableSlot * ExecResult(PlanState *pstate)
Definition: nodeResult.c:67
#define makeNode(_type_)
Definition: nodes.h:155
#define innerPlan(node)
Definition: plannodes.h:181
#define outerPlan(node)
Definition: plannodes.h:182
Definition: pg_list.h:54
ExprState * qual
Definition: execnodes.h:1139
Plan * plan
Definition: execnodes.h:1118
EState * state
Definition: execnodes.h:1120
ExecProcNodeMtd ExecProcNode
Definition: execnodes.h:1124
List * qual
Definition: plannodes.h:153
ExprState * resconstantqual
Definition: execnodes.h:1322
bool rs_done
Definition: execnodes.h:1323
PlanState ps
Definition: execnodes.h:1321
bool rs_checkqual
Definition: execnodes.h:1324
Node * resconstantqual
Definition: plannodes.h:199
Plan plan
Definition: plannodes.h:198

References Assert, EXEC_FLAG_BACKWARD, EXEC_FLAG_MARK, ExecAssignExprContext(), ExecAssignProjectionInfo(), ExecInitNode(), ExecInitQual(), ExecInitResultTupleSlotTL(), PlanState::ExecProcNode, ExecResult(), innerPlan, makeNode, outerPlan, outerPlanState, PlanState::plan, Result::plan, ResultState::ps, PlanState::qual, Plan::qual, ResultState::resconstantqual, Result::resconstantqual, ResultState::rs_checkqual, ResultState::rs_done, PlanState::state, and TTSOpsVirtual.

Referenced by ExecInitNode().

◆ ExecReScanResult()

void ExecReScanResult ( ResultState node)

Definition at line 249 of file nodeResult.c.

250 {
252 
253  node->rs_done = false;
254  node->rs_checkqual = (node->resconstantqual != NULL);
255 
256  /*
257  * If chgParam of subnode is not null then plan will be re-scanned by
258  * first ExecProcNode.
259  */
260  if (outerPlan && outerPlan->chgParam == NULL)
262 }
void ExecReScan(PlanState *node)
Definition: execAmi.c:76

References ExecReScan(), outerPlan, outerPlanState, ResultState::resconstantqual, ResultState::rs_checkqual, and ResultState::rs_done.

Referenced by ExecReScan().

◆ ExecResult()

static TupleTableSlot* ExecResult ( PlanState pstate)
static

Definition at line 67 of file nodeResult.c.

68 {
69  ResultState *node = castNode(ResultState, pstate);
70  TupleTableSlot *outerTupleSlot;
72  ExprContext *econtext;
73 
75 
76  econtext = node->ps.ps_ExprContext;
77 
78  /*
79  * check constant qualifications like (2 > 1), if not already done
80  */
81  if (node->rs_checkqual)
82  {
83  bool qualResult = ExecQual(node->resconstantqual, econtext);
84 
85  node->rs_checkqual = false;
86  if (!qualResult)
87  {
88  node->rs_done = true;
89  return NULL;
90  }
91  }
92 
93  /*
94  * Reset per-tuple memory context to free any expression evaluation
95  * storage allocated in the previous tuple cycle.
96  */
97  ResetExprContext(econtext);
98 
99  /*
100  * if rs_done is true then it means that we were asked to return a
101  * constant tuple and we already did the last time ExecResult() was
102  * called, OR that we failed the constant qual check. Either way, now we
103  * are through.
104  */
105  if (!node->rs_done)
106  {
107  outerPlan = outerPlanState(node);
108 
109  if (outerPlan != NULL)
110  {
111  /*
112  * retrieve tuples from the outer plan until there are no more.
113  */
114  outerTupleSlot = ExecProcNode(outerPlan);
115 
116  if (TupIsNull(outerTupleSlot))
117  return NULL;
118 
119  /*
120  * prepare to compute projection expressions, which will expect to
121  * access the input tuples as varno OUTER.
122  */
123  econtext->ecxt_outertuple = outerTupleSlot;
124  }
125  else
126  {
127  /*
128  * if we don't have an outer plan, then we are just generating the
129  * results from a constant target list. Do it only once.
130  */
131  node->rs_done = true;
132  }
133 
134  /* form the result tuple using ExecProject(), and return it */
135  return ExecProject(node->ps.ps_ProjInfo);
136  }
137 
138  return NULL;
139 }
static TupleTableSlot * ExecProject(ProjectionInfo *projInfo)
Definition: executor.h:376
#define ResetExprContext(econtext)
Definition: executor.h:544
static bool ExecQual(ExprState *state, ExprContext *econtext)
Definition: executor.h:413
static TupleTableSlot * ExecProcNode(PlanState *node)
Definition: executor.h:269
#define CHECK_FOR_INTERRUPTS()
Definition: miscadmin.h:122
#define castNode(_type_, nodeptr)
Definition: nodes.h:176
TupleTableSlot * ecxt_outertuple
Definition: execnodes.h:259
ExprContext * ps_ExprContext
Definition: execnodes.h:1157
ProjectionInfo * ps_ProjInfo
Definition: execnodes.h:1158
#define TupIsNull(slot)
Definition: tuptable.h:306

References castNode, CHECK_FOR_INTERRUPTS, ExprContext::ecxt_outertuple, ExecProcNode(), ExecProject(), ExecQual(), outerPlan, outerPlanState, ResultState::ps, PlanState::ps_ExprContext, PlanState::ps_ProjInfo, ResultState::resconstantqual, ResetExprContext, ResultState::rs_checkqual, ResultState::rs_done, and TupIsNull.

Referenced by ExecInitResult().

◆ ExecResultMarkPos()

void ExecResultMarkPos ( ResultState node)

Definition at line 146 of file nodeResult.c.

147 {
149 
150  if (outerPlan != NULL)
152  else
153  elog(DEBUG2, "Result nodes do not support mark/restore");
154 }
#define DEBUG2
Definition: elog.h:29
#define elog(elevel,...)
Definition: elog.h:224
void ExecMarkPos(PlanState *node)
Definition: execAmi.c:326

References DEBUG2, elog, ExecMarkPos(), outerPlan, and outerPlanState.

Referenced by ExecMarkPos().

◆ ExecResultRestrPos()

void ExecResultRestrPos ( ResultState node)

Definition at line 161 of file nodeResult.c.

162 {
164 
165  if (outerPlan != NULL)
167  else
168  elog(ERROR, "Result nodes do not support mark/restore");
169 }
#define ERROR
Definition: elog.h:39
void ExecRestrPos(PlanState *node)
Definition: execAmi.c:375

References elog, ERROR, ExecRestrPos(), outerPlan, and outerPlanState.

Referenced by ExecRestrPos().