187 foreach(lc, targetList)
194 if (attno >= resultDesc->
natts)
196 (
errcode(ERRCODE_DATATYPE_MISMATCH),
197 errmsg(
"table row type and query-specified row type do not match"),
198 errdetail(
"Query has too many columns.")));
202 if (!attr->attisdropped)
207 (
errcode(ERRCODE_DATATYPE_MISMATCH),
208 errmsg(
"table row type and query-specified row type do not match"),
209 errdetail(
"Table has type %s at ordinal position %d, but query expects %s.",
224 (
errcode(ERRCODE_DATATYPE_MISMATCH),
225 errmsg(
"table row type and query-specified row type do not match"),
226 errdetail(
"Query provides a value for a dropped column at ordinal position %d.",
230 if (attno != resultDesc->
natts)
232 (
errcode(ERRCODE_DATATYPE_MISMATCH),
233 errmsg(
"table row type and query-specified row type do not match"),
234 errdetail(
"Query has too few columns.")));
308 errmsg(
"could not serialize access due to concurrent update")));
328 elog(
ERROR,
"failed to fetch conflicting tuple for ON CONFLICT");
352 int natts = tupdesc->
natts;
354 int ri_NumGeneratedNeeded;
381 ri_NumGeneratedNeeded = 0;
383 for (
int i = 0;
i < natts;
i++)
385 if (
TupleDescAttr(tupdesc,
i)->attgenerated == ATTRIBUTE_GENERATED_STORED)
392 elog(
ERROR,
"no generation expression found for column number %d of table \"%s\"",
411 ri_NumGeneratedNeeded++;
452 int natts = tupdesc->
natts;
486 nulls =
palloc(
sizeof(*nulls) * natts);
489 memcpy(nulls, slot->
tts_isnull,
sizeof(*nulls) * natts);
491 for (
int i = 0;
i < natts;
i++)
495 if (ri_GeneratedExprs[
i])
500 Assert(attr->attgenerated == ATTRIBUTE_GENERATED_STORED);
525 memcpy(slot->
tts_isnull, nulls,
sizeof(*nulls) * natts);
549 bool need_projection =
false;
553 foreach(l, subplan->targetlist)
558 insertTargetList =
lappend(insertTargetList, tle);
560 need_projection =
true;
630 Assert(whichrel >= 0 && whichrel < mtstate->mt_nrels);
782 resultRelInfo = partRelInfo;
793 if (resultRelationDesc->
rd_rel->relhasindex &&
846 bool flushed =
false;
865 if (resultRelInfo->
ri_Slots == NULL)
1006 if (resultRelationDesc->
rd_rel->relispartition &&
1018 List *arbiterIndexes;
1037 specConflict =
false;
1039 &conflictTid, arbiterIndexes))
1053 &conflictTid, slot, canSetTag,
1100 slot, estate,
false,
true,
1107 specToken, !specConflict);
1141 slot, estate,
false,
1173 ar_insert_trig_tcs = NULL;
1178 ar_insert_trig_tcs);
1202 *inserted_tuple = slot;
1204 *insert_destrel = resultRelInfo;
1227 int numInserted = numSlots;
1240 for (
i = 0;
i < numInserted;
i++)
1262 if (canSetTag && numInserted > 0)
1320 resultRelInfo, tupleid, oldtuple,
1321 epqreturnslot, result, &context->
tmfd);
1359 ItemPointer tupleid,
bool changingPart,
bool lockUpdated)
1369 lazyEPQSlotPtr = &lazyEPQSlot;
1373 lazyEPQSlotPtr = NULL;
1420 ar_delete_trig_tcs = NULL;
1425 ar_delete_trig_tcs, changingPart);
1455 bool processReturning,
1467 *tupleDeleted =
false;
1474 epqreturnslot, NULL))
1483 Assert(oldtuple != NULL);
1527 result =
ExecDeleteAct(context, resultRelInfo, tupleid, changingPart,
1560 (
errcode(ERRCODE_TRIGGERED_DATA_CHANGE_VIOLATION),
1561 errmsg(
"tuple to be deleted was already modified by an operation triggered by the current command"),
1562 errhint(
"Consider using an AFTER trigger instead of a BEFORE trigger to propagate changes to other rows.")));
1578 errmsg(
"could not serialize access due to concurrent update")));
1592 if (processReturning &&
1619 *epqreturnslot = epqslot;
1630 errmsg(
"could not serialize access due to concurrent delete")));
1635 elog(
ERROR,
"unrecognized table_tuple_delete status: %u",
1655 *tupleDeleted =
true;
1681 if (oldtuple != NULL)
1689 elog(
ERROR,
"failed to fetch deleted tuple for DELETE RETURNING");
1755 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1756 errmsg(
"invalid ON UPDATE specification"),
1757 errdetail(
"The result tuple would appear in a different partition than the original tuple.")));
1798 &tuple_deleted, &epqslot);
1846 elog(
ERROR,
"failed to fetch tuple being updated");
1860 if (tupconv_map != NULL)
1868 inserted_tuple, insert_destrel);
1904 if (resultRelationDesc->
rd_rel->relhasindex &&
1917 resultRelInfo, tupleid, oldtuple, slot,
1918 result, &context->
tmfd);
1972 bool partition_constraint_failed;
2000 partition_constraint_failed =
2001 resultRelationDesc->
rd_rel->relispartition &&
2005 if (!partition_constraint_failed &&
2013 resultRelInfo, slot, estate);
2020 if (partition_constraint_failed)
2033 tupleid, oldtuple, slot,
2034 canSetTag, updateCxt,
2057 if (insert_destrel &&
2105 lazyEPQSlotPtr = &lazyEPQSlot;
2109 lazyEPQSlotPtr = NULL;
2119 if (result ==
TM_Ok)
2150 tupleid, oldtuple, slot,
2200 foreach(lc, ancestorRels)
2204 bool has_noncloned_fkey =
false;
2207 if (rInfo == rootRelInfo)
2219 has_noncloned_fkey =
true;
2225 if (has_noncloned_fkey)
2227 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
2228 errmsg(
"cannot move tuple across partitions when a non-root ancestor of the source partition is directly referenced in a foreign key"),
2229 errdetail(
"A foreign key points to ancestor \"%s\" but not the root ancestor \"%s\".",
2232 errhint(
"Consider defining the foreign key on table \"%s\".",
2238 rootRelInfo, sourcePartInfo, destPartInfo,
2239 tupleid, NULL, newslot,
NIL, NULL,
true);
2272 bool canSetTag,
bool locked)
2283 elog(
ERROR,
"cannot UPDATE during bootstrap");
2333 result =
ExecUpdateAct(context, resultRelInfo, tupleid, oldtuple, slot,
2374 (
errcode(ERRCODE_TRIGGERED_DATA_CHANGE_VIOLATION),
2375 errmsg(
"tuple to be updated was already modified by an operation triggered by the current command"),
2376 errhint(
"Consider using an AFTER trigger instead of a BEFORE trigger to propagate changes to other rows.")));
2393 errmsg(
"could not serialize access due to concurrent update")));
2435 errmsg(
"could not serialize access due to concurrent delete")));
2440 elog(
ERROR,
"unrecognized table_tuple_update status: %u",
2536 (
errcode(ERRCODE_CARDINALITY_VIOLATION),
2538 errmsg(
"%s command cannot affect row a second time",
2539 "ON CONFLICT DO UPDATE"),
2540 errhint(
"Ensure that no rows proposed for insertion within the same command have duplicate constrained values.")));
2543 elog(
ERROR,
"attempted to lock invisible tuple");
2553 elog(
ERROR,
"unexpected self-updated tuple");
2560 errmsg(
"could not serialize access due to concurrent update")));
2584 errmsg(
"could not serialize access due to concurrent delete")));
2592 elog(
ERROR,
"unrecognized table_tuple_lock status: %u",
test);
2623 if (!
ExecQual(onConflictSetWhere, econtext))
2665 *returning =
ExecUpdate(context, resultRelInfo,
2731 matched = tupleid != NULL;
2811 elog(
ERROR,
"failed to fetch the target tuple");
2851 switch (commandType)
2864 tupleid, NULL, newslot, &result))
2866 if (result ==
TM_Ok)
2870 result =
ExecUpdateAct(context, resultRelInfo, tupleid, NULL,
2871 newslot,
false,
false, &updateCxt);
2875 tupleid, NULL, newslot);
2883 NULL, NULL, &result))
2885 if (result ==
TM_Ok)
2891 if (result ==
TM_Ok)
2905 elog(
ERROR,
"unknown action in MERGE WHEN MATCHED clause");
2924 (
errcode(ERRCODE_CARDINALITY_VIOLATION),
2926 errmsg(
"%s command cannot affect row a second time",
2928 errhint(
"Ensure that not more than one source row matches any one target row.")));
2930 elog(
ERROR,
"attempted to update or delete invisible tuple");
2937 errmsg(
"could not serialize access due to concurrent delete")));
3009 errmsg(
"tuple to be deleted was already moved to another partition due to concurrent update")));
3022 goto lmerge_matched;
3047 (
errcode(ERRCODE_TRIGGERED_DATA_CHANGE_VIOLATION),
3048 errmsg(
"tuple to be updated or deleted was already modified by an operation triggered by the current command"),
3049 errhint(
"Consider using an AFTER trigger instead of a BEFORE trigger to propagate changes to other rows.")));
3054 elog(
ERROR,
"unexpected table_tuple_lock status: %u",
3064 elog(
ERROR,
"unexpected tuple operation result: %d", result);
3113 foreach(l, actionStates)
3130 switch (commandType)
3143 canSetTag, NULL, NULL);
3150 elog(
ERROR,
"unknown action in MERGE WHEN NOT MATCHED clause");
3202 if (
unlikely(!resultRelInfo->ri_projectNewInfoValid))
3205 foreach(l, mergeActionList)
3228 list = &resultRelInfo->ri_matchedMergeAction;
3230 list = &resultRelInfo->ri_notMatchedMergeAction;
3233 switch (
action->commandType)
3250 if (rootRelInfo->ri_RelationDesc->rd_rel->relkind ==
3251 RELKIND_PARTITIONED_TABLE)
3268 rootRelInfo->ri_RelationDesc);
3276 tgtslot = resultRelInfo->ri_newTupleSlot;
3295 resultRelInfo->ri_newTupleSlot,
3478 bool has_before_insert_row_trig;
3480 has_before_insert_row_trig = (partrel->
ri_TrigDesc &&
3484 !has_before_insert_row_trig ? slot : NULL;
3498 *partRelInfo = partrel;
3537 elog(
ERROR,
"ModifyTable should not be called during EvalPlanQual");
3675 if (relkind == RELKIND_RELATION ||
3676 relkind == RELKIND_MATVIEW ||
3677 relkind == RELKIND_PARTITIONED_TABLE)
3707 tuple_ctid = *tupleid;
3708 tupleid = &tuple_ctid;
3745 oldtuple = &oldtupdata;
3750 Assert(relkind == RELKIND_FOREIGN_TABLE);
3761 slot =
ExecInsert(&context, resultRelInfo, slot,
3775 if (oldtuple != NULL)
3788 elog(
ERROR,
"failed to fetch tuple being updated");
3795 slot =
ExecUpdate(&context, resultRelInfo, tupleid, oldtuple,
3800 slot =
ExecDelete(&context, resultRelInfo, tupleid, oldtuple,
3801 true,
false, node->
canSetTag, NULL, NULL);
3849 bool missing_ok,
bool update_cache)
3871 for (
int ndx = 0; ndx < node->
mt_nrels; ndx++)
3888 elog(
ERROR,
"incorrect result relation OID %u", resultoid);
4016 for (
i = 0;
i < nrels;
i++)
4046 if (relkind == RELKIND_RELATION ||
4047 relkind == RELKIND_MATVIEW ||
4048 relkind == RELKIND_PARTITIONED_TABLE)
4053 elog(
ERROR,
"could not find junk ctid column");
4055 else if (relkind == RELKIND_FOREIGN_TABLE)
4074 elog(
ERROR,
"could not find junk wholerow column");
4085 elog(
ERROR,
"could not find junk wholerow column");
4111 if (rel->
rd_rel->relkind == RELKIND_PARTITIONED_TABLE &&
4126 foreach(ll, wcoList)
4132 wcoExprs =
lappend(wcoExprs, wcoExpr);
4275 arowmarks =
lappend(arowmarks, aerm);
4292 #ifdef USE_ASSERT_CHECKING
4293 #define MT_NRELS_HASH 4
4295 #define MT_NRELS_HASH 64
4308 for (
i = 0;
i < nrels;
i++)
4448 elog(
ERROR,
"ExecReScanModifyTable is not implemented");
#define AttributeNumberIsValid(attributeNumber)
bool bms_is_member(int x, const Bitmapset *a)
Bitmapset * bms_add_member(Bitmapset *a, int x)
bool bms_overlap(const Bitmapset *a, const Bitmapset *b)
static Datum values[MAXATTR]
Datum datumCopy(Datum value, bool typByVal, int typLen)
elog(ERROR, "%s: %s", p2, msg)
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, bool onlySummarizing)
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)
Bitmapset * ExecGetUpdatedCols(ResultRelInfo *relinfo, EState *estate)
TupleTableSlot * ExecGetReturningSlot(EState *estate, ResultRelInfo *relInfo)
void ExecInitResultRelation(EState *estate, ResultRelInfo *resultRelInfo, Index rti)
void ExecAssignExprContext(EState *estate, PlanState *planstate)
TupleConversionMap * ExecGetRootToChildMap(ResultRelInfo *resultRelInfo, EState *estate)
TupleConversionMap * ExecGetChildToRootMap(ResultRelInfo *resultRelInfo)
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)
if(TABLE==NULL||TABLE_index==NULL)
static void ItemPointerSetInvalid(ItemPointerData *pointer)
static bool ItemPointerIndicatesMovedPartitions(const ItemPointerData *pointer)
ItemPointerData * ItemPointer
static void ItemPointerCopy(const ItemPointerData *fromPointer, ItemPointerData *toPointer)
Assert(fmt[strlen(fmt) - 1] !='\n')
List * lappend(List *list, void *datum)
bool list_member_ptr(const List *list, const void *datum)
void list_free(List *list)
List * lcons(void *datum, List *list)
uint32 SpeculativeInsertionLockAcquire(TransactionId xid)
void SpeculativeInsertionLockRelease(TransactionId xid)
void * palloc0(Size size)
MemoryContext CurrentMemoryContext
#define IsBootstrapProcessingMode()
#define CHECK_FOR_INTERRUPTS()
Oid exprType(const Node *expr)
static void ExecInitInsertProjection(ModifyTableState *mtstate, ResultRelInfo *resultRelInfo)
static void ExecPendingInserts(EState *estate)
static void ExecSetupTransitionCaptureState(ModifyTableState *mtstate, EState *estate)
void ExecInitMergeTupleSlots(ModifyTableState *mtstate, ResultRelInfo *resultRelInfo)
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 * ExecInsert(ModifyTableContext *context, ResultRelInfo *resultRelInfo, TupleTableSlot *slot, bool canSetTag, TupleTableSlot **inserted_tuple, ResultRelInfo **insert_destrel)
void ExecInitStoredGenerated(ResultRelInfo *resultRelInfo, EState *estate, CmdType cmdtype)
static void ExecMergeNotMatched(ModifyTableContext *context, ResultRelInfo *resultRelInfo, bool canSetTag)
static bool ExecDeletePrologue(ModifyTableContext *context, ResultRelInfo *resultRelInfo, ItemPointer tupleid, HeapTuple oldtuple, TupleTableSlot **epqreturnslot, TM_Result *result)
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 void ExecCheckTIDVisible(EState *estate, ResultRelInfo *relinfo, ItemPointer tid, TupleTableSlot *tempSlot)
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)
struct MTTargetRelLookup MTTargetRelLookup
static TM_Result ExecDeleteAct(ModifyTableContext *context, ResultRelInfo *resultRelInfo, ItemPointer tupleid, bool changingPart, bool lockUpdated)
ResultRelInfo * ExecLookupResultRelByOid(ModifyTableState *node, Oid resultoid, bool missing_ok, bool update_cache)
struct UpdateContext UpdateContext
static void ExecUpdateEpilogue(ModifyTableContext *context, UpdateContext *updateCxt, ResultRelInfo *resultRelInfo, ItemPointer tupleid, HeapTuple oldtuple, TupleTableSlot *slot)
static bool ExecCrossPartitionUpdate(ModifyTableContext *context, ResultRelInfo *resultRelInfo, ItemPointer tupleid, HeapTuple oldtuple, TupleTableSlot *slot, bool canSetTag, UpdateContext *updateCxt, TupleTableSlot **retry_slot, TupleTableSlot **inserted_tuple, ResultRelInfo **insert_destrel)
static void fireBSTriggers(ModifyTableState *node)
static TupleTableSlot * ExecProcessReturning(ResultRelInfo *resultRelInfo, TupleTableSlot *tupleSlot, TupleTableSlot *planSlot)
void ExecReScanModifyTable(ModifyTableState *node)
static TupleTableSlot * ExecUpdate(ModifyTableContext *context, ResultRelInfo *resultRelInfo, ItemPointer tupleid, HeapTuple oldtuple, TupleTableSlot *slot, bool canSetTag, bool locked)
void ExecEndModifyTable(ModifyTableState *node)
static TM_Result ExecUpdateAct(ModifyTableContext *context, ResultRelInfo *resultRelInfo, ItemPointer tupleid, HeapTuple oldtuple, TupleTableSlot *slot, bool canSetTag, bool lockUpdated, UpdateContext *updateCxt)
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, TM_Result *result)
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 * GetEPQSlot(void *arg)
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)
#define forboth(cell1, list1, cell2, list2)
static void * list_nth(const List *list, int n)
#define ERRCODE_T_R_SERIALIZATION_FAILURE
static Oid DatumGetObjectId(Datum X)
static Pointer DatumGetPointer(Datum X)
static TransactionId DatumGetTransactionId(Datum 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_insert_pending_result_relations
MemoryContext es_query_cxt
struct EPQState * es_epq_active
List * es_insert_pending_modifytables
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
ResultRelInfo * resultRelInfo
ProjectionInfo * mas_proj
MergeActionState * relaction
TupleTableSlot * planSlot
TupleTableSlot * cpUpdateReturningSlot
ModifyTableState * mtstate
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
List * ri_WithCheckOptions
TupleTableSlot * ri_oldTupleSlot
TriggerDesc * ri_TrigDesc
Bitmapset * ri_extraUpdatedCols
ExprState ** ri_GeneratedExprsI
int ri_NumGeneratedNeededU
TupleTableSlot * ri_newTupleSlot
List * ri_WithCheckOptionExprs
ProjectionInfo * ri_projectNew
ProjectionInfo * ri_projectReturning
ExprState ** ri_GeneratedExprsU
struct FdwRoutine * ri_FdwRoutine
TupleTableSlot ** ri_PlanSlots
bool ri_usesFdwDirectModify
int ri_NumGeneratedNeededI
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
TU_UpdateIndexes updateIndexes
#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)
#define TUPLE_LOCK_FLAG_FIND_LAST_VERSION
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, TU_UpdateIndexes *update_indexes, LazyTupleTableSlot *lockedSlot)
static void table_tuple_insert(Relation rel, TupleTableSlot *slot, CommandId cid, int options, struct BulkInsertStateData *bistate)
static void table_tuple_insert_speculative(Relation rel, TupleTableSlot *slot, CommandId cid, int options, struct BulkInsertStateData *bistate, uint32 specToken)
static TM_Result table_tuple_delete(Relation rel, ItemPointer tid, CommandId cid, Snapshot snapshot, Snapshot crosscheck, bool wait, TM_FailureData *tmfd, bool changingPart, LazyTupleTableSlot *lockedSlot)
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)
bool ExecBRUpdateTriggers(EState *estate, EPQState *epqstate, ResultRelInfo *relinfo, ItemPointer tupleid, HeapTuple fdw_trigtuple, TupleTableSlot *newslot, TM_Result *tmresult, TM_FailureData *tmfd)
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)
void ExecASUpdateTriggers(EState *estate, ResultRelInfo *relinfo, TransitionCaptureState *transition_capture)
void ExecASDeleteTriggers(EState *estate, ResultRelInfo *relinfo, TransitionCaptureState *transition_capture)
bool ExecBRDeleteTriggers(EState *estate, EPQState *epqstate, ResultRelInfo *relinfo, ItemPointer tupleid, HeapTuple fdw_trigtuple, TupleTableSlot **epqslot, TM_Result *tmresult, TM_FailureData *tmfd)
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)
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)
#define MAKE_LAZY_TTS(lazySlot, callback, arg)
static void slot_getallattrs(TupleTableSlot *slot)
static void ExecMaterializeSlot(TupleTableSlot *slot)
void pull_varattnos(Node *node, Index varno, Bitmapset **varattnos)
bool TransactionIdIsCurrentTransactionId(TransactionId xid)
TransactionId GetCurrentTransactionId(void)
#define IsolationUsesXactSnapshot()