#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.