PostgreSQL Source Code  git master
execUtils.c File Reference
#include "postgres.h"
#include "access/parallel.h"
#include "access/table.h"
#include "access/tableam.h"
#include "executor/executor.h"
#include "executor/nodeModifyTable.h"
#include "jit/jit.h"
#include "mb/pg_wchar.h"
#include "miscadmin.h"
#include "parser/parse_relation.h"
#include "partitioning/partdesc.h"
#include "storage/lmgr.h"
#include "utils/builtins.h"
#include "utils/memutils.h"
#include "utils/rel.h"
#include "utils/typcache.h"
Include dependency graph for execUtils.c:

Go to the source code of this file.

Functions

static bool tlist_matches_tupdesc (PlanState *ps, List *tlist, int varno, TupleDesc tupdesc)
 
static void ShutdownExprContext (ExprContext *econtext, bool isCommit)
 
static RTEPermissionInfoGetResultRTEPermissionInfo (ResultRelInfo *relinfo, EState *estate)
 
EStateCreateExecutorState (void)
 
void FreeExecutorState (EState *estate)
 
static ExprContextCreateExprContextInternal (EState *estate, Size minContextSize, Size initBlockSize, Size maxBlockSize)
 
ExprContextCreateExprContext (EState *estate)
 
ExprContextCreateWorkExprContext (EState *estate)
 
ExprContextCreateStandaloneExprContext (void)
 
void FreeExprContext (ExprContext *econtext, bool isCommit)
 
void ReScanExprContext (ExprContext *econtext)
 
ExprContextMakePerTupleExprContext (EState *estate)
 
void ExecAssignExprContext (EState *estate, PlanState *planstate)
 
TupleDesc ExecGetResultType (PlanState *planstate)
 
const TupleTableSlotOpsExecGetResultSlotOps (PlanState *planstate, bool *isfixed)
 
void ExecAssignProjectionInfo (PlanState *planstate, TupleDesc inputDesc)
 
void ExecConditionalAssignProjectionInfo (PlanState *planstate, TupleDesc inputDesc, int varno)
 
void ExecAssignScanType (ScanState *scanstate, TupleDesc tupDesc)
 
void ExecCreateScanSlotFromOuterPlan (EState *estate, ScanState *scanstate, const TupleTableSlotOps *tts_ops)
 
bool ExecRelationIsTargetRelation (EState *estate, Index scanrelid)
 
Relation ExecOpenScanRelation (EState *estate, Index scanrelid, int eflags)
 
void ExecInitRangeTable (EState *estate, List *rangeTable, List *permInfos)
 
Relation ExecGetRangeTableRelation (EState *estate, Index rti)
 
void ExecInitResultRelation (EState *estate, ResultRelInfo *resultRelInfo, Index rti)
 
void UpdateChangedParamSet (PlanState *node, Bitmapset *newchg)
 
int executor_errposition (EState *estate, int location)
 
void RegisterExprContextCallback (ExprContext *econtext, ExprContextCallbackFunction function, Datum arg)
 
void UnregisterExprContextCallback (ExprContext *econtext, ExprContextCallbackFunction function, Datum arg)
 
Datum GetAttributeByName (HeapTupleHeader tuple, const char *attname, bool *isNull)
 
Datum GetAttributeByNum (HeapTupleHeader tuple, AttrNumber attrno, bool *isNull)
 
int ExecTargetListLength (List *targetlist)
 
int ExecCleanTargetListLength (List *targetlist)
 
TupleTableSlotExecGetTriggerOldSlot (EState *estate, ResultRelInfo *relInfo)
 
TupleTableSlotExecGetTriggerNewSlot (EState *estate, ResultRelInfo *relInfo)
 
TupleTableSlotExecGetReturningSlot (EState *estate, ResultRelInfo *relInfo)
 
TupleConversionMapExecGetChildToRootMap (ResultRelInfo *resultRelInfo)
 
TupleConversionMapExecGetRootToChildMap (ResultRelInfo *resultRelInfo, EState *estate)
 
BitmapsetExecGetInsertedCols (ResultRelInfo *relinfo, EState *estate)
 
BitmapsetExecGetUpdatedCols (ResultRelInfo *relinfo, EState *estate)
 
BitmapsetExecGetExtraUpdatedCols (ResultRelInfo *relinfo, EState *estate)
 
BitmapsetExecGetAllUpdatedCols (ResultRelInfo *relinfo, EState *estate)
 
Oid ExecGetResultRelCheckAsUser (ResultRelInfo *relInfo, EState *estate)
 

Function Documentation

◆ CreateExecutorState()

EState* CreateExecutorState ( void  )

Definition at line 88 of file execUtils.c.

89 {
90  EState *estate;
91  MemoryContext qcontext;
92  MemoryContext oldcontext;
93 
94  /*
95  * Create the per-query context for this Executor run.
96  */
98  "ExecutorState",
100 
101  /*
102  * Make the EState node within the per-query context. This way, we don't
103  * need a separate pfree() operation for it at shutdown.
104  */
105  oldcontext = MemoryContextSwitchTo(qcontext);
106 
107  estate = makeNode(EState);
108 
109  /*
110  * Initialize all fields of the Executor State structure
111  */
113  estate->es_snapshot = InvalidSnapshot; /* caller must initialize this */
114  estate->es_crosscheck_snapshot = InvalidSnapshot; /* no crosscheck */
115  estate->es_range_table = NIL;
116  estate->es_range_table_size = 0;
117  estate->es_relations = NULL;
118  estate->es_rowmarks = NULL;
119  estate->es_rteperminfos = NIL;
120  estate->es_plannedstmt = NULL;
121 
122  estate->es_junkFilter = NULL;
123 
124  estate->es_output_cid = (CommandId) 0;
125 
126  estate->es_result_relations = NULL;
129  estate->es_trig_target_relations = NIL;
130 
133 
134  estate->es_param_list_info = NULL;
135  estate->es_param_exec_vals = NULL;
136 
137  estate->es_queryEnv = NULL;
138 
139  estate->es_query_cxt = qcontext;
140 
141  estate->es_tupleTable = NIL;
142 
143  estate->es_processed = 0;
144  estate->es_total_processed = 0;
145 
146  estate->es_top_eflags = 0;
147  estate->es_instrument = 0;
148  estate->es_finished = false;
149 
150  estate->es_exprcontexts = NIL;
151 
152  estate->es_subplanstates = NIL;
153 
154  estate->es_auxmodifytables = NIL;
155 
156  estate->es_per_tuple_exprcontext = NULL;
157 
158  estate->es_sourceText = NULL;
159 
160  estate->es_use_parallel_mode = false;
161 
162  estate->es_jit_flags = 0;
163  estate->es_jit = NULL;
164 
165  /*
166  * Return the executor state structure
167  */
168  MemoryContextSwitchTo(oldcontext);
169 
170  return estate;
171 }
uint32 CommandId
Definition: c.h:653
MemoryContext CurrentMemoryContext
Definition: mcxt.c:131
#define AllocSetContextCreate
Definition: memutils.h:129
#define ALLOCSET_DEFAULT_SIZES
Definition: memutils.h:153
#define makeNode(_type_)
Definition: nodes.h:155
static MemoryContext MemoryContextSwitchTo(MemoryContext context)
Definition: palloc.h:124
#define NIL
Definition: pg_list.h:68
@ ForwardScanDirection
Definition: sdir.h:28
#define InvalidSnapshot
Definition: snapshot.h:123
uint64 es_processed
Definition: execnodes.h:669
struct ExecRowMark ** es_rowmarks
Definition: execnodes.h:628
List * es_tuple_routing_result_relations
Definition: execnodes.h:653
int es_top_eflags
Definition: execnodes.h:674
struct JitContext * es_jit
Definition: execnodes.h:714
int es_instrument
Definition: execnodes.h:675
PlannedStmt * es_plannedstmt
Definition: execnodes.h:631
QueryEnvironment * es_queryEnv
Definition: execnodes.h:662
ResultRelInfo ** es_result_relations
Definition: execnodes.h:640
ParamExecData * es_param_exec_vals
Definition: execnodes.h:660
uint64 es_total_processed
Definition: execnodes.h:671
List * es_range_table
Definition: execnodes.h:624
List * es_rteperminfos
Definition: execnodes.h:630
List * es_exprcontexts
Definition: execnodes.h:678
ParamListInfo es_param_list_info
Definition: execnodes.h:659
bool es_finished
Definition: execnodes.h:676
List * es_insert_pending_result_relations
Definition: execnodes.h:721
MemoryContext es_query_cxt
Definition: execnodes.h:665
List * es_tupleTable
Definition: execnodes.h:667
ScanDirection es_direction
Definition: execnodes.h:621
List * es_trig_target_relations
Definition: execnodes.h:656
int es_jit_flags
Definition: execnodes.h:713
List * es_opened_result_relations
Definition: execnodes.h:643
bool es_use_parallel_mode
Definition: execnodes.h:699
Relation * es_relations
Definition: execnodes.h:626
List * es_subplanstates
Definition: execnodes.h:680
ExprContext * es_per_tuple_exprcontext
Definition: execnodes.h:689
CommandId es_output_cid
Definition: execnodes.h:637
Index es_range_table_size
Definition: execnodes.h:625
List * es_insert_pending_modifytables
Definition: execnodes.h:722
const char * es_sourceText
Definition: execnodes.h:632
Snapshot es_snapshot
Definition: execnodes.h:622
List * es_auxmodifytables
Definition: execnodes.h:682
JunkFilter * es_junkFilter
Definition: execnodes.h:634
Snapshot es_crosscheck_snapshot
Definition: execnodes.h:623

