From 4ab2d5f6b4651b6cdad47a170f53147bb7d8d5c2 Mon Sep 17 00:00:00 2001 From: Yugo Nagata Date: Thu, 5 Jun 2025 15:32:37 +0900 Subject: [PATCH v3 3/3] Improve error reporting for concurrent updates on system catalog tuples Previously, when multiple sessions attempted to modify the same system catalog tuple concurrently due to insufficient locking, DDL commands could fail with an internal error: ERROR: tuple concurrently updated This commit improves the behavior by reporting a more appropriate and user-facing error message in such cases, making it easier for users to understand the cause of the failure. --- src/backend/access/heap/heapam.c | 34 ++++++++++++++++++++++++++++---- 1 file changed, 30 insertions(+), 4 deletions(-) diff --git a/src/backend/access/heap/heapam.c b/src/backend/access/heap/heapam.c index 0dcd6ee817e..712b7ded6d2 100644 --- a/src/backend/access/heap/heapam.c +++ b/src/backend/access/heap/heapam.c @@ -3194,6 +3194,7 @@ simple_heap_delete(Relation relation, ItemPointer tid) { TM_Result result; TM_FailureData tmfd; + bool is_catalog = IsCatalogRelation(relation); result = heap_delete(relation, tid, GetCurrentCommandId(true), InvalidSnapshot, @@ -3211,11 +3212,23 @@ simple_heap_delete(Relation relation, ItemPointer tid) break; case TM_Updated: - elog(ERROR, "tuple concurrently updated"); + if (is_catalog) + ereport(ERROR, + (errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE), + errmsg("operation failed due to a concurrent command"), + errdetail("Another command modified the same object in a concurrent session."))); + else + elog(ERROR, "tuple concurrently updated"); break; case TM_Deleted: - elog(ERROR, "tuple concurrently deleted"); + if (is_catalog) + ereport(ERROR, + (errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE), + errmsg("operation failed due to a concurrent command"), + errdetail("Another command dropped the same object in a concurrent session."))); + else + elog(ERROR, "tuple concurrently deleted"); break; default: @@ -4486,6 +4499,7 @@ simple_heap_update(Relation relation, ItemPointer otid, HeapTuple tup, TM_Result result; TM_FailureData tmfd; LockTupleMode lockmode; + bool is_catalog = IsCatalogRelation(relation); result = heap_update(relation, otid, tup, GetCurrentCommandId(true), InvalidSnapshot, @@ -4503,11 +4517,23 @@ simple_heap_update(Relation relation, ItemPointer otid, HeapTuple tup, break; case TM_Updated: - elog(ERROR, "tuple concurrently updated"); + if (is_catalog) + ereport(ERROR, + (errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE), + errmsg("operation failed due to a concurrent command"), + errdetail("Another command modified the same object in a concurrent session."))); + else + elog(ERROR, "tuple concurrently updated"); break; case TM_Deleted: - elog(ERROR, "tuple concurrently deleted"); + if (is_catalog) + ereport(ERROR, + (errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE), + errmsg("operation failed due to a concurrent command"), + errdetail("Another command dropped the same object in a concurrent session."))); + else + elog(ERROR, "tuple concurrently deleted"); break; default: -- 2.43.0