#include "access/xlogdefs.h"
#include "nodes/pg_list.h"
#include "utils/timestamp.h"

Include dependency graph for conflict.h:

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

Data Structures
struct	ConflictTupleInfo

Macros
#define	CONFLICT_NUM_TYPES (CT_MULTIPLE_UNIQUE_CONFLICTS + 1)

Typedefs
typedef struct EState	EState

typedef struct ResultRelInfo	ResultRelInfo

typedef struct TupleTableSlot	TupleTableSlot

typedef struct ConflictTupleInfo	ConflictTupleInfo

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

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

void	ReportApplyConflict (EState estate, ResultRelInfo relinfo, int elevel, ConflictType type, TupleTableSlot searchslot, TupleTableSlot remoteslot, List *conflicttuples)

void	InitConflictIndexes (ResultRelInfo *relInfo)

Macro Definition Documentation

◆ CONFLICT_NUM_TYPES

#define CONFLICT_NUM_TYPES (CT_MULTIPLE_UNIQUE_CONFLICTS + 1)

Definition at line 64 of file conflict.h.

Typedef Documentation

◆ ConflictTupleInfo

typedef struct ConflictTupleInfo ConflictTupleInfo

◆ EState

typedef struct EState EState

Definition at line 17 of file conflict.h.

◆ ResultRelInfo

typedef struct ResultRelInfo ResultRelInfo

Definition at line 18 of file conflict.h.

◆ TupleTableSlot

typedef struct TupleTableSlot TupleTableSlot

Definition at line 19 of file conflict.h.

Enumeration Type Documentation

◆ ConflictType

enum ConflictType

Enumerator
CT_INSERT_EXISTS
CT_UPDATE_ORIGIN_DIFFERS
CT_UPDATE_EXISTS
CT_UPDATE_DELETED
CT_UPDATE_MISSING
CT_DELETE_ORIGIN_DIFFERS
CT_DELETE_MISSING
CT_MULTIPLE_UNIQUE_CONFLICTS

Definition at line 31 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 was concurrently deleted by a different origin */
    CT_UPDATE_DELETED,
 
    /* 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,
 
    /* The row to be inserted/updated violates multiple unique constraint */
    CT_MULTIPLE_UNIQUE_CONFLICTS,
 
    /*
     * 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 63 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 139 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 *	remoteslot,
		List *	conflicttuples
	)

Definition at line 104 of file conflict.c.

{
    Relation    localrel = relinfo->ri_RelationDesc;
    StringInfoData err_detail;
 
    initStringInfo(&err_detail);
 
    /* Form errdetail message by combining conflicting tuples information. */
    foreach_ptr(ConflictTupleInfo, conflicttuple, conflicttuples)
        errdetail_apply_conflict(estate, relinfo, type, searchslot,
                                 conflicttuple->slot, remoteslot,
                                 conflicttuple->indexoid,
                                 conflicttuple->xmin,
                                 conflicttuple->origin,
                                 conflicttuple->ts,
                                 &err_detail);
 
    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_internal("%s", err_detail.data));
}

References ConflictTypeNames, StringInfoData::data, ereport, errcode_apply_conflict(), errdetail_apply_conflict(), errdetail_internal(), errmsg(), foreach_ptr, get_namespace_name(), initStringInfo(), MySubscription, Subscription::oid, pgstat_report_subscription_conflict(), RelationGetNamespace, RelationGetRelationName, ResultRelInfo::ri_RelationDesc, and type.