References ALLOCSET_DEFAULT_SIZES, AllocSetContextCreate, CurrentMemoryContext, EState::es_auxmodifytables, EState::es_crosscheck_snapshot, EState::es_direction, EState::es_exprcontexts, EState::es_finished, EState::es_insert_pending_modifytables, EState::es_insert_pending_result_relations, EState::es_instrument, EState::es_jit, EState::es_jit_flags, EState::es_junkFilter, EState::es_opened_result_relations, EState::es_output_cid, EState::es_param_exec_vals, EState::es_param_list_info, EState::es_per_tuple_exprcontext, EState::es_plannedstmt, EState::es_processed, EState::es_query_cxt, EState::es_queryEnv, EState::es_range_table, EState::es_range_table_size, EState::es_relations, EState::es_result_relations, EState::es_rowmarks, EState::es_rteperminfos, EState::es_snapshot, EState::es_sourceText, EState::es_subplanstates, EState::es_top_eflags, EState::es_total_processed, EState::es_trig_target_relations, EState::es_tuple_routing_result_relations, EState::es_tupleTable, EState::es_use_parallel_mode, ForwardScanDirection, InvalidSnapshot, makeNode, MemoryContextSwitchTo(), and NIL.

Referenced by afterTriggerInvokeEvents(), ATRewriteTable(), check_default_partition_contents(), compute_expr_stats(), compute_index_stats(), CopyFrom(), create_edata_for_relation(), create_estate_for_relation(), EvalPlanQualStart(), evaluate_expr(), ExecuteCallStmt(), ExecuteQuery(), ExecuteTruncateGuts(), ExplainExecuteQuery(), fileIterateForeignScan(), get_qual_for_range(), heapam_index_build_range_scan(), heapam_index_validate_scan(), IndexCheckExclusion(), make_build_data(), operator_predicate_proof(), plpgsql_create_econtext(), plpgsql_inline_handler(), standard_ExecutorStart(), StoreAttrDefault(), tuplesort_begin_cluster(), and validateDomainConstraint().

◆ CreateExprContext()

ExprContext* CreateExprContext ( EState estate)

Definition at line 304 of file execUtils.c.

305 {
307 }
static ExprContext * CreateExprContextInternal(EState *estate, Size minContextSize, Size initBlockSize, Size maxBlockSize)
Definition: execUtils.c:234

References ALLOCSET_DEFAULT_SIZES, and CreateExprContextInternal().

Referenced by ExecAssignExprContext(), ExecInitMergeJoin(), ExecInitSubPlan(), ExecuteCallStmt(), MakePerTupleExprContext(), and plpgsql_create_econtext().

◆ CreateExprContextInternal()

static ExprContext* CreateExprContextInternal ( EState estate,
Size  minContextSize,
Size  initBlockSize,
Size  maxBlockSize 
)
static

Definition at line 234 of file execUtils.c.

236 {
237  ExprContext *econtext;
238  MemoryContext oldcontext;
239 
240  /* Create the ExprContext node within the per-query memory context */
241  oldcontext = MemoryContextSwitchTo(estate->es_query_cxt);
242 
243  econtext = makeNode(ExprContext);
244 
245  /* Initialize fields of ExprContext */
246  econtext->ecxt_scantuple = NULL;
247  econtext->ecxt_innertuple = NULL;
248  econtext->ecxt_outertuple = NULL;
249 
250  econtext->ecxt_per_query_memory = estate->es_query_cxt;
251 
252  /*
253  * Create working memory for expression evaluation in this context.
254  */
255  econtext->ecxt_per_tuple_memory =
257  "ExprContext",
258  minContextSize,
259  initBlockSize,
260  maxBlockSize);
261 
262  econtext->ecxt_param_exec_vals = estate->es_param_exec_vals;
263  econtext->ecxt_param_list_info = estate->es_param_list_info;
264 
265  econtext->ecxt_aggvalues = NULL;
266  econtext->ecxt_aggnulls = NULL;
267 
268  econtext->caseValue_datum = (Datum) 0;
269  econtext->caseValue_isNull = true;
270 
271  econtext->domainValue_datum = (Datum) 0;
272  econtext->domainValue_isNull = true;
273 
274  econtext->ecxt_estate = estate;
275 
276  econtext->ecxt_callbacks = NULL;
277 
278  /*
279  * Link the ExprContext into the EState to ensure it is shut down when the
280  * EState is freed. Because we use lcons(), shutdowns will occur in
281  * reverse order of creation, which may not be essential but can't hurt.
282  */
283  estate->es_exprcontexts = lcons(econtext, estate->es_exprcontexts);
284 
285  MemoryContextSwitchTo(oldcontext);
286 
287  return econtext;
288 }
List * lcons(void *datum, List *list)
Definition: list.c:495
uintptr_t Datum
Definition: postgres.h:64
Datum domainValue_datum
Definition: execnodes.h:286
ParamListInfo ecxt_param_list_info
Definition: execnodes.h:267
MemoryContext ecxt_per_tuple_memory
Definition: execnodes.h:263
TupleTableSlot * ecxt_innertuple
Definition: execnodes.h:257
ParamExecData * ecxt_param_exec_vals
Definition: execnodes.h:266
Datum * ecxt_aggvalues
Definition: execnodes.h:274
bool caseValue_isNull
Definition: execnodes.h:282
TupleTableSlot * ecxt_scantuple
Definition: execnodes.h:255
Datum caseValue_datum
Definition: execnodes.h:280
bool * ecxt_aggnulls
Definition: execnodes.h:276
MemoryContext ecxt_per_query_memory
Definition: execnodes.h:262
ExprContext_CB * ecxt_callbacks
Definition: execnodes.h:294
bool domainValue_isNull
Definition: execnodes.h:288
struct EState * ecxt_estate
Definition: execnodes.h:291
TupleTableSlot * ecxt_outertuple
Definition: execnodes.h:259

References AllocSetContextCreate, ExprContext::caseValue_datum, ExprContext::caseValue_isNull, ExprContext::domainValue_datum, ExprContext::domainValue_isNull, ExprContext::ecxt_aggnulls, ExprContext::ecxt_aggvalues, ExprContext::ecxt_callbacks, ExprContext::ecxt_estate, ExprContext::ecxt_innertuple, ExprContext::ecxt_outertuple, ExprContext::ecxt_param_exec_vals, ExprContext::ecxt_param_list_info, ExprContext::ecxt_per_query_memory, ExprContext::ecxt_per_tuple_memory, ExprContext::ecxt_scantuple, EState::es_exprcontexts, EState::es_param_exec_vals, EState::es_param_list_info, EState::es_query_cxt, lcons(), makeNode, and MemoryContextSwitchTo().

Referenced by CreateExprContext(), and CreateWorkExprContext().

◆ CreateStandaloneExprContext()

ExprContext* CreateStandaloneExprContext ( void  )

Definition at line 355 of file execUtils.c.

356 {
357  ExprContext *econtext;
358 
359  /* Create the ExprContext node within the caller's memory context */
360  econtext = makeNode(ExprContext);
361 
362  /* Initialize fields of ExprContext */
363  econtext->ecxt_scantuple = NULL;
364  econtext->ecxt_innertuple = NULL;
365  econtext->ecxt_outertuple = NULL;
366 
368 
369  /*
370  * Create working memory for expression evaluation in this context.
371  */
372  econtext->ecxt_per_tuple_memory =
374  "ExprContext",
376 
377  econtext->ecxt_param_exec_vals = NULL;
378  econtext->ecxt_param_list_info = NULL;
379 
380  econtext->ecxt_aggvalues = NULL;
381  econtext->ecxt_aggnulls = NULL;
382 
383  econtext->caseValue_datum = (Datum) 0;
384  econtext->caseValue_isNull = true;
385 
386  econtext->domainValue_datum = (Datum) 0;
387  econtext->domainValue_isNull = true;
388 
389  econtext->ecxt_estate = NULL;
390 
391  econtext->ecxt_callbacks = NULL;
392 
393  return econtext;
394 }

References ALLOCSET_DEFAULT_SIZES, AllocSetContextCreate, ExprContext::caseValue_datum, ExprContext::caseValue_isNull, CurrentMemoryContext, ExprContext::domainValue_datum, ExprContext::domainValue_isNull, ExprContext::ecxt_aggnulls, ExprContext::ecxt_aggvalues, ExprContext::ecxt_callbacks, ExprContext::ecxt_estate, ExprContext::ecxt_innertuple, ExprContext::ecxt_outertuple, ExprContext::ecxt_param_exec_vals, ExprContext::ecxt_param_list_info, ExprContext::ecxt_per_query_memory, ExprContext::ecxt_per_tuple_memory, ExprContext::ecxt_scantuple, and makeNode.

