index c5b2541319ee8fa13e01cd1d368e409316c64c74..c69c461b62a5e656c2a1c516ffd9b2eba0ef99a3 100644 (file)
@@ -401,7 +401,7 @@ RemoveSubscriptionRel(Oid subid, Oid relid)
scan = heap_beginscan_catalog(rel, nkeys, skey);
while (HeapTupleIsValid(tup = heap_getnext(scan, ForwardScanDirection)))
{
- simple_heap_delete(rel, &tup->t_self);
+ CatalogTupleDelete(rel, &tup->t_self);
}
heap_endscan(scan);
index 2b3785f394514f7bc938c61d8e17fd7bd8442038..ea0a56140191e141e51dde1c7e52137476eff280 100644 (file)
/* insert it into pg_statistic_ext */
statrel = heap_open(StatisticExtRelationId, RowExclusiveLock);
htup = heap_form_tuple(statrel->rd_att, values, nulls);
- CatalogTupleInsert(statrel, htup);
- statoid = HeapTupleGetOid(htup);
+ statoid = CatalogTupleInsert(statrel, htup);
heap_freetuple(htup);
relation_close(statrel, RowExclusiveLock);
CacheInvalidateRelcacheByRelid(relid);
- simple_heap_delete(relation, &tup->t_self);
+ CatalogTupleDelete(relation, &tup->t_self);
ReleaseSysCache(tup);