86 bool use_parallel_mode,
142 (*ExecutorStart_hook) (queryDesc, eflags);
154 Assert(queryDesc != NULL);
180 queryDesc->
estate = estate;
241 elog(
ERROR,
"unrecognized operation code: %d",
305 (*ExecutorRun_hook) (queryDesc, direction, count, execute_once);
321 Assert(queryDesc != NULL);
323 estate = queryDesc->
estate;
360 elog(
ERROR,
"can't re-execute query flagged for single execution");
404 (*ExecutorFinish_hook) (queryDesc);
416 Assert(queryDesc != NULL);
418 estate = queryDesc->
estate;
464 (*ExecutorEnd_hook) (queryDesc);
476 Assert(queryDesc != NULL);
478 estate = queryDesc->
estate;
533 Assert(queryDesc != NULL);
535 estate = queryDesc->
estate;
575 foreach(l, rangeTable)
583 if (ereport_on_violation)
591 result = (*ExecutorCheckPerms_hook) (rangeTable,
592 ereport_on_violation);
621 if (requiredPerms == 0)
642 remainingPerms = requiredPerms & ~relPerms;
643 if (remainingPerms != 0)
746 elog(
ERROR,
"whole-row update is not implemented");
776 foreach(l, plannedstmt->
rtable)
925 subplanstate =
ExecInitNode(subplan, estate, sp_eflags);
951 bool junk_filter_needed =
false;
960 junk_filter_needed =
true;
965 if (junk_filter_needed)
976 tupType =
j->jf_cleanTupType;
1000 switch (resultRel->
rd_rel->relkind)
1002 case RELKIND_RELATION:
1003 case RELKIND_PARTITIONED_TABLE:
1006 case RELKIND_SEQUENCE:
1008 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
1009 errmsg(
"cannot change sequence \"%s\"",
1012 case RELKIND_TOASTVALUE:
1014 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
1015 errmsg(
"cannot change TOAST relation \"%s\"",
1032 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
1033 errmsg(
"cannot insert into view \"%s\"",
1035 errhint(
"To enable inserting into the view, provide an INSTEAD OF INSERT trigger or an unconditional ON INSERT DO INSTEAD rule.")));
1040 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
1041 errmsg(
"cannot update view \"%s\"",
1043 errhint(
"To enable updating the view, provide an INSTEAD OF UPDATE trigger or an unconditional ON UPDATE DO INSTEAD rule.")));
1048 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
1049 errmsg(
"cannot delete from view \"%s\"",
1051 errhint(
"To enable deleting from the view, provide an INSTEAD OF DELETE trigger or an unconditional ON DELETE DO INSTEAD rule.")));
1054 elog(
ERROR,
"unrecognized CmdType: %d", (
int) operation);
1058 case RELKIND_MATVIEW:
1061 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
1062 errmsg(
"cannot change materialized view \"%s\"",
1065 case RELKIND_FOREIGN_TABLE:
1073 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1074 errmsg(
"cannot insert into foreign table \"%s\"",
1079 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
1080 errmsg(
"foreign table \"%s\" does not allow inserts",
1086 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1087 errmsg(
"cannot update foreign table \"%s\"",
1092 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
1093 errmsg(
"foreign table \"%s\" does not allow updates",
1099 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1100 errmsg(
"cannot delete from foreign table \"%s\"",
1105 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
1106 errmsg(
"foreign table \"%s\" does not allow deletes",
1110 elog(
ERROR,
"unrecognized CmdType: %d", (
int) operation);
1116 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
1117 errmsg(
"cannot change relation \"%s\"",
1134 switch (rel->
rd_rel->relkind)
1136 case RELKIND_RELATION:
1137 case RELKIND_PARTITIONED_TABLE:
1140 case RELKIND_SEQUENCE:
1143 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
1144 errmsg(
"cannot lock rows in sequence \"%s\"",
1147 case RELKIND_TOASTVALUE:
1150 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
1151 errmsg(
"cannot lock rows in TOAST relation \"%s\"",
1157 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
1158 errmsg(
"cannot lock rows in view \"%s\"",
1161 case RELKIND_MATVIEW:
1165 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
1166 errmsg(
"cannot lock rows in materialized view \"%s\"",
1169 case RELKIND_FOREIGN_TABLE:
1174 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1175 errmsg(
"cannot lock rows in foreign table \"%s\"",
1180 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
1181 errmsg(
"cannot lock rows in relation \"%s\"",
1197 Index resultRelationIndex,
1199 int instrument_options)
1218 if (instrument_options)
1227 if (resultRelationDesc->
rd_rel->relkind == RELKIND_FOREIGN_TABLE)
1368 if (!partRel->
rd_rel->relispartition)
1369 elog(
ERROR,
"cannot find ancestors of a non-partition result relation");
1370 Assert(rootRelInfo != NULL);
1390 if (ancOid == rootRelOid)
1403 ancResultRels =
lappend(ancResultRels, rInfo);
1405 ancResultRels =
lappend(ancResultRels, rootRelInfo);
1593 bool use_parallel_mode,
1596 uint64 numberTuples,
1602 uint64 current_tuple_count;
1607 current_tuple_count = 0;
1619 use_parallel_mode =
false;
1622 if (use_parallel_mode)
1667 if (!
dest->receiveSlot(slot,
dest))
1684 current_tuple_count++;
1685 if (numberTuples && numberTuples == current_tuple_count)
1696 if (use_parallel_mode)
1722 if (ncheck != rel->
rd_rel->relchecks)
1723 elog(
ERROR,
"%d pg_constraint record(s) missing for relation \"%s\"",
1736 for (
i = 0;
i < ncheck;
i++)
1757 for (
i = 0;
i < ncheck;
i++)
1783 EState *estate,
bool emitError)
1887 (
errcode(ERRCODE_CHECK_VIOLATION),
1888 errmsg(
"new row for relation \"%s\" violates partition constraint",
1890 val_desc ?
errdetail(
"Failing row contains %s.", val_desc) : 0,
1918 int natts = tupdesc->
natts;
1921 for (attrChk = 1; attrChk <= natts; attrChk++)
1969 (
errcode(ERRCODE_NOT_NULL_VIOLATION),
1970 errmsg(
"null value in column \"%s\" of relation \"%s\" violates not-null constraint",
1973 val_desc ?
errdetail(
"Failing row contains %s.", val_desc) : 0,
1979 if (rel->
rd_rel->relchecks > 0)
1983 if ((failed =
ExecRelCheck(resultRelInfo, slot, estate)) != NULL)
2020 (
errcode(ERRCODE_CHECK_VIOLATION),
2021 errmsg(
"new row for relation \"%s\" violates check constraint \"%s\"",
2023 val_desc ?
errdetail(
"Failing row contains %s.", val_desc) : 0,
2068 if (wco->
kind != kind)
2129 (
errcode(ERRCODE_WITH_CHECK_OPTION_VIOLATION),
2130 errmsg(
"new row violates check option for view \"%s\"",
2132 val_desc ?
errdetail(
"Failing row contains %s.",
2139 (
errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
2140 errmsg(
"new row violates row-level security policy \"%s\" for table \"%s\"",
2144 (
errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
2145 errmsg(
"new row violates row-level security policy for table \"%s\"",
2152 (
errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
2153 errmsg(
"target row violates row-level security policy \"%s\" (USING expression) for table \"%s\"",
2157 (
errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
2158 errmsg(
"target row violates row-level security policy (USING expression) for table \"%s\"",
2164 (
errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
2165 errmsg(
"new row violates row-level security policy \"%s\" (USING expression) for table \"%s\"",
2169 (
errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
2170 errmsg(
"new row violates row-level security policy (USING expression) for table \"%s\"",
2209 bool write_comma =
false;
2210 bool write_comma_collist =
false;
2213 bool table_perm =
false;
2214 bool any_perm =
false;
2243 table_perm = any_perm =
true;
2248 for (
i = 0;
i < tupdesc->
natts;
i++)
2250 bool column_perm =
false;
2256 if (att->attisdropped)
2272 column_perm = any_perm =
true;
2274 if (write_comma_collist)
2277 write_comma_collist =
true;
2283 if (table_perm || column_perm)
2293 &foutoid, &typisvarlena);
2303 vallen = strlen(
val);
2304 if (vallen <= maxfieldlen)
2326 return collist.
data;
2366 if (rti > 0 && rti <= estate->es_range_table_size &&
2375 elog(
ERROR,
"failed to find ExecRowMark for rangetable index %u", rti);
2402 elog(
ERROR,
"could not find junk %s column", resname);
2411 elog(
ERROR,
"could not find junk %s column", resname);
2421 elog(
ERROR,
"could not find junk %s column", resname);
2475 if (testslot != inputslot)
2512 Plan *subplan,
List *auxrowmarks,
int epqParam)
2532 epqstate->
plan = subplan;
2555 epqstate->
plan = subplan;
2573 Assert(rti > 0 && rti <= epqstate->parentestate->es_range_table_size);
2606 elog(
ERROR,
"EvalPlanQual doesn't support locking rowmarks");
2623 if (tableoid != erm->
relid)
2646 bool updated =
false;
2652 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
2653 errmsg(
"cannot lock rows in foreign table \"%s\"",
2662 elog(
ERROR,
"failed to fetch tuple for EvalPlanQual recheck");
2677 elog(
ERROR,
"failed to fetch tuple for EvalPlanQual recheck");
2725 if (recheckestate == NULL)
2908 palloc0(rtsize *
sizeof(
bool));
AclResult pg_attribute_aclcheck_all(Oid table_oid, Oid roleid, AclMode mode, AclMaskHow how)
void aclcheck_error(AclResult aclerr, ObjectType objtype, const char *objectname)
AclResult pg_attribute_aclcheck(Oid table_oid, AttrNumber attnum, Oid roleid, AclMode mode)
AclMode pg_class_aclmask(Oid table_oid, Oid roleid, AclMode mask, AclMaskHow how)
AclResult pg_class_aclcheck(Oid table_oid, Oid roleid, AclMode mode)
AttrMap * build_attrmap_by_name_if_req(TupleDesc indesc, TupleDesc outdesc)
#define AttributeNumberIsValid(attributeNumber)
#define InvalidAttrNumber
void pgstat_report_query_id(uint64 query_id, bool force)
int bms_next_member(const Bitmapset *a, int prevbit)
bool bms_is_member(int x, const Bitmapset *a)
Bitmapset * bms_add_member(Bitmapset *a, int x)
Bitmapset * bms_union(const Bitmapset *a, const Bitmapset *b)
bool bms_is_empty(const Bitmapset *a)
bool bms_overlap(const Bitmapset *a, const Bitmapset *b)
#define MemSet(start, val, len)
#define OidIsValid(objectId)
int errdetail(const char *fmt,...)
int errhint(const char *fmt,...)
int errcode(int sqlerrcode)
int errmsg(const char *fmt,...)
#define ereport(elevel,...)
void ExecReScan(PlanState *node)
ExprState * ExecPrepareExpr(Expr *node, EState *estate)
bool ExecCheck(ExprState *state, ExprContext *econtext)
ExprState * ExecPrepareCheck(List *qual, EState *estate)
void ExecCloseIndices(ResultRelInfo *resultRelInfo)
JunkFilter * ExecInitJunkFilter(List *targetList, TupleTableSlot *slot)
AttrNumber ExecFindJunkAttributeInTlist(List *targetlist, const char *attrName)
TupleTableSlot * ExecFilterJunk(JunkFilter *junkfilter, TupleTableSlot *slot)
static bool ExecCheckRTEPermsModified(Oid relOid, Oid userid, Bitmapset *modifiedCols, AclMode requiredPerms)
static void EvalPlanQualStart(EPQState *epqstate, Plan *planTree)
LockTupleMode ExecUpdateLockMode(EState *estate, ResultRelInfo *relinfo)
bool ExecCheckRTPerms(List *rangeTable, bool ereport_on_violation)
ExecutorEnd_hook_type ExecutorEnd_hook
void EvalPlanQualBegin(EPQState *epqstate)
TupleTableSlot * EvalPlanQual(EPQState *epqstate, Relation relation, Index rti, TupleTableSlot *inputslot)
ExecutorFinish_hook_type ExecutorFinish_hook
static const char * ExecRelCheck(ResultRelInfo *resultRelInfo, TupleTableSlot *slot, EState *estate)
bool ExecPartitionCheck(ResultRelInfo *resultRelInfo, TupleTableSlot *slot, EState *estate, bool emitError)
static void ExecEndPlan(PlanState *planstate, EState *estate)
ExecutorStart_hook_type ExecutorStart_hook
TupleTableSlot * EvalPlanQualNext(EPQState *epqstate)
void ExecutorEnd(QueryDesc *queryDesc)
void ExecWithCheckOptions(WCOKind kind, ResultRelInfo *resultRelInfo, TupleTableSlot *slot, EState *estate)
ExecutorCheckPerms_hook_type ExecutorCheckPerms_hook
void InitResultRelInfo(ResultRelInfo *resultRelInfo, Relation resultRelationDesc, Index resultRelationIndex, ResultRelInfo *partition_root_rri, int instrument_options)
ExecAuxRowMark * ExecBuildAuxRowMark(ExecRowMark *erm, List *targetlist)
void standard_ExecutorStart(QueryDesc *queryDesc, int eflags)
void ExecutorFinish(QueryDesc *queryDesc)
static bool ExecCheckRTEPerms(RangeTblEntry *rte)
static void CheckValidRowMarkRel(Relation rel, RowMarkType markType)
void EvalPlanQualEnd(EPQState *epqstate)
static void ExecCheckXactReadOnly(PlannedStmt *plannedstmt)
void EvalPlanQualSetPlan(EPQState *epqstate, Plan *subplan, List *auxrowmarks)
void ExecutorRewind(QueryDesc *queryDesc)
void ExecutorStart(QueryDesc *queryDesc, int eflags)
void standard_ExecutorRun(QueryDesc *queryDesc, ScanDirection direction, uint64 count, bool execute_once)
bool EvalPlanQualFetchRowMark(EPQState *epqstate, Index rti, TupleTableSlot *slot)
ExecutorRun_hook_type ExecutorRun_hook
static void ExecPostprocessPlan(EState *estate)
static void ExecutePlan(EState *estate, PlanState *planstate, bool use_parallel_mode, CmdType operation, bool sendTuples, uint64 numberTuples, ScanDirection direction, DestReceiver *dest, bool execute_once)
void ExecCloseResultRelations(EState *estate)
void EvalPlanQualInit(EPQState *epqstate, EState *parentestate, Plan *subplan, List *auxrowmarks, int epqParam)
static char * ExecBuildSlotValueDescription(Oid reloid, TupleTableSlot *slot, TupleDesc tupdesc, Bitmapset *modifiedCols, int maxfieldlen)
ExecRowMark * ExecFindRowMark(EState *estate, Index rti, bool missing_ok)
List * ExecGetAncestorResultRels(EState *estate, ResultRelInfo *resultRelInfo)
TupleTableSlot * EvalPlanQualSlot(EPQState *epqstate, Relation relation, Index rti)
void ExecutorRun(QueryDesc *queryDesc, ScanDirection direction, uint64 count, bool execute_once)
ResultRelInfo * ExecGetTriggerResultRel(EState *estate, Oid relid, ResultRelInfo *rootRelInfo)
void standard_ExecutorEnd(QueryDesc *queryDesc)
void ExecCloseRangeTableRelations(EState *estate)
void ExecPartitionCheckEmitError(ResultRelInfo *resultRelInfo, TupleTableSlot *slot, EState *estate)
void ExecConstraints(ResultRelInfo *resultRelInfo, TupleTableSlot *slot, EState *estate)
static void InitPlan(QueryDesc *queryDesc, int eflags)
void CheckValidResultRel(ResultRelInfo *resultRelInfo, CmdType operation)
void standard_ExecutorFinish(QueryDesc *queryDesc)
void ExecEndNode(PlanState *node)
PlanState * ExecInitNode(Plan *node, EState *estate, int eflags)
bool ExecShutdownNode(PlanState *node)
void CheckCmdReplicaIdentity(Relation rel, CmdType cmd)
void ExecResetTupleTable(List *tupleTable, bool shouldFree)
TupleTableSlot * MakeTupleTableSlot(TupleDesc tupleDesc, const TupleTableSlotOps *tts_ops)
const TupleTableSlotOps TTSOpsVirtual
TupleTableSlot * ExecInitExtraTupleSlot(EState *estate, TupleDesc tupledesc, const TupleTableSlotOps *tts_ops)
void ExecStoreHeapTupleDatum(Datum data, TupleTableSlot *slot)
TupleDesc ExecGetResultType(PlanState *planstate)
void ExecInitRangeTable(EState *estate, List *rangeTable)
Bitmapset * ExecGetAllUpdatedCols(ResultRelInfo *relinfo, EState *estate)
Bitmapset * ExecGetUpdatedCols(ResultRelInfo *relinfo, EState *estate)
EState * CreateExecutorState(void)
Relation ExecGetRangeTableRelation(EState *estate, Index rti)
void FreeExecutorState(EState *estate)
Bitmapset * ExecGetInsertedCols(ResultRelInfo *relinfo, EState *estate)
#define EXEC_FLAG_BACKWARD
#define ResetPerTupleExprContext(estate)
#define GetPerTupleExprContext(estate)
void(* ExecutorRun_hook_type)(QueryDesc *queryDesc, ScanDirection direction, uint64 count, bool execute_once)
void(* ExecutorFinish_hook_type)(QueryDesc *queryDesc)
static RangeTblEntry * exec_rt_fetch(Index rti, EState *estate)
#define EXEC_FLAG_WITH_NO_DATA
void(* ExecutorStart_hook_type)(QueryDesc *queryDesc, int eflags)
static bool ExecQual(ExprState *state, ExprContext *econtext)
void(* ExecutorEnd_hook_type)(QueryDesc *queryDesc)
bool(* ExecutorCheckPerms_hook_type)(List *, bool)
#define EXEC_FLAG_SKIP_TRIGGERS
#define EXEC_FLAG_EXPLAIN_ONLY
static Datum ExecGetJunkAttribute(TupleTableSlot *slot, AttrNumber attno, bool *isNull)
static TupleTableSlot * ExecProcNode(PlanState *node)
char * OidOutputFunctionCall(Oid functionId, Datum val)
FdwRoutine * GetFdwRoutineForRelation(Relation relation, bool makecopy)
Instrumentation * InstrAlloc(int n, int instrument_options, bool async_mode)
void InstrStartNode(Instrumentation *instr)
void InstrStopNode(Instrumentation *instr, double nTuples)
#define ItemPointerSetInvalid(pointer)
Assert(fmt[strlen(fmt) - 1] !='\n')
List * lappend(List *list, void *datum)
@ LockTupleNoKeyExclusive
void getTypeOutputInfo(Oid type, Oid *typOutput, bool *typIsVarlena)
char get_rel_relkind(Oid relid)
Oid get_rel_namespace(Oid relid)
char * get_rel_name(Oid relid)
bool MatViewIncrementalMaintenanceIsEnabled(void)
int pg_mbcliplen(const char *mbstr, int len, int limit)
void * palloc0(Size size)
bool isTempNamespace(Oid namespaceId)
void ExecSetParamPlanMulti(const Bitmapset *params, ExprContext *econtext)
ObjectType get_relkind_objtype(char relkind)
static MemoryContext MemoryContextSwitchTo(MemoryContext context)
@ WCO_RLS_MERGE_UPDATE_CHECK
@ WCO_RLS_MERGE_DELETE_CHECK
List * RelationGetPartitionQual(Relation rel)
List * get_partition_ancestors(Oid relid)
FormData_pg_attribute * Form_pg_attribute
static int list_length(const List *l)
#define forboth(cell1, list1, cell2, list2)
#define RowMarkRequiresRowShareLock(marktype)
@ ROW_MARK_NOKEYEXCLUSIVE
#define DatumGetObjectId(X)
#define DatumGetPointer(X)
void * stringToNode(const char *str)
#define RelationGetRelid(relation)
#define RelationGetDescr(relation)
#define RelationGetRelationName(relation)
int errtableconstraint(Relation rel, const char *conname)
int errtablecol(Relation rel, int attnum)
Bitmapset * RelationGetIndexAttrBitmap(Relation relation, IndexAttrBitmapKind attrKind)
int errtable(Relation rel)
int check_enable_rls(Oid relid, Oid checkAsUser, bool noError)
#define ScanDirectionIsNoMovement(direction)
void UnregisterSnapshot(Snapshot snapshot)
Snapshot RegisterSnapshot(Snapshot snapshot)
void appendBinaryStringInfo(StringInfo str, const char *data, int datalen)
void appendStringInfoString(StringInfo str, const char *s)
void appendStringInfoChar(StringInfo str, char ch)
void initStringInfo(StringInfo str)
ExecAuxRowMark ** relsubs_rowmark
TupleTableSlot * origslot
TupleTableSlot ** relsubs_slot
PlanState * recheckplanstate
struct ExecRowMark ** es_rowmarks
List * es_tuple_routing_result_relations
PlannedStmt * es_plannedstmt
QueryEnvironment * es_queryEnv
ResultRelInfo ** es_result_relations
ParamExecData * es_param_exec_vals
ParamListInfo es_param_list_info
MemoryContext es_query_cxt
ScanDirection es_direction
struct EPQState * es_epq_active
List * es_trig_target_relations
List * es_opened_result_relations
bool es_use_parallel_mode
Index es_range_table_size
const char * es_sourceText
List * es_auxmodifytables
JunkFilter * es_junkFilter
Snapshot es_crosscheck_snapshot
LockClauseStrength strength
LockWaitPolicy waitPolicy
TupleTableSlot * ecxt_scantuple
ExecForeignInsert_function ExecForeignInsert
ExecForeignUpdate_function ExecForeignUpdate
RefetchForeignRow_function RefetchForeignRow
ExecForeignDelete_function ExecForeignDelete
IsForeignRelUpdatable_function IsForeignRelUpdatable
LockClauseStrength strength
LockWaitPolicy waitPolicy
Bitmapset * rewindPlanIDs
PlannedStmt * plannedstmt
struct Instrumentation * totaltime
QueryEnvironment * queryEnv
Snapshot crosscheck_snapshot
List * ri_matchedMergeAction
TupleTableSlot * ri_PartitionTupleSlot
List * ri_notMatchedMergeAction
bool ri_projectNewInfoValid
OnConflictSetState * ri_onConflict
List * ri_onConflictArbiterIndexes
struct ResultRelInfo * ri_RootResultRelInfo
ExprState ** ri_ConstraintExprs
ExprState * ri_PartitionCheckExpr
Instrumentation * ri_TrigInstrument
RelationPtr ri_IndexRelationDescs
TupleTableSlot * ri_ReturningSlot
ExprState ** ri_GeneratedExprs
List * ri_WithCheckOptions
TupleTableSlot * ri_oldTupleSlot
struct CopyMultiInsertBuffer * ri_CopyMultiInsertBuffer
TriggerDesc * ri_TrigDesc
TupleConversionMap * ri_ChildToRootMap
bool ri_ChildToRootMapValid
List * ri_ancestorResultRels
TupleTableSlot * ri_newTupleSlot
List * ri_WithCheckOptionExprs
ProjectionInfo * ri_projectNew
ProjectionInfo * ri_projectReturning
struct FdwRoutine * ri_FdwRoutine
ExprState ** ri_TrigWhenExprs
FmgrInfo * ri_TrigFunctions
TupleConversionMap * ri_RootToPartitionMap
bool ri_usesFdwDirectModify
IndexInfo ** ri_IndexRelationInfo
TupleTableSlot * ri_TrigNewSlot
TupleTableSlot * ri_TrigOldSlot
bool trig_update_instead_row
bool trig_delete_instead_row
bool trig_insert_instead_row
#define FirstLowInvalidHeapAttributeNumber
void table_close(Relation relation, LOCKMODE lockmode)
Relation table_open(Oid relationId, LOCKMODE lockmode)
TupleTableSlot * table_slot_create(Relation relation, List **reglist)
static bool table_tuple_fetch_row_version(Relation rel, ItemPointer tid, Snapshot snapshot, TupleTableSlot *slot)
TriggerDesc * CopyTriggerDesc(TriggerDesc *trigdesc)
void AfterTriggerEndQuery(EState *estate)
void AfterTriggerBeginQuery(void)
TupleTableSlot * execute_attr_map_slot(AttrMap *attrMap, TupleTableSlot *in_slot, TupleTableSlot *out_slot)
#define TupleDescAttr(tupdesc, i)
static TupleTableSlot * ExecClearTuple(TupleTableSlot *slot)
static TupleTableSlot * ExecCopySlot(TupleTableSlot *dstslot, TupleTableSlot *srcslot)
static void slot_getallattrs(TupleTableSlot *slot)
static void ExecMaterializeSlot(TupleTableSlot *slot)
static bool slot_attisnull(TupleTableSlot *slot, int attnum)
void PreventCommandIfReadOnly(const char *cmdname)
void PreventCommandIfParallelMode(const char *cmdname)
static const char * CreateCommandName(Node *parsetree)
void ExitParallelMode(void)
void EnterParallelMode(void)
bool IsInParallelMode(void)
CommandId GetCurrentCommandId(bool used)