Referenced by BuildTupleHashTableExt(), domain_check_input(), and hypothetical_dense_rank_final().

◆ CreateWorkExprContext()

ExprContext* CreateWorkExprContext ( EState estate)

Definition at line 319 of file execUtils.c.

320 {
321  Size minContextSize = ALLOCSET_DEFAULT_MINSIZE;
322  Size initBlockSize = ALLOCSET_DEFAULT_INITSIZE;
323  Size maxBlockSize = ALLOCSET_DEFAULT_MAXSIZE;
324 
325  /* choose the maxBlockSize to be no larger than 1/16 of work_mem */
326  while (16 * maxBlockSize > work_mem * 1024L)
327  maxBlockSize >>= 1;
328 
329  if (maxBlockSize < ALLOCSET_DEFAULT_INITSIZE)
330  maxBlockSize = ALLOCSET_DEFAULT_INITSIZE;
331 
332  return CreateExprContextInternal(estate, minContextSize,
333  initBlockSize, maxBlockSize);
334 }
size_t Size
Definition: c.h:592
int work_mem
Definition: globals.c:128
#define ALLOCSET_DEFAULT_MAXSIZE
Definition: memutils.h:152
#define ALLOCSET_DEFAULT_MINSIZE
Definition: memutils.h:150
#define ALLOCSET_DEFAULT_INITSIZE
Definition: memutils.h:151

References ALLOCSET_DEFAULT_INITSIZE, ALLOCSET_DEFAULT_MAXSIZE, ALLOCSET_DEFAULT_MINSIZE, CreateExprContextInternal(), and work_mem.

Referenced by ExecInitAgg().

◆ ExecAssignExprContext()

◆ ExecAssignProjectionInfo()

void ExecAssignProjectionInfo ( PlanState planstate,
TupleDesc  inputDesc 
)

Definition at line 538 of file execUtils.c.

540 {
541  planstate->ps_ProjInfo =
543  planstate->ps_ExprContext,
544  planstate->ps_ResultTupleSlot,
545  planstate,
546  inputDesc);
547 }
ProjectionInfo * ExecBuildProjectionInfo(List *targetList, ExprContext *econtext, TupleTableSlot *slot, PlanState *parent, TupleDesc inputDesc)
Definition: execExpr.c:354
Plan * plan
Definition: execnodes.h:1043
TupleTableSlot * ps_ResultTupleSlot
Definition: execnodes.h:1081
ProjectionInfo * ps_ProjInfo
Definition: execnodes.h:1083
List * targetlist
Definition: plannodes.h:152

References ExecBuildProjectionInfo(), PlanState::plan, PlanState::ps_ExprContext, PlanState::ps_ProjInfo, PlanState::ps_ResultTupleSlot, and Plan::targetlist.

Referenced by ExecConditionalAssignProjectionInfo(), ExecInitAgg(), ExecInitGroup(), ExecInitHashJoin(), ExecInitMergeJoin(), ExecInitNestLoop(), ExecInitResult(), and ExecInitWindowAgg().

◆ ExecAssignScanType()

void ExecAssignScanType ( ScanState scanstate,
TupleDesc  tupDesc 
)

Definition at line 647 of file execUtils.c.

648 {
649  TupleTableSlot *slot = scanstate->ss_ScanTupleSlot;
650 
651  ExecSetSlotDescriptor(slot, tupDesc);
652 }
void ExecSetSlotDescriptor(TupleTableSlot *slot, TupleDesc tupdesc)
Definition: execTuples.c:1288
TupleTableSlot * ss_ScanTupleSlot
Definition: execnodes.h:1486

References ExecSetSlotDescriptor(), and ScanState::ss_ScanTupleSlot.

Referenced by ExecWorkTableScan().

◆ ExecCleanTargetListLength()

int ExecCleanTargetListLength ( List targetlist)

Definition at line 1119 of file execUtils.c.

1120 {
1121  int len = 0;
1122  ListCell *tl;
1123 
1124  foreach(tl, targetlist)
1125  {
1126  TargetEntry *curTle = lfirst_node(TargetEntry, tl);
1127 
1128  if (!curTle->resjunk)
1129  len++;
1130  }
1131  return len;
1132 }
const void size_t len
#define lfirst_node(type, lc)
Definition: pg_list.h:176

References len, and lfirst_node.

Referenced by ApplyRetrieveRule(), check_sql_fn_retval(), and ExecTypeFromTLInternal().

◆ ExecConditionalAssignProjectionInfo()

void ExecConditionalAssignProjectionInfo ( PlanState planstate,
TupleDesc  inputDesc,
int  varno 
)

Definition at line 558 of file execUtils.c.

560 {
561  if (tlist_matches_tupdesc(planstate,
562  planstate->plan->targetlist,
563  varno,
564  inputDesc))
565  {
566  planstate->ps_ProjInfo = NULL;
567  planstate->resultopsset = planstate->scanopsset;
568  planstate->resultopsfixed = planstate->scanopsfixed;
569  planstate->resultops = planstate->scanops;
570  }
571  else
572  {
573  if (!planstate->ps_ResultTupleSlot)
574  {
575  ExecInitResultSlot(planstate, &TTSOpsVirtual);
576  planstate->resultops = &TTSOpsVirtual;
577  planstate->resultopsfixed = true;
578  planstate->resultopsset = true;
579  }
580  ExecAssignProjectionInfo(planstate, inputDesc);
581  }
582 }
const TupleTableSlotOps TTSOpsVirtual
Definition: execTuples.c:83
void ExecInitResultSlot(PlanState *planstate, const TupleTableSlotOps *tts_ops)
Definition: execTuples.c:1778
static bool tlist_matches_tupdesc(PlanState *ps, List *tlist, int varno, TupleDesc tupdesc)
Definition: execUtils.c:585
void ExecAssignProjectionInfo(PlanState *planstate, TupleDesc inputDesc)
Definition: execUtils.c:538
const TupleTableSlotOps * resultops
Definition: execnodes.h:1120
bool resultopsset
Definition: execnodes.h:1128
const TupleTableSlotOps * scanops
Definition: execnodes.h:1117
bool scanopsset
Definition: execnodes.h:1125
bool scanopsfixed
Definition: execnodes.h:1121
bool resultopsfixed
Definition: execnodes.h:1124

References ExecAssignProjectionInfo(), ExecInitResultSlot(), PlanState::plan, PlanState::ps_ProjInfo, PlanState::ps_ResultTupleSlot, PlanState::resultops, PlanState::resultopsfixed, PlanState::resultopsset, PlanState::scanops, PlanState::scanopsfixed, PlanState::scanopsset, Plan::targetlist, tlist_matches_tupdesc(), and TTSOpsVirtual.

Referenced by ExecAssignScanProjectionInfo(), ExecAssignScanProjectionInfoWithVarno(), ExecInitGather(), and ExecInitGatherMerge().

◆ ExecCreateScanSlotFromOuterPlan()

void ExecCreateScanSlotFromOuterPlan ( EState estate,
ScanState scanstate,
const TupleTableSlotOps tts_ops 
)

Definition at line 659 of file execUtils.c.

662 {
664  TupleDesc tupDesc;
665 
666  outerPlan = outerPlanState(scanstate);
667  tupDesc = ExecGetResultType(outerPlan);
668 
669  ExecInitScanTupleSlot(estate, scanstate, tupDesc, tts_ops);
670 }
void ExecInitScanTupleSlot(EState *estate, ScanState *scanstate, TupleDesc tupledesc, const TupleTableSlotOps *tts_ops)
Definition: execTuples.c:1810
TupleDesc ExecGetResultType(PlanState *planstate)
Definition: execUtils.c:493
#define outerPlanState(node)
Definition: execnodes.h:1139
#define outerPlan(node)
Definition: plannodes.h:182

References ExecGetResultType(), ExecInitScanTupleSlot(), outerPlan, and outerPlanState.

Referenced by ExecInitAgg(), ExecInitGroup(), ExecInitIncrementalSort(), ExecInitMaterial(), ExecInitMemoize(), ExecInitSort(), and ExecInitWindowAgg().

◆ ExecGetAllUpdatedCols()

Bitmapset* ExecGetAllUpdatedCols ( ResultRelInfo relinfo,
EState estate 
)

Definition at line 1324 of file execUtils.c.

1325 {
1326  Bitmapset *ret;
1327  MemoryContext oldcxt;
1328 
1330 
1331  ret = bms_union(ExecGetUpdatedCols(relinfo, estate),
1332  ExecGetExtraUpdatedCols(relinfo, estate));
1333 
1334  MemoryContextSwitchTo(oldcxt);
1335 
1336  return ret;
1337 }
Bitmapset * bms_union(const Bitmapset *a, const Bitmapset *b)
Definition: bitmapset.c:251
Bitmapset * ExecGetUpdatedCols(ResultRelInfo *relinfo, EState *estate)
Definition: execUtils.c:1288
Bitmapset * ExecGetExtraUpdatedCols(ResultRelInfo *relinfo, EState *estate)
Definition: execUtils.c:1309
#define GetPerTupleMemoryContext(estate)
Definition: executor.h:555

