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",
307 (*ExecutorRun_hook) (queryDesc, direction, count, execute_once);
323 Assert(queryDesc != NULL);
325 estate = queryDesc->
estate;
362 elog(
ERROR,
"can't re-execute query flagged for single execution");
412 (*ExecutorFinish_hook) (queryDesc);
424 Assert(queryDesc != NULL);
426 estate = queryDesc->
estate;
472 (*ExecutorEnd_hook) (queryDesc);
484 Assert(queryDesc != NULL);
486 estate = queryDesc->
estate;
541 Assert(queryDesc != NULL);
543 estate = queryDesc->
estate;
582 bool ereport_on_violation)
587 #ifdef USE_ASSERT_CHECKING
591 foreach(l, rangeTable)
605 rte->
relkind == RELKIND_VIEW));
618 foreach(l, rteperminfos)
626 if (ereport_on_violation)
635 result = (*ExecutorCheckPerms_hook) (rangeTable, rteperminfos,
636 ereport_on_violation);
654 Assert(requiredPerms != 0);
673 remainingPerms = requiredPerms & ~relPerms;
674 if (remainingPerms != 0)
779 elog(
ERROR,
"whole-row update is not implemented");
955 subplanstate =
ExecInitNode(subplan, estate, sp_eflags);
981 bool junk_filter_needed =
false;
984 foreach(tlist,
plan->targetlist)
990 junk_filter_needed =
true;
995 if (junk_filter_needed)
1006 tupType =
j->jf_cleanTupType;
1030 switch (resultRel->
rd_rel->relkind)
1032 case RELKIND_RELATION:
1033 case RELKIND_PARTITIONED_TABLE:
1036 case RELKIND_SEQUENCE:
1038 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
1039 errmsg(
"cannot change sequence \"%s\"",
1042 case RELKIND_TOASTVALUE:
1044 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
1045 errmsg(
"cannot change TOAST relation \"%s\"",
1062 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
1063 errmsg(
"cannot insert into view \"%s\"",
1065 errhint(
"To enable inserting into the view, provide an INSTEAD OF INSERT trigger or an unconditional ON INSERT DO INSTEAD rule.")));
1070 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
1071 errmsg(
"cannot update view \"%s\"",
1073 errhint(
"To enable updating the view, provide an INSTEAD OF UPDATE trigger or an unconditional ON UPDATE DO INSTEAD rule.")));
1078 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
1079 errmsg(
"cannot delete from view \"%s\"",
1081 errhint(
"To enable deleting from the view, provide an INSTEAD OF DELETE trigger or an unconditional ON DELETE DO INSTEAD rule.")));
1084 elog(
ERROR,
"unrecognized CmdType: %d", (
int) operation);
1088 case RELKIND_MATVIEW:
1091 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
1092 errmsg(
"cannot change materialized view \"%s\"",
1095 case RELKIND_FOREIGN_TABLE:
1103 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1104 errmsg(
"cannot insert into foreign table \"%s\"",
1109 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
1110 errmsg(
"foreign table \"%s\" does not allow inserts",
1116 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1117 errmsg(
"cannot update foreign table \"%s\"",
1122 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
1123 errmsg(
"foreign table \"%s\" does not allow updates",
1129 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1130 errmsg(
"cannot delete from foreign table \"%s\"",
1135 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
1136 errmsg(
"foreign table \"%s\" does not allow deletes",
1140 elog(
ERROR,
"unrecognized CmdType: %d", (
int) operation);
1146 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
1147 errmsg(
"cannot change relation \"%s\"",
1164 switch (rel->
rd_rel->relkind)
1166 case RELKIND_RELATION:
1167 case RELKIND_PARTITIONED_TABLE:
1170 case RELKIND_SEQUENCE:
1173 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
1174 errmsg(
"cannot lock rows in sequence \"%s\"",
1177 case RELKIND_TOASTVALUE:
1180 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
1181 errmsg(
"cannot lock rows in TOAST relation \"%s\"",
1187 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
1188 errmsg(
"cannot lock rows in view \"%s\"",
1191 case RELKIND_MATVIEW:
1195 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
1196 errmsg(
"cannot lock rows in materialized view \"%s\"",
1199 case RELKIND_FOREIGN_TABLE:
1204 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1205 errmsg(
"cannot lock rows in foreign table \"%s\"",
1210 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
1211 errmsg(
"cannot lock rows in relation \"%s\"",
1227 Index resultRelationIndex,
1229 int instrument_options)
1232 resultRelInfo->
type = T_ResultRelInfo;
1248 if (instrument_options)
1257 if (resultRelationDesc->
rd_rel->relkind == RELKIND_FOREIGN_TABLE)
1402 if (!partRel->
rd_rel->relispartition)
1403 elog(
ERROR,
"cannot find ancestors of a non-partition result relation");
1404 Assert(rootRelInfo != NULL);
1424 if (ancOid == rootRelOid)
1437 ancResultRels =
lappend(ancResultRels, rInfo);
1439 ancResultRels =
lappend(ancResultRels, rootRelInfo);
1627 bool use_parallel_mode,
1630 uint64 numberTuples,
1636 uint64 current_tuple_count;
1641 current_tuple_count = 0;
1653 use_parallel_mode =
false;
1656 if (use_parallel_mode)
1701 if (!
dest->receiveSlot(slot,
dest))
1718 current_tuple_count++;
1719 if (numberTuples && numberTuples == current_tuple_count)
1730 if (use_parallel_mode)
1756 if (ncheck != rel->
rd_rel->relchecks)
1757 elog(
ERROR,
"%d pg_constraint record(s) missing for relation \"%s\"",
1770 for (
i = 0;
i < ncheck;
i++)
1791 for (
i = 0;
i < ncheck;
i++)
1817 EState *estate,
bool emitError)
1921 (
errcode(ERRCODE_CHECK_VIOLATION),
1922 errmsg(
"new row for relation \"%s\" violates partition constraint",
1924 val_desc ?
errdetail(
"Failing row contains %s.", val_desc) : 0,
1952 int natts = tupdesc->
natts;
1955 for (attrChk = 1; attrChk <= natts; attrChk++)
2004 (
errcode(ERRCODE_NOT_NULL_VIOLATION),
2005 errmsg(
"null value in column \"%s\" of relation \"%s\" violates not-null constraint",
2008 val_desc ?
errdetail(
"Failing row contains %s.", val_desc) : 0,
2014 if (rel->
rd_rel->relchecks > 0)
2018 if ((failed =
ExecRelCheck(resultRelInfo, slot, estate)) != NULL)
2056 (
errcode(ERRCODE_CHECK_VIOLATION),
2057 errmsg(
"new row for relation \"%s\" violates check constraint \"%s\"",
2059 val_desc ?
errdetail(
"Failing row contains %s.", val_desc) : 0,
2104 if (wco->
kind != kind)
2166 (
errcode(ERRCODE_WITH_CHECK_OPTION_VIOLATION),
2167 errmsg(
"new row violates check option for view \"%s\"",
2169 val_desc ?
errdetail(
"Failing row contains %s.",
2176 (
errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
2177 errmsg(
"new row violates row-level security policy \"%s\" for table \"%s\"",
2181 (
errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
2182 errmsg(
"new row violates row-level security policy for table \"%s\"",
2189 (
errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
2190 errmsg(
"target row violates row-level security policy \"%s\" (USING expression) for table \"%s\"",
2194 (
errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
2195 errmsg(
"target row violates row-level security policy (USING expression) for table \"%s\"",
2201 (
errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
2202 errmsg(
"new row violates row-level security policy \"%s\" (USING expression) for table \"%s\"",
2206 (
errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
2207 errmsg(
"new row violates row-level security policy (USING expression) for table \"%s\"",
2246 bool write_comma =
false;
2247 bool write_comma_collist =
false;
2250 bool table_perm =
false;
2251 bool any_perm =
false;
2280 table_perm = any_perm =
true;
2285 for (
i = 0;
i < tupdesc->
natts;
i++)
2287 bool column_perm =
false;
2293 if (att->attisdropped)
2309 column_perm = any_perm =
true;
2311 if (write_comma_collist)
2314 write_comma_collist =
true;
2320 if (table_perm || column_perm)
2330 &foutoid, &typisvarlena);
2340 vallen = strlen(
val);
2341 if (vallen <= maxfieldlen)
2363 return collist.
data;
2403 if (rti > 0 && rti <= estate->es_range_table_size &&
2412 elog(
ERROR,
"failed to find ExecRowMark for rangetable index %u", rti);
2439 elog(
ERROR,
"could not find junk %s column", resname);
2448 elog(
ERROR,
"could not find junk %s column", resname);
2458 elog(
ERROR,
"could not find junk %s column", resname);
2512 if (testslot != inputslot)
2565 int epqParam,
List *resultRelations)
2586 epqstate->
plan = subplan;
2610 epqstate->
plan = subplan;
2628 Assert(rti > 0 && rti <= epqstate->parentestate->es_range_table_size);
2661 elog(
ERROR,
"EvalPlanQual doesn't support locking rowmarks");
2678 if (tableoid != erm->
relid)
2701 bool updated =
false;
2707 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
2708 errmsg(
"cannot lock rows in foreign table \"%s\"",
2717 elog(
ERROR,
"failed to fetch tuple for EvalPlanQual recheck");
2732 elog(
ERROR,
"failed to fetch tuple for EvalPlanQual recheck");
2780 if (recheckestate == NULL)
2799 rtsize *
sizeof(
bool));
2977 Assert(rtindex > 0 && rtindex <= rtsize);
2982 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)
#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 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)
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)
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)
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)
#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)
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)
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)
#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
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
uint64 es_total_processed
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)