133 (*ExecutorStart_hook) (queryDesc, eflags);
145 Assert(queryDesc != NULL);
174 queryDesc->
estate = estate;
235 elog(
ERROR,
"unrecognized operation code: %d",
299 (*ExecutorRun_hook) (queryDesc, direction, count);
315 Assert(queryDesc != NULL);
317 estate = queryDesc->
estate;
407 (*ExecutorFinish_hook) (queryDesc);
419 Assert(queryDesc != NULL);
421 estate = queryDesc->
estate;
467 (*ExecutorEnd_hook) (queryDesc);
479 Assert(queryDesc != NULL);
481 estate = queryDesc->
estate;
540 Assert(queryDesc != NULL);
542 estate = queryDesc->
estate;
581 bool ereport_on_violation)
586#ifdef USE_ASSERT_CHECKING
590 foreach(l, rangeTable)
594 if (rte->perminfoindex != 0)
604 rte->relkind == RELKIND_VIEW));
617 foreach(l, rteperminfos)
625 if (ereport_on_violation)
634 result = (*ExecutorCheckPerms_hook) (rangeTable, rteperminfos,
635 ereport_on_violation);
653 Assert(requiredPerms != 0);
672 remainingPerms = requiredPerms & ~relPerms;
673 if (remainingPerms != 0)
778 elog(
ERROR,
"whole-row update is not implemented");
972 subplanstate =
ExecInitNode(subplan, estate, sp_eflags);
998 bool junk_filter_needed =
false;
1001 foreach(tlist,
plan->targetlist)
1007 junk_filter_needed =
true;
1012 if (junk_filter_needed)
1023 tupType =
j->jf_cleanTupType;
1055 switch (resultRel->
rd_rel->relkind)
1057 case RELKIND_RELATION:
1058 case RELKIND_PARTITIONED_TABLE:
1061 case RELKIND_SEQUENCE:
1063 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
1064 errmsg(
"cannot change sequence \"%s\"",
1067 case RELKIND_TOASTVALUE:
1069 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
1070 errmsg(
"cannot change TOAST relation \"%s\"",
1085 case RELKIND_MATVIEW:
1088 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
1089 errmsg(
"cannot change materialized view \"%s\"",
1092 case RELKIND_FOREIGN_TABLE:
1100 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1101 errmsg(
"cannot insert into foreign table \"%s\"",
1106 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
1107 errmsg(
"foreign table \"%s\" does not allow inserts",
1113 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1114 errmsg(
"cannot update foreign table \"%s\"",
1119 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
1120 errmsg(
"foreign table \"%s\" does not allow updates",
1126 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1127 errmsg(
"cannot delete from foreign table \"%s\"",
1132 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
1133 errmsg(
"foreign table \"%s\" does not allow deletes",
1137 elog(
ERROR,
"unrecognized CmdType: %d", (
int) operation);
1143 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
1144 errmsg(
"cannot change relation \"%s\"",
1161 switch (rel->
rd_rel->relkind)
1163 case RELKIND_RELATION:
1164 case RELKIND_PARTITIONED_TABLE:
1167 case RELKIND_SEQUENCE:
1170 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
1171 errmsg(
"cannot lock rows in sequence \"%s\"",
1174 case RELKIND_TOASTVALUE:
1177 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
1178 errmsg(
"cannot lock rows in TOAST relation \"%s\"",
1184 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
1185 errmsg(
"cannot lock rows in view \"%s\"",
1188 case RELKIND_MATVIEW:
1192 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
1193 errmsg(
"cannot lock rows in materialized view \"%s\"",
1196 case RELKIND_FOREIGN_TABLE:
1201 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1202 errmsg(
"cannot lock rows in foreign table \"%s\"",
1207 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
1208 errmsg(
"cannot lock rows in relation \"%s\"",
1224 Index resultRelationIndex,
1226 int instrument_options)
1229 resultRelInfo->
type = T_ResultRelInfo;
1247 if (instrument_options)
1256 if (resultRelationDesc->
rd_rel->relkind == RELKIND_FOREIGN_TABLE)
1404 if (!partRel->
rd_rel->relispartition)
1405 elog(
ERROR,
"cannot find ancestors of a non-partition result relation");
1406 Assert(rootRelInfo != NULL);
1426 if (ancOid == rootRelOid)
1439 ancResultRels =
lappend(ancResultRels, rInfo);
1441 ancResultRels =
lappend(ancResultRels, rootRelInfo);
1633 bool use_parallel_mode;
1635 uint64 current_tuple_count;
1640 current_tuple_count = 0;
1655 use_parallel_mode =
false;
1661 if (use_parallel_mode)
1706 if (!
dest->receiveSlot(slot,
dest))
1723 current_tuple_count++;
1724 if (numberTuples && numberTuples == current_tuple_count)
1735 if (use_parallel_mode)
1761 if (ncheck != rel->
rd_rel->relchecks)
1762 elog(
ERROR,
"%d pg_constraint record(s) missing for relation \"%s\"",
1775 for (
i = 0;
i < ncheck;
i++)
1780 if (!check[
i].ccenforced)
1801 for (
i = 0;
i < ncheck;
i++)
1810 if (checkconstr && !
ExecCheck(checkconstr, econtext))
1827 EState *estate,
bool emitError)
1931 (
errcode(ERRCODE_CHECK_VIOLATION),
1932 errmsg(
"new row for relation \"%s\" violates partition constraint",
1934 val_desc ?
errdetail(
"Failing row contains %s.", val_desc) : 0,
1962 int natts = tupdesc->
natts;
1965 for (attrChk = 1; attrChk <= natts; attrChk++)
2014 (
errcode(ERRCODE_NOT_NULL_VIOLATION),
2015 errmsg(
"null value in column \"%s\" of relation \"%s\" violates not-null constraint",
2018 val_desc ?
errdetail(
"Failing row contains %s.", val_desc) : 0,
2024 if (rel->
rd_rel->relchecks > 0)
2028 if ((failed =
ExecRelCheck(resultRelInfo, slot, estate)) != NULL)
2066 (
errcode(ERRCODE_CHECK_VIOLATION),
2067 errmsg(
"new row for relation \"%s\" violates check constraint \"%s\"",
2069 val_desc ?
errdetail(
"Failing row contains %s.", val_desc) : 0,
2114 if (wco->
kind != kind)
2176 (
errcode(ERRCODE_WITH_CHECK_OPTION_VIOLATION),
2177 errmsg(
"new row violates check option for view \"%s\"",
2179 val_desc ?
errdetail(
"Failing row contains %s.",
2186 (
errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
2187 errmsg(
"new row violates row-level security policy \"%s\" for table \"%s\"",
2191 (
errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
2192 errmsg(
"new row violates row-level security policy for table \"%s\"",
2199 (
errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
2200 errmsg(
"target row violates row-level security policy \"%s\" (USING expression) for table \"%s\"",
2204 (
errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
2205 errmsg(
"target row violates row-level security policy (USING expression) for table \"%s\"",
2211 (
errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
2212 errmsg(
"new row violates row-level security policy \"%s\" (USING expression) for table \"%s\"",
2216 (
errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
2217 errmsg(
"new row violates row-level security policy (USING expression) for table \"%s\"",
2256 bool write_comma =
false;
2257 bool write_comma_collist =
false;
2260 bool table_perm =
false;
2261 bool any_perm =
false;
2290 table_perm = any_perm =
true;
2295 for (
i = 0;
i < tupdesc->
natts;
i++)
2297 bool column_perm =
false;
2303 if (att->attisdropped)
2319 column_perm = any_perm =
true;
2321 if (write_comma_collist)
2324 write_comma_collist =
true;
2330 if (table_perm || column_perm)
2332 if (att->attgenerated == ATTRIBUTE_GENERATED_VIRTUAL)
2342 &foutoid, &typisvarlena);
2352 vallen = strlen(
val);
2353 if (vallen <= maxfieldlen)
2375 return collist.
data;
2415 if (rti > 0 && rti <= estate->es_range_table_size &&
2424 elog(
ERROR,
"failed to find ExecRowMark for rangetable index %u", rti);
2451 elog(
ERROR,
"could not find junk %s column", resname);
2460 elog(
ERROR,
"could not find junk %s column", resname);
2470 elog(
ERROR,
"could not find junk %s column", resname);
2524 if (testslot != inputslot)
2577 int epqParam,
List *resultRelations)
2598 epqstate->
plan = subplan;
2622 epqstate->
plan = subplan;
2640 Assert(rti > 0 && rti <= epqstate->parentestate->es_range_table_size);
2673 elog(
ERROR,
"EvalPlanQual doesn't support locking rowmarks");
2690 if (tableoid != erm->
relid)
2713 bool updated =
false;
2719 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
2720 errmsg(
"cannot lock rows in foreign table \"%s\"",
2729 elog(
ERROR,
"failed to fetch tuple for EvalPlanQual recheck");
2744 elog(
ERROR,
"failed to fetch tuple for EvalPlanQual recheck");
2792 if (recheckestate == NULL)
2811 rtsize *
sizeof(
bool));
2996 Assert(rtindex > 0 && rtindex <= rtsize);
3001 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, bool missing_ok)
#define AttributeNumberIsValid(attributeNumber)
#define InvalidAttrNumber
void pgstat_report_query_id(uint64 query_id, bool force)
int bms_next_member(const Bitmapset *a, int prevbit)
int bms_num_members(const Bitmapset *a)
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_overlap(const Bitmapset *a, const Bitmapset *b)
Bitmapset * bms_copy(const Bitmapset *a)
#define Assert(condition)
#define MemSet(start, val, len)
#define OidIsValid(objectId)
bool IsInplaceUpdateRelation(Relation relation)
int errdetail(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)
TupleTableSlot * ExecFilterJunk(JunkFilter *junkfilter, TupleTableSlot *slot)
AttrNumber ExecFindJunkAttributeInTlist(List *targetlist, const char *attrName)
JunkFilter * ExecInitJunkFilter(List *targetList, TupleTableSlot *slot)
static void EvalPlanQualStart(EPQState *epqstate, Plan *planTree)
LockTupleMode ExecUpdateLockMode(EState *estate, ResultRelInfo *relinfo)
ExecRowMark * ExecFindRowMark(EState *estate, Index rti, bool missing_ok)
ExecAuxRowMark * ExecBuildAuxRowMark(ExecRowMark *erm, List *targetlist)
ExecutorEnd_hook_type ExecutorEnd_hook
ResultRelInfo * ExecGetTriggerResultRel(EState *estate, Oid relid, ResultRelInfo *rootRelInfo)
void CheckValidResultRel(ResultRelInfo *resultRelInfo, CmdType operation, List *mergeActions)
TupleTableSlot * EvalPlanQualSlot(EPQState *epqstate, Relation relation, Index rti)
void EvalPlanQualBegin(EPQState *epqstate)
ExecutorFinish_hook_type ExecutorFinish_hook
char * ExecBuildSlotValueDescription(Oid reloid, TupleTableSlot *slot, TupleDesc tupdesc, Bitmapset *modifiedCols, int maxfieldlen)
static bool ExecCheckOneRelPerms(RTEPermissionInfo *perminfo)
bool ExecPartitionCheck(ResultRelInfo *resultRelInfo, TupleTableSlot *slot, EState *estate, bool emitError)
static void ExecEndPlan(PlanState *planstate, EState *estate)
ExecutorStart_hook_type ExecutorStart_hook
void ExecutorEnd(QueryDesc *queryDesc)
void EvalPlanQualInit(EPQState *epqstate, EState *parentestate, Plan *subplan, List *auxrowmarks, int epqParam, List *resultRelations)
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)
void standard_ExecutorStart(QueryDesc *queryDesc, int eflags)
void ExecutorFinish(QueryDesc *queryDesc)
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)
TupleTableSlot * EvalPlanQual(EPQState *epqstate, Relation relation, Index rti, TupleTableSlot *inputslot)
bool EvalPlanQualFetchRowMark(EPQState *epqstate, Index rti, TupleTableSlot *slot)
static bool ExecCheckPermissionsModified(Oid relOid, Oid userid, Bitmapset *modifiedCols, AclMode requiredPerms)
ExecutorRun_hook_type ExecutorRun_hook
static void ExecPostprocessPlan(EState *estate)
static const char * ExecRelCheck(ResultRelInfo *resultRelInfo, TupleTableSlot *slot, EState *estate)
static void ExecutePlan(QueryDesc *queryDesc, CmdType operation, bool sendTuples, uint64 numberTuples, ScanDirection direction, DestReceiver *dest)
void ExecCloseResultRelations(EState *estate)
void standard_ExecutorRun(QueryDesc *queryDesc, ScanDirection direction, uint64 count)
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)
bool ExecCheckPermissions(List *rangeTable, List *rteperminfos, bool ereport_on_violation)
void ExecutorRun(QueryDesc *queryDesc, ScanDirection direction, uint64 count)
List * ExecGetAncestorResultRels(EState *estate, ResultRelInfo *resultRelInfo)
TupleTableSlot * EvalPlanQualNext(EPQState *epqstate)
void standard_ExecutorFinish(QueryDesc *queryDesc)
void ExecDoInitialPruning(EState *estate)
void ExecEndNode(PlanState *node)
PlanState * ExecInitNode(Plan *node, EState *estate, int eflags)
void ExecShutdownNode(PlanState *node)
void CheckCmdReplicaIdentity(Relation rel, CmdType cmd)
void ExecResetTupleTable(List *tupleTable, bool shouldFree)
const TupleTableSlotOps TTSOpsVirtual
TupleTableSlot * ExecInitExtraTupleSlot(EState *estate, TupleDesc tupledesc, const TupleTableSlotOps *tts_ops)
void ExecStoreHeapTupleDatum(Datum data, TupleTableSlot *slot)
TupleTableSlot * MakeTupleTableSlot(TupleDesc tupleDesc, const TupleTableSlotOps *tts_ops)
TupleDesc ExecGetResultType(PlanState *planstate)
Bitmapset * ExecGetInsertedCols(ResultRelInfo *relinfo, EState *estate)
void ExecInitRangeTable(EState *estate, List *rangeTable, List *permInfos, Bitmapset *unpruned_relids)
Bitmapset * ExecGetUpdatedCols(ResultRelInfo *relinfo, EState *estate)
Relation ExecGetRangeTableRelation(EState *estate, Index rti)
void FreeExecutorState(EState *estate)
Bitmapset * ExecGetAllUpdatedCols(ResultRelInfo *relinfo, EState *estate)
EState * CreateExecutorState(void)
#define EXEC_FLAG_BACKWARD
#define ResetPerTupleExprContext(estate)
#define GetPerTupleExprContext(estate)
void(* ExecutorFinish_hook_type)(QueryDesc *queryDesc)
static RangeTblEntry * exec_rt_fetch(Index rti, EState *estate)
void(* ExecutorRun_hook_type)(QueryDesc *queryDesc, ScanDirection direction, uint64 count)
void(* ExecutorStart_hook_type)(QueryDesc *queryDesc, int eflags)
static bool ExecQual(ExprState *state, ExprContext *econtext)
bool(* ExecutorCheckPerms_hook_type)(List *rangeTable, List *rtePermInfos, bool ereport_on_violation)
void(* ExecutorEnd_hook_type)(QueryDesc *queryDesc)
static TupleTableSlot * ExecProcNode(PlanState *node)
#define EXEC_FLAG_SKIP_TRIGGERS
#define EXEC_FLAG_EXPLAIN_ONLY
static Datum ExecGetJunkAttribute(TupleTableSlot *slot, AttrNumber attno, bool *isNull)
#define palloc_array(type, count)
#define palloc0_array(type, count)
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)
static void ItemPointerSetInvalid(ItemPointerData *pointer)
List * lappend(List *list, void *datum)
@ LockTupleNoKeyExclusive
char * get_rel_name(Oid relid)
void getTypeOutputInfo(Oid type, Oid *typOutput, bool *typIsVarlena)
char get_rel_relkind(Oid relid)
Oid get_rel_namespace(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)
RTEPermissionInfo * getRTEPermissionInfo(List *rteperminfos, RangeTblEntry *rte)
@ 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
#define lfirst_node(type, lc)
static int list_length(const List *l)
#define forboth(cell1, list1, cell2, list2)
void pgstat_update_parallel_workers_stats(PgStat_Counter workers_to_launch, PgStat_Counter workers_launched)
#define RowMarkRequiresRowShareLock(marktype)
@ ROW_MARK_NOKEYEXCLUSIVE
static Oid DatumGetObjectId(Datum X)
static Pointer DatumGetPointer(Datum X)
@ MERGE_WHEN_NOT_MATCHED_BY_TARGET
@ MERGE_WHEN_NOT_MATCHED_BY_SOURCE
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)
bool view_has_instead_trigger(Relation view, CmdType event, List *mergeActionList)
void error_view_not_updatable(Relation view, CmdType command, List *mergeActionList, const char *detail)
Node * expand_generated_columns_in_expr(Node *node, Relation rel, int rt_index)
int check_enable_rls(Oid relid, Oid checkAsUser, bool noError)
#define ScanDirectionIsNoMovement(direction)
void UnregisterSnapshot(Snapshot snapshot)
Snapshot RegisterSnapshot(Snapshot snapshot)
Snapshot GetActiveSnapshot(void)
void appendBinaryStringInfo(StringInfo str, const void *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
List * es_part_prune_infos
struct ExecRowMark ** es_rowmarks
int es_parallel_workers_to_launch
List * es_tuple_routing_result_relations
PlannedStmt * es_plannedstmt
QueryEnvironment * es_queryEnv
ResultRelInfo ** es_result_relations
ParamExecData * es_param_exec_vals
uint64 es_total_processed
Bitmapset * es_unpruned_relids
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
int es_parallel_workers_launched
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
Bitmapset * unprunableRelids
PlannedStmt * plannedstmt
struct Instrumentation * totaltime
QueryEnvironment * queryEnv
Snapshot crosscheck_snapshot
TupleConversionMap * ri_RootToChildMap
TupleTableSlot * ri_PartitionTupleSlot
bool ri_projectNewInfoValid
OnConflictSetState * ri_onConflict
List * ri_onConflictArbiterIndexes
struct ResultRelInfo * ri_RootResultRelInfo
ExprState ** ri_ConstraintExprs
ExprState * ri_PartitionCheckExpr
Instrumentation * ri_TrigInstrument
ExprState * ri_MergeJoinCondition
RelationPtr ri_IndexRelationDescs
TupleTableSlot * ri_ReturningSlot
List * ri_WithCheckOptions
TupleTableSlot * ri_oldTupleSlot
bool ri_RootToChildMapValid
struct CopyMultiInsertBuffer * ri_CopyMultiInsertBuffer
TriggerDesc * ri_TrigDesc
TupleTableSlot * ri_AllNullSlot
Bitmapset * ri_extraUpdatedCols
ExprState ** ri_GeneratedExprsI
TupleConversionMap * ri_ChildToRootMap
bool ri_ChildToRootMapValid
List * ri_MergeActions[NUM_MERGE_MATCH_KINDS]
List * ri_ancestorResultRels
TupleTableSlot * ri_newTupleSlot
List * ri_WithCheckOptionExprs
ProjectionInfo * ri_projectNew
ProjectionInfo * ri_projectReturning
ExprState ** ri_GeneratedExprsU
struct FdwRoutine * ri_FdwRoutine
ExprState ** ri_TrigWhenExprs
FmgrInfo * ri_TrigFunctions
bool ri_usesFdwDirectModify
IndexInfo ** ri_IndexRelationInfo
TupleTableSlot * ri_TrigNewSlot
TupleTableSlot * ri_TrigOldSlot
#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)
static FormData_pg_attribute * TupleDescAttr(TupleDesc tupdesc, int i)
static TupleTableSlot * ExecClearTuple(TupleTableSlot *slot)
static void slot_getallattrs(TupleTableSlot *slot)
static TupleTableSlot * ExecCopySlot(TupleTableSlot *dstslot, TupleTableSlot *srcslot)
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)