20 #include "catalog/pg_class_d.h"
21 #include "catalog/pg_collation_d.h"
22 #include "catalog/pg_extension_d.h"
23 #include "catalog/pg_namespace_d.h"
24 #include "catalog/pg_operator_d.h"
25 #include "catalog/pg_proc_d.h"
26 #include "catalog/pg_publication_d.h"
27 #include "catalog/pg_subscription_d.h"
28 #include "catalog/pg_type_d.h"
65 #define SH_PREFIX catalogid
66 #define SH_ELEMENT_TYPE CatalogIdMapEntry
67 #define SH_KEY_TYPE CatalogId
69 #define SH_HASH_KEY(tb, key) hash_bytes((const unsigned char *) &(key), sizeof(CatalogId))
70 #define SH_EQUAL(tb, a, b) ((a).oid == (b).oid && (a).tableoid == (b).tableoid)
72 #define SH_GET_HASH(tb, a) (a)->hashval
73 #define SH_SCOPE static inline
74 #define SH_RAW_ALLOCATOR pg_malloc0
79 #define CATALOGIDHASH_INITIAL_SIZE 10000
84 InhInfo *inhinfo,
int numInherits);
88 static int strInArray(
const char *pattern,
char **arr,
int arr_size);
116 int numAccessMethods;
124 int numForeignDataWrappers;
125 int numForeignServers;
127 int numEventTriggers;
165 pg_log_info(
"reading user-defined aggregate functions");
171 pg_log_info(
"reading user-defined access methods");
174 pg_log_info(
"reading user-defined operator classes");
177 pg_log_info(
"reading user-defined operator families");
180 pg_log_info(
"reading user-defined text search parsers");
183 pg_log_info(
"reading user-defined text search templates");
186 pg_log_info(
"reading user-defined text search dictionaries");
189 pg_log_info(
"reading user-defined text search configurations");
192 pg_log_info(
"reading user-defined foreign-data wrappers");
195 pg_log_info(
"reading user-defined foreign servers");
213 pg_log_info(
"reading table inheritance information");
225 flagInhTables(fout, tblinfo, numTables, inhinfo, numInherits);
227 pg_log_info(
"reading column info for interesting tables");
230 pg_log_info(
"flagging inherited columns in subtables");
239 pg_log_info(
"flagging indexes in partitioned tables");
260 pg_log_info(
"reading publication membership of tables");
263 pg_log_info(
"reading publication membership of schemas");
269 pg_log_info(
"reading subscription membership of tables");
274 *numTablesPtr = numTables;
292 InhInfo *inhinfo,
int numInherits)
307 for (
i = 0;
i < numInherits;
i++)
327 if (parent == NULL ||
332 pg_fatal(
"failed sanity check, parent OID %u of table \"%s\" (OID %u) not found",
333 inhinfo[
i].inhparent,
350 for (
i = 0;
i < numTables;
i++)
357 if (tblinfo[
i].dobj.dump)
362 for (
j = 0;
j < numParents;
j++)
363 parents[
j]->interesting =
true;
373 if (tblinfo[
i].numParents != 1)
374 pg_fatal(
"invalid number of parents %d for table \"%s\"",
375 tblinfo[
i].numParents,
376 tblinfo[
i].dobj.name);
384 attachinfo->
dobj.namespace = tblinfo[
i].
dobj.namespace;
414 for (
i = 0;
i < numTables;
i++)
416 if (!tblinfo[
i].ispartition || tblinfo[
i].numParents == 0)
419 Assert(tblinfo[
i].numParents == 1);
427 if (
index->parentidx == 0)
431 if (parentidx == NULL)
441 attachinfo->
dobj.namespace =
index->indextable->dobj.namespace;
463 index->indextable->dobj.dumpId);
513 for (
i = 0;
i < numTables;
i++)
520 if (tbinfo->
relkind == RELKIND_SEQUENCE ||
521 tbinfo->
relkind == RELKIND_VIEW ||
522 tbinfo->
relkind == RELKIND_MATVIEW)
540 bool foundSameGenerated;
541 bool foundDiffGenerated;
547 foundNotNull =
false;
548 foundDefault =
false;
549 foundSameGenerated =
false;
550 foundDiffGenerated =
false;
551 for (k = 0; k < numParents; k++)
565 foundDefault |= (parentDef != NULL &&
566 strcmp(parentDef->
adef_expr,
"NULL") != 0 &&
571 if (parentDef != NULL &&
575 foundSameGenerated =
true;
577 foundDiffGenerated =
true;
594 if (foundDefault && tbinfo->
attrdefs[
j] == NULL)
604 attrDef->
dobj.namespace = tbinfo->
dobj.namespace;
630 if (foundSameGenerated && !foundDiffGenerated &&
650 dobj->namespace = NULL;
833 catId.
tableoid = RelationRelationId;
851 catId.
tableoid = RelationRelationId;
888 catId.
tableoid = ProcedureRelationId;
906 catId.
tableoid = OperatorRelationId;
924 catId.
tableoid = CollationRelationId;
942 catId.
tableoid = NamespaceRelationId;
960 catId.
tableoid = ExtensionRelationId;
978 catId.
tableoid = PublicationRelationId;
996 catId.
tableoid = SubscriptionRelationId;
1070 if (s ==
' ' || s ==
'\0')
1074 if (argNum >= arraysize)
1075 pg_fatal(
"could not parse numeric array \"%s\": too many numbers",
str);
1077 array[argNum++] =
atooid(temp);
1085 if (!(isdigit((
unsigned char) s) || s ==
'-') ||
1086 j >=
sizeof(temp) - 1)
1087 pg_fatal(
"could not parse numeric array \"%s\": invalid character in number",
str);
1092 while (argNum < arraysize)
1109 for (
i = 0;
i < arr_size;
i++)
1111 if (strcmp(pattern, arr[
i]) == 0)
void recordExtensionMembership(CatalogId catId, ExtensionInfo *ext)
FuncInfo * findFuncByOid(Oid oid)
static void flagInhAttrs(Archive *fout, DumpOptions *dopt, TableInfo *tblinfo, int numTables)
static void flagInhTables(Archive *fout, TableInfo *tblinfo, int numTables, InhInfo *inhinfo, int numInherits)
static void flagInhIndexes(Archive *fout, TableInfo *tblinfo, int numTables)
NamespaceInfo * findNamespaceByOid(Oid oid)
SubscriptionInfo * findSubscriptionByOid(Oid oid)
ExtensionInfo * findOwningExtension(CatalogId catalogId)
TableInfo * getSchemaData(Archive *fout, int *numTablesPtr)
DumpableObject * findObjectByCatalogId(CatalogId catalogId)
void addObjectDependency(DumpableObject *dobj, DumpId refId)
static int allocedDumpIds
DumpableObject * findObjectByDumpId(DumpId dumpId)
void parseOidArray(const char *str, Oid *array, int arraysize)
TableInfo * findTableByOid(Oid oid)
static IndxInfo * findIndexByOid(Oid oid)
DumpId createDumpId(void)
ExtensionInfo * findExtensionByOid(Oid oid)
void AssignDumpId(DumpableObject *dobj)
DumpId getMaxDumpId(void)
static DumpableObject ** dumpIdMap
#define CATALOGIDHASH_INITIAL_SIZE
static int strInArray(const char *pattern, char **arr, int arr_size)
void getDumpableObjects(DumpableObject ***objs, int *numObjs)
CollInfo * findCollationByOid(Oid oid)
static catalogid_hash * catalogIdHash
TypeInfo * findTypeByOid(Oid oid)
OprInfo * findOprByOid(Oid oid)
struct _catalogIdMapEntry CatalogIdMapEntry
void removeObjectDependency(DumpableObject *dobj, DumpId refId)
PublicationInfo * findPublicationByOid(Oid oid)
#define OidIsValid(objectId)
char * pg_strdup(const char *in)
#define pg_realloc_array(pointer, type, count)
#define pg_malloc_array(type, count)
#define pg_malloc_object(type)
Assert(fmt[strlen(fmt) - 1] !='\n')
NamespaceInfo * getNamespaces(Archive *fout, int *numNamespaces)
void getConstraints(Archive *fout, TableInfo tblinfo[], int numTables)
void getPublicationNamespaces(Archive *fout)
void getPartitioningInfo(Archive *fout)
DefaultACLInfo * getDefaultACLs(Archive *fout, int *numDefaultACLs)
void getPolicies(Archive *fout, TableInfo tblinfo[], int numTables)
void getExtensionMembership(Archive *fout, ExtensionInfo extinfo[], int numExtensions)
ForeignServerInfo * getForeignServers(Archive *fout, int *numForeignServers)
AccessMethodInfo * getAccessMethods(Archive *fout, int *numAccessMethods)
FdwInfo * getForeignDataWrappers(Archive *fout, int *numForeignDataWrappers)
FuncInfo * getFuncs(Archive *fout, int *numFuncs)
TSConfigInfo * getTSConfigurations(Archive *fout, int *numTSConfigs)
ConvInfo * getConversions(Archive *fout, int *numConversions)
void getOwnedSeqs(Archive *fout, TableInfo tblinfo[], int numTables)
void getPublicationTables(Archive *fout, TableInfo tblinfo[], int numTables)
AggInfo * getAggregates(Archive *fout, int *numAggs)
void getIndexes(Archive *fout, TableInfo tblinfo[], int numTables)
TSDictInfo * getTSDictionaries(Archive *fout, int *numTSDicts)
InhInfo * getInherits(Archive *fout, int *numInherits)
OpfamilyInfo * getOpfamilies(Archive *fout, int *numOpfamilies)
void getTableAttrs(Archive *fout, TableInfo *tblinfo, int numTables)
void getSubscriptionTables(Archive *fout)
PublicationInfo * getPublications(Archive *fout, int *numPublications)
TSTemplateInfo * getTSTemplates(Archive *fout, int *numTSTemplates)
ProcLangInfo * getProcLangs(Archive *fout, int *numProcLangs)
TypeInfo * getTypes(Archive *fout, int *numTypes)
void getExtendedStatistics(Archive *fout)
void processExtensionTables(Archive *fout, ExtensionInfo extinfo[], int numExtensions)
OpclassInfo * getOpclasses(Archive *fout, int *numOpclasses)
CollInfo * getCollations(Archive *fout, int *numCollations)
void getSubscriptions(Archive *fout)
ExtensionInfo * getExtensions(Archive *fout, int *numExtensions)
TSParserInfo * getTSParsers(Archive *fout, int *numTSParsers)
TransformInfo * getTransforms(Archive *fout, int *numTransforms)
void getTriggers(Archive *fout, TableInfo tblinfo[], int numTables)
OprInfo * getOperators(Archive *fout, int *numOprs)
RuleInfo * getRules(Archive *fout, int *numRules)
EventTriggerInfo * getEventTriggers(Archive *fout, int *numEventTriggers)
TableInfo * getTables(Archive *fout, int *numTables)
bool shouldPrintColumn(const DumpOptions *dopt, const TableInfo *tbinfo, int colno)
CastInfo * getCasts(Archive *fout, int *numCasts)
#define DUMP_COMPONENT_ALL
#define DUMP_COMPONENT_NONE
#define DUMP_COMPONENT_DEFINITION
void simple_ptr_list_append(SimplePtrList *list, void *ptr)
DumpComponents components
DumpableObjectType objType
DumpComponents dump_contains
SimplePtrList partattaches
struct _indxInfo * indexes
struct _tableInfo ** parents
struct _attrDefInfo ** attrdefs