References bms_union(), ExecGetExtraUpdatedCols(), ExecGetUpdatedCols(), GetPerTupleMemoryContext, and MemoryContextSwitchTo().

Referenced by ExecARUpdateTriggers(), ExecASUpdateTriggers(), ExecBRUpdateTriggers(), ExecBSUpdateTriggers(), and ExecUpdateLockMode().

◆ ExecGetChildToRootMap()

TupleConversionMap* ExecGetChildToRootMap ( ResultRelInfo resultRelInfo)

Definition at line 1206 of file execUtils.c.

1207 {
1208  /* If we didn't already do so, compute the map for this child. */
1209  if (!resultRelInfo->ri_ChildToRootMapValid)
1210  {
1211  ResultRelInfo *rootRelInfo = resultRelInfo->ri_RootResultRelInfo;
1212 
1213  if (rootRelInfo)
1214  resultRelInfo->ri_ChildToRootMap =
1216  RelationGetDescr(rootRelInfo->ri_RelationDesc));
1217  else /* this isn't a child result rel */
1218  resultRelInfo->ri_ChildToRootMap = NULL;
1219 
1220  resultRelInfo->ri_ChildToRootMapValid = true;
1221  }
1222 
1223  return resultRelInfo->ri_ChildToRootMap;
1224 }
#define RelationGetDescr(relation)
Definition: rel.h:531
struct ResultRelInfo * ri_RootResultRelInfo
Definition: execnodes.h:580
Relation ri_RelationDesc
Definition: execnodes.h:456
TupleConversionMap * ri_ChildToRootMap
Definition: execnodes.h:560
bool ri_ChildToRootMapValid
Definition: execnodes.h:561
TupleConversionMap * convert_tuples_by_name(TupleDesc indesc, TupleDesc outdesc)
Definition: tupconvert.c:102

References convert_tuples_by_name(), RelationGetDescr, ResultRelInfo::ri_ChildToRootMap, ResultRelInfo::ri_ChildToRootMapValid, ResultRelInfo::ri_RelationDesc, and ResultRelInfo::ri_RootResultRelInfo.

Referenced by adjust_partition_colnos(), AfterTriggerExecute(), AfterTriggerSaveEvent(), ExecCrossPartitionUpdate(), and TransitionTableAddTuple().

◆ ExecGetExtraUpdatedCols()

Bitmapset* ExecGetExtraUpdatedCols ( ResultRelInfo relinfo,
EState estate 
)

Definition at line 1309 of file execUtils.c.

1310 {
1311  /* Compute the info if we didn't already */
1312  if (relinfo->ri_GeneratedExprsU == NULL)
1313  ExecInitStoredGenerated(relinfo, estate, CMD_UPDATE);
1314  return relinfo->ri_extraUpdatedCols;
1315 }
void ExecInitStoredGenerated(ResultRelInfo *resultRelInfo, EState *estate, CmdType cmdtype)
@ CMD_UPDATE
Definition: nodes.h:256
Bitmapset * ri_extraUpdatedCols
Definition: execnodes.h:474
ExprState ** ri_GeneratedExprsU
Definition: execnodes.h:529

References CMD_UPDATE, ExecInitStoredGenerated(), ResultRelInfo::ri_extraUpdatedCols, and ResultRelInfo::ri_GeneratedExprsU.

Referenced by ExecGetAllUpdatedCols(), and index_unchanged_by_update().

◆ ExecGetInsertedCols()

Bitmapset* ExecGetInsertedCols ( ResultRelInfo relinfo,
EState estate 
)

Definition at line 1267 of file execUtils.c.

1268 {
1269  RTEPermissionInfo *perminfo = GetResultRTEPermissionInfo(relinfo, estate);
1270 
1271  if (perminfo == NULL)
1272  return NULL;
1273 
1274  /* Map the columns to child's attribute numbers if needed. */
1275  if (relinfo->ri_RootResultRelInfo)
1276  {
1277  TupleConversionMap *map = ExecGetRootToChildMap(relinfo, estate);
1278 
1279  if (map)
1280  return execute_attr_map_cols(map->attrMap, perminfo->insertedCols);
1281  }
1282 
1283  return perminfo->insertedCols;
1284 }
static RTEPermissionInfo * GetResultRTEPermissionInfo(ResultRelInfo *relinfo, EState *estate)
Definition: execUtils.c:1344
TupleConversionMap * ExecGetRootToChildMap(ResultRelInfo *resultRelInfo, EState *estate)
Definition: execUtils.c:1232
Bitmapset * insertedCols
Definition: parsenodes.h:1253
AttrMap * attrMap
Definition: tupconvert.h:28
Bitmapset * execute_attr_map_cols(AttrMap *attrMap, Bitmapset *in_cols)
Definition: tupconvert.c:252

References TupleConversionMap::attrMap, ExecGetRootToChildMap(), execute_attr_map_cols(), GetResultRTEPermissionInfo(), RTEPermissionInfo::insertedCols, and ResultRelInfo::ri_RootResultRelInfo.

Referenced by ExecConstraints(), ExecPartitionCheckEmitError(), and ExecWithCheckOptions().

◆ ExecGetRangeTableRelation()

Relation ExecGetRangeTableRelation ( EState estate,
Index  rti 
)

Definition at line 762 of file execUtils.c.

763 {
764  Relation rel;
765 
766  Assert(rti > 0 && rti <= estate->es_range_table_size);
767 
768  rel = estate->es_relations[rti - 1];
769  if (rel == NULL)
770  {
771  /* First time through, so open the relation */
772  RangeTblEntry *rte = exec_rt_fetch(rti, estate);
773 
774  Assert(rte->rtekind == RTE_RELATION);
775 
776  if (!IsParallelWorker())
777  {
778  /*
779  * In a normal query, we should already have the appropriate lock,
780  * but verify that through an Assert. Since there's already an
781  * Assert inside table_open that insists on holding some lock, it
782  * seems sufficient to check this only when rellockmode is higher
783  * than the minimum.
784  */
785  rel = table_open(rte->relid, NoLock);
787  CheckRelationLockedByMe(rel, rte->rellockmode, false));
788  }
789  else
790  {
791  /*
792  * If we are a parallel worker, we need to obtain our own local
793  * lock on the relation. This ensures sane behavior in case the
794  * parent process exits before we do.
795  */
796  rel = table_open(rte->relid, rte->rellockmode);
797  }
798 
799  estate->es_relations[rti - 1] = rel;
800  }
801 
802  return rel;
803 }
static RangeTblEntry * exec_rt_fetch(Index rti, EState *estate)
Definition: executor.h:587
#define IsParallelWorker()
Definition: parallel.h:60
Assert(fmt[strlen(fmt) - 1] !='\n')
bool CheckRelationLockedByMe(Relation relation, LOCKMODE lockmode, bool orstronger)
Definition: lmgr.c:330
#define NoLock
Definition: lockdefs.h:34
#define AccessShareLock
Definition: lockdefs.h:36
@ RTE_RELATION
Definition: parsenodes.h:1011
RTEKind rtekind
Definition: parsenodes.h:1030
Relation table_open(Oid relationId, LOCKMODE lockmode)
Definition: table.c:40

References AccessShareLock, Assert(), CheckRelationLockedByMe(), EState::es_relations, exec_rt_fetch(), IsParallelWorker, NoLock, RangeTblEntry::relid, RangeTblEntry::rellockmode, RTE_RELATION, RangeTblEntry::rtekind, and table_open().

Referenced by CreatePartitionPruneState(), ExecInitResultRelation(), ExecOpenScanRelation(), and InitPlan().

◆ ExecGetResultRelCheckAsUser()

Oid ExecGetResultRelCheckAsUser ( ResultRelInfo relInfo,
EState estate 
)

Definition at line 1395 of file execUtils.c.

1396 {
1397  RTEPermissionInfo *perminfo = GetResultRTEPermissionInfo(relInfo, estate);
1398 
1399  /* XXX - maybe ok to return GetUserId() in this case? */
1400  if (perminfo == NULL)
1401  elog(ERROR, "no RTEPermissionInfo found for result relation with OID %u",
1402  RelationGetRelid(relInfo->ri_RelationDesc));
1403 
1404  return perminfo->checkAsUser ? perminfo->checkAsUser : GetUserId();
1405 }
#define ERROR
Definition: elog.h:39
#define elog(elevel,...)
Definition: elog.h:224
Oid GetUserId(void)
Definition: miscinit.c:514
#define RelationGetRelid(relation)
Definition: rel.h:505

References RTEPermissionInfo::checkAsUser, elog, ERROR, GetResultRTEPermissionInfo(), GetUserId(), RelationGetRelid, and ResultRelInfo::ri_RelationDesc.

Referenced by create_foreign_modify().

◆ ExecGetResultSlotOps()

const TupleTableSlotOps* ExecGetResultSlotOps ( PlanState planstate,
bool isfixed 
)

Definition at line 502 of file execUtils.c.

