#include "nodes/execnodes.h"
#include "utils/timestamp.h"

Include dependency graph for conflict.h:

This graph shows which files directly or indirectly include this file:

Macros
#define	CONFLICT_NUM_TYPES (CT_DELETE_MISSING + 1)

Enumerations
enum	ConflictType { CT_INSERT_EXISTS , CT_UPDATE_ORIGIN_DIFFERS , CT_UPDATE_EXISTS , CT_UPDATE_MISSING , CT_DELETE_ORIGIN_DIFFERS , CT_DELETE_MISSING }

Functions
bool	GetTupleTransactionInfo (TupleTableSlot localslot, TransactionId xmin, RepOriginId localorigin, TimestampTz localts)

void	ReportApplyConflict (EState estate, ResultRelInfo relinfo, int elevel, ConflictType type, TupleTableSlot searchslot, TupleTableSlot localslot, TupleTableSlot *remoteslot, Oid indexoid, TransactionId localxmin, RepOriginId localorigin, TimestampTz localts)

void	InitConflictIndexes (ResultRelInfo *relInfo)

Macro Definition Documentation

◆ CONFLICT_NUM_TYPES

#define CONFLICT_NUM_TYPES (CT_DELETE_MISSING + 1)

Definition at line 51 of file conflict.h.

Enumeration Type Documentation

◆ ConflictType

enum ConflictType

Enumerator
CT_INSERT_EXISTS
CT_UPDATE_ORIGIN_DIFFERS
CT_UPDATE_EXISTS
CT_UPDATE_MISSING
CT_DELETE_ORIGIN_DIFFERS
CT_DELETE_MISSING

Definition at line 24 of file conflict.h.

 {
     /* The row to be inserted violates unique constraint */
     CT_INSERT_EXISTS,
  
     /* The row to be updated was modified by a different origin */
     CT_UPDATE_ORIGIN_DIFFERS,
  
     /* The updated row value violates unique constraint */
     CT_UPDATE_EXISTS,
  
     /* The row to be updated is missing */
     CT_UPDATE_MISSING,
  
     /* The row to be deleted was modified by a different origin */
     CT_DELETE_ORIGIN_DIFFERS,
  
     /* The row to be deleted is missing */
     CT_DELETE_MISSING,
  
     /*
      * Other conflicts, such as exclusion constraint violations, involve more
      * complex rules than simple equality checks. These conflicts are left for
      * future improvements.
      */
 } ConflictType;

Function Documentation

◆ GetTupleTransactionInfo()

bool GetTupleTransactionInfo	(	TupleTableSlot *	localslot,
		TransactionId *	xmin,
		RepOriginId *	localorigin,
		TimestampTz *	localts
	)

Definition at line 61 of file conflict.c.

 {
     Datum       xminDatum;
     bool        isnull;
  
     xminDatum = slot_getsysattr(localslot, MinTransactionIdAttributeNumber,
                                 &isnull);
     *xmin = DatumGetTransactionId(xminDatum);
     Assert(!isnull);
  
     /*
      * The commit timestamp data is not available if track_commit_timestamp is
      * disabled.
      */
     if (!track_commit_timestamp)
     {
         *localorigin = InvalidRepOriginId;
         *localts = 0;
         return false;
     }
  
     return TransactionIdGetCommitTsData(*xmin, localts, localorigin);
 }

References Assert, DatumGetTransactionId(), InvalidRepOriginId, MinTransactionIdAttributeNumber, slot_getsysattr(), track_commit_timestamp, and TransactionIdGetCommitTsData().

Referenced by apply_handle_delete_internal(), apply_handle_tuple_routing(), apply_handle_update_internal(), and CheckAndReportConflict().

◆ InitConflictIndexes()

void InitConflictIndexes ( ResultRelInfo * relInfo )

Definition at line 136 of file conflict.c.

 {
     List       *uniqueIndexes = NIL;
  
     for (int i = 0; i < relInfo->ri_NumIndices; i++)
     {
         Relation    indexRelation = relInfo->ri_IndexRelationDescs[i];
  
         if (indexRelation == NULL)
             continue;
  
         /* Detect conflict only for unique indexes */
         if (!relInfo->ri_IndexRelationInfo[i]->ii_Unique)
             continue;
  
         /* Don't support conflict detection for deferrable index */
         if (!indexRelation->rd_index->indimmediate)
             continue;
  
         uniqueIndexes = lappend_oid(uniqueIndexes,
                                     RelationGetRelid(indexRelation));
     }
  
     relInfo->ri_onConflictArbiterIndexes = uniqueIndexes;
 }

References i, IndexInfo::ii_Unique, lappend_oid(), NIL, RelationData::rd_index, RelationGetRelid, ResultRelInfo::ri_IndexRelationDescs, ResultRelInfo::ri_IndexRelationInfo, ResultRelInfo::ri_NumIndices, and ResultRelInfo::ri_onConflictArbiterIndexes.

Referenced by apply_handle_insert_internal(), apply_handle_tuple_routing(), and apply_handle_update_internal().

◆ ReportApplyConflict()

void ReportApplyConflict	(	EState *	estate,
		ResultRelInfo *	relinfo,
		int	elevel,
		ConflictType	type,
		TupleTableSlot *	searchslot,
		TupleTableSlot *	localslot,
		TupleTableSlot *	remoteslot,
		Oid	indexoid,
		TransactionId	localxmin,
		RepOriginId	localorigin,
		TimestampTz	localts
	)

Definition at line 107 of file conflict.c.

 {
     Relation    localrel = relinfo->ri_RelationDesc;
  
     Assert(!OidIsValid(indexoid) ||
            CheckRelationOidLockedByMe(indexoid, RowExclusiveLock, true));
  
     pgstat_report_subscription_conflict(MySubscription->oid, type);
  
     ereport(elevel,
             errcode_apply_conflict(type),
             errmsg("conflict detected on relation \"%s.%s\": conflict=%s",
                    get_namespace_name(RelationGetNamespace(localrel)),
                    RelationGetRelationName(localrel),
                    ConflictTypeNames[type]),
             errdetail_apply_conflict(estate, relinfo, type, searchslot,
                                      localslot, remoteslot, indexoid,
                                      localxmin, localorigin, localts));
 }

References Assert, CheckRelationOidLockedByMe(), ConflictTypeNames, ereport, errcode_apply_conflict(), errdetail_apply_conflict(), errmsg(), get_namespace_name(), MySubscription, Subscription::oid, OidIsValid, pgstat_report_subscription_conflict(), RelationGetNamespace, RelationGetRelationName, ResultRelInfo::ri_RelationDesc, RowExclusiveLock, and type.