Skip to content

Commit 5236dcd

Browse files
committed
Fix creation of partition descriptor during concurrent detach+drop
If a partition undergoes DETACH CONCURRENTLY immediately followed by DROP, this could cause a problem for a concurrent transaction recomputing the partition descriptor when running a prepared statement, because it tries to dereference a pointer to a tuple that's not found in a catalog scan. The existing retry logic added in commit dbca346 is sufficient to cope with the overall problem, provided we don't try to dereference a non-existant heap tuple. Arguably, the code in RelationBuildPartitionDesc() has been wrong all along, since no check was added in commit 898e5e3 against receiving a NULL tuple from the catalog scan; that bug has only become user-visible with DETACH CONCURRENTLY which was added in branch 14. Therefore, even though there's no known mechanism to cause a crash because of this, backpatch the addition of such a check to all supported branches. In branches prior to 14, this would cause the code to fail with a "missing relpartbound for relation XYZ" error instead of crashing; that's okay, because there are no reports of such behavior anyway. Author: Kuntal Ghosh <kuntalghosh.2007@gmail.com> Reviewed-by: Junwang Zhao <zhjwpku@gmail.com> Reviewed-by: Tender Wang <tndrwang@gmail.com> Discussion: https://postgr.es/m/18559-b48286d2eacd9a4e@postgresql.org
1 parent 016f443 commit 5236dcd

File tree

1 file changed

+10
-6
lines changed

1 file changed

+10
-6
lines changed

src/backend/partitioning/partdesc.c

Lines changed: 10 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -164,8 +164,6 @@ RelationBuildPartitionDesc(Relation rel)
164164
Relation pg_class;
165165
SysScanDesc scan;
166166
ScanKeyData key[1];
167-
Datum datum;
168-
bool isnull;
169167

170168
pg_class = table_open(RelationRelationId, AccessShareLock);
171169
ScanKeyInit(&key[0],
@@ -175,10 +173,16 @@ RelationBuildPartitionDesc(Relation rel)
175173
scan = systable_beginscan(pg_class, ClassOidIndexId, true,
176174
NULL, 1, key);
177175
tuple = systable_getnext(scan);
178-
datum = heap_getattr(tuple, Anum_pg_class_relpartbound,
179-
RelationGetDescr(pg_class), &isnull);
180-
if (!isnull)
181-
boundspec = stringToNode(TextDatumGetCString(datum));
176+
if (HeapTupleIsValid(tuple))
177+
{
178+
Datum datum;
179+
bool isnull;
180+
181+
datum = heap_getattr(tuple, Anum_pg_class_relpartbound,
182+
RelationGetDescr(pg_class), &isnull);
183+
if (!isnull)
184+
boundspec = stringToNode(TextDatumGetCString(datum));
185+
}
182186
systable_endscan(scan);
183187
table_close(pg_class, AccessShareLock);
184188
}

0 commit comments

Comments
 (0)