208 foreach(lc, targetList)
215 if (attno >= resultDesc->
natts)
217 (
errcode(ERRCODE_DATATYPE_MISMATCH),
218 errmsg(
"table row type and query-specified row type do not match"),
219 errdetail(
"Query has too many columns.")));
223 if (!attr->attisdropped)
228 (
errcode(ERRCODE_DATATYPE_MISMATCH),
229 errmsg(
"table row type and query-specified row type do not match"),
230 errdetail(
"Table has type %s at ordinal position %d, but query expects %s.",
245 (
errcode(ERRCODE_DATATYPE_MISMATCH),
246 errmsg(
"table row type and query-specified row type do not match"),
247 errdetail(
"Query provides a value for a dropped column at ordinal position %d.",
251 if (attno != resultDesc->
natts)
253 (
errcode(ERRCODE_DATATYPE_MISMATCH),
254 errmsg(
"table row type and query-specified row type do not match"),
255 errdetail(
"Query has too few columns.")));
329 errmsg(
"could not serialize access due to concurrent update")));
349 elog(
ERROR,
"failed to fetch conflicting tuple for ON CONFLICT");
364 int natts = tupdesc->
natts;
384 for (
int i = 0;
i < natts;
i++)
386 if (
TupleDescAttr(tupdesc,
i)->attgenerated == ATTRIBUTE_GENERATED_STORED)
407 elog(
ERROR,
"no generation expression found for column number %d of table \"%s\"",
428 nulls =
palloc(
sizeof(*nulls) * natts);
431 memcpy(nulls, slot->
tts_isnull,
sizeof(*nulls) * natts);
433 for (
int i = 0;
i < natts;
i++)
437 if (attr->attgenerated == ATTRIBUTE_GENERATED_STORED &&
468 memcpy(slot->
tts_isnull, nulls,
sizeof(*nulls) * natts);
492 bool need_projection =
false;
496 foreach(l, subplan->targetlist)
501 insertTargetList =
lappend(insertTargetList, tle);
503 need_projection =
true;
573 Assert(whichrel >= 0 && whichrel < mtstate->mt_nrels);
737 resultRelInfo = partRelInfo;
748 if (resultRelationDesc->
rd_rel->relhasindex &&
814 if (resultRelInfo->
ri_Slots == NULL)
933 if (resultRelationDesc->
rd_rel->relispartition &&
945 List *arbiterIndexes;
962 specConflict =
false;
964 &conflictTid, arbiterIndexes))
978 &conflictTid, slot, canSetTag,
1025 slot, estate,
false,
true,
1031 specToken, !specConflict);
1065 slot, estate,
false,
1096 ar_insert_trig_tcs = NULL;
1101 ar_insert_trig_tcs);
1125 *inserted_tuple = slot;
1127 *insert_destrel = resultRelInfo;
1150 int numInserted = numSlots;
1163 for (
i = 0;
i < numInserted;
i++)
1186 if (canSetTag && numInserted > 0)
1206 resultRelInfo, tupleid, oldtuple,
1269 ar_delete_trig_tcs = NULL;
1274 ar_delete_trig_tcs, changingPart);
1304 bool processReturning,
1316 *tupleDeleted =
false;
1332 Assert(oldtuple != NULL);
1376 result =
ExecDeleteAct(context, resultRelInfo, tupleid, changingPart);
1408 (
errcode(ERRCODE_TRIGGERED_DATA_CHANGE_VIOLATION),
1409 errmsg(
"tuple to be deleted was already modified by an operation triggered by the current command"),
1410 errhint(
"Consider using an AFTER trigger instead of a BEFORE trigger to propagate changes to other rows.")));
1426 errmsg(
"could not serialize access due to concurrent update")));
1461 *epqreturnslot = epqslot;
1482 (
errcode(ERRCODE_TRIGGERED_DATA_CHANGE_VIOLATION),
1483 errmsg(
"tuple to be deleted was already modified by an operation triggered by the current command"),
1484 errhint(
"Consider using an AFTER trigger instead of a BEFORE trigger to propagate changes to other rows.")));
1503 elog(
ERROR,
"unexpected table_tuple_lock status: %u",
1516 errmsg(
"could not serialize access due to concurrent delete")));
1527 elog(
ERROR,
"unrecognized table_tuple_delete status: %u",
1547 *tupleDeleted =
true;
1568 if (oldtuple != NULL)
1576 elog(
ERROR,
"failed to fetch deleted tuple for DELETE RETURNING");
1639 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1640 errmsg(
"invalid ON UPDATE specification"),
1641 errdetail(
"The result tuple would appear in a different partition than the original tuple.")));
1682 &tuple_deleted, &epqslot);
1726 elog(
ERROR,
"failed to fetch tuple being updated");
1741 if (tupconv_map != NULL)
1749 inserted_tuple, insert_destrel);
1781 if (resultRelationDesc->
rd_rel->relhasindex &&
1789 resultRelInfo, tupleid, oldtuple, slot,
1845 bool partition_constraint_failed;
1869 partition_constraint_failed =
1870 resultRelationDesc->
rd_rel->relispartition &&
1874 if (!partition_constraint_failed &&
1882 resultRelInfo, slot, estate);
1889 if (partition_constraint_failed)
1901 tupleid, oldtuple, slot,
1902 canSetTag, updateCxt,
1924 if (insert_destrel &&
1976 if (result ==
TM_Ok)
1992 List *recheckIndexes)
2006 tupleid, oldtuple, slot,
2054 foreach(lc, ancestorRels)
2058 bool has_noncloned_fkey =
false;
2061 if (rInfo == rootRelInfo)
2073 has_noncloned_fkey =
true;
2079 if (has_noncloned_fkey)
2081 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
2082 errmsg(
"cannot move tuple across partitions when a non-root ancestor of the source partition is directly referenced in a foreign key"),
2083 errdetail(
"A foreign key points to ancestor \"%s\", but not the root ancestor \"%s\".",
2086 errhint(
"Consider defining the foreign key on \"%s\".",
2092 rootRelInfo, sourcePartInfo, destPartInfo,
2093 tupleid, NULL, newslot,
NIL, NULL,
true);
2138 elog(
ERROR,
"cannot UPDATE during bootstrap");
2183 result =
ExecUpdateAct(context, resultRelInfo, tupleid, oldtuple, slot,
2184 canSetTag, &updateCxt);
2223 (
errcode(ERRCODE_TRIGGERED_DATA_CHANGE_VIOLATION),
2224 errmsg(
"tuple to be updated was already modified by an operation triggered by the current command"),
2225 errhint(
"Consider using an AFTER trigger instead of a BEFORE trigger to propagate changes to other rows.")));
2242 errmsg(
"could not serialize access due to concurrent update")));
2282 elog(
ERROR,
"failed to fetch tuple being updated");
2306 (
errcode(ERRCODE_TRIGGERED_DATA_CHANGE_VIOLATION),
2307 errmsg(
"tuple to be updated was already modified by an operation triggered by the current command"),
2308 errhint(
"Consider using an AFTER trigger instead of a BEFORE trigger to propagate changes to other rows.")));
2313 elog(
ERROR,
"unexpected table_tuple_lock status: %u",
2325 errmsg(
"could not serialize access due to concurrent delete")));
2330 elog(
ERROR,
"unrecognized table_tuple_update status: %u",
2340 slot, recheckIndexes);
2428 (
errcode(ERRCODE_CARDINALITY_VIOLATION),
2430 errmsg(
"%s command cannot affect row a second time",
2431 "ON CONFLICT DO UPDATE"),
2432 errhint(
"Ensure that no rows proposed for insertion within the same command have duplicate constrained values.")));
2435 elog(
ERROR,
"attempted to lock invisible tuple");
2445 elog(
ERROR,
"unexpected self-updated tuple");
2452 errmsg(
"could not serialize access due to concurrent update")));
2476 errmsg(
"could not serialize access due to concurrent delete")));
2484 elog(
ERROR,
"unrecognized table_tuple_lock status: %u",
test);
2515 if (!
ExecQual(onConflictSetWhere, econtext))
2557 *returning =
ExecUpdate(context, resultRelInfo,
2623 matched = tupleid != NULL;
2703 elog(
ERROR,
"failed to fetch the target tuple");
2744 switch (commandType)
2760 tupleid, NULL, newslot))
2766 result =
ExecUpdateAct(context, resultRelInfo, tupleid, NULL,
2767 newslot, mtstate->
canSetTag, &updateCxt);
2771 tupleid, NULL, newslot, recheckIndexes);
2785 result =
ExecDeleteAct(context, resultRelInfo, tupleid,
false);
2786 if (result ==
TM_Ok)
2800 elog(
ERROR,
"unknown action in MERGE WHEN MATCHED clause");
2819 (
errcode(ERRCODE_CARDINALITY_VIOLATION),
2821 errmsg(
"%s command cannot affect row a second time",
2823 errhint(
"Ensure that not more than one source row matches any one target row.")));
2825 elog(
ERROR,
"attempted to update or delete invisible tuple");
2832 errmsg(
"could not serialize access due to concurrent delete")));
2868 goto lmerge_matched;
2926 errmsg(
"tuple to be deleted was already moved to another partition due to concurrent update")));
2939 goto lmerge_matched;
2964 (
errcode(ERRCODE_TRIGGERED_DATA_CHANGE_VIOLATION),
2965 errmsg(
"tuple to be updated or deleted was already modified by an operation triggered by the current command"),
2966 errhint(
"Consider using an AFTER trigger instead of a BEFORE trigger to propagate changes to other rows.")));
2971 elog(
ERROR,
"unexpected table_tuple_lock status: %u",
2981 elog(
ERROR,
"unexpected tuple operation result: %d", result);
3030 foreach(l, actionStates)
3047 switch (commandType)
3060 canSetTag, NULL, NULL);
3067 elog(
ERROR,
"unknown action in MERGE WHEN NOT MATCHED clause");
3119 if (
unlikely(!resultRelInfo->ri_projectNewInfoValid))
3122 foreach(l, mergeActionList)
3145 list = &resultRelInfo->ri_matchedMergeAction;
3147 list = &resultRelInfo->ri_notMatchedMergeAction;
3150 switch (
action->commandType)
3167 if (rootRelInfo->ri_RelationDesc->rd_rel->relkind ==
3168 RELKIND_PARTITIONED_TABLE)
3185 rootRelInfo->ri_RelationDesc);
3193 tgtslot = resultRelInfo->ri_newTupleSlot;
3212 resultRelInfo->ri_newTupleSlot,
3414 bool has_before_insert_row_trig;
3416 has_before_insert_row_trig = (partrel->
ri_TrigDesc &&
3420 !has_before_insert_row_trig ? slot : NULL;
3434 *partRelInfo = partrel;
3476 elog(
ERROR,
"ModifyTable should not be called during EvalPlanQual");
3614 if (relkind == RELKIND_RELATION ||
3615 relkind == RELKIND_MATVIEW ||
3616 relkind == RELKIND_PARTITIONED_TABLE)
3646 tuple_ctid = *tupleid;
3647 tupleid = &tuple_ctid;
3684 oldtuple = &oldtupdata;
3689 Assert(relkind == RELKIND_FOREIGN_TABLE);
3700 slot =
ExecInsert(&context, resultRelInfo, slot,
3714 if (oldtuple != NULL)
3727 elog(
ERROR,
"failed to fetch tuple being updated");
3735 slot =
ExecUpdate(&context, resultRelInfo, tupleid, oldtuple,
3740 slot =
ExecDelete(&context, resultRelInfo, tupleid, oldtuple,
3741 true,
false, node->
canSetTag, NULL, NULL);
3769 foreach(lc, relinfos)
3771 resultRelInfo =
lfirst(lc);
3802 bool missing_ok,
bool update_cache)
3824 for (
int ndx = 0; ndx < node->
mt_nrels; ndx++)
3841 elog(
ERROR,
"incorrect result relation OID %u", resultoid);
3969 for (
i = 0;
i < nrels;
i++)
3999 if (relkind == RELKIND_RELATION ||
4000 relkind == RELKIND_MATVIEW ||
4001 relkind == RELKIND_PARTITIONED_TABLE)
4006 elog(
ERROR,
"could not find junk ctid column");
4008 else if (relkind == RELKIND_FOREIGN_TABLE)
4027 elog(
ERROR,
"could not find junk wholerow column");
4038 elog(
ERROR,
"could not find junk wholerow column");
4064 if (rel->
rd_rel->relkind == RELKIND_PARTITIONED_TABLE &&
4079 foreach(ll, wcoList)
4085 wcoExprs =
lappend(wcoExprs, wcoExpr);
4228 arowmarks =
lappend(arowmarks, aerm);
4245 #ifdef USE_ASSERT_CHECKING
4246 #define MT_NRELS_HASH 4
4248 #define MT_NRELS_HASH 64
4261 for (
i = 0;
i < nrels;
i++)
4401 elog(
ERROR,
"ExecReScanModifyTable is not implemented");
#define AttributeNumberIsValid(attributeNumber)
bool bms_is_member(int x, const Bitmapset *a)
static Datum values[MAXATTR]
Datum datumCopy(Datum value, bool typByVal, int typLen)
void * hash_search(HTAB *hashp, const void *keyPtr, HASHACTION action, bool *foundPtr)
HTAB * hash_create(const char *tabname, long nelem, const HASHCTL *info, int flags)
int errdetail(const char *fmt,...)
int errhint(const char *fmt,...)
int errcode(int sqlerrcode)
int errmsg(const char *fmt,...)
#define ereport(elevel,...)
ExprState * ExecPrepareExpr(Expr *node, EState *estate)
ProjectionInfo * ExecBuildUpdateProjection(List *targetList, bool evalTargetList, List *targetColnos, TupleDesc relDesc, ExprContext *econtext, TupleTableSlot *slot, PlanState *parent)
ExprState * ExecInitQual(List *qual, PlanState *parent)
ProjectionInfo * ExecBuildProjectionInfo(List *targetList, ExprContext *econtext, TupleTableSlot *slot, PlanState *parent, TupleDesc inputDesc)
bool ExecCheckIndexConstraints(ResultRelInfo *resultRelInfo, TupleTableSlot *slot, EState *estate, ItemPointer conflictTid, List *arbiterIndexes)
List * ExecInsertIndexTuples(ResultRelInfo *resultRelInfo, TupleTableSlot *slot, EState *estate, bool update, bool noDupErr, bool *specConflict, List *arbiterIndexes)
void ExecOpenIndices(ResultRelInfo *resultRelInfo, bool speculative)
AttrNumber ExecFindJunkAttributeInTlist(List *targetlist, const char *attrName)
LockTupleMode ExecUpdateLockMode(EState *estate, ResultRelInfo *relinfo)
void EvalPlanQualBegin(EPQState *epqstate)
TupleTableSlot * EvalPlanQual(EPQState *epqstate, Relation relation, Index rti, TupleTableSlot *inputslot)
bool ExecPartitionCheck(ResultRelInfo *resultRelInfo, TupleTableSlot *slot, EState *estate, bool emitError)
void ExecWithCheckOptions(WCOKind kind, ResultRelInfo *resultRelInfo, TupleTableSlot *slot, EState *estate)
ExecAuxRowMark * ExecBuildAuxRowMark(ExecRowMark *erm, List *targetlist)
void EvalPlanQualEnd(EPQState *epqstate)
void EvalPlanQualSetPlan(EPQState *epqstate, Plan *subplan, List *auxrowmarks)
void EvalPlanQualInit(EPQState *epqstate, EState *parentestate, Plan *subplan, List *auxrowmarks, int epqParam)
ExecRowMark * ExecFindRowMark(EState *estate, Index rti, bool missing_ok)
List * ExecGetAncestorResultRels(EState *estate, ResultRelInfo *resultRelInfo)
TupleTableSlot * EvalPlanQualSlot(EPQState *epqstate, Relation relation, Index rti)
void ExecPartitionCheckEmitError(ResultRelInfo *resultRelInfo, TupleTableSlot *slot, EState *estate)
void ExecConstraints(ResultRelInfo *resultRelInfo, TupleTableSlot *slot, EState *estate)
void CheckValidResultRel(ResultRelInfo *resultRelInfo, CmdType operation)
ResultRelInfo * ExecFindPartition(ModifyTableState *mtstate, ResultRelInfo *rootResultRelInfo, PartitionTupleRouting *proute, TupleTableSlot *slot, EState *estate)
PartitionTupleRouting * ExecSetupPartitionTupleRouting(EState *estate, Relation rel)
void ExecCleanupTupleRouting(ModifyTableState *mtstate, PartitionTupleRouting *proute)
void ExecEndNode(PlanState *node)
PlanState * ExecInitNode(Plan *node, EState *estate, int eflags)
const TupleTableSlotOps TTSOpsVirtual
TupleTableSlot * ExecStoreVirtualTuple(TupleTableSlot *slot)
void ExecDropSingleTupleTableSlot(TupleTableSlot *slot)
TupleTableSlot * ExecStoreAllNullTuple(TupleTableSlot *slot)
void ExecInitResultTypeTL(PlanState *planstate)
void ExecInitResultTupleSlotTL(PlanState *planstate, const TupleTableSlotOps *tts_ops)
TupleTableSlot * MakeSingleTupleTableSlot(TupleDesc tupdesc, const TupleTableSlotOps *tts_ops)
void ExecForceStoreHeapTuple(HeapTuple tuple, TupleTableSlot *slot, bool shouldFree)
TupleTableSlot * ExecGetReturningSlot(EState *estate, ResultRelInfo *relInfo)
void ExecInitResultRelation(EState *estate, ResultRelInfo *resultRelInfo, Index rti)
void ExecAssignExprContext(EState *estate, PlanState *planstate)
TupleConversionMap * ExecGetChildToRootMap(ResultRelInfo *resultRelInfo)
Bitmapset * ExecGetExtraUpdatedCols(ResultRelInfo *relinfo, EState *estate)
void ExecFreeExprContext(PlanState *planstate)
#define InstrCountFiltered1(node, delta)
#define outerPlanState(node)
#define InstrCountTuples2(node, delta)
#define EXEC_FLAG_BACKWARD
#define ResetPerTupleExprContext(estate)
#define GetPerTupleExprContext(estate)
static TupleTableSlot * ExecProject(ProjectionInfo *projInfo)
#define ResetExprContext(econtext)
#define GetPerTupleMemoryContext(estate)
static bool ExecQual(ExprState *state, ExprContext *econtext)
#define EvalPlanQualSetSlot(epqstate, slot)
static Datum ExecEvalExpr(ExprState *state, ExprContext *econtext, bool *isNull)
#define EXEC_FLAG_EXPLAIN_ONLY
static Datum ExecGetJunkAttribute(TupleTableSlot *slot, AttrNumber attno, bool *isNull)
static TupleTableSlot * ExecProcNode(PlanState *node)
#define DatumGetHeapTupleHeader(X)
#define HeapTupleHeaderGetDatumLength(tup)
#define ItemPointerCopy(fromPointer, toPointer)
#define ItemPointerIndicatesMovedPartitions(pointer)
ItemPointerData * ItemPointer
#define ItemPointerSetInvalid(pointer)
Assert(fmt[strlen(fmt) - 1] !='\n')
List * lappend(List *list, void *datum)
void list_free(List *list)
List * lcons(void *datum, List *list)
uint32 SpeculativeInsertionLockAcquire(TransactionId xid)
void SpeculativeInsertionLockRelease(TransactionId xid)
MemoryContext CurrentMemoryContext
#define IsBootstrapProcessingMode()
#define CHECK_FOR_INTERRUPTS()
Oid exprType(const Node *expr)
static void ExecInitInsertProjection(ModifyTableState *mtstate, ResultRelInfo *resultRelInfo)
static void ExecSetupTransitionCaptureState(ModifyTableState *mtstate, EState *estate)
void ExecInitMergeTupleSlots(ModifyTableState *mtstate, ResultRelInfo *resultRelInfo)
static bool ExecDeletePrologue(ModifyTableContext *context, ResultRelInfo *resultRelInfo, ItemPointer tupleid, HeapTuple oldtuple, TupleTableSlot **epqreturnslot)
static TupleTableSlot * ExecMerge(ModifyTableContext *context, ResultRelInfo *resultRelInfo, ItemPointer tupleid, bool canSetTag)
struct ModifyTableContext ModifyTableContext
static void ExecUpdatePrepareSlot(ResultRelInfo *resultRelInfo, TupleTableSlot *slot, EState *estate)
static TupleTableSlot * mergeGetUpdateNewTuple(ResultRelInfo *relinfo, TupleTableSlot *planSlot, TupleTableSlot *oldSlot, MergeActionState *relaction)
static TupleTableSlot * ExecInsert(ModifyTableContext *context, ResultRelInfo *resultRelInfo, TupleTableSlot *slot, bool canSetTag, TupleTableSlot **inserted_tuple, ResultRelInfo **insert_destrel)
static void ExecMergeNotMatched(ModifyTableContext *context, ResultRelInfo *resultRelInfo, bool canSetTag)
static void ExecCheckPlanOutput(Relation resultRel, List *targetList)
static TupleTableSlot * ExecModifyTable(PlanState *pstate)
static void ExecCrossPartitionUpdateForeignKey(ModifyTableContext *context, ResultRelInfo *sourcePartInfo, ResultRelInfo *destPartInfo, ItemPointer tupleid, TupleTableSlot *oldslot, TupleTableSlot *newslot)
TupleTableSlot * ExecGetUpdateNewTuple(ResultRelInfo *relinfo, TupleTableSlot *planSlot, TupleTableSlot *oldSlot)
static void ExecInitUpdateProjection(ModifyTableState *mtstate, ResultRelInfo *resultRelInfo)
static bool ExecCrossPartitionUpdate(ModifyTableContext *context, ResultRelInfo *resultRelInfo, ItemPointer tupleid, HeapTuple oldtuple, TupleTableSlot *slot, bool canSetTag, UpdateContext *updateCxt, TupleTableSlot **inserted_tuple, ResultRelInfo **insert_destrel)
static void ExecCheckTIDVisible(EState *estate, ResultRelInfo *relinfo, ItemPointer tid, TupleTableSlot *tempSlot)
static TM_Result ExecDeleteAct(ModifyTableContext *context, ResultRelInfo *resultRelInfo, ItemPointer tupleid, bool changingPart)
static void ExecCheckTupleVisible(EState *estate, Relation rel, TupleTableSlot *slot)
static TupleTableSlot * ExecGetInsertNewTuple(ResultRelInfo *relinfo, TupleTableSlot *planSlot)
void ExecComputeStoredGenerated(ResultRelInfo *resultRelInfo, EState *estate, TupleTableSlot *slot, CmdType cmdtype)
static TupleTableSlot * ExecPrepareTupleRouting(ModifyTableState *mtstate, EState *estate, PartitionTupleRouting *proute, ResultRelInfo *targetRelInfo, TupleTableSlot *slot, ResultRelInfo **partRelInfo)
static void ExecUpdateEpilogue(ModifyTableContext *context, UpdateContext *updateCxt, ResultRelInfo *resultRelInfo, ItemPointer tupleid, HeapTuple oldtuple, TupleTableSlot *slot, List *recheckIndexes)
struct MTTargetRelLookup MTTargetRelLookup
static TupleTableSlot * ExecUpdate(ModifyTableContext *context, ResultRelInfo *resultRelInfo, ItemPointer tupleid, HeapTuple oldtuple, TupleTableSlot *slot, bool canSetTag)
ResultRelInfo * ExecLookupResultRelByOid(ModifyTableState *node, Oid resultoid, bool missing_ok, bool update_cache)
struct UpdateContext UpdateContext
static TM_Result ExecUpdateAct(ModifyTableContext *context, ResultRelInfo *resultRelInfo, ItemPointer tupleid, HeapTuple oldtuple, TupleTableSlot *slot, bool canSetTag, UpdateContext *updateCxt)
static TupleTableSlot * internalGetUpdateNewTuple(ResultRelInfo *relinfo, TupleTableSlot *planSlot, TupleTableSlot *oldSlot, MergeActionState *relaction)
static void fireBSTriggers(ModifyTableState *node)
static TupleTableSlot * ExecProcessReturning(ResultRelInfo *resultRelInfo, TupleTableSlot *tupleSlot, TupleTableSlot *planSlot)
void ExecReScanModifyTable(ModifyTableState *node)
void ExecEndModifyTable(ModifyTableState *node)
ModifyTableState * ExecInitModifyTable(ModifyTable *node, EState *estate, int eflags)
static void fireASTriggers(ModifyTableState *node)
static bool ExecOnConflictUpdate(ModifyTableContext *context, ResultRelInfo *resultRelInfo, ItemPointer conflictTid, TupleTableSlot *excludedSlot, bool canSetTag, TupleTableSlot **returning)
static void ExecBatchInsert(ModifyTableState *mtstate, ResultRelInfo *resultRelInfo, TupleTableSlot **slots, TupleTableSlot **planSlots, int numSlots, EState *estate, bool canSetTag)
static bool ExecUpdatePrologue(ModifyTableContext *context, ResultRelInfo *resultRelInfo, ItemPointer tupleid, HeapTuple oldtuple, TupleTableSlot *slot)
static void ExecDeleteEpilogue(ModifyTableContext *context, ResultRelInfo *resultRelInfo, ItemPointer tupleid, HeapTuple oldtuple, bool changingPart)
static bool ExecMergeMatched(ModifyTableContext *context, ResultRelInfo *resultRelInfo, ItemPointer tupleid, bool canSetTag)
static void ExecInitMerge(ModifyTableState *mtstate, EState *estate)
static TupleTableSlot * ExecDelete(ModifyTableContext *context, ResultRelInfo *resultRelInfo, ItemPointer tupleid, HeapTuple oldtuple, bool processReturning, bool changingPart, bool canSetTag, bool *tupleDeleted, TupleTableSlot **epqreturnslot)
#define IsA(nodeptr, _type_)
#define castNode(_type_, nodeptr)
static MemoryContext MemoryContextSwitchTo(MemoryContext context)
@ WCO_RLS_MERGE_UPDATE_CHECK
@ WCO_RLS_MERGE_DELETE_CHECK
FormData_pg_attribute * Form_pg_attribute
#define lfirst_node(type, lc)
static int list_length(const List *l)
static void * list_nth(const List *list, int n)
#define ERRCODE_T_R_SERIALIZATION_FAILURE
#define DatumGetTransactionId(X)
#define DatumGetObjectId(X)
#define DatumGetPointer(X)
#define RelationGetRelid(relation)
#define RelationGetDescr(relation)
#define RelationGetRelationName(relation)
Node * build_column_default(Relation rel, int attrno)
int RI_FKey_trigger_type(Oid tgfoid)
List * es_tuple_routing_result_relations
MemoryContext es_query_cxt
struct EPQState * es_epq_active
List * es_opened_result_relations
List * es_auxmodifytables
Snapshot es_crosscheck_snapshot
TupleTableSlot * ecxt_innertuple
TupleTableSlot * ecxt_scantuple
TupleTableSlot * ecxt_outertuple
BeginForeignModify_function BeginForeignModify
EndForeignModify_function EndForeignModify
ExecForeignInsert_function ExecForeignInsert
ExecForeignUpdate_function ExecForeignUpdate
ExecForeignBatchInsert_function ExecForeignBatchInsert
GetForeignModifyBatchSize_function GetForeignModifyBatchSize
ExecForeignDelete_function ExecForeignDelete
ProjectionInfo * mas_proj
MergeActionState * relaction
TupleTableSlot * planSlot
TupleTableSlot *(* GetUpdateNewTuple)(ResultRelInfo *resultRelInfo, TupleTableSlot *epqslot, TupleTableSlot *oldSlot, MergeActionState *relaction)
TupleTableSlot * cpUpdateReturningSlot
ModifyTableState * mtstate
TupleTableSlot * cpUpdateRetrySlot
ResultRelInfo * resultRelInfo
struct PartitionTupleRouting * mt_partition_tuple_routing
TupleTableSlot * mt_root_tuple_slot
ResultRelInfo * rootResultRelInfo
struct TransitionCaptureState * mt_transition_capture
struct TransitionCaptureState * mt_oc_transition_capture
Bitmapset * fdwDirectModifyPlans
List * withCheckOptionLists
OnConflictAction onConflictAction
TupleTableSlot * oc_ProjSlot
TupleTableSlot * oc_Existing
ExprState * oc_WhereClause
ProjectionInfo * oc_ProjInfo
ExprContext * ps_ExprContext
TupleTableSlot * ps_ResultTupleSlot
ExecProcNodeMtd ExecProcNode
ExprContext * pi_exprContext
List * ri_matchedMergeAction
TupleTableSlot * ri_PartitionTupleSlot
List * ri_notMatchedMergeAction
bool ri_projectNewInfoValid
OnConflictSetState * ri_onConflict
List * ri_onConflictArbiterIndexes
struct ResultRelInfo * ri_RootResultRelInfo
TupleTableSlot ** ri_Slots
RelationPtr ri_IndexRelationDescs
int ri_NumSlotsInitialized
ExprState ** ri_GeneratedExprs
List * ri_WithCheckOptions
TupleTableSlot * ri_oldTupleSlot
TriggerDesc * ri_TrigDesc
TupleTableSlot * ri_newTupleSlot
List * ri_WithCheckOptionExprs
ProjectionInfo * ri_projectNew
ProjectionInfo * ri_projectReturning
struct FdwRoutine * ri_FdwRoutine
int ri_NumGeneratedNeeded
TupleConversionMap * ri_RootToPartitionMap
TupleTableSlot ** ri_PlanSlots
bool ri_usesFdwDirectModify
TupleTableSlot * tcs_original_insert_tuple
bool tcs_update_new_table
bool tcs_update_old_table
bool trig_delete_before_row
bool trig_update_instead_row
bool trig_delete_instead_row
bool trig_update_after_row
bool trig_insert_instead_row
bool trig_update_before_row
bool trig_insert_before_row
bool has_generated_stored
TupleDesc tts_tupleDescriptor
const TupleTableSlotOps *const tts_ops
#define MinTransactionIdAttributeNumber
#define FirstLowInvalidHeapAttributeNumber
TupleTableSlot * table_slot_create(Relation relation, List **reglist)
static TM_Result table_tuple_lock(Relation rel, ItemPointer tid, Snapshot snapshot, TupleTableSlot *slot, CommandId cid, LockTupleMode mode, LockWaitPolicy wait_policy, uint8 flags, TM_FailureData *tmfd)
static void table_tuple_complete_speculative(Relation rel, TupleTableSlot *slot, uint32 specToken, bool succeeded)
static TM_Result table_tuple_delete(Relation rel, ItemPointer tid, CommandId cid, Snapshot snapshot, Snapshot crosscheck, bool wait, TM_FailureData *tmfd, bool changingPart)
#define TUPLE_LOCK_FLAG_FIND_LAST_VERSION
static void table_tuple_insert(Relation rel, TupleTableSlot *slot, CommandId cid, int options, struct BulkInsertStateData *bistate)
static TM_Result table_tuple_update(Relation rel, ItemPointer otid, TupleTableSlot *slot, CommandId cid, Snapshot snapshot, Snapshot crosscheck, bool wait, TM_FailureData *tmfd, LockTupleMode *lockmode, bool *update_indexes)
static void table_tuple_insert_speculative(Relation rel, TupleTableSlot *slot, CommandId cid, int options, struct BulkInsertStateData *bistate, uint32 specToken)
static bool table_tuple_satisfies_snapshot(Relation rel, TupleTableSlot *slot, Snapshot snapshot)
static bool table_tuple_fetch_row_version(Relation rel, ItemPointer tid, Snapshot snapshot, TupleTableSlot *slot)
void ExecARDeleteTriggers(EState *estate, ResultRelInfo *relinfo, ItemPointer tupleid, HeapTuple fdw_trigtuple, TransitionCaptureState *transition_capture, bool is_crosspart_update)
void ExecBSInsertTriggers(EState *estate, ResultRelInfo *relinfo)
bool ExecBRInsertTriggers(EState *estate, ResultRelInfo *relinfo, TupleTableSlot *slot)
bool ExecIRDeleteTriggers(EState *estate, ResultRelInfo *relinfo, HeapTuple trigtuple)
void ExecBSDeleteTriggers(EState *estate, ResultRelInfo *relinfo)
bool ExecIRInsertTriggers(EState *estate, ResultRelInfo *relinfo, TupleTableSlot *slot)
void ExecARUpdateTriggers(EState *estate, ResultRelInfo *relinfo, ResultRelInfo *src_partinfo, ResultRelInfo *dst_partinfo, ItemPointer tupleid, HeapTuple fdw_trigtuple, TupleTableSlot *newslot, List *recheckIndexes, TransitionCaptureState *transition_capture, bool is_crosspart_update)
bool ExecBRUpdateTriggers(EState *estate, EPQState *epqstate, ResultRelInfo *relinfo, ItemPointer tupleid, HeapTuple fdw_trigtuple, TupleTableSlot *newslot, TM_FailureData *tmfd)
void ExecASUpdateTriggers(EState *estate, ResultRelInfo *relinfo, TransitionCaptureState *transition_capture)
void ExecASDeleteTriggers(EState *estate, ResultRelInfo *relinfo, TransitionCaptureState *transition_capture)
void ExecARInsertTriggers(EState *estate, ResultRelInfo *relinfo, TupleTableSlot *slot, List *recheckIndexes, TransitionCaptureState *transition_capture)
TransitionCaptureState * MakeTransitionCaptureState(TriggerDesc *trigdesc, Oid relid, CmdType cmdType)
void ExecASInsertTriggers(EState *estate, ResultRelInfo *relinfo, TransitionCaptureState *transition_capture)
bool ExecIRUpdateTriggers(EState *estate, ResultRelInfo *relinfo, HeapTuple trigtuple, TupleTableSlot *newslot)
bool ExecBRDeleteTriggers(EState *estate, EPQState *epqstate, ResultRelInfo *relinfo, ItemPointer tupleid, HeapTuple fdw_trigtuple, TupleTableSlot **epqslot)
void ExecBSUpdateTriggers(EState *estate, ResultRelInfo *relinfo)
TupleTableSlot * execute_attr_map_slot(AttrMap *attrMap, TupleTableSlot *in_slot, TupleTableSlot *out_slot)
TupleDesc CreateTupleDescCopy(TupleDesc tupdesc)
#define TupleDescAttr(tupdesc, i)
static TupleTableSlot * ExecClearTuple(TupleTableSlot *slot)
static TupleTableSlot * ExecCopySlot(TupleTableSlot *dstslot, TupleTableSlot *srcslot)
static Datum slot_getsysattr(TupleTableSlot *slot, int attnum, bool *isnull)
static void slot_getallattrs(TupleTableSlot *slot)
static void ExecMaterializeSlot(TupleTableSlot *slot)
bool TransactionIdIsCurrentTransactionId(TransactionId xid)
TransactionId GetCurrentTransactionId(void)
#define IsolationUsesXactSnapshot()