503 {
504  if (planstate->resultopsset && planstate->resultops)
505  {
506  if (isfixed)
507  *isfixed = planstate->resultopsfixed;
508  return planstate->resultops;
509  }
510 
511  if (isfixed)
512  {
513  if (planstate->resultopsset)
514  *isfixed = planstate->resultopsfixed;
515  else if (planstate->ps_ResultTupleSlot)
516  *isfixed = TTS_FIXED(planstate->ps_ResultTupleSlot);
517  else
518  *isfixed = false;
519  }
520 
521  if (!planstate->ps_ResultTupleSlot)
522  return &TTSOpsVirtual;
523 
524  return planstate->ps_ResultTupleSlot->tts_ops;
525 }
const TupleTableSlotOps *const tts_ops
Definition: tuptable.h:121
#define TTS_FIXED(slot)
Definition: tuptable.h:108

References PlanState::ps_ResultTupleSlot, PlanState::resultops, PlanState::resultopsfixed, PlanState::resultopsset, TTS_FIXED, TupleTableSlot::tts_ops, and TTSOpsVirtual.

Referenced by ExecComputeSlotInfo(), ExecInitAgg(), ExecInitGroup(), ExecInitHashJoin(), ExecInitLimit(), ExecInitLockRows(), ExecInitMergeJoin(), and ExecInitSubqueryScan().

◆ ExecGetResultType()

◆ ExecGetReturningSlot()

TupleTableSlot* ExecGetReturningSlot ( EState estate,
ResultRelInfo relInfo 
)

Definition at line 1182 of file execUtils.c.

1183 {
1184  if (relInfo->ri_ReturningSlot == NULL)
1185  {
1186  Relation rel = relInfo->ri_RelationDesc;
1187  MemoryContext oldcontext = MemoryContextSwitchTo(estate->es_query_cxt);
1188 
1189  relInfo->ri_ReturningSlot =
1190  ExecInitExtraTupleSlot(estate,
1191  RelationGetDescr(rel),
1192  table_slot_callbacks(rel));
1193 
1194  MemoryContextSwitchTo(oldcontext);
1195  }
1196 
1197  return relInfo->ri_ReturningSlot;
1198 }
TupleTableSlot * ExecInitExtraTupleSlot(EState *estate, TupleDesc tupledesc, const TupleTableSlotOps *tts_ops)
Definition: execTuples.c:1830
TupleTableSlot * ri_ReturningSlot
Definition: execnodes.h:498
const TupleTableSlotOps * table_slot_callbacks(Relation relation)
Definition: tableam.c:58

References EState::es_query_cxt, ExecInitExtraTupleSlot(), MemoryContextSwitchTo(), RelationGetDescr, ResultRelInfo::ri_RelationDesc, ResultRelInfo::ri_ReturningSlot, and table_slot_callbacks().

Referenced by apply_returning_filter(), ExecDelete(), and ExecInsert().

◆ ExecGetRootToChildMap()

TupleConversionMap* ExecGetRootToChildMap ( ResultRelInfo resultRelInfo,
EState estate 
)

Definition at line 1232 of file execUtils.c.

1233 {
1234  /* Mustn't get called for a non-child result relation. */
1235  Assert(resultRelInfo->ri_RootResultRelInfo);
1236 
1237  /* If we didn't already do so, compute the map for this child. */
1238  if (!resultRelInfo->ri_RootToChildMapValid)
1239  {
1240  ResultRelInfo *rootRelInfo = resultRelInfo->ri_RootResultRelInfo;
1241  TupleDesc indesc = RelationGetDescr(rootRelInfo->ri_RelationDesc);
1242  TupleDesc outdesc = RelationGetDescr(resultRelInfo->ri_RelationDesc);
1243  Relation childrel = resultRelInfo->ri_RelationDesc;
1244  AttrMap *attrMap;
1245  MemoryContext oldcontext;
1246 
1247  /*
1248  * When this child table is not a partition (!relispartition), it may
1249  * have columns that are not present in the root table, which we ask
1250  * to ignore by passing true for missing_ok.
1251  */
1252  oldcontext = MemoryContextSwitchTo(estate->es_query_cxt);
1253  attrMap = build_attrmap_by_name_if_req(indesc, outdesc,
1254  !childrel->rd_rel->relispartition);
1255  if (attrMap)
1256  resultRelInfo->ri_RootToChildMap =
1257  convert_tuples_by_name_attrmap(indesc, outdesc, attrMap);
1258  MemoryContextSwitchTo(oldcontext);
1259  resultRelInfo->ri_RootToChildMapValid = true;
1260  }
1261 
1262  return resultRelInfo->ri_RootToChildMap;
1263 }
AttrMap * build_attrmap_by_name_if_req(TupleDesc indesc, TupleDesc outdesc, bool missing_ok)
Definition: attmap.c:263
Definition: attmap.h:35
Form_pg_class rd_rel
Definition: rel.h:111
TupleConversionMap * ri_RootToChildMap
Definition: execnodes.h:566
bool ri_RootToChildMapValid
Definition: execnodes.h:567
TupleConversionMap * convert_tuples_by_name_attrmap(TupleDesc indesc, TupleDesc outdesc, AttrMap *attrMap)
Definition: tupconvert.c:124

References Assert(), build_attrmap_by_name_if_req(), convert_tuples_by_name_attrmap(), EState::es_query_cxt, MemoryContextSwitchTo(), RelationData::rd_rel, RelationGetDescr, ResultRelInfo::ri_RelationDesc, ResultRelInfo::ri_RootResultRelInfo, ResultRelInfo::ri_RootToChildMap, and ResultRelInfo::ri_RootToChildMapValid.

Referenced by apply_handle_tuple_routing(), CopyFrom(), ExecFindPartition(), ExecGetInsertedCols(), ExecGetUpdatedCols(), ExecInitPartitionInfo(), ExecInitRoutingInfo(), and ExecPrepareTupleRouting().

◆ ExecGetTriggerNewSlot()

TupleTableSlot* ExecGetTriggerNewSlot ( EState estate,
ResultRelInfo relInfo 
)

Definition at line 1160 of file execUtils.c.

1161 {
1162  if (relInfo->ri_TrigNewSlot == NULL)
1163  {
1164  Relation rel = relInfo->ri_RelationDesc;
1165  MemoryContext oldcontext = MemoryContextSwitchTo(estate->es_query_cxt);
1166 
1167  relInfo->ri_TrigNewSlot =
1168  ExecInitExtraTupleSlot(estate,
1169  RelationGetDescr(rel),
1170  table_slot_callbacks(rel));
1171 
1172  MemoryContextSwitchTo(oldcontext);
1173  }
1174 
1175  return relInfo->ri_TrigNewSlot;
1176 }
TupleTableSlot * ri_TrigNewSlot
Definition: execnodes.h:500

References EState::es_query_cxt, ExecInitExtraTupleSlot(), MemoryContextSwitchTo(), RelationGetDescr, ResultRelInfo::ri_RelationDesc, ResultRelInfo::ri_TrigNewSlot, and table_slot_callbacks().

Referenced by AfterTriggerExecute(), and AfterTriggerSaveEvent().

◆ ExecGetTriggerOldSlot()

TupleTableSlot* ExecGetTriggerOldSlot ( EState estate,
ResultRelInfo relInfo 
)

◆ ExecGetUpdatedCols()

Bitmapset* ExecGetUpdatedCols ( ResultRelInfo relinfo,
EState estate 
)

Definition at line 1288 of file execUtils.c.

1289 {
1290  RTEPermissionInfo *perminfo = GetResultRTEPermissionInfo(relinfo, estate);
1291 
1292  if (perminfo == NULL)
1293  return NULL;
1294 
1295  /* Map the columns to child's attribute numbers if needed. */
1296  if (relinfo->ri_RootResultRelInfo)
1297  {
1298  TupleConversionMap *map = ExecGetRootToChildMap(relinfo, estate);
1299 
1300  if (map)
1301  return execute_attr_map_cols(map->attrMap, perminfo->updatedCols);
1302  }
1303 
1304  return perminfo->updatedCols;
1305 }
Bitmapset * updatedCols
Definition: parsenodes.h:1254

References TupleConversionMap::attrMap, ExecGetRootToChildMap(), execute_attr_map_cols(), GetResultRTEPermissionInfo(), ResultRelInfo::ri_RootResultRelInfo, and RTEPermissionInfo::updatedCols.

Referenced by ExecConstraints(), ExecGetAllUpdatedCols(), ExecInitStoredGenerated(), ExecPartitionCheckEmitError(), ExecWithCheckOptions(), and index_unchanged_by_update().

◆ ExecInitRangeTable()

void ExecInitRangeTable ( EState estate,
List rangeTable,
List permInfos 
)

Definition at line 728 of file execUtils.c.

