87 bool use_parallel_mode,
143 (*ExecutorStart_hook) (queryDesc, eflags);
155 Assert(queryDesc != NULL);
181 queryDesc->
estate = estate;
242 elog(
ERROR,
"unrecognized operation code: %d",
306 (*ExecutorRun_hook) (queryDesc, direction, count, execute_once);
322 Assert(queryDesc != NULL);
324 estate = queryDesc->
estate;
361 elog(
ERROR,
"can't re-execute query flagged for single execution");
405 (*ExecutorFinish_hook) (queryDesc);
417 Assert(queryDesc != NULL);
419 estate = queryDesc->
estate;
465 (*ExecutorEnd_hook) (queryDesc);
477 Assert(queryDesc != NULL);
479 estate = queryDesc->
estate;
534 Assert(queryDesc != NULL);
536 estate = queryDesc->
estate;
575 bool ereport_on_violation)
580 foreach(l, rteperminfos)
588 if (ereport_on_violation)
597 result = (*ExecutorCheckPerms_hook) (rangeTable, rteperminfos,
598 ereport_on_violation);
616 Assert(requiredPerms != 0);
635 remainingPerms = requiredPerms & ~relPerms;
636 if (remainingPerms != 0)
741 elog(
ERROR,
"whole-row update is not implemented");
918 subplanstate =
ExecInitNode(subplan, estate, sp_eflags);
944 bool junk_filter_needed =
false;
953 junk_filter_needed =
true;
958 if (junk_filter_needed)
969 tupType =
j->jf_cleanTupType;
993 switch (resultRel->
rd_rel->relkind)
995 case RELKIND_RELATION:
996 case RELKIND_PARTITIONED_TABLE:
999 case RELKIND_SEQUENCE:
1001 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
1002 errmsg(
"cannot change sequence \"%s\"",
1005 case RELKIND_TOASTVALUE:
1007 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
1008 errmsg(
"cannot change TOAST relation \"%s\"",
1025 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
1026 errmsg(
"cannot insert into view \"%s\"",
1028 errhint(
"To enable inserting into the view, provide an INSTEAD OF INSERT trigger or an unconditional ON INSERT DO INSTEAD rule.")));
1033 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
1034 errmsg(
"cannot update view \"%s\"",
1036 errhint(
"To enable updating the view, provide an INSTEAD OF UPDATE trigger or an unconditional ON UPDATE DO INSTEAD rule.")));
1041 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
1042 errmsg(
"cannot delete from view \"%s\"",
1044 errhint(
"To enable deleting from the view, provide an INSTEAD OF DELETE trigger or an unconditional ON DELETE DO INSTEAD rule.")));
1047 elog(
ERROR,
"unrecognized CmdType: %d", (
int) operation);
1051 case RELKIND_MATVIEW:
1054 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
1055 errmsg(
"cannot change materialized view \"%s\"",
1058 case RELKIND_FOREIGN_TABLE:
1066 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1067 errmsg(
"cannot insert into foreign table \"%s\"",
1072 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
1073 errmsg(
"foreign table \"%s\" does not allow inserts",
1079 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1080 errmsg(
"cannot update foreign table \"%s\"",
1085 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
1086 errmsg(
"foreign table \"%s\" does not allow updates",
1092 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1093 errmsg(
"cannot delete from foreign table \"%s\"",
1098 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
1099 errmsg(
"foreign table \"%s\" does not allow deletes",
1103 elog(
ERROR,
"unrecognized CmdType: %d", (
int) operation);
1109 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
1110 errmsg(
"cannot change relation \"%s\"",
1127 switch (rel->
rd_rel->relkind)
1129 case RELKIND_RELATION:
1130 case RELKIND_PARTITIONED_TABLE:
1133 case RELKIND_SEQUENCE:
1136 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
1137 errmsg(
"cannot lock rows in sequence \"%s\"",
1140 case RELKIND_TOASTVALUE:
1143 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
1144 errmsg(
"cannot lock rows in TOAST relation \"%s\"",
1150 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
1151 errmsg(
"cannot lock rows in view \"%s\"",
1154 case RELKIND_MATVIEW:
1158 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
1159 errmsg(
"cannot lock rows in materialized view \"%s\"",
1162 case RELKIND_FOREIGN_TABLE:
1167 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1168 errmsg(
"cannot lock rows in foreign table \"%s\"",
1173 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
1174 errmsg(
"cannot lock rows in relation \"%s\"",
1190 Index resultRelationIndex,
1192 int instrument_options)
1195 resultRelInfo->
type = T_ResultRelInfo;
1211 if (instrument_options)
1220 if (resultRelationDesc->
rd_rel->relkind == RELKIND_FOREIGN_TABLE)
1365 if (!partRel->
rd_rel->relispartition)
1366 elog(
ERROR,
"cannot find ancestors of a non-partition result relation");
1367 Assert(rootRelInfo != NULL);
1387 if (ancOid == rootRelOid)
1400 ancResultRels =
lappend(ancResultRels, rInfo);
1402 ancResultRels =
lappend(ancResultRels, rootRelInfo);
1590 bool use_parallel_mode,
1593 uint64 numberTuples,
1599 uint64 current_tuple_count;
1604 current_tuple_count = 0;
1616 use_parallel_mode =
false;
1619 if (use_parallel_mode)
1664 if (!
dest->receiveSlot(slot,
dest))
1681 current_tuple_count++;
1682 if (numberTuples && numberTuples == current_tuple_count)
1693 if (use_parallel_mode)
1719 if (ncheck != rel->
rd_rel->relchecks)
1720 elog(
ERROR,
"%d pg_constraint record(s) missing for relation \"%s\"",
1733 for (
i = 0;
i < ncheck;
i++)
1754 for (
i = 0;
i < ncheck;
i++)
1780 EState *estate,
bool emitError)
1884 (
errcode(ERRCODE_CHECK_VIOLATION),
1885 errmsg(
"new row for relation \"%s\" violates partition constraint",
1887 val_desc ?
errdetail(
"Failing row contains %s.", val_desc) : 0,
1915 int natts = tupdesc->
natts;
1918 for (attrChk = 1; attrChk <= natts; attrChk++)
1967 (
errcode(ERRCODE_NOT_NULL_VIOLATION),
1968 errmsg(
"null value in column \"%s\" of relation \"%s\" violates not-null constraint",
1971 val_desc ?
errdetail(
"Failing row contains %s.", val_desc) : 0,
1977 if (rel->
rd_rel->relchecks > 0)
1981 if ((failed =
ExecRelCheck(resultRelInfo, slot, estate)) != NULL)
2019 (
errcode(ERRCODE_CHECK_VIOLATION),
2020 errmsg(
"new row for relation \"%s\" violates check constraint \"%s\"",
2022 val_desc ?
errdetail(
"Failing row contains %s.", val_desc) : 0,
2067 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)
2909 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, 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)
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)
#define MemSet(start, val, len)
#define OidIsValid(objectId)
elog(ERROR, "%s: %s", p2, msg)
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 void EvalPlanQualStart(EPQState *epqstate, Plan *planTree)
LockTupleMode ExecUpdateLockMode(EState *estate, ResultRelInfo *relinfo)
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)
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
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 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)
static bool ExecCheckPermissionsModified(Oid relOid, Oid userid, Bitmapset *modifiedCols, AclMode requiredPerms)
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)
bool ExecCheckPermissions(List *rangeTable, List *rteperminfos, bool ereport_on_violation)
void CheckValidResultRel(ResultRelInfo *resultRelInfo, CmdType operation)
void standard_ExecutorFinish(QueryDesc *queryDesc)
void ExecEndNode(PlanState *node)
void ExecShutdownNode(PlanState *node)
PlanState * ExecInitNode(Plan *node, EState *estate, int eflags)
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)
Bitmapset * ExecGetAllUpdatedCols(ResultRelInfo *relinfo, EState *estate)
Bitmapset * ExecGetUpdatedCols(ResultRelInfo *relinfo, EState *estate)
void ExecInitRangeTable(EState *estate, List *rangeTable, List *permInfos)
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)
bool(* ExecutorCheckPerms_hook_type)(List *rangeTable, List *rtePermInfos, bool ereport_on_violation)
void(* ExecutorEnd_hook_type)(QueryDesc *queryDesc)
#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)
static void ItemPointerSetInvalid(ItemPointerData *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
#define lfirst_node(type, lc)
static int list_length(const List *l)
#define forboth(cell1, list1, cell2, list2)
#define RowMarkRequiresRowShareLock(marktype)
@ ROW_MARK_NOKEYEXCLUSIVE
static Oid DatumGetObjectId(Datum X)
static Pointer DatumGetPointer(Datum 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 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
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
TupleConversionMap * ri_RootToChildMap
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
List * ri_WithCheckOptions
TupleTableSlot * ri_oldTupleSlot
bool ri_RootToChildMapValid
struct CopyMultiInsertBuffer * ri_CopyMultiInsertBuffer
TriggerDesc * ri_TrigDesc
Bitmapset * ri_extraUpdatedCols
ExprState ** ri_GeneratedExprsI
TupleConversionMap * ri_ChildToRootMap
bool ri_ChildToRootMapValid
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
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)