65 #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); \
285 #ifdef USE_ASSERT_CHECKING
286 static void AssertPendingSyncConsistency(
Relation relation);
295 static void formrdesc(
const char *relationName,
Oid relationReltype,
354 elog(
FATAL,
"cannot read pg_class without having selected a database");
379 if (force_non_historic)
399 return pg_class_tuple;
443 relation->
rd_rel = relationForm;
475 switch (relation->
rd_rel->relkind)
477 case RELKIND_RELATION:
478 case RELKIND_TOASTVALUE:
480 case RELKIND_MATVIEW:
481 case RELKIND_PARTITIONED_TABLE:
485 case RELKIND_PARTITIONED_INDEX:
534 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)
1210 else if (relation->
rd_rel->relkind == RELKIND_PARTITIONED_TABLE)
1229 if (relation->
rd_rel->relhasrules)
1237 if (relation->
rd_rel->relhastriggers)
1242 if (relation->
rd_rel->relrowsecurity)
1298 #ifdef MAYBE_RECOVER_RELATION_BUILD_MEMORY
1323 if (!RELKIND_HAS_STORAGE(relation->
rd_rel->relkind))
1326 if (relation->
rd_rel->reltablespace)
1335 if (relation->
rd_rel->relfilenode)
1358 elog(
ERROR,
"could not find pg_class entry for %u",
1362 relation->
rd_rel->reltablespace = physrel->reltablespace;
1363 relation->
rd_rel->relfilenode = physrel->relfilenode;
1374 relation->
rd_rel->relisshared);
1376 elog(
ERROR,
"could not find relation mapping for relation \"%s\", OID %u",
1429 Datum indclassDatum;
1430 Datum indoptionDatum;
1449 elog(
ERROR,
"cache lookup failed for index %u",
1463 elog(
ERROR,
"cache lookup failed for access method %u",
1464 relation->
rd_rel->relam);
1471 elog(
ERROR,
"relnatts disagrees with indnatts for index %u",
1504 int nsupport = indnatts * amsupport;
1529 Anum_pg_index_indcollation,
1542 Anum_pg_index_indclass,
1555 amsupport, indnkeyatts);
1561 Anum_pg_index_indoption,
1604 for (attIndex = 0; attIndex < maxAttributeNumber; attIndex++)
1616 opFamily[attIndex] = opcentry->
opcfamily;
1617 opcInType[attIndex] = opcentry->
opcintype;
1618 if (maxSupportNumber > 0)
1619 memcpy(&indexSupport[attIndex * maxSupportNumber],
1666 ctl.keysize =
sizeof(
Oid);
1679 opcentry->
valid =
false;
1697 #ifdef DISCARD_CACHES_ENABLED
1699 opcentry->
valid =
false;
1702 if (opcentry->
valid)
1720 (operatorClassOid != OID_BTREE_OPS_OID &&
1721 operatorClassOid != INT2_BTREE_OPS_OID);
1730 Anum_pg_opclass_oid,
1741 opcentry->
opcfamily = opclassform->opcfamily;
1742 opcentry->
opcintype = opclassform->opcintype;
1745 elog(
ERROR,
"could not find tuple for opclass %u", operatorClassOid);
1757 Anum_pg_amproc_amprocfamily,
1761 Anum_pg_amproc_amproclefttype,
1765 Anum_pg_amproc_amprocrighttype,
1776 if (amprocform->amprocnum <= 0 ||
1778 elog(
ERROR,
"invalid amproc number %d for opclass %u",
1779 amprocform->amprocnum, operatorClassOid);
1789 opcentry->
valid =
true;
1813 if (relation->
rd_rel->relkind == RELKIND_SEQUENCE)
1841 elog(
ERROR,
"cache lookup failed for access method %u",
1842 relation->
rd_rel->relam);
1918 relation->
rd_rel->relnamespace = PG_CATALOG_NAMESPACE;
1919 relation->
rd_rel->reltype = relationReltype;
1925 relation->
rd_rel->relisshared = isshared;
1927 relation->
rd_rel->reltablespace = GLOBALTABLESPACE_OID;
1930 relation->
rd_rel->relpersistence = RELPERSISTENCE_PERMANENT;
1933 relation->
rd_rel->relispopulated =
true;
1935 relation->
rd_rel->relreplident = REPLICA_IDENTITY_NOTHING;
1936 relation->
rd_rel->relpages = 0;
1937 relation->
rd_rel->reltuples = -1;
1938 relation->
rd_rel->relallvisible = 0;
1939 relation->
rd_rel->relkind = RELKIND_RELATION;
1941 relation->
rd_rel->relam = HEAP_TABLE_AM_OID;
1959 has_not_null =
false;
1960 for (
i = 0;
i < natts;
i++)
1965 has_not_null |= attrs[
i].attnotnull;
2012 relation->
rd_rel->relam = HEAP_TABLE_AM_OID;
2021 relation->
rd_rel->relhasindex =
false;
2026 relation->
rd_rel->relhasindex =
true;
2091 if (rd->
rd_rel->relkind == RELKIND_INDEX ||
2092 rd->
rd_rel->relkind == RELKIND_PARTITIONED_INDEX)
2131 .
name =
"relcache reference",
2219 #ifdef RELCACHE_FORCE_RELEASE
2263 relation->
rd_rel->relkind == RELKIND_PARTITIONED_INDEX) &&
2297 elog(
ERROR,
"could not find pg_class tuple for index %u",
2326 elog(
ERROR,
"cache lookup failed for index %u",
2337 relation->
rd_index->indnullsnotdistinct =
index->indnullsnotdistinct;
2391 if (relation->
rd_rel->relkind == RELKIND_INDEX)
2473 if (remember_tupdesc)
2609 if ((relation->
rd_rel->relkind == RELKIND_INDEX ||
2610 relation->
rd_rel->relkind == RELKIND_PARTITIONED_INDEX) &&
2726 elog(
ERROR,
"relation %u deleted while still in use", save_relid);
2740 keep_partkey = (relation->
rd_partkey != NULL);
2752 #define SWAPFIELD(fldtype, fldname) \
2754 fldtype _tmp = newrel->fldname; \
2755 newrel->fldname = relation->fldname; \
2756 relation->fldname = _tmp; \
2921 elog(
ERROR,
"relation %u is still open", rid);
3076 rebuildFirstList =
lcons(relation, rebuildFirstList);
3078 rebuildFirstList =
lappend(rebuildFirstList, relation);
3080 rebuildList =
lcons(relation, rebuildList);
3082 rebuildList =
lappend(rebuildList, relation);
3093 foreach(l, rebuildFirstList)
3099 foreach(l, rebuildList)
3140 #ifdef USE_ASSERT_CHECKING
3142 AssertPendingSyncConsistency(
Relation relation)
3144 bool relcache_verdict =
3147 RELKIND_HAS_STORAGE(relation->
rd_rel->relkind)) ||
3183 rels =
palloc(maxrels *
sizeof(*rels));
3191 if (locallock->
nLocks <= 0)
3200 if (nrels >= maxrels)
3203 rels =
repalloc(rels, maxrels *
sizeof(*rels));
3210 AssertPendingSyncConsistency(idhentry->
reldesc);
3212 for (
i = 0;
i < nrels;
i++)
3275 if (idhentry != NULL)
3307 bool clear_relcache =
false;
3323 #ifdef USE_ASSERT_CHECKING
3326 int expected_refcnt;
3373 elog(
WARNING,
"cannot remove relcache entry for \"%s\" because it has nonzero refcount",
3413 mySubid, parentSubid);
3424 if (idhentry != NULL)
3426 mySubid, parentSubid);
3483 elog(
WARNING,
"cannot remove relcache entry for \"%s\" because it has nonzero refcount",
3531 bool shared_relation,
3532 bool mapped_relation,
3533 char relpersistence,
3538 int natts = tupDesc->
natts;
3553 case DatabaseRelationId:
3554 case AuthIdRelationId:
3555 case AuthMemRelationId:
3556 case RelationRelationId:
3557 case AttributeRelationId:
3558 case ProcedureRelationId:
3559 case TypeRelationId:
3574 elog(
ERROR,
"shared_relation flag for \"%s\" does not match IsSharedRelation(%u)",
3578 Assert(mapped_relation || !shared_relation);
3616 has_not_null =
false;
3617 for (
i = 0;
i < natts;
i++)
3622 datt->attidentity = satt->attidentity;
3623 datt->attgenerated = satt->attgenerated;
3624 datt->attnotnull = satt->attnotnull;
3625 has_not_null |= satt->attnotnull;
3642 rel->
rd_rel->relnamespace = relnamespace;
3644 rel->
rd_rel->relkind = relkind;
3645 rel->
rd_rel->relnatts = natts;
3648 rel->
rd_rel->relowner = BOOTSTRAP_SUPERUSERID;
3651 rel->
rd_rel->relpersistence = relpersistence;
3652 switch (relpersistence)
3654 case RELPERSISTENCE_UNLOGGED:
3655 case RELPERSISTENCE_PERMANENT:
3659 case RELPERSISTENCE_TEMP:
3665 elog(
ERROR,
"invalid relpersistence: %c", relpersistence);
3670 if (relkind == RELKIND_MATVIEW)
3671 rel->
rd_rel->relispopulated =
false;
3673 rel->
rd_rel->relispopulated =
true;
3677 (relkind == RELKIND_RELATION ||
3678 relkind == RELKIND_MATVIEW ||
3679 relkind == RELKIND_PARTITIONED_TABLE))
3680 rel->
rd_rel->relreplident = REPLICA_IDENTITY_DEFAULT;
3682 rel->
rd_rel->relreplident = REPLICA_IDENTITY_NOTHING;
3689 rel->
rd_rel->relisshared = shared_relation;
3693 for (
i = 0;
i < natts;
i++)
3696 rel->
rd_rel->reltablespace = reltablespace;
3698 if (mapped_relation)
3705 rel->
rd_rel->relfilenode = relfilenumber;
3711 rel->
rd_rel->relam = accessmtd;
3720 if (RELKIND_HAS_TABLE_AM(relkind) || relkind == RELKIND_SEQUENCE)
3784 else if (relation->
rd_rel->relkind == RELKIND_INDEX)
3788 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
3789 errmsg(
"index relfilenumber value not set when in binary upgrade mode")));
3794 else if (relation->
rd_rel->relkind == RELKIND_RELATION)
3798 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
3799 errmsg(
"heap relfilenumber value not set when in binary upgrade mode")));
3806 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
3807 errmsg(
"unexpected request for new relfilenumber in binary upgrade mode")));
3817 elog(
ERROR,
"could not find tuple for relation %u",
3864 newrlocator.
relNumber = newrelfilenumber;
3866 if (RELKIND_HAS_TABLE_AM(relation->
rd_rel->relkind))
3870 &freezeXid, &minmulti);
3872 else if (RELKIND_HAS_STORAGE(relation->
rd_rel->relkind))
3883 elog(
ERROR,
"relation \"%s\" does not have storage",
3902 Assert(classform->relfrozenxid == freezeXid);
3903 Assert(classform->relminmxid == minmulti);
3904 Assert(classform->relpersistence == persistence);
3917 relation->
rd_rel->relisshared,
3926 classform->relfilenode = newrelfilenumber;
3929 if (relation->
rd_rel->relkind != RELKIND_SEQUENCE)
3931 classform->relpages = 0;
3932 classform->reltuples = -1;
3933 classform->relallvisible = 0;
3935 classform->relfrozenxid = freezeXid;
3936 classform->relminmxid = minmulti;
3937 classform->relpersistence = persistence;
3992 #define INITRELCACHESIZE 400
4009 ctl.keysize =
sizeof(
Oid);
4068 formrdesc(
"pg_database", DatabaseRelation_Rowtype_Id,
true,
4070 formrdesc(
"pg_authid", AuthIdRelation_Rowtype_Id,
true,
4072 formrdesc(
"pg_auth_members", AuthMemRelation_Rowtype_Id,
true,
4074 formrdesc(
"pg_shseclabel", SharedSecLabelRelation_Rowtype_Id,
true,
4076 formrdesc(
"pg_subscription", SubscriptionRelation_Rowtype_Id,
true,
4079 #define NUM_CRITICAL_SHARED_RELS 5
4125 needNewCacheFile =
true;
4127 formrdesc(
"pg_class", RelationRelation_Rowtype_Id,
false,
4129 formrdesc(
"pg_attribute", AttributeRelation_Rowtype_Id,
false,
4131 formrdesc(
"pg_proc", ProcedureRelation_Rowtype_Id,
false,
4133 formrdesc(
"pg_type", TypeRelation_Rowtype_Id,
false,
4136 #define NUM_CRITICAL_LOCAL_RELS 4
4173 RelationRelationId);
4175 AttributeRelationId);
4179 OperatorClassRelationId);
4181 AccessMethodProcedureRelationId);
4187 #define NUM_CRITICAL_LOCAL_INDEXES 7
4207 DatabaseRelationId);
4209 DatabaseRelationId);
4217 SharedSecLabelRelationId);
4219 #define NUM_CRITICAL_SHARED_INDEXES 6
4245 bool restart =
false;
4264 errcode(ERRCODE_UNDEFINED_OBJECT),
4293 elog(
ERROR,
"invalid relowner in pg_class entry for \"%s\"",
4311 relation->
rd_rel->relhasrules =
false;
4314 if (relation->
rd_rel->relhastriggers && relation->
trigdesc == NULL)
4318 relation->
rd_rel->relhastriggers =
false;
4339 (RELKIND_HAS_TABLE_AM(relation->
rd_rel->relkind) || relation->
rd_rel->relkind == RELKIND_SEQUENCE))
4362 if (needNewCacheFile)
4401 errmsg_internal(
"could not open critical system index %u", indexoid));
4435 for (
i = 0;
i < natts;
i++)
4458 if (pgclassdesc == NULL)
4471 if (pgindexdesc == NULL)
4504 Anum_pg_attrdef_adrelid,
4521 elog(
WARNING,
"unexpected pg_attrdef record found for attribute %d of relation \"%s\"",
4527 Anum_pg_attrdef_adbin,
4530 elog(
WARNING,
"null adbin for attribute %d of relation \"%s\"",
4537 attrdef[found].
adnum = adform->adnum;
4548 elog(
WARNING,
"%d pg_attrdef record(s) missing for relation \"%s\"",
4586 int ncheck = relation->
rd_rel->relchecks;
4600 Anum_pg_constraint_conrelid,
4615 if (conform->contype != CONSTRAINT_CHECK)
4619 if (found >= ncheck)
4621 elog(
WARNING,
"unexpected pg_constraint record found for relation \"%s\"",
4626 check[found].
ccvalid = conform->convalidated;
4633 Anum_pg_constraint_conbin,
4634 conrel->
rd_att, &isnull);
4652 if (found != ncheck)
4653 elog(
WARNING,
"%d pg_constraint record(s) missing for relation \"%s\"",
4710 if (!relation->
rd_rel->relhastriggers &&
4711 relation->
rd_rel->relkind != RELKIND_PARTITIONED_TABLE)
4724 Anum_pg_constraint_conrelid,
4738 if (constraint->contype != CONSTRAINT_FOREIGN)
4742 info->
conoid = constraint->oid;
4743 info->
conrelid = constraint->conrelid;
4744 info->
confrelid = constraint->confrelid;
4750 NULL, NULL, NULL, NULL);
4753 result =
lappend(result, info);
4812 char replident = relation->
rd_rel->relreplident;
4815 bool pkdeferrable =
false;
4832 Anum_pg_index_indrelid,
4850 if (!
index->indislive)
4861 if (!
index->indisvalid || !
index->indisunique ||
4862 !
index->indimmediate ||
4867 if (
index->indisprimary)
4868 pkeyIndex =
index->indexrelid;
4871 if (
index->indisreplident)
4872 candidateIndex =
index->indexrelid;
4888 if (replident == REPLICA_IDENTITY_DEFAULT &&
OidIsValid(pkeyIndex) && !pkdeferrable)
4890 else if (replident == REPLICA_IDENTITY_INDEX &&
OidIsValid(candidateIndex))
4952 Anum_pg_statistic_ext_stxrelid,
5064 Anum_pg_index_indexprs,
5116 Anum_pg_index_indexprs,
5126 foreach(lc, rawExprs)
5177 Anum_pg_index_indpred,
5255 List *newindexoidlist;
5277 elog(
ERROR,
"unknown attrKind %u", attrKind);
5292 if (indexoidlist ==
NIL)
5316 pkindexattrs = NULL;
5317 idindexattrs = NULL;
5318 hotblockingattrs = NULL;
5319 summarizedattrs = NULL;
5320 foreach(l, indexoidlist)
5326 Node *indexExpressions;
5327 Node *indexPredicate;
5350 indexExpressions = NULL;
5357 indexPredicate = NULL;
5360 isKey = indexDesc->
rd_index->indisunique &&
5361 indexExpressions == NULL &&
5362 indexPredicate == NULL;
5365 isPK = (indexOid == relpkindex);
5368 isIDKey = (indexOid == relreplindex);
5376 attrs = &summarizedattrs;
5378 attrs = &hotblockingattrs;
5381 for (
i = 0;
i < indexDesc->
rd_index->indnatts;
i++)
5383 int attrnum = indexDesc->
rd_index->indkey.values[
i];
5404 if (isKey && i < indexDesc->rd_index->indnkeyatts)
5408 if (isPK && i < indexDesc->rd_index->indnkeyatts)
5412 if (isIDKey && i < indexDesc->rd_index->indnkeyatts)
5434 if (
equal(indexoidlist, newindexoidlist) &&
5491 return pkindexattrs;
5493 return idindexattrs;
5495 return hotblockingattrs;
5497 return summarizedattrs;
5499 elog(
ERROR,
"unknown attrKind %u", attrKind);
5549 elog(
ERROR,
"could not open relation with OID %u",
5553 for (
i = 0;
i < indexDesc->
rd_index->indnatts;
i++)
5555 int attrnum = indexDesc->
rd_index->indkey.values[
i];
5563 if (i < indexDesc->rd_index->indnkeyatts)
5581 return idindexattrs;
5617 *operators = ops = (
Oid *)
palloc(
sizeof(
Oid) * indnkeyatts);
5618 *procs = funcs = (
Oid *)
palloc(
sizeof(
Oid) * indnkeyatts);
5624 memcpy(ops, indexRelation->
rd_exclops,
sizeof(
Oid) * indnkeyatts);
5625 memcpy(funcs, indexRelation->
rd_exclprocs,
sizeof(
Oid) * indnkeyatts);
5640 Anum_pg_constraint_conrelid,
5658 if ((conform->contype != CONSTRAINT_EXCLUSION &&
5659 !(conform->conperiod && (
5660 conform->contype == CONSTRAINT_PRIMARY
5661 || conform->contype == CONSTRAINT_UNIQUE))) ||
5667 elog(
ERROR,
"unexpected exclusion constraint record found for rel %s",
5673 Anum_pg_constraint_conexclop,
5674 conrel->
rd_att, &isnull);
5676 elog(
ERROR,
"null conexclop for rel %s",
5682 nelem != indnkeyatts ||
5685 elog(
ERROR,
"conexclop is not a 1-D Oid array");
5694 elog(
ERROR,
"exclusion constraint record missing for rel %s",
5698 for (
i = 0;
i < indnkeyatts;
i++)
5705 elog(
ERROR,
"could not find strategy for operator %u in family %u",
5714 memcpy(indexRelation->
rd_exclops, ops,
sizeof(
Oid) * indnkeyatts);
5715 memcpy(indexRelation->
rd_exclprocs, funcs,
sizeof(
Oid) * indnkeyatts);
5772 if (relation->
rd_rel->relispartition)
5777 foreach(lc, ancestors)
5790 foreach(lc, puboids)
5799 elog(
ERROR,
"cache lookup failed for publication %u", pubid);
5815 if (!pubform->puballtables &&
5816 (pubform->pubupdate || pubform->pubdelete) &&
5818 pubform->pubviaroot))
5820 if (pubform->pubupdate)
5822 if (pubform->pubdelete)
5832 if (!pubform->puballtables &&
5833 (pubform->pubupdate || pubform->pubdelete) &&
5835 pubform->pubviaroot))
5837 if (pubform->pubupdate)
5839 if (pubform->pubdelete)
5884 for (
int i = 0;
i < natts;
i++)
5916 for (
i = 0;
i < natts;
i++)
5924 if (attoptions != (
Datum) 0)
5937 for (
i = 0;
i < natts;
i++)
5981 const char *colname;
5984 if (
attnum > 0 && attnum <= reldesc->natts)
6093 snprintf(initfilename,
sizeof(initfilename),
"global/%s",
6096 snprintf(initfilename,
sizeof(initfilename),
"%s/%s",
6111 nailed_rels = nailed_indexes = 0;
6114 if (fread(&magic, 1,
sizeof(magic), fp) !=
sizeof(magic))
6119 for (relno = 0;; relno++)
6128 nread = fread(&
len, 1,
sizeof(
len), fp);
6129 if (nread !=
sizeof(
len))
6141 if (num_rels >= max_rels)
6150 if (fread(rel, 1,
len, fp) !=
len)
6154 if (fread(&
len, 1,
sizeof(
len), fp) !=
sizeof(
len))
6158 if (fread(relform, 1,
len, fp) !=
len)
6167 rel->
rd_att->
tdtypeid = relform->reltype ? relform->reltype : RECORDOID;
6171 has_not_null =
false;
6172 for (
i = 0;
i < relform->relnatts;
i++)
6176 if (fread(&
len, 1,
sizeof(
len), fp) !=
sizeof(
len))
6180 if (fread(attr, 1,
len, fp) !=
len)
6183 has_not_null |= attr->attnotnull;
6187 if (fread(&
len, 1,
sizeof(
len), fp) !=
sizeof(
len))
6215 if (rel->
rd_rel->relkind == RELKIND_INDEX)
6230 if (fread(&
len, 1,
sizeof(
len), fp) !=
sizeof(
len))
6261 if (fread(&
len, 1,
sizeof(
len), fp) !=
sizeof(
len))
6265 if (fread(opfamily, 1,
len, fp) !=
len)
6271 if (fread(&
len, 1,
sizeof(
len), fp) !=
sizeof(
len))
6275 if (fread(opcintype, 1,
len, fp) !=
len)
6281 if (fread(&
len, 1,
sizeof(
len), fp) !=
sizeof(
len))
6284 if (fread(support, 1,
len, fp) !=
len)
6290 if (fread(&
len, 1,
sizeof(
len), fp) !=
sizeof(
len))
6294 if (fread(indcollation, 1,
len, fp) !=
len)
6300 if (fread(&
len, 1,
sizeof(
len), fp) !=
sizeof(
len))
6304 if (fread(indoption, 1,
len, fp) !=
len)
6313 for (
i = 0;
i < relform->relnatts;
i++)
6315 if (fread(&
len, 1,
sizeof(
len), fp) !=
sizeof(
len))
6338 if (RELKIND_HAS_TABLE_AM(rel->
rd_rel->relkind) || rel->
rd_rel->relkind == RELKIND_SEQUENCE)
6437 elog(
WARNING,
"found %d nailed shared rels and %d nailed shared indexes in init file, but expected %d and %d respectively",
6438 nailed_rels, nailed_indexes,
6451 elog(
WARNING,
"found %d nailed rels and %d nailed indexes in init file, but expected %d and %d respectively",
6452 nailed_rels, nailed_indexes,
6464 for (relno = 0; relno < num_rels; relno++)
6519 snprintf(tempfilename,
sizeof(tempfilename),
"global/%s.%d",
6521 snprintf(finalfilename,
sizeof(finalfilename),
"global/%s",
6526 snprintf(tempfilename,
sizeof(tempfilename),
"%s/%s.%d",
6528 snprintf(finalfilename,
sizeof(finalfilename),
"%s/%s",
6532 unlink(tempfilename);
6543 errmsg(
"could not create relation-cache initialization file \"%s\": %m",
6545 errdetail(
"Continuing anyway, but there's something wrong.")));
6554 if (fwrite(&magic, 1,
sizeof(magic), fp) !=
sizeof(magic))
6570 if (relform->relisshared != shared)
6597 for (
i = 0;
i < relform->relnatts;
i++)
6612 if (rel->
rd_rel->relkind == RELKIND_INDEX)
6622 relform->relnatts *
sizeof(
Oid),
6627 relform->relnatts *
sizeof(
Oid),
6637 relform->relnatts *
sizeof(
Oid),
6642 relform->relnatts *
sizeof(
int16),
6648 for (
i = 0;
i < relform->relnatts;
i++)
6693 if (rename(tempfilename, finalfilename) < 0)
6694 unlink(tempfilename);
6699 unlink(tempfilename);
6709 if (fwrite(&
len, 1,
sizeof(
len), fp) !=
sizeof(
len))
6732 if (relationId == SharedSecLabelRelationId ||
6733 relationId == TriggerRelidNameIndexId ||
6734 relationId == DatabaseNameIndexId ||
6735 relationId == SharedSecLabelObjectIndexId)
6776 snprintf(localinitfname,
sizeof(localinitfname),
"%s/%s",
6778 snprintf(sharedinitfname,
sizeof(sharedinitfname),
"global/%s",
6817 snprintf(path,
sizeof(path),
"global/%s",
6829 if (strspn(de->
d_name,
"0123456789") == strlen(de->
d_name))
6832 snprintf(path,
sizeof(path),
"%s/%s/%s",
6854 if (strspn(de->
d_name,
"0123456789") == strlen(de->
d_name))
6857 snprintf(initfilename,
sizeof(initfilename),
"%s/%s/%s",
6869 if (unlink(initfilename) < 0)
6872 if (errno != ENOENT)
6875 errmsg(
"could not remove cache file \"%s\": %m",
IndexAmRoutine * GetIndexAmRoutine(Oid amhandler)
bytea *(* amoptions_function)(Datum reloptions, bool validate)
#define DatumGetArrayTypeP(X)
Datum array_get_element(Datum arraydatum, int nSubscripts, int *indx, int arraytyplen, int elmlen, bool elmbyval, char elmalign, bool *isNull)
void bms_free(Bitmapset *a)
Bitmapset * bms_add_member(Bitmapset *a, int x)
Bitmapset * bms_copy(const Bitmapset *a)
#define TextDatumGetCString(d)
#define TopSubTransactionId
#define InvalidSubTransactionId
#define Assert(condition)
TransactionId MultiXactId
#define PointerIsValid(pointer)
#define OidIsValid(objectId)
bool IsSystemRelation(Relation relation)
RelFileNumber GetNewRelFileNumber(Oid reltablespace, Relation pg_class, char relpersistence)
bool IsCatalogNamespace(Oid namespaceId)
bool IsCatalogRelation(Relation relation)
bool IsSharedRelation(Oid relationId)
void CreateCacheMemoryContext(void)
Node * eval_const_expressions(PlannerInfo *root, Node *node)
Datum datumCopy(Datum value, bool typByVal, int typLen)
static void PGresult * res
void * hash_search(HTAB *hashp, const void *keyPtr, HASHACTION action, bool *foundPtr)
void hash_seq_term(HASH_SEQ_STATUS *status)
HTAB * hash_create(const char *tabname, long nelem, const HASHCTL *info, int flags)
void * hash_seq_search(HASH_SEQ_STATUS *status)
void hash_seq_init(HASH_SEQ_STATUS *status, HTAB *hashp)
int err_generic_string(int field, const char *str)
int errmsg_internal(const char *fmt,...)
int errcode_for_file_access(void)
int errdetail(const char *fmt,...)
int errcode(int sqlerrcode)
int errmsg(const char *fmt,...)
#define ereport(elevel,...)
bool equal(const void *a, const void *b)
FILE * AllocateFile(const char *name, const char *mode)
struct dirent * ReadDirExtended(DIR *dir, const char *dirname, int elevel)
DIR * AllocateDir(const char *dirname)
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)
RelFileNumber binary_upgrade_next_heap_pg_class_relfilenumber
const TableAmRoutine * GetHeapamTableAmRoutine(void)
HeapTuple heap_copytuple(HeapTuple tuple)
bool heap_attisnull(HeapTuple tup, int attnum, TupleDesc tupleDesc)
void heap_freetuple(HeapTuple htup)
HeapTupleData * HeapTuple
HeapTupleHeaderData * HeapTupleHeader
#define HeapTupleIsValid(tuple)
static Datum heap_getattr(HeapTuple tup, int attnum, TupleDesc tupleDesc, bool *isnull)
#define HeapTupleHeaderSetXmin(tup, xid)
#define HeapTupleHeaderGetXmin(tup)
static Datum fastgetattr(HeapTuple tup, int attnum, TupleDesc tupleDesc, bool *isnull)
#define IsParallelWorker()
RelFileNumber binary_upgrade_next_index_pg_class_relfilenumber
void index_close(Relation relation, LOCKMODE lockmode)
Relation index_open(Oid relationId, LOCKMODE lockmode)
bytea * index_opclass_options(Relation indrel, AttrNumber attnum, Datum attoptions, bool validate)
void CatalogTupleUpdate(Relation heapRel, ItemPointer otid, HeapTuple tup)
static int pg_cmp_s16(int16 a, int16 b)
void AcceptInvalidationMessages(void)
void CacheInvalidateRelcache(Relation relation)
void list_sort(List *list, list_sort_comparator cmp)
List * list_concat_unique_oid(List *list1, const List *list2)
List * lappend(List *list, void *datum)
List * lappend_oid(List *list, Oid datum)
List * list_copy(const List *oldlist)
int list_oid_cmp(const ListCell *p1, const ListCell *p2)
void list_free(List *list)
List * lcons(void *datum, List *list)
void list_free_deep(List *list)
void UnlockRelationOid(Oid relid, LOCKMODE lockmode)
void RelationInitLockInfo(Relation relation)
void LockRelationOid(Oid relid, LOCKMODE lockmode)
void UnlockTuple(Relation relation, ItemPointer tid, LOCKMODE lockmode)
#define InplaceUpdateTupleLock
char * get_namespace_name(Oid nspid)
Datum get_attoptions(Oid relid, int16 attnum)
Oid get_rel_namespace(Oid relid)
RegProcedure get_opcode(Oid opno)
int get_op_opfamily_strategy(Oid opno, Oid opfamily)
char * get_attname(Oid relid, AttrNumber attnum, bool missing_ok)
bool LWLockAcquire(LWLock *lock, LWLockMode mode)
void LWLockRelease(LWLock *lock)
List * make_ands_implicit(Expr *clause)
Const * makeConst(Oid consttype, int32 consttypmod, Oid constcollid, int constlen, Datum constvalue, bool constisnull, bool constbyval)
void MemoryContextSetParent(MemoryContext context, MemoryContext new_parent)
void pfree(void *pointer)
void MemoryContextDeleteChildren(MemoryContext context)
void * palloc0(Size size)
void * MemoryContextAllocZero(MemoryContext context, Size size)
MemoryContext CurrentMemoryContext
void * repalloc(void *pointer, Size size)
void * MemoryContextAlloc(MemoryContext context, Size size)
char * MemoryContextStrdup(MemoryContext context, const char *string)
MemoryContext CacheMemoryContext
void MemoryContextDelete(MemoryContext context)
#define AllocSetContextCreate
#define ALLOCSET_DEFAULT_SIZES
#define ALLOCSET_SMALL_SIZES
#define MemoryContextCopyAndSetIdentifier(cxt, id)
#define IsBootstrapProcessingMode()
#define InvalidMultiXactId
void namestrcpy(Name name, const char *str)
bool isTempOrTempToastNamespace(Oid namespaceId)
ProcNumber GetTempNamespaceProcNumber(Oid namespaceId)
Oid exprType(const Node *expr)
int32 exprTypmod(const Node *expr)
Oid exprCollation(const Node *expr)
void fix_opfuncids(Node *node)
List * get_partition_ancestors(Oid relid)
FormData_pg_am * Form_pg_am
static AmcheckOptions opts
FormData_pg_amproc * Form_pg_amproc
FormData_pg_attrdef * Form_pg_attrdef
#define ATTRIBUTE_FIXED_PART_SIZE
FormData_pg_attribute * Form_pg_attribute
#define ERRCODE_DATA_CORRUPTED
FormData_pg_class * Form_pg_class
void DeconstructFkConstraintRow(HeapTuple tuple, int *numfks, AttrNumber *conkey, AttrNumber *confkey, Oid *pf_eq_oprs, Oid *pp_eq_oprs, Oid *ff_eq_oprs, int *num_fk_del_set_cols, AttrNumber *fk_del_set_cols)
FormData_pg_constraint * Form_pg_constraint
FormData_pg_index * Form_pg_index
static int list_length(const List *l)
#define forboth(cell1, list1, cell2, list2)
FormData_pg_opclass * Form_pg_opclass
List * GetSchemaPublications(Oid schemaid)
List * GetRelationPublications(Oid relid)
List * GetAllTablesPublications(void)
bool is_publishable_relation(Relation rel)
FormData_pg_publication * Form_pg_publication
FormData_pg_rewrite * Form_pg_rewrite
FormData_pg_statistic_ext * Form_pg_statistic_ext
void pgstat_unlink_relation(Relation rel)
void RelationBuildRowSecurity(Relation relation)
#define qsort(a, b, c, d)
static Datum PointerGetDatum(const void *X)
static Datum Int16GetDatum(int16 X)
static Datum ObjectIdGetDatum(Oid X)
static Pointer DatumGetPointer(Datum X)
#define PG_DIAG_SCHEMA_NAME
#define PG_DIAG_CONSTRAINT_NAME
#define PG_DIAG_TABLE_NAME
#define PG_DIAG_COLUMN_NAME
Expr * canonicalize_qual(Expr *qual, bool is_check)
#define ProcNumberForTempRelations()
#define INVALID_PROC_NUMBER
char * psprintf(const char *fmt,...)
bool pub_rf_contains_invalid_column(Oid pubid, Relation relation, List *ancestors, bool pubviaroot)
bool pub_collist_contains_invalid_column(Oid pubid, Relation relation, List *ancestors, bool pubviaroot)
MemoryContextSwitchTo(old_ctx)
void * stringToNode(const char *str)
#define RelationGetForm(relation)
#define RelationHasReferenceCountZero(relation)
#define RelationGetRelid(relation)
#define RelationHasSecurityInvoker(relation)
#define RelationGetDescr(relation)
#define RelationIsMapped(relation)
#define RelationGetNumberOfAttributes(relation)
#define RelationGetRelationName(relation)
#define RelationIsAccessibleInLogicalDecoding(relation)
#define RelationIsValid(relation)
#define RelationGetNamespace(relation)
#define IndexRelationGetNumberOfAttributes(relation)
#define IndexRelationGetNumberOfKeyAttributes(relation)
#define RelationIsPermanent(relation)
static void RelationCloseSmgr(Relation relation)
#define RECOVER_RELATION_BUILD_MEMORY
static int NextEOXactTupleDescNum
static bool load_relcache_init_file(bool shared)
void RelationBuildPublicationDesc(Relation relation, PublicationDesc *pubdesc)
static void RelationParseRelOptions(Relation relation, HeapTuple tuple)
List * RelationGetIndexList(Relation relation)
void RelationCacheInvalidate(bool debug_discard)
#define NUM_CRITICAL_LOCAL_RELS
#define NUM_CRITICAL_SHARED_INDEXES
#define RelationCacheInsert(RELATION, replace_allowed)
void RelationDecrementReferenceCount(Relation rel)
static Relation RelationBuildDesc(Oid targetRelId, bool insertIt)
bool criticalRelcachesBuilt
static TupleDesc BuildHardcodedDescriptor(int natts, const FormData_pg_attribute *attrs)
static const FormData_pg_attribute Desc_pg_shseclabel[Natts_pg_shseclabel]
bool criticalSharedRelcachesBuilt
static Oid eoxact_list[MAX_EOXACT_LIST]
static void formrdesc(const char *relationName, Oid relationReltype, bool isshared, int natts, const FormData_pg_attribute *attrs)
Oid RelationGetPrimaryKeyIndex(Relation relation)
static void ResOwnerReleaseRelation(Datum res)
static Relation AllocateRelationDesc(Form_pg_class relp)
static const FormData_pg_attribute Desc_pg_database[Natts_pg_database]
static void unlink_initfile(const char *initfilename, int elevel)
int errtableconstraint(Relation rel, const char *conname)
int errtablecol(Relation rel, int attnum)
void RelationInitIndexAccessInfo(Relation relation)
static void InitIndexAmRoutine(Relation relation)
static void write_item(const void *data, Size len, FILE *fp)
List * RelationGetIndexPredicate(Relation relation)
static const FormData_pg_attribute Desc_pg_attribute[Natts_pg_attribute]
List * RelationGetStatExtList(Relation relation)
static bool equalRuleLocks(RuleLock *rlock1, RuleLock *rlock2)
static int in_progress_list_maxlen
static int CheckConstraintCmp(const void *a, const void *b)
void AtEOSubXact_RelationCache(bool isCommit, SubTransactionId mySubid, SubTransactionId parentSubid)
static void ResourceOwnerRememberRelationRef(ResourceOwner owner, Relation rel)
static const FormData_pg_attribute Desc_pg_class[Natts_pg_class]
static void RelationReloadNailed(Relation relation)
static const FormData_pg_attribute Desc_pg_authid[Natts_pg_authid]
static TupleDesc GetPgClassDescriptor(void)
static void AttrDefaultFetch(Relation relation, int ndef)
static HTAB * OpClassCache
static const ResourceOwnerDesc relref_resowner_desc
static void IndexSupportInitialize(oidvector *indclass, RegProcedure *indexSupport, Oid *opFamily, Oid *opcInType, StrategyNumber maxSupportNumber, AttrNumber maxAttributeNumber)
void RelationIncrementReferenceCount(Relation rel)
#define RelationCacheDelete(RELATION)
void RelationCacheInitFilePostInvalidate(void)
Bitmapset * RelationGetIndexAttrBitmap(Relation relation, IndexAttrBitmapKind attrKind)
void RelationCacheInitializePhase3(void)
#define NUM_CRITICAL_SHARED_RELS
List * RelationGetDummyIndexExpressions(Relation relation)
static void RelationDestroyRelation(Relation relation, bool remember_tupdesc)
static void RelationClearRelation(Relation relation, bool rebuild)
List * RelationGetFKeyList(Relation relation)
#define EOXactListAdd(rel)
#define RelationIdCacheLookup(ID, RELATION)
void RelationInitTableAccessMethod(Relation relation)
static const FormData_pg_attribute Desc_pg_subscription[Natts_pg_subscription]
static void RelationFlushRelation(Relation relation)
static void RelationBuildRuleLock(Relation relation)
static void ResourceOwnerForgetRelationRef(ResourceOwner owner, Relation rel)
static int in_progress_list_len
static const FormData_pg_attribute Desc_pg_proc[Natts_pg_proc]
void RelationSetNewRelfilenumber(Relation relation, char persistence)
static const FormData_pg_attribute Desc_pg_index[Natts_pg_index]
static int EOXactTupleDescArrayLen
Oid RelationGetReplicaIndex(Relation relation)
Relation RelationIdGetRelation(Oid relationId)
static TupleDesc GetPgIndexDescriptor(void)
static void RelationCloseCleanup(Relation relation)
#define NUM_CRITICAL_LOCAL_INDEXES
static const FormData_pg_attribute Desc_pg_auth_members[Natts_pg_auth_members]
static void RelationCacheInitFileRemoveInDir(const char *tblspcpath)
static char * ResOwnerPrintRelCache(Datum res)
void AtEOXact_RelationCache(bool isCommit)
static void CheckConstraintFetch(Relation relation)
void RelationForgetRelation(Oid rid)
static void AtEOSubXact_cleanup(Relation relation, bool isCommit, SubTransactionId mySubid, SubTransactionId parentSubid)
void RelationCacheInitialize(void)
void RelationCacheInitFilePreInvalidate(void)
static bytea ** CopyIndexAttOptions(bytea **srcopts, int natts)
static void write_relcache_init_file(bool shared)
Relation RelationBuildLocalRelation(const char *relname, Oid relnamespace, TupleDesc tupDesc, Oid relid, Oid accessmtd, RelFileNumber relfilenumber, Oid reltablespace, bool shared_relation, bool mapped_relation, char relpersistence, char relkind)
void RelationAssumeNewRelfilelocator(Relation relation)
static void RememberToFreeTupleDescAtEOX(TupleDesc td)
static HeapTuple ScanPgRelation(Oid targetRelId, bool indexOK, bool force_non_historic)
static void RelationInitPhysicalAddr(Relation relation)
static void RelationBuildTupleDesc(Relation relation)
static bool equalRSDesc(RowSecurityDesc *rsdesc1, RowSecurityDesc *rsdesc2)
void RelationCacheInitFileRemove(void)
static void AtEOXact_cleanup(Relation relation, bool isCommit)
int errtablecolname(Relation rel, const char *colname)
struct relidcacheent RelIdCacheEnt
static const FormData_pg_attribute Desc_pg_type[Natts_pg_type]
void RelationCacheInitializePhase2(void)
static InProgressEnt * in_progress_list
bool RelationIdIsInInitFile(Oid relationId)
static void RelationReloadIndexInfo(Relation relation)
static long relcacheInvalsReceived
static void load_critical_index(Oid indexoid, Oid heapoid)
static void InitTableAmRoutine(Relation relation)
int errtable(Relation rel)
void RelationCacheInvalidateEntry(Oid relationId)
static bool equalPolicy(RowSecurityPolicy *policy1, RowSecurityPolicy *policy2)
bytea ** RelationGetIndexAttOptions(Relation relation, bool copy)
Bitmapset * RelationGetIdentityKeyBitmap(Relation relation)
static int eoxact_list_len
struct opclasscacheent OpClassCacheEnt
static OpClassCacheEnt * LookupOpclassInfo(Oid operatorClassOid, StrategyNumber numSupport)
static TupleDesc * EOXactTupleDescArray
static bool eoxact_list_overflowed
void RelationGetExclusionInfo(Relation indexRelation, Oid **operators, Oid **procs, uint16 **strategies)
static int AttrDefaultCmp(const void *a, const void *b)
#define SWAPFIELD(fldtype, fldname)
#define RELCACHE_INIT_FILEMAGIC
List * RelationGetIndexExpressions(Relation relation)
static HTAB * RelationIdCache
struct inprogressent InProgressEnt
static void RelationInvalidateRelation(Relation relation)
void RelationClose(Relation relation)
struct RelationData * Relation
#define RELCACHE_INIT_FILENAME
@ INDEX_ATTR_BITMAP_HOT_BLOCKING
@ INDEX_ATTR_BITMAP_PRIMARY_KEY
@ INDEX_ATTR_BITMAP_SUMMARIZED
@ INDEX_ATTR_BITMAP_IDENTITY_KEY
#define AssertPendingSyncs_RelationCache()
void RelationMapInvalidateAll(void)
void RelationMapInitialize(void)
void RelationMapInitializePhase2(void)
RelFileNumber RelationMapOidToFilenumber(Oid relationId, bool shared)
void RelationMapUpdateMap(Oid relationId, RelFileNumber fileNumber, bool shared, bool immediate)
void RelationMapInitializePhase3(void)
bytea * extractRelOptions(HeapTuple tuple, TupleDesc tupdesc, amoptions_function amoptions)
#define InvalidRelFileNumber
#define TABLESPACE_VERSION_DIRECTORY
#define RelFileNumberIsValid(relnumber)
ResourceOwner CurrentResourceOwner
void ResourceOwnerForget(ResourceOwner owner, Datum value, const ResourceOwnerDesc *kind)
void ResourceOwnerRemember(ResourceOwner owner, Datum value, const ResourceOwnerDesc *kind)
void ResourceOwnerEnlarge(ResourceOwner owner)
@ RESOURCE_RELEASE_BEFORE_LOCKS
#define RELEASE_PRIO_RELCACHE_REFS
void setRuleCheckAsUser(Node *node, Oid userid)
void ScanKeyInit(ScanKey entry, AttrNumber attributeNumber, StrategyNumber strategy, RegProcedure procedure, Datum argument)
SMgrRelation smgropen(RelFileLocator rlocator, ProcNumber backend)
void smgrreleaseall(void)
void smgrclose(SMgrRelation reln)
void smgrdounlinkall(SMgrRelation *rels, int nrels, bool isRedo)
Snapshot GetTransactionSnapshot(void)
void PushActiveSnapshot(Snapshot snapshot)
bool HistoricSnapshotActive(void)
void PopActiveSnapshot(void)
Snapshot GetNonHistoricCatalogSnapshot(Oid relid)
bool RelFileLocatorSkippingWAL(RelFileLocator rlocator)
SMgrRelation RelationCreateStorage(RelFileLocator rlocator, char relpersistence, bool register_delete)
void RelationDropStorage(Relation rel)
#define BTGreaterStrategyNumber
#define BTEqualStrategyNumber
amoptions_function amoptions
PublicationActions pubactions
bool cols_valid_for_delete
bool cols_valid_for_update
MemoryContext rd_partkeycxt
const struct TableAmRoutine * rd_tableam
TransactionId rd_partdesc_nodetached_xmin
struct IndexAmRoutine * rd_indam
SubTransactionId rd_firstRelfilelocatorSubid
struct RowSecurityDesc * rd_rsdesc
PartitionDesc rd_partdesc
RegProcedure * rd_support
PartitionDesc rd_partdesc_nodetached
PublicationDesc * rd_pubdesc
struct FdwRoutine * rd_fdwroutine
struct HeapTupleData * rd_indextuple
MemoryContext rd_partcheckcxt
Bitmapset * rd_hotblockingattr
SubTransactionId rd_newRelfilelocatorSubid
SubTransactionId rd_createSubid
MemoryContext rd_indexcxt
RelFileLocator rd_locator
struct FmgrInfo * rd_supportinfo
SubTransactionId rd_droppedSubid
MemoryContext rd_rulescxt
Bitmapset * rd_summarizedattr
struct PgStat_TableStatus * pgstat_info
bool has_generated_stored
struct AttrMissing * missing
int16 values[FLEXIBLE_ARRAY_MEMBER]
Oid values[FLEXIBLE_ARRAY_MEMBER]
StrategyNumber numSupport
RegProcedure * supportProcs
#define FirstLowInvalidHeapAttributeNumber
void ReleaseSysCache(HeapTuple tuple)
HeapTuple SearchSysCacheLockedCopy1(int cacheId, Datum key1)
HeapTuple SearchSysCache1(int cacheId, Datum key1)
bool RelationSupportsSysCache(Oid relid)
void InitCatalogCachePhase2(void)
void table_close(Relation relation, LOCKMODE lockmode)
Relation table_open(Oid relationId, LOCKMODE lockmode)
static void table_relation_set_new_filelocator(Relation rel, const RelFileLocator *newrlocator, char persistence, TransactionId *freezeXid, MultiXactId *minmulti)
const TableAmRoutine * GetTableAmRoutine(Oid amhandler)
#define InvalidTransactionId
void FreeTriggerDesc(TriggerDesc *trigdesc)
void RelationBuildTriggers(Relation relation)
void FreeTupleDesc(TupleDesc tupdesc)
TupleDesc CreateTemplateTupleDesc(int natts)
TupleDesc CreateTupleDescCopy(TupleDesc tupdesc)
bool equalTupleDescs(TupleDesc tupdesc1, TupleDesc tupdesc2)
#define TupleDescAttr(tupdesc, i)
void pull_varattnos(Node *node, Index varno, Bitmapset **varattnos)
SubTransactionId GetCurrentSubTransactionId(void)
bool IsTransactionState(void)
void CommandCounterIncrement(void)
TransactionId GetCurrentTransactionId(void)
static struct rule * rules