729 {
730  /* Remember the range table List as-is */
731  estate->es_range_table = rangeTable;
732 
733  /* ... and the RTEPermissionInfo List too */
734  estate->es_rteperminfos = permInfos;
735 
736  /* Set size of associated arrays */
737  estate->es_range_table_size = list_length(rangeTable);
738 
739  /*
740  * Allocate an array to store an open Relation corresponding to each
741  * rangetable entry, and initialize entries to NULL. Relations are opened
742  * and stored here as needed.
743  */
744  estate->es_relations = (Relation *)
745  palloc0(estate->es_range_table_size * sizeof(Relation));
746 
747  /*
748  * es_result_relations and es_rowmarks are also parallel to
749  * es_range_table, but are allocated only if needed.
750  */
751  estate->es_result_relations = NULL;
752  estate->es_rowmarks = NULL;
753 }
void * palloc0(Size size)
Definition: mcxt.c:1334
static int list_length(const List *l)
Definition: pg_list.h:152

References EState::es_range_table, EState::es_range_table_size, EState::es_relations, EState::es_result_relations, EState::es_rowmarks, EState::es_rteperminfos, list_length(), and palloc0().

Referenced by CopyFrom(), create_edata_for_relation(), create_estate_for_relation(), and InitPlan().

◆ ExecInitResultRelation()

void ExecInitResultRelation ( EState estate,
ResultRelInfo resultRelInfo,
Index  rti 
)

Definition at line 814 of file execUtils.c.

816 {
817  Relation resultRelationDesc;
818 
819  resultRelationDesc = ExecGetRangeTableRelation(estate, rti);
820  InitResultRelInfo(resultRelInfo,
821  resultRelationDesc,
822  rti,
823  NULL,
824  estate->es_instrument);
825 
826  if (estate->es_result_relations == NULL)
827  estate->es_result_relations = (ResultRelInfo **)
828  palloc0(estate->es_range_table_size * sizeof(ResultRelInfo *));
829  estate->es_result_relations[rti - 1] = resultRelInfo;
830 
831  /*
832  * Saving in the list allows to avoid needlessly traversing the whole
833  * array when only a few of its entries are possibly non-NULL.
834  */
836  lappend(estate->es_opened_result_relations, resultRelInfo);
837 }
void InitResultRelInfo(ResultRelInfo *resultRelInfo, Relation resultRelationDesc, Index resultRelationIndex, ResultRelInfo *partition_root_rri, int instrument_options)
Definition: execMain.c:1199
Relation ExecGetRangeTableRelation(EState *estate, Index rti)
Definition: execUtils.c:762
List * lappend(List *list, void *datum)
Definition: list.c:339

References EState::es_instrument, EState::es_opened_result_relations, EState::es_range_table_size, EState::es_result_relations, ExecGetRangeTableRelation(), InitResultRelInfo(), lappend(), and palloc0().

Referenced by CopyFrom(), and ExecInitModifyTable().

◆ ExecOpenScanRelation()

Relation ExecOpenScanRelation ( EState estate,
Index  scanrelid,
int  eflags 
)

Definition at line 697 of file execUtils.c.

698 {
699  Relation rel;
700 
701  /* Open the relation. */
702  rel = ExecGetRangeTableRelation(estate, scanrelid);
703 
704  /*
705  * Complain if we're attempting a scan of an unscannable relation, except
706  * when the query won't actually be run. This is a slightly klugy place
707  * to do this, perhaps, but there is no better place.
708  */
709  if ((eflags & (EXEC_FLAG_EXPLAIN_ONLY | EXEC_FLAG_WITH_NO_DATA)) == 0 &&
710  !RelationIsScannable(rel))
711  ereport(ERROR,
712  (errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
713  errmsg("materialized view \"%s\" has not been populated",
715  errhint("Use the REFRESH MATERIALIZED VIEW command.")));
716 
717  return rel;
718 }
int errhint(const char *fmt,...)
Definition: elog.c:1319
int errcode(int sqlerrcode)
Definition: elog.c:859
int errmsg(const char *fmt,...)
Definition: elog.c:1072
#define ereport(elevel,...)
Definition: elog.h:149
#define EXEC_FLAG_WITH_NO_DATA
Definition: executor.h:71
#define EXEC_FLAG_EXPLAIN_ONLY
Definition: executor.h:65
#define RelationIsScannable(relation)
Definition: rel.h:669
#define RelationGetRelationName(relation)
Definition: rel.h:539

References ereport, errcode(), errhint(), errmsg(), ERROR, EXEC_FLAG_EXPLAIN_ONLY, EXEC_FLAG_WITH_NO_DATA, ExecGetRangeTableRelation(), RelationGetRelationName, and RelationIsScannable.

Referenced by ExecInitBitmapHeapScan(), ExecInitCustomScan(), ExecInitForeignScan(), ExecInitIndexOnlyScan(), ExecInitIndexScan(), ExecInitSampleScan(), ExecInitSeqScan(), ExecInitTidRangeScan(), ExecInitTidScan(), and postgresBeginDirectModify().

◆ ExecRelationIsTargetRelation()

bool ExecRelationIsTargetRelation ( EState estate,
Index  scanrelid 
)

Definition at line 684 of file execUtils.c.

685 {
686  return list_member_int(estate->es_plannedstmt->resultRelations, scanrelid);
687 }
bool list_member_int(const List *list, int datum)
Definition: list.c:702
List * resultRelations
Definition: plannodes.h:78

References EState::es_plannedstmt, list_member_int(), and PlannedStmt::resultRelations.

◆ ExecTargetListLength()

int ExecTargetListLength ( List targetlist)

Definition at line 1109 of file execUtils.c.

1110 {
1111  /* This used to be more complex, but fjoins are dead */
1112  return list_length(targetlist);
1113 }

References list_length().

Referenced by ExecTypeFromTLInternal().

◆ executor_errposition()

int executor_errposition ( EState estate,
int  location 
)

Definition at line 870 of file execUtils.c.

871 {
872  int pos;
873 
874  /* No-op if location was not provided */
875  if (location < 0)
876  return 0;
877  /* Can't do anything if source text is not available */
878  if (estate == NULL || estate->es_sourceText == NULL)
879  return 0;
880  /* Convert offset to character number */
881  pos = pg_mbstrlen_with_len(estate->es_sourceText, location) + 1;
882  /* And pass it to the ereport mechanism */
883  return errposition(pos);
884 }
int errposition(int cursorpos)
Definition: elog.c:1448
int pg_mbstrlen_with_len(const char *mbstr, int limit)
Definition: mbutils.c:1057

References errposition(), EState::es_sourceText, and pg_mbstrlen_with_len().

Referenced by ExecInitFunc(), ExecInitSubscriptingRef(), and init_sexpr().

◆ FreeExecutorState()

void FreeExecutorState ( EState estate)

Definition at line 189 of file execUtils.c.

190 {
191  /*
192  * Shut down and free any remaining ExprContexts. We do this explicitly
193  * to ensure that any remaining shutdown callbacks get called (since they
194  * might need to release resources that aren't simply memory within the
195  * per-query memory context).
196  */
197  while (estate->es_exprcontexts)
198  {
199  /*
200  * XXX: seems there ought to be a faster way to implement this than
201  * repeated list_delete(), no?
202  */
204  true);
205  /* FreeExprContext removed the list link for us */
206  }
207 
208  /* release JIT context, if allocated */
209  if (estate->es_jit)
210  {
211  jit_release_context(estate->es_jit);
212  estate->es_jit = NULL;
213  }
214 
215  /* release partition directory, if allocated */
216  if (estate->es_partition_directory)
217  {
219  estate->es_partition_directory = NULL;
220  }
221 
222  /*
223  * Free the per-query memory context, thereby releasing all working
224  * memory, including the EState node itself.
225  */
227 }
void FreeExprContext(ExprContext *econtext, bool isCommit)
Definition: execUtils.c:414
void jit_release_context(JitContext *context)
Definition: jit.c:137
void MemoryContextDelete(MemoryContext context)
Definition: mcxt.c:442
void DestroyPartitionDirectory(PartitionDirectory pdir)
Definition: partdesc.c:442
#define linitial(l)
Definition: pg_list.h:178
PartitionDirectory es_partition_directory
Definition: execnodes.h:647

References DestroyPartitionDirectory(), EState::es_exprcontexts, EState::es_jit, EState::es_partition_directory, EState::es_query_cxt, FreeExprContext(), jit_release_context(), linitial, and MemoryContextDelete().

Referenced by afterTriggerInvokeEvents(), ATRewriteTable(), check_default_partition_contents(), compute_expr_stats(), compute_index_stats(), CopyFrom(), EvalPlanQualEnd(), evaluate_expr(), ExecuteCallStmt(), ExecuteQuery(), ExecuteTruncateGuts(), ExplainExecuteQuery(), finish_edata(), freestate_cluster(), get_qual_for_range(), heapam_index_build_range_scan(), heapam_index_validate_scan(), IndexCheckExclusion(), make_build_data(), operator_predicate_proof(), plpgsql_inline_handler(), plpgsql_xact_cb(), standard_ExecutorEnd(), StoreAttrDefault(), and validateDomainConstraint().

◆ FreeExprContext()

void FreeExprContext ( ExprContext econtext,
bool  isCommit 
)

Definition at line 414 of file execUtils.c.

