mirror of
https://github.com/postgres/postgres.git
synced 2025-10-25 13:17:41 +03:00
73eba5004a
Introduce a new conflict type, multiple_unique_conflicts, to handle cases where an incoming row during logical replication violates multiple UNIQUE constraints. Previously, the apply worker detected and reported only the first encountered key conflict (insert_exists/update_exists), causing repeated failures as each constraint violation needs to be handled one by one making the process slow and error-prone. With this patch, the apply worker checks all unique constraints upfront once the first key conflict is detected and reports multiple_unique_conflicts if multiple violations exist. This allows users to resolve all conflicts at once by deleting all conflicting tuples rather than dealing with them individually or skipping the transaction. In the future, this will also allow us to specify different resolution handlers for such a conflict type. Add the stats for this conflict type in pg_stat_subscription_stats. Author: Nisha Moond <nisha.moond412@gmail.com> Author: Zhijie Hou <houzj.fnst@fujitsu.com> Reviewed-by: Amit Kapila <amit.kapila16@gmail.com> Reviewed-by: Peter Smith <smithpb2250@gmail.com> Reviewed-by: Dilip Kumar <dilipbalaut@gmail.com> Discussion: https://postgr.es/m/CABdArM7FW-_dnthGkg2s0fy1HhUB8C3ELA0gZX1kkbs1ZZoV3Q@mail.gmail.com
83 lines
2.6 KiB
C
83 lines
2.6 KiB
C
/*-------------------------------------------------------------------------
|
|
* conflict.h
|
|
* Exports for conflicts logging.
|
|
*
|
|
* Copyright (c) 2024-2025, PostgreSQL Global Development Group
|
|
*
|
|
*-------------------------------------------------------------------------
|
|
*/
|
|
#ifndef CONFLICT_H
|
|
#define CONFLICT_H
|
|
|
|
#include "nodes/execnodes.h"
|
|
#include "utils/timestamp.h"
|
|
|
|
/*
|
|
* Conflict types that could occur while applying remote changes.
|
|
*
|
|
* This enum is used in statistics collection (see
|
|
* PgStat_StatSubEntry::conflict_count and
|
|
* PgStat_BackendSubEntry::conflict_count) as well, therefore, when adding new
|
|
* values or reordering existing ones, ensure to review and potentially adjust
|
|
* the corresponding statistics collection codes.
|
|
*/
|
|
typedef enum
|
|
{
|
|
/* 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,
|
|
|
|
/* 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;
|
|
|
|
#define CONFLICT_NUM_TYPES (CT_MULTIPLE_UNIQUE_CONFLICTS + 1)
|
|
|
|
/*
|
|
* Information for the existing local tuple that caused the conflict.
|
|
*/
|
|
typedef struct ConflictTupleInfo
|
|
{
|
|
TupleTableSlot *slot; /* tuple slot holding the conflicting local
|
|
* tuple */
|
|
Oid indexoid; /* OID of the index where the conflict
|
|
* occurred */
|
|
TransactionId xmin; /* transaction ID of the modification causing
|
|
* the conflict */
|
|
RepOriginId origin; /* origin identifier of the modification */
|
|
TimestampTz ts; /* timestamp of when the modification on the
|
|
* conflicting local tuple occurred */
|
|
} ConflictTupleInfo;
|
|
|
|
extern bool GetTupleTransactionInfo(TupleTableSlot *localslot,
|
|
TransactionId *xmin,
|
|
RepOriginId *localorigin,
|
|
TimestampTz *localts);
|
|
extern void ReportApplyConflict(EState *estate, ResultRelInfo *relinfo,
|
|
int elevel, ConflictType type,
|
|
TupleTableSlot *searchslot,
|
|
TupleTableSlot *remoteslot,
|
|
List *conflicttuples);
|
|
extern void InitConflictIndexes(ResultRelInfo *relInfo);
|
|
#endif
|