44 #include "utils/fmgroids.h"
45 #include "utils/fmgrprotos.h"
54 #define GETNEWOID_LOG_THRESHOLD 1000000
55 #define GETNEWOID_LOG_MAX_INTERVAL 128000000
155 return (relid == RelationRelationId ||
156 relid == DatabaseRelationId);
188 Oid relnamespace = reltuple->relnamespace;
205 return namespaceId == PG_CATALOG_NAMESPACE;
223 return (namespaceId == PG_TOAST_NAMESPACE) ||
241 return (
name[0] ==
'p' &&
267 if (relationId == AuthIdRelationId ||
268 relationId == AuthMemRelationId ||
269 relationId == DatabaseRelationId ||
270 relationId == DbRoleSettingRelationId ||
271 relationId == ParameterAclRelationId ||
272 relationId == ReplicationOriginRelationId ||
273 relationId == SharedDependRelationId ||
274 relationId == SharedDescriptionRelationId ||
275 relationId == SharedSecLabelRelationId ||
276 relationId == SubscriptionRelationId ||
277 relationId == TableSpaceRelationId)
280 if (relationId == AuthIdOidIndexId ||
281 relationId == AuthIdRolnameIndexId ||
282 relationId == AuthMemMemRoleIndexId ||
283 relationId == AuthMemRoleMemIndexId ||
284 relationId == AuthMemOidIndexId ||
285 relationId == AuthMemGrantorIndexId ||
286 relationId == DatabaseNameIndexId ||
287 relationId == DatabaseOidIndexId ||
288 relationId == DbRoleSettingDatidRolidIndexId ||
289 relationId == ParameterAclOidIndexId ||
290 relationId == ParameterAclParnameIndexId ||
291 relationId == ReplicationOriginIdentIndex ||
292 relationId == ReplicationOriginNameIndex ||
293 relationId == SharedDependDependerIndexId ||
294 relationId == SharedDependReferenceIndexId ||
295 relationId == SharedDescriptionObjIndexId ||
296 relationId == SharedSecLabelObjectIndexId ||
297 relationId == SubscriptionNameIndexId ||
298 relationId == SubscriptionObjectIndexId ||
299 relationId == TablespaceNameIndexId ||
300 relationId == TablespaceOidIndexId)
303 if (relationId == PgAuthidToastTable ||
304 relationId == PgAuthidToastIndex ||
305 relationId == PgDatabaseToastTable ||
306 relationId == PgDatabaseToastIndex ||
307 relationId == PgDbRoleSettingToastTable ||
308 relationId == PgDbRoleSettingToastIndex ||
309 relationId == PgParameterAclToastTable ||
310 relationId == PgParameterAclToastIndex ||
311 relationId == PgReplicationOriginToastTable ||
312 relationId == PgReplicationOriginToastIndex ||
313 relationId == PgShdescriptionToastTable ||
314 relationId == PgShdescriptionToastIndex ||
315 relationId == PgShseclabelToastTable ||
316 relationId == PgShseclabelToastIndex ||
317 relationId == PgSubscriptionToastTable ||
318 relationId == PgSubscriptionToastIndex ||
319 relationId == PgTablespaceToastTable ||
320 relationId == PgTablespaceToastIndex)
348 if (classId == LargeObjectRelationId)
364 if (classId == NamespaceRelationId &&
365 objectId == PG_PUBLIC_NAMESPACE)
374 if (classId == DatabaseRelationId)
465 if (retries >= retries_before_log)
468 (
errmsg(
"still searching for an unused OID in relation \"%s\"",
470 errdetail_plural(
"OID candidates have been checked %llu time, but no unused OID has been found yet.",
471 "OID candidates have been checked %llu times, but no unused OID has been found yet.",
473 (
unsigned long long) retries)));
480 retries_before_log *= 2;
495 (
errmsg_plural(
"new OID has been assigned in relation \"%s\" after %llu retry",
496 "new OID has been assigned in relation \"%s\" after %llu retries",
535 switch (relpersistence)
537 case RELPERSISTENCE_TEMP:
540 case RELPERSISTENCE_UNLOGGED:
541 case RELPERSISTENCE_PERMANENT:
545 elog(
ERROR,
"invalid relpersistence: %c", relpersistence);
576 if (
access(rpath, F_OK) == 0)
627 (
errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
628 errmsg(
"must be superuser to call %s()",
636 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
637 errmsg(
"pg_nextoid() can only be used on system catalogs")));
641 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
642 errmsg(
"index \"%s\" does not belong to table \"%s\"",
649 (
errcode(ERRCODE_UNDEFINED_COLUMN),
650 errmsg(
"column \"%s\" of relation \"%s\" does not exist",
654 attno = attform->attnum;
656 if (attform->atttypid != OIDOID)
658 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
659 errmsg(
"column \"%s\" is not of type oid",
663 idx->rd_index->indkey.values[0] != attno)
665 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
666 errmsg(
"index \"%s\" is not the index for column \"%s\"",
694 (
errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
695 errmsg(
"must be superuser to call %s()",
696 "pg_stop_making_pinned_objects")));
Datum idx(PG_FUNCTION_ARGS)
#define Assert(condition)
bool IsToastRelation(Relation relation)
#define GETNEWOID_LOG_THRESHOLD
bool IsToastNamespace(Oid namespaceId)
bool IsSystemRelation(Relation relation)
Oid GetNewOidWithIndex(Relation relation, Oid indexId, AttrNumber oidcolumn)
RelFileNumber GetNewRelFileNumber(Oid reltablespace, Relation pg_class, char relpersistence)
bool IsCatalogNamespace(Oid namespaceId)
bool IsToastClass(Form_pg_class reltuple)
bool IsCatalogRelation(Relation relation)
bool IsPinnedObject(Oid classId, Oid objectId)
bool IsSharedRelation(Oid relationId)
bool IsCatalogRelationOid(Oid relid)
bool IsInplaceUpdateRelation(Relation relation)
bool IsReservedName(const char *name)
#define GETNEWOID_LOG_MAX_INTERVAL
Datum pg_nextoid(PG_FUNCTION_ARGS)
bool IsInplaceUpdateOid(Oid relid)
bool IsSystemClass(Oid relid, Form_pg_class reltuple)
Datum pg_stop_making_pinned_objects(PG_FUNCTION_ARGS)
int errmsg_plural(const char *fmt_singular, const char *fmt_plural, unsigned long n,...)
int errdetail_plural(const char *fmt_singular, const char *fmt_plural, unsigned long n,...)
int errcode(int sqlerrcode)
int errmsg(const char *fmt,...)
#define ereport(elevel,...)
#define PG_GETARG_NAME(n)
void systable_endscan(SysScanDesc sysscan)
HeapTuple systable_getnext(SysScanDesc sysscan)
SysScanDesc systable_beginscan(Relation heapRelation, Oid indexId, bool indexOK, Snapshot snapshot, int nkeys, ScanKey key)
#define HeapTupleIsValid(tuple)
void index_close(Relation relation, LOCKMODE lockmode)
Relation index_open(Oid relationId, LOCKMODE lockmode)
void pfree(void *pointer)
#define IsBootstrapProcessingMode()
#define CHECK_FOR_INTERRUPTS()
bool isTempToastNamespace(Oid namespaceId)
FormData_pg_attribute * Form_pg_attribute
FormData_pg_class * Form_pg_class
static Datum ObjectIdGetDatum(Oid X)
#define ProcNumberForTempRelations()
#define INVALID_PROC_NUMBER
#define RelationGetRelid(relation)
#define RelationGetRelationName(relation)
#define RelationGetNamespace(relation)
#define IndexRelationGetNumberOfKeyAttributes(relation)
#define relpath(rlocator, forknum)
#define InvalidRelFileNumber
void ScanKeyInit(ScanKey entry, AttrNumber attributeNumber, StrategyNumber strategy, RegProcedure procedure, Datum argument)
#define BTEqualStrategyNumber
void ReleaseSysCache(HeapTuple tuple)
HeapTuple SearchSysCacheAttName(Oid relid, const char *attname)
void table_close(Relation relation, LOCKMODE lockmode)
Relation table_open(Oid relationId, LOCKMODE lockmode)
#define FirstUnpinnedObjectId
void StopGeneratingPinnedObjectIds(void)