67 #include "catalog/schemapg.h"
84 #include "utils/fmgroids.h"
93 #define RELCACHE_INIT_FILEMAGIC 0x573266
99 #if defined(RECOVER_RELATION_BUILD_MEMORY) && (RECOVER_RELATION_BUILD_MEMORY != 0)
100 #define MAYBE_RECOVER_RELATION_BUILD_MEMORY 1
102 #define RECOVER_RELATION_BUILD_MEMORY 0
103 #ifdef DISCARD_CACHES_ENABLED
104 #define MAYBE_RECOVER_RELATION_BUILD_MEMORY 1
184 #define MAX_EOXACT_LIST 32
189 #define EOXactListAdd(rel) \
191 if (eoxact_list_len < MAX_EOXACT_LIST) \
192 eoxact_list[eoxact_list_len++] = (rel)->rd_id; \
194 eoxact_list_overflowed = true; \
209 #define RelationCacheInsert(RELATION, replace_allowed) \
211 RelIdCacheEnt *hentry; bool found; \
212 hentry = (RelIdCacheEnt *) hash_search(RelationIdCache, \
213 &((RELATION)->rd_id), \
214 HASH_ENTER, &found); \
218 Relation _old_rel = hentry->reldesc; \
219 Assert(replace_allowed); \
220 hentry->reldesc = (RELATION); \
221 if (RelationHasReferenceCountZero(_old_rel)) \
222 RelationDestroyRelation(_old_rel, false); \
223 else if (!IsBootstrapProcessingMode()) \
224 elog(WARNING, "leaking still-referenced relcache entry for \"%s\"", \
225 RelationGetRelationName(_old_rel)); \
228 hentry->reldesc = (RELATION); \
231 #define RelationIdCacheLookup(ID, RELATION) \
233 RelIdCacheEnt *hentry; \
234 hentry = (RelIdCacheEnt *) hash_search(RelationIdCache, \
238 RELATION = hentry->reldesc; \
243 #define RelationCacheDelete(RELATION) \
245 RelIdCacheEnt *hentry; \
246 hentry = (RelIdCacheEnt *) hash_search(RelationIdCache, \
247 &((RELATION)->rd_id), \
248 HASH_REMOVE, NULL); \
249 if (hentry == NULL) \
250 elog(WARNING, "failed to delete relcache entry for OID %u", \
251 (RELATION)->rd_id); \
283 #ifdef USE_ASSERT_CHECKING
284 static void AssertPendingSyncConsistency(
Relation relation);
293 static void formrdesc(
const char *relationName,
Oid relationReltype,
352 elog(
FATAL,
"cannot read pg_class without having selected a database");
377 if (force_non_historic)
397 return pg_class_tuple;
441 relation->
rd_rel = relationForm;
473 switch (relation->
rd_rel->relkind)
475 case RELKIND_RELATION:
476 case RELKIND_TOASTVALUE:
478 case RELKIND_MATVIEW:
479 case RELKIND_PARTITIONED_TABLE:
483 case RELKIND_PARTITIONED_INDEX:
532 relation->
rd_rel->reltype ? relation->
rd_rel->reltype : RECORDOID;
546 Anum_pg_attribute_attrelid,
550 Anum_pg_attribute_attnum,
561 AttributeRelidNumIndexId,
580 elog(
ERROR,
"invalid attribute number %d for relation \"%s\"",
588 if (attp->attnotnull)
590 if (attp->attgenerated == ATTRIBUTE_GENERATED_STORED)
596 if (attp->atthasmissing)
603 Anum_pg_attribute_attmissingval,
604 pg_attribute_desc->
rd_att,
614 if (attrmiss == NULL)
617 relation->
rd_rel->relnatts *
658 elog(
ERROR,
"pg_attribute catalog is missing %d attribute(s) for relation OID %u",
666 #ifdef USE_ASSERT_CHECKING
690 relation->
rd_rel->relchecks > 0)
701 if (relation->
rd_rel->relchecks > 0)
768 Anum_pg_rewrite_ev_class,
783 RewriteRelRulenameIndexId,
799 rule->ruleId = rewrite_form->oid;
801 rule->event = rewrite_form->ev_type -
'0';
802 rule->enabled = rewrite_form->ev_enabled;
803 rule->isInstead = rewrite_form->is_instead;
812 Anum_pg_rewrite_ev_action,
823 Anum_pg_rewrite_ev_qual,
842 relation->
rd_rel->relkind == RELKIND_VIEW &&
846 check_as_user = relation->
rd_rel->relowner;
862 if (numlocks >= maxlocks)
940 else if (rlock2 != NULL)
985 else if (policy2 != NULL)
1002 if (rsdesc1 == NULL && rsdesc2 == NULL)
1005 if ((rsdesc1 != NULL && rsdesc2 == NULL) ||
1006 (rsdesc1 == NULL && rsdesc2 != NULL))
1040 int in_progress_offset;
1061 #ifdef MAYBE_RECOVER_RELATION_BUILD_MEMORY
1068 "RelationBuildDesc workspace",
1099 #ifdef MAYBE_RECOVER_RELATION_BUILD_MEMORY
1117 Assert(relid == targetRelId);
1140 switch (relation->
rd_rel->relpersistence)
1142 case RELPERSISTENCE_UNLOGGED:
1143 case RELPERSISTENCE_PERMANENT:
1147 case RELPERSISTENCE_TEMP:
1175 elog(
ERROR,
"invalid relpersistence: %c",
1176 relation->
rd_rel->relpersistence);
1204 if (relation->
rd_rel->relkind == RELKIND_INDEX ||
1205 relation->
rd_rel->relkind == RELKIND_PARTITIONED_INDEX)
1207 else if (RELKIND_HAS_TABLE_AM(relation->
rd_rel->relkind) ||
1208 relation->
rd_rel->relkind == RELKIND_SEQUENCE)
1222 if (relation->
rd_rel->relhasrules)
1230 if (relation->
rd_rel->relhastriggers)
1235 if (relation->
rd_rel->relrowsecurity)
1291 #ifdef MAYBE_RECOVER_RELATION_BUILD_MEMORY
1316 if (!RELKIND_HAS_STORAGE(relation->
rd_rel->relkind))
1319 if (relation->
rd_rel->reltablespace)
1328 if (relation->
rd_rel->relfilenode)
1351 elog(
ERROR,
"could not find pg_class entry for %u",
1355 relation->
rd_rel->reltablespace = physrel->reltablespace;
1356 relation->
rd_rel->relfilenode = physrel->relfilenode;
1367 relation->
rd_rel->relisshared);
1369 elog(
ERROR,
"could not find relation mapping for relation \"%s\", OID %u",
1422 Datum indclassDatum;
1423 Datum indoptionDatum;
1442 elog(
ERROR,
"cache lookup failed for index %u",
1456 elog(
ERROR,
"cache lookup failed for access method %u",
1457 relation->
rd_rel->relam);
1464 elog(
ERROR,
"relnatts disagrees with indnatts for index %u",
1497 int nsupport = indnatts * amsupport;
1522 Anum_pg_index_indcollation,
1535 Anum_pg_index_indclass,
1548 amsupport, indnkeyatts);
1554 Anum_pg_index_indoption,
1597 for (attIndex = 0; attIndex < maxAttributeNumber; attIndex++)
1609 opFamily[attIndex] = opcentry->
opcfamily;
1610 opcInType[attIndex] = opcentry->
opcintype;
1611 if (maxSupportNumber > 0)
1612 memcpy(&indexSupport[attIndex * maxSupportNumber],
1672 opcentry->
valid =
false;
1690 #ifdef DISCARD_CACHES_ENABLED
1692 opcentry->
valid =
false;
1695 if (opcentry->
valid)
1713 (operatorClassOid != OID_BTREE_OPS_OID &&
1714 operatorClassOid != INT2_BTREE_OPS_OID);
1723 Anum_pg_opclass_oid,
1734 opcentry->
opcfamily = opclassform->opcfamily;
1735 opcentry->
opcintype = opclassform->opcintype;
1738 elog(
ERROR,
"could not find tuple for opclass %u", operatorClassOid);
1750 Anum_pg_amproc_amprocfamily,
1754 Anum_pg_amproc_amproclefttype,
1758 Anum_pg_amproc_amprocrighttype,
1769 if (amprocform->amprocnum <= 0 ||
1771 elog(
ERROR,
"invalid amproc number %d for opclass %u",
1772 amprocform->amprocnum, operatorClassOid);
1782 opcentry->
valid =
true;
1806 if (relation->
rd_rel->relkind == RELKIND_SEQUENCE)
1834 elog(
ERROR,
"cache lookup failed for access method %u",
1835 relation->
rd_rel->relam);
1911 relation->
rd_rel->relnamespace = PG_CATALOG_NAMESPACE;
1912 relation->
rd_rel->reltype = relationReltype;
1918 relation->
rd_rel->relisshared = isshared;
1920 relation->
rd_rel->reltablespace = GLOBALTABLESPACE_OID;
1923 relation->
rd_rel->relpersistence = RELPERSISTENCE_PERMANENT;
1926 relation->
rd_rel->relispopulated =
true;
1928 relation->
rd_rel->relreplident = REPLICA_IDENTITY_NOTHING;
1929 relation->
rd_rel->relpages = 0;
1930 relation->
rd_rel->reltuples = -1;
1931 relation->
rd_rel->relallvisible = 0;
1932 relation->
rd_rel->relkind = RELKIND_RELATION;
1934 relation->
rd_rel->relam = HEAP_TABLE_AM_OID;
1952 has_not_null =
false;
1953 for (
i = 0;
i < natts;
i++)
1958 has_not_null |= attrs[
i].attnotnull;
2005 relation->
rd_rel->relam = HEAP_TABLE_AM_OID;
2014 relation->
rd_rel->relhasindex =
false;
2019 relation->
rd_rel->relhasindex =
true;
2084 if (rd->
rd_rel->relkind == RELKIND_INDEX ||
2085 rd->
rd_rel->relkind == RELKIND_PARTITIONED_INDEX)
2181 #ifdef RELCACHE_FORCE_RELEASE
2225 relation->
rd_rel->relkind == RELKIND_PARTITIONED_INDEX) &&
2259 elog(
ERROR,
"could not find pg_class tuple for index %u",
2288 elog(
ERROR,
"cache lookup failed for index %u",
2299 relation->
rd_index->indnullsnotdistinct =
index->indnullsnotdistinct;
2352 if (relation->
rd_rel->relkind == RELKIND_INDEX)
2434 if (remember_tupdesc)
2545 if ((relation->
rd_rel->relkind == RELKIND_INDEX ||
2546 relation->
rd_rel->relkind == RELKIND_PARTITIONED_INDEX) &&
2662 elog(
ERROR,
"relation %u deleted while still in use", save_relid);
2676 keep_partkey = (relation->
rd_partkey != NULL);
2688 #define SWAPFIELD(fldtype, fldname) \
2690 fldtype _tmp = newrel->fldname; \
2691 newrel->fldname = relation->fldname; \
2692 relation->fldname = _tmp; \
2843 elog(
ERROR,
"relation %u is still open", rid);
2998 rebuildFirstList =
lcons(relation, rebuildFirstList);
3000 rebuildFirstList =
lappend(rebuildFirstList, relation);
3002 rebuildList =
lcons(relation, rebuildList);
3004 rebuildList =
lappend(rebuildList, relation);
3016 foreach(l, rebuildFirstList)
3022 foreach(l, rebuildList)
3082 #ifdef USE_ASSERT_CHECKING
3084 AssertPendingSyncConsistency(
Relation relation)
3086 bool relcache_verdict =
3089 RELKIND_HAS_STORAGE(relation->
rd_rel->relkind)) ||
3125 rels =
palloc(maxrels *
sizeof(*rels));
3133 if (locallock->
nLocks <= 0)
3142 if (nrels >= maxrels)
3145 rels =
repalloc(rels, maxrels *
sizeof(*rels));
3152 AssertPendingSyncConsistency(idhentry->
reldesc);
3154 for (
i = 0;
i < nrels;
i++)
3217 if (idhentry != NULL)
3249 bool clear_relcache =
false;
3265 #ifdef USE_ASSERT_CHECKING
3268 int expected_refcnt;
3315 elog(
WARNING,
"cannot remove relcache entry for \"%s\" because it has nonzero refcount",
3355 mySubid, parentSubid);
3366 if (idhentry != NULL)
3368 mySubid, parentSubid);
3425 elog(
WARNING,
"cannot remove relcache entry for \"%s\" because it has nonzero refcount",
3473 bool shared_relation,
3474 bool mapped_relation,
3475 char relpersistence,
3480 int natts = tupDesc->
natts;
3495 case DatabaseRelationId:
3496 case AuthIdRelationId:
3497 case AuthMemRelationId:
3498 case RelationRelationId:
3499 case AttributeRelationId:
3500 case ProcedureRelationId:
3501 case TypeRelationId:
3516 elog(
ERROR,
"shared_relation flag for \"%s\" does not match IsSharedRelation(%u)",
3520 Assert(mapped_relation || !shared_relation);
3558 has_not_null =
false;
3559 for (
i = 0;
i < natts;
i++)
3564 datt->attidentity = satt->attidentity;
3565 datt->attgenerated = satt->attgenerated;
3566 datt->attnotnull = satt->attnotnull;
3567 has_not_null |= satt->attnotnull;
3584 rel->
rd_rel->relnamespace = relnamespace;
3586 rel->
rd_rel->relkind = relkind;
3587 rel->
rd_rel->relnatts = natts;
3590 rel->
rd_rel->relowner = BOOTSTRAP_SUPERUSERID;
3593 rel->
rd_rel->relpersistence = relpersistence;
3594 switch (relpersistence)
3596 case RELPERSISTENCE_UNLOGGED:
3597 case RELPERSISTENCE_PERMANENT:
3601 case RELPERSISTENCE_TEMP:
3607 elog(
ERROR,
"invalid relpersistence: %c", relpersistence);
3612 if (relkind == RELKIND_MATVIEW)
3613 rel->
rd_rel->relispopulated =
false;
3615 rel->
rd_rel->relispopulated =
true;
3619 (relkind == RELKIND_RELATION ||
3620 relkind == RELKIND_MATVIEW ||
3621 relkind == RELKIND_PARTITIONED_TABLE))
3622 rel->
rd_rel->relreplident = REPLICA_IDENTITY_DEFAULT;
3624 rel->
rd_rel->relreplident = REPLICA_IDENTITY_NOTHING;
3631 rel->
rd_rel->relisshared = shared_relation;
3635 for (
i = 0;
i < natts;
i++)
3638 rel->
rd_rel->reltablespace = reltablespace;
3640 if (mapped_relation)
3647 rel->
rd_rel->relfilenode = relfilenumber;
3653 rel->
rd_rel->relam = accessmtd;
3662 if (RELKIND_HAS_TABLE_AM(relkind) || relkind == RELKIND_SEQUENCE)
3725 else if (relation->
rd_rel->relkind == RELKIND_INDEX)
3729 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
3730 errmsg(
"index relfilenumber value not set when in binary upgrade mode")));
3735 else if (relation->
rd_rel->relkind == RELKIND_RELATION)
3739 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
3740 errmsg(
"heap relfilenumber value not set when in binary upgrade mode")));
3747 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
3748 errmsg(
"unexpected request for new relfilenumber in binary upgrade mode")));
3758 elog(
ERROR,
"could not find tuple for relation %u",
3804 newrlocator.
relNumber = newrelfilenumber;
3806 if (RELKIND_HAS_TABLE_AM(relation->
rd_rel->relkind))
3810 &freezeXid, &minmulti);
3812 else if (RELKIND_HAS_STORAGE(relation->
rd_rel->relkind))
3823 elog(
ERROR,
"relation \"%s\" does not have storage",
3842 Assert(classform->relfrozenxid == freezeXid);
3843 Assert(classform->relminmxid == minmulti);
3844 Assert(classform->relpersistence == persistence);
3857 relation->
rd_rel->relisshared,
3866 classform->relfilenode = newrelfilenumber;
3869 if (relation->
rd_rel->relkind != RELKIND_SEQUENCE)
3871 classform->relpages = 0;
3872 classform->reltuples = -1;
3873 classform->relallvisible = 0;
3875 classform->relfrozenxid = freezeXid;
3876 classform->relminmxid = minmulti;
3877 classform->relpersistence = persistence;
3931 #define INITRELCACHESIZE 400
4007 formrdesc(
"pg_database", DatabaseRelation_Rowtype_Id,
true,
4009 formrdesc(
"pg_authid", AuthIdRelation_Rowtype_Id,
true,
4011 formrdesc(
"pg_auth_members", AuthMemRelation_Rowtype_Id,
true,
4013 formrdesc(
"pg_shseclabel", SharedSecLabelRelation_Rowtype_Id,
true,
4015 formrdesc(
"pg_subscription", SubscriptionRelation_Rowtype_Id,
true,
4018 #define NUM_CRITICAL_SHARED_RELS 5
4064 needNewCacheFile =
true;
4066 formrdesc(
"pg_class", RelationRelation_Rowtype_Id,
false,
4068 formrdesc(
"pg_attribute", AttributeRelation_Rowtype_Id,
false,
4070 formrdesc(
"pg_proc", ProcedureRelation_Rowtype_Id,
false,
4072 formrdesc(
"pg_type", TypeRelation_Rowtype_Id,
false,
4075 #define NUM_CRITICAL_LOCAL_RELS 4
4112 RelationRelationId);
4114 AttributeRelationId);
4118 OperatorClassRelationId);
4120 AccessMethodProcedureRelationId);
4126 #define NUM_CRITICAL_LOCAL_INDEXES 7
4146 DatabaseRelationId);
4148 DatabaseRelationId);
4156 SharedSecLabelRelationId);
4158 #define NUM_CRITICAL_SHARED_INDEXES 6
4184 bool restart =
false;
4202 elog(
FATAL,
"cache lookup failed for relation %u",
4230 elog(
ERROR,
"invalid relowner in pg_class entry for \"%s\"",
4248 relation->
rd_rel->relhasrules =
false;
4251 if (relation->
rd_rel->relhastriggers && relation->
trigdesc == NULL)
4255 relation->
rd_rel->relhastriggers =
false;
4276 (RELKIND_HAS_TABLE_AM(relation->
rd_rel->relkind) || relation->
rd_rel->relkind == RELKIND_SEQUENCE))
4299 if (needNewCacheFile)
4336 elog(
PANIC,
"could not open critical system index %u", indexoid);
4370 for (
i = 0;
i < natts;
i++)
4393 if (pgclassdesc == NULL)
4406 if (pgindexdesc == NULL)
4439 Anum_pg_attrdef_adrelid,
4456 elog(
WARNING,
"unexpected pg_attrdef record found for attribute %d of relation \"%s\"",
4462 Anum_pg_attrdef_adbin,
4465 elog(
WARNING,
"null adbin for attribute %d of relation \"%s\"",
4472 attrdef[found].
adnum = adform->adnum;
4483 elog(
WARNING,
"%d pg_attrdef record(s) missing for relation \"%s\"",
4521 int ncheck = relation->
rd_rel->relchecks;
4535 Anum_pg_constraint_conrelid,
4550 if (conform->contype != CONSTRAINT_CHECK)
4554 if (found >= ncheck)
4556 elog(
WARNING,
"unexpected pg_constraint record found for relation \"%s\"",
4561 check[found].
ccvalid = conform->convalidated;
4568 Anum_pg_constraint_conbin,
4569 conrel->
rd_att, &isnull);
4587 if (found != ncheck)
4588 elog(
WARNING,
"%d pg_constraint record(s) missing for relation \"%s\"",
4645 if (!relation->
rd_rel->relhastriggers &&
4646 relation->
rd_rel->relkind != RELKIND_PARTITIONED_TABLE)
4659 Anum_pg_constraint_conrelid,
4673 if (constraint->contype != CONSTRAINT_FOREIGN)
4677 info->
conoid = constraint->oid;
4678 info->
conrelid = constraint->conrelid;
4679 info->
confrelid = constraint->confrelid;
4685 NULL, NULL, NULL, NULL);
4688 result =
lappend(result, info);
4747 char replident = relation->
rd_rel->relreplident;
4766 Anum_pg_index_indrelid,
4784 if (!
index->indislive)
4795 if (!
index->indisvalid || !
index->indisunique ||
4796 !
index->indimmediate ||
4801 if (
index->indisprimary)
4802 pkeyIndex =
index->indexrelid;
4805 if (
index->indisreplident)
4806 candidateIndex =
index->indexrelid;
4821 if (replident == REPLICA_IDENTITY_DEFAULT &&
OidIsValid(pkeyIndex))
4823 else if (replident == REPLICA_IDENTITY_INDEX &&
OidIsValid(candidateIndex))
4885 Anum_pg_statistic_ext_stxrelid,
4996 Anum_pg_index_indexprs,
5048 Anum_pg_index_indexprs,
5058 foreach(lc, rawExprs)
5109 Anum_pg_index_indpred,
5177 List *newindexoidlist;
5199 elog(
ERROR,
"unknown attrKind %u", attrKind);
5214 if (indexoidlist ==
NIL)
5238 pkindexattrs = NULL;
5239 idindexattrs = NULL;
5240 hotblockingattrs = NULL;
5241 summarizedattrs = NULL;
5242 foreach(l, indexoidlist)
5248 Node *indexExpressions;
5249 Node *indexPredicate;
5272 indexExpressions = NULL;
5279 indexPredicate = NULL;
5282 isKey = indexDesc->
rd_index->indisunique &&
5283 indexExpressions == NULL &&
5284 indexPredicate == NULL;
5287 isPK = (indexOid == relpkindex);
5290 isIDKey = (indexOid == relreplindex);
5298 attrs = &summarizedattrs;
5300 attrs = &hotblockingattrs;
5303 for (
i = 0;
i < indexDesc->
rd_index->indnatts;
i++)
5305 int attrnum = indexDesc->
rd_index->indkey.values[
i];
5326 if (isKey && i < indexDesc->rd_index->indnkeyatts)
5330 if (isPK && i < indexDesc->rd_index->indnkeyatts)
5334 if (isIDKey && i < indexDesc->rd_index->indnkeyatts)
5356 if (
equal(indexoidlist, newindexoidlist) &&
5413 return pkindexattrs;
5415 return idindexattrs;
5417 return hotblockingattrs;
5419 return summarizedattrs;
5421 elog(
ERROR,
"unknown attrKind %u", attrKind);
5471 elog(
ERROR,
"could not open relation with OID %u",
5475 for (
i = 0;
i < indexDesc->
rd_index->indnatts;
i++)
5477 int attrnum = indexDesc->
rd_index->indkey.values[
i];
5485 if (i < indexDesc->rd_index->indnkeyatts)
5503 return idindexattrs;
5536 *operators = ops = (
Oid *)
palloc(
sizeof(
Oid) * indnkeyatts);
5537 *procs = funcs = (
Oid *)
palloc(
sizeof(
Oid) * indnkeyatts);
5543 memcpy(ops, indexRelation->
rd_exclops,
sizeof(
Oid) * indnkeyatts);
5544 memcpy(funcs, indexRelation->
rd_exclprocs,
sizeof(
Oid) * indnkeyatts);
5559 Anum_pg_constraint_conrelid,
5577 if (conform->contype != CONSTRAINT_EXCLUSION ||
5583 elog(
ERROR,
"unexpected exclusion constraint record found for rel %s",
5589 Anum_pg_constraint_conexclop,
5590 conrel->
rd_att, &isnull);
5592 elog(
ERROR,
"null conexclop for rel %s",
5598 nelem != indnkeyatts ||
5601 elog(
ERROR,
"conexclop is not a 1-D Oid array");
5610 elog(
ERROR,
"exclusion constraint record missing for rel %s",
5614 for (
i = 0;
i < indnkeyatts;
i++)
5621 elog(
ERROR,
"could not find strategy for operator %u in family %u",
5630 memcpy(indexRelation->
rd_exclops, ops,
sizeof(
Oid) * indnkeyatts);
5631 memcpy(indexRelation->
rd_exclprocs, funcs,
sizeof(
Oid) * indnkeyatts);
5688 if (relation->
rd_rel->relispartition)
5693 foreach(lc, ancestors)
5706 foreach(lc, puboids)
5715 elog(
ERROR,
"cache lookup failed for publication %u", pubid);
5731 if (!pubform->puballtables &&
5732 (pubform->pubupdate || pubform->pubdelete) &&
5734 pubform->pubviaroot))
5736 if (pubform->pubupdate)
5738 if (pubform->pubdelete)
5748 if (!pubform->puballtables &&
5749 (pubform->pubupdate || pubform->pubdelete) &&
5751 pubform->pubviaroot))
5753 if (pubform->pubupdate)
5755 if (pubform->pubdelete)