conflict.h File Reference

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

Go to the source code of 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  )

extern

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(), fb(), 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 )

extern

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 fb(), i, lappend_oid(), NIL, RelationData::rd_index, and RelationGetRelid.

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  )

extern

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, ereport, errcode_apply_conflict(), errdetail_apply_conflict(), errdetail_internal(), errmsg(), fb(), foreach_ptr, get_namespace_name(), initStringInfo(), MySubscription, Subscription::oid, pgstat_report_subscription_conflict(), RelationGetNamespace, RelationGetRelationName, and type.

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