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_type_d.h"
64 #define SH_PREFIX catalogid
65 #define SH_ELEMENT_TYPE CatalogIdMapEntry
66 #define SH_KEY_TYPE CatalogId
68 #define SH_HASH_KEY(tb, key) hash_bytes((const unsigned char *) &(key), sizeof(CatalogId))
69 #define SH_EQUAL(tb, a, b) ((a).oid == (b).oid && (a).tableoid == (b).tableoid)
71 #define SH_GET_HASH(tb, a) (a)->hashval
72 #define SH_SCOPE static inline
73 #define SH_RAW_ALLOCATOR pg_malloc0
78 #define CATALOGIDHASH_INITIAL_SIZE 10000
83 InhInfo *inhinfo,
int numInherits);
86 static int strInArray(
const char *pattern,
char **arr,
int arr_size);
114 int numAccessMethods;
122 int numForeignDataWrappers;
123 int numForeignServers;
125 int numEventTriggers;
163 pg_log_info(
"reading user-defined aggregate functions");
169 pg_log_info(
"reading user-defined access methods");
172 pg_log_info(
"reading user-defined operator classes");
175 pg_log_info(
"reading user-defined operator families");
178 pg_log_info(
"reading user-defined text search parsers");
181 pg_log_info(
"reading user-defined text search templates");
184 pg_log_info(
"reading user-defined text search dictionaries");
187 pg_log_info(
"reading user-defined text search configurations");
190 pg_log_info(
"reading user-defined foreign-data wrappers");
193 pg_log_info(
"reading user-defined foreign servers");
211 pg_log_info(
"reading table inheritance information");
223 flagInhTables(fout, tblinfo, numTables, inhinfo, numInherits);
225 pg_log_info(
"reading column info for interesting tables");
228 pg_log_info(
"flagging inherited columns in subtables");
237 pg_log_info(
"flagging indexes in partitioned tables");
258 pg_log_info(
"reading publication membership of tables");
261 pg_log_info(
"reading publication membership of schemas");
269 *numTablesPtr = numTables;
287 InhInfo *inhinfo,
int numInherits)
302 for (
i = 0;
i < numInherits;
i++)
322 if (parent == NULL ||
327 pg_fatal(
"failed sanity check, parent OID %u of table \"%s\" (OID %u) not found",
328 inhinfo[
i].inhparent,
345 for (
i = 0;
i < numTables;
i++)
352 if (tblinfo[
i].dobj.dump)
357 for (
j = 0;
j < numParents;
j++)
358 parents[
j]->interesting =
true;
368 if (tblinfo[
i].numParents != 1)
369 pg_fatal(
"invalid number of parents %d for table \"%s\"",
370 tblinfo[
i].numParents,
371 tblinfo[
i].dobj.name);
379 attachinfo->
dobj.namespace = tblinfo[
i].
dobj.namespace;
409 for (
i = 0;
i < numTables;
i++)
411 if (!tblinfo[
i].ispartition || tblinfo[
i].numParents == 0)
414 Assert(tblinfo[
i].numParents == 1);
422 if (
index->parentidx == 0)
426 if (parentidx == NULL)
436 attachinfo->
dobj.namespace =
index->indextable->dobj.namespace;
458 index->indextable->dobj.dumpId);
507 for (
i = 0;
i < numTables;
i++)
514 if (tbinfo->
relkind == RELKIND_SEQUENCE ||
515 tbinfo->
relkind == RELKIND_VIEW ||
516 tbinfo->
relkind == RELKIND_MATVIEW)
534 bool foundSameGenerated;
535 bool foundDiffGenerated;
541 foundNotNull =
false;
542 foundDefault =
false;
543 foundSameGenerated =
false;
544 foundDiffGenerated =
false;
545 for (k = 0; k < numParents; k++)
557 foundNotNull |= parent->
notnull[inhAttrInd];
558 foundDefault |= (parentDef != NULL &&
559 strcmp(parentDef->
adef_expr,
"NULL") != 0 &&
564 if (parentDef != NULL &&
568 foundSameGenerated =
true;
570 foundDiffGenerated =
true;
586 if (foundDefault && tbinfo->
attrdefs[
j] == NULL)
596 attrDef->
dobj.namespace = tbinfo->
dobj.namespace;
622 if (foundSameGenerated && !foundDiffGenerated &&
642 dobj->namespace = NULL;
825 catId.
tableoid = RelationRelationId;
843 catId.
tableoid = RelationRelationId;
880 catId.
tableoid = ProcedureRelationId;
898 catId.
tableoid = OperatorRelationId;
916 catId.
tableoid = CollationRelationId;
934 catId.
tableoid = NamespaceRelationId;
952 catId.
tableoid = ExtensionRelationId;
970 catId.
tableoid = PublicationRelationId;
1044 if (s ==
' ' || s ==
'\0')
1048 if (argNum >= arraysize)
1049 pg_fatal(
"could not parse numeric array \"%s\": too many numbers",
str);
1051 array[argNum++] =
atooid(temp);
1059 if (!(isdigit((
unsigned char) s) || s ==
'-') ||
1060 j >=
sizeof(temp) - 1)
1061 pg_fatal(
"could not parse numeric array \"%s\": invalid character in number",
str);
1066 while (argNum < arraysize)
1083 for (
i = 0;
i < arr_size;
i++)
1085 if (strcmp(pattern, arr[
i]) == 0)
void recordExtensionMembership(CatalogId catId, ExtensionInfo *ext)
FuncInfo * findFuncByOid(Oid oid)
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)
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)
static void flagInhAttrs(DumpOptions *dopt, TableInfo *tblinfo, int numTables)
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)
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