415 {
416  EState *estate;
417 
418  /* Call any registered callbacks */
419  ShutdownExprContext(econtext, isCommit);
420  /* And clean up the memory used */
422  /* Unlink self from owning EState, if any */
423  estate = econtext->ecxt_estate;
424  if (estate)
426  econtext);
427  /* And delete the ExprContext node */
428  pfree(econtext);
429 }
static void ShutdownExprContext(ExprContext *econtext, bool isCommit)
Definition: execUtils.c:954
List * list_delete_ptr(List *list, void *datum)
Definition: list.c:872
void pfree(void *pointer)
Definition: mcxt.c:1508

References ExprContext::ecxt_estate, ExprContext::ecxt_per_tuple_memory, EState::es_exprcontexts, list_delete_ptr(), MemoryContextDelete(), pfree(), and ShutdownExprContext().

Referenced by FreeExecutorState(), plpgsql_destroy_econtext(), and plpgsql_subxact_cb().

◆ GetAttributeByName()

Datum GetAttributeByName ( HeapTupleHeader  tuple,
const char *  attname,
bool isNull 
)

Definition at line 995 of file execUtils.c.

996 {
997  AttrNumber attrno;
998  Datum result;
999  Oid tupType;
1000  int32 tupTypmod;
1001  TupleDesc tupDesc;
1002  HeapTupleData tmptup;
1003  int i;
1004 
1005  if (attname == NULL)
1006  elog(ERROR, "invalid attribute name");
1007 
1008  if (isNull == NULL)
1009  elog(ERROR, "a NULL isNull pointer was passed");
1010 
1011  if (tuple == NULL)
1012  {
1013  /* Kinda bogus but compatible with old behavior... */
1014  *isNull = true;
1015  return (Datum) 0;
1016  }
1017 
1018  tupType = HeapTupleHeaderGetTypeId(tuple);
1019  tupTypmod = HeapTupleHeaderGetTypMod(tuple);
1020  tupDesc = lookup_rowtype_tupdesc(tupType, tupTypmod);
1021 
1022  attrno = InvalidAttrNumber;
1023  for (i = 0; i < tupDesc->natts; i++)
1024  {
1025  Form_pg_attribute att = TupleDescAttr(tupDesc, i);
1026 
1027  if (namestrcmp(&(att->attname), attname) == 0)
1028  {
1029  attrno = att->attnum;
1030  break;
1031  }
1032  }
1033 
1034  if (attrno == InvalidAttrNumber)
1035  elog(ERROR, "attribute \"%s\" does not exist", attname);
1036 
1037  /*
1038  * heap_getattr needs a HeapTuple not a bare HeapTupleHeader. We set all
1039  * the fields in the struct just in case user tries to inspect system
1040  * columns.
1041  */
1042  tmptup.t_len = HeapTupleHeaderGetDatumLength(tuple);
1043  ItemPointerSetInvalid(&(tmptup.t_self));
1044  tmptup.t_tableOid = InvalidOid;
1045  tmptup.t_data = tuple;
1046 
1047  result = heap_getattr(&tmptup,
1048  attrno,
1049  tupDesc,
1050  isNull);
1051 
1052  ReleaseTupleDesc(tupDesc);
1053 
1054  return result;
1055 }
int16 AttrNumber
Definition: attnum.h:21
#define InvalidAttrNumber
Definition: attnum.h:23
signed int int32
Definition: c.h:481
static Datum heap_getattr(HeapTuple tup, int attnum, TupleDesc tupleDesc, bool *isnull)
Definition: htup_details.h:792
#define HeapTupleHeaderGetTypMod(tup)
Definition: htup_details.h:466
#define HeapTupleHeaderGetTypeId(tup)
Definition: htup_details.h:456
#define HeapTupleHeaderGetDatumLength(tup)
Definition: htup_details.h:450
int i
Definition: isn.c:73
static void ItemPointerSetInvalid(ItemPointerData *pointer)
Definition: itemptr.h:184
int namestrcmp(Name name, const char *str)
Definition: name.c:247
NameData attname
Definition: pg_attribute.h:41
FormData_pg_attribute * Form_pg_attribute
Definition: pg_attribute.h:209
#define InvalidOid
Definition: postgres_ext.h:36
unsigned int Oid
Definition: postgres_ext.h:31
ItemPointerData t_self
Definition: htup.h:65
uint32 t_len
Definition: htup.h:64
HeapTupleHeader t_data
Definition: htup.h:68
Oid t_tableOid
Definition: htup.h:66
#define ReleaseTupleDesc(tupdesc)
Definition: tupdesc.h:122
#define TupleDescAttr(tupdesc, i)
Definition: tupdesc.h:92
TupleDesc lookup_rowtype_tupdesc(Oid type_id, int32 typmod)
Definition: typcache.c:1833

References attname, elog, ERROR, heap_getattr(), HeapTupleHeaderGetDatumLength, HeapTupleHeaderGetTypeId, HeapTupleHeaderGetTypMod, i, InvalidAttrNumber, InvalidOid, ItemPointerSetInvalid(), lookup_rowtype_tupdesc(), namestrcmp(), TupleDescData::natts, ReleaseTupleDesc, HeapTupleData::t_data, HeapTupleData::t_len, HeapTupleData::t_self, HeapTupleData::t_tableOid, and TupleDescAttr.

Referenced by c_overpaid(), and overpaid().

◆ GetAttributeByNum()

Datum GetAttributeByNum ( HeapTupleHeader  tuple,
AttrNumber  attrno,
bool isNull 
)

Definition at line 1058 of file execUtils.c.

1061 {
1062  Datum result;
1063  Oid tupType;
1064  int32 tupTypmod;
1065  TupleDesc tupDesc;
1066  HeapTupleData tmptup;
1067 
1068  if (!AttributeNumberIsValid(attrno))
1069  elog(ERROR, "invalid attribute number %d", attrno);
1070 
1071  if (isNull == NULL)
1072  elog(ERROR, "a NULL isNull pointer was passed");
1073 
1074  if (tuple == NULL)
1075  {
1076  /* Kinda bogus but compatible with old behavior... */
1077  *isNull = true;
1078  return (Datum) 0;
1079  }
1080 
1081  tupType = HeapTupleHeaderGetTypeId(tuple);
1082  tupTypmod = HeapTupleHeaderGetTypMod(tuple);
1083  tupDesc = lookup_rowtype_tupdesc(tupType, tupTypmod);
1084 
1085  /*
1086  * heap_getattr needs a HeapTuple not a bare HeapTupleHeader. We set all
1087  * the fields in the struct just in case user tries to inspect system
1088  * columns.
1089  */
1090  tmptup.t_len = HeapTupleHeaderGetDatumLength(tuple);
1091  ItemPointerSetInvalid(&(tmptup.t_self));
1092  tmptup.t_tableOid = InvalidOid;
1093  tmptup.t_data = tuple;
1094 
1095  result = heap_getattr(&tmptup,
1096  attrno,
1097  tupDesc,
1098  isNull);
1099 
1100  ReleaseTupleDesc(tupDesc);
1101 
1102  return result;
1103 }
#define AttributeNumberIsValid(attributeNumber)
Definition: attnum.h:34

References AttributeNumberIsValid, elog, ERROR, heap_getattr(), HeapTupleHeaderGetDatumLength, HeapTupleHeaderGetTypeId, HeapTupleHeaderGetTypMod, InvalidOid, ItemPointerSetInvalid(), lookup_rowtype_tupdesc(), ReleaseTupleDesc, HeapTupleData::t_data, HeapTupleData::t_len, HeapTupleData::t_self, and HeapTupleData::t_tableOid.

◆ GetResultRTEPermissionInfo()

static RTEPermissionInfo * GetResultRTEPermissionInfo ( ResultRelInfo relinfo,
EState estate 
)
static

Definition at line 1344 of file execUtils.c.

1345 {
1346  Index rti;
1347  RangeTblEntry *rte;
1348  RTEPermissionInfo *perminfo = NULL;
1349 
1350  if (relinfo->ri_RootResultRelInfo)
1351  {
1352  /*
1353  * For inheritance child result relations (a partition routing target
1354  * of an INSERT or a child UPDATE target), this returns the root
1355  * parent's RTE to fetch the RTEPermissionInfo because that's the only
1356  * one that has one assigned.
1357  */
1358  rti = relinfo->ri_RootResultRelInfo->ri_RangeTableIndex;
1359  }
1360  else if (relinfo->ri_RangeTableIndex != 0)
1361  {
1362  /*
1363  * Non-child result relation should have their own RTEPermissionInfo.
1364  */
1365  rti = relinfo->ri_RangeTableIndex;
1366  }
1367  else
1368  {
1369  /*
1370  * The relation isn't in the range table and it isn't a partition
1371  * routing target. This ResultRelInfo must've been created only for
1372  * firing triggers and the relation is not being inserted into. (See
1373  * ExecGetTriggerResultRel.)
1374  */
1375  rti = 0;
1376  }
1377 
1378  if (rti > 0)
1379  {
1380  rte = exec_rt_fetch(rti, estate);
1381  perminfo = getRTEPermissionInfo(estate->es_rteperminfos, rte);
1382  }
1383 
1384  return perminfo;
1385 }
unsigned int Index
Definition: c.h:601
RTEPermissionInfo * getRTEPermissionInfo(List *rteperminfos, RangeTblEntry *rte)
Index ri_RangeTableIndex
Definition: execnodes.h:453

References EState::es_rteperminfos, exec_rt_fetch(), getRTEPermissionInfo(), ResultRelInfo::ri_RangeTableIndex, and ResultRelInfo::ri_RootResultRelInfo.

Referenced by ExecGetInsertedCols(), ExecGetResultRelCheckAsUser(), and ExecGetUpdatedCols().

◆ MakePerTupleExprContext()

ExprContext* MakePerTupleExprContext ( EState estate)

Definition at line 456 of file execUtils.c.

457 {
458  if (estate->es_per_tuple_exprcontext == NULL)
460 
461  return estate->es_per_tuple_exprcontext;
462 }

References CreateExprContext(), and EState::es_per_tuple_exprcontext.

◆ RegisterExprContextCallback()

void RegisterExprContextCallback ( ExprContext econtext,
ExprContextCallbackFunction  function,
Datum  arg 
)

Definition at line 897 of file execUtils.c.

900 {
901  ExprContext_CB *ecxt_callback;
902 
903  /* Save the info in appropriate memory context */
904  ecxt_callback = (ExprContext_CB *)
906  sizeof(ExprContext_CB));
907 
908  ecxt_callback->function = function;
909  ecxt_callback->arg = arg;
910 
911  /* link to front of list for appropriate execution order */
912  ecxt_callback->next = econtext->ecxt_callbacks;
913  econtext->ecxt_callbacks = ecxt_callback;
914 }
void * MemoryContextAlloc(MemoryContext context, Size size)
Definition: mcxt.c:1168
void * arg
struct ExprContext_CB * next
Definition: execnodes.h:221
ExprContextCallbackFunction function
Definition: execnodes.h:222

References arg, ExprContext_CB::arg, ExprContext::ecxt_callbacks, ExprContext::ecxt_per_query_memory, ExprContext_CB::function, MemoryContextAlloc(), and ExprContext_CB::next.

Referenced by AggRegisterCallback(), ExecMakeFunctionResultSet(), ExecPrepareTuplestoreResult(), fmgr_sql(), and init_MultiFuncCall().

◆ ReScanExprContext()

void ReScanExprContext ( ExprContext econtext)

Definition at line 441 of file execUtils.c.

442 {
443  /* Call any registered callbacks */
444  ShutdownExprContext(econtext, true);
445  /* And clean up the memory used */
447 }
void MemoryContextReset(MemoryContext context)
Definition: mcxt.c:371

References ExprContext::ecxt_per_tuple_memory, MemoryContextReset(), and ShutdownExprContext().

Referenced by agg_refill_hash_table(), agg_retrieve_direct(), domain_check_input(), ExecEndAgg(), ExecReScan(), ExecReScanAgg(), and ValuesNext().

◆ ShutdownExprContext()

static void ShutdownExprContext ( ExprContext econtext,
bool  isCommit 
)
static

Definition at line 954 of file execUtils.c.

955 {
956  ExprContext_CB *ecxt_callback;
957  MemoryContext oldcontext;
958 
959  /* Fast path in normal case where there's nothing to do. */
960  if (econtext->ecxt_callbacks == NULL)
961  return;
962 
963  /*
964  * Call the callbacks in econtext's per-tuple context. This ensures that
965  * any memory they might leak will get cleaned up.
966  */
967  oldcontext = MemoryContextSwitchTo(econtext->ecxt_per_tuple_memory);
968 
969  /*
970  * Call each callback function in reverse registration order.
971  */
972  while ((ecxt_callback = econtext->ecxt_callbacks) != NULL)
973  {
974  econtext->ecxt_callbacks = ecxt_callback->next;
975  if (isCommit)
976  ecxt_callback->function(ecxt_callback->arg);
977  pfree(ecxt_callback);
978  }
979 
980  MemoryContextSwitchTo(oldcontext);
981 }

References ExprContext_CB::arg, ExprContext::ecxt_callbacks, ExprContext::ecxt_per_tuple_memory, ExprContext_CB::function, MemoryContextSwitchTo(), ExprContext_CB::next, and pfree().

Referenced by FreeExprContext(), and ReScanExprContext().

◆ tlist_matches_tupdesc()

static bool tlist_matches_tupdesc ( PlanState ps,
List tlist,
int  varno,
TupleDesc  tupdesc 
)
static

Definition at line 585 of file execUtils.c.

586 {
587  int numattrs = tupdesc->natts;
588  int attrno;
589  ListCell *tlist_item = list_head(tlist);
590 
591  /* Check the tlist attributes */
592  for (attrno = 1; attrno <= numattrs; attrno++)
593  {
594  Form_pg_attribute att_tup = TupleDescAttr(tupdesc, attrno - 1);
595  Var *var;
596 
597  if (tlist_item == NULL)
598  return false; /* tlist too short */
599  var = (Var *) ((TargetEntry *) lfirst(tlist_item))->expr;
600  if (!var || !IsA(var, Var))
601  return false; /* tlist item not a Var */
602  /* if these Asserts fail, planner messed up */
603  Assert(var->varno == varno);
604  Assert(var->varlevelsup == 0);
605  if (var->varattno != attrno)
606  return false; /* out of order */
607  if (att_tup->attisdropped)
608  return false; /* table contains dropped columns */
609  if (att_tup->atthasmissing)
610  return false; /* table contains cols with missing values */
611 
612  /*
613  * Note: usually the Var's type should match the tupdesc exactly, but
614  * in situations involving unions of columns that have different
615  * typmods, the Var may have come from above the union and hence have
616  * typmod -1. This is a legitimate situation since the Var still
617  * describes the column, just not as exactly as the tupdesc does. We
618  * could change the planner to prevent it, but it'd then insert
619  * projection steps just to convert from specific typmod to typmod -1,
620  * which is pretty silly.
621  */
622  if (var->vartype != att_tup->atttypid ||
623  (var->vartypmod != att_tup->atttypmod &&
624  var->vartypmod != -1))
625  return false; /* type mismatch */
626 
627  tlist_item = lnext(tlist, tlist_item);
628  }
629 
630  if (tlist_item)
631  return false; /* tlist too long */
632 
633  return true;
634 }
#define IsA(nodeptr, _type_)
Definition: nodes.h:158
#define lfirst(lc)
Definition: pg_list.h:172
static ListCell * list_head(const List *l)
Definition: pg_list.h:128
static ListCell * lnext(const List *l, const ListCell *c)
Definition: pg_list.h:343
Definition: primnodes.h:234
AttrNumber varattno
Definition: primnodes.h:246
int varno
Definition: primnodes.h:241
Index varlevelsup
Definition: primnodes.h:266

References Assert(), IsA, lfirst, list_head(), lnext(), TupleDescData::natts, TupleDescAttr, Var::varattno, Var::varlevelsup, and Var::varno.

Referenced by ExecConditionalAssignProjectionInfo().

◆ UnregisterExprContextCallback()

void UnregisterExprContextCallback ( ExprContext econtext,
ExprContextCallbackFunction  function,
Datum  arg 
)

Definition at line 923 of file execUtils.c.

926 {
927  ExprContext_CB **prev_callback;
928  ExprContext_CB *ecxt_callback;
929 
930  prev_callback = &econtext->ecxt_callbacks;
931 
932  while ((ecxt_callback = *prev_callback) != NULL)
933  {
934  if (ecxt_callback->function == function && ecxt_callback->arg == arg)
935  {
936  *prev_callback = ecxt_callback->next;
937  pfree(ecxt_callback);
938  }
939  else
940  prev_callback = &ecxt_callback->next;
941  }
942 }

References arg, ExprContext_CB::arg, ExprContext::ecxt_callbacks, ExprContext_CB::function, ExprContext_CB::next, and pfree().

Referenced by end_MultiFuncCall(), and fmgr_sql().

◆ UpdateChangedParamSet()

void UpdateChangedParamSet ( PlanState node,
Bitmapset newchg 
)

Definition at line 844 of file execUtils.c.

845 {
846  Bitmapset *parmset;
847 
848  /*
849  * The plan node only depends on params listed in its allParam set. Don't
850  * include anything else into its chgParam set.
851  */
852  parmset = bms_intersect(node->plan->allParam, newchg);
853  node->chgParam = bms_join(node->chgParam, parmset);
854 }
Bitmapset * bms_join(Bitmapset *a, Bitmapset *b)
Definition: bitmapset.c:1230
Bitmapset * bms_intersect(const Bitmapset *a, const Bitmapset *b)
Definition: bitmapset.c:292
Bitmapset * chgParam
Definition: execnodes.h:1075
Bitmapset * allParam
Definition: plannodes.h:171

References Plan::allParam, bms_intersect(), bms_join(), PlanState::chgParam, and PlanState::plan.

Referenced by ExecReScan(), ExecReScanAppend(), ExecReScanBitmapAnd(), ExecReScanBitmapOr(), ExecReScanMergeAppend(), and ExecReScanSubqueryScan().