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);
87 static int strInArray(
const char *pattern,
char **arr,
int arr_size);
115 int numAccessMethods;
123 int numForeignDataWrappers;
124 int numForeignServers;
126 int numEventTriggers;
164 pg_log_info(
"reading user-defined aggregate functions");
170 pg_log_info(
"reading user-defined access methods");
173 pg_log_info(
"reading user-defined operator classes");
176 pg_log_info(
"reading user-defined operator families");
179 pg_log_info(
"reading user-defined text search parsers");
182 pg_log_info(
"reading user-defined text search templates");
185 pg_log_info(
"reading user-defined text search dictionaries");
188 pg_log_info(
"reading user-defined text search configurations");
191 pg_log_info(
"reading user-defined foreign-data wrappers");
194 pg_log_info(
"reading user-defined foreign servers");
212 pg_log_info(
"reading table inheritance information");
224 flagInhTables(fout, tblinfo, numTables, inhinfo, numInherits);
226 pg_log_info(
"reading column info for interesting tables");
229 pg_log_info(
"flagging inherited columns in subtables");
238 pg_log_info(
"flagging indexes in partitioned tables");
259 pg_log_info(
"reading publication membership of tables");
262 pg_log_info(
"reading publication membership of schemas");
270 *numTablesPtr = numTables;
288 InhInfo *inhinfo,
int numInherits)
303 for (
i = 0;
i < numInherits;
i++)
323 if (parent == NULL ||
328 pg_fatal(
"failed sanity check, parent OID %u of table \"%s\" (OID %u) not found",
329 inhinfo[
i].inhparent,
346 for (
i = 0;
i < numTables;
i++)
353 if (tblinfo[
i].dobj.dump)
358 for (
j = 0;
j < numParents;
j++)
359 parents[
j]->interesting =
true;
369 if (tblinfo[
i].numParents != 1)
370 pg_fatal(
"invalid number of parents %d for table \"%s\"",
371 tblinfo[
i].numParents,
372 tblinfo[
i].dobj.name);
380 attachinfo->
dobj.namespace = tblinfo[
i].
dobj.namespace;
410 for (
i = 0;
i < numTables;
i++)
412 if (!tblinfo[
i].ispartition || tblinfo[
i].numParents == 0)
415 Assert(tblinfo[
i].numParents == 1);
423 if (
index->parentidx == 0)
427 if (parentidx == NULL)
437 attachinfo->
dobj.namespace =
index->indextable->dobj.namespace;
459 index->indextable->dobj.dumpId);
509 for (
i = 0;
i < numTables;
i++)
516 if (tbinfo->
relkind == RELKIND_SEQUENCE ||
517 tbinfo->
relkind == RELKIND_VIEW ||
518 tbinfo->
relkind == RELKIND_MATVIEW)
536 bool foundSameGenerated;
537 bool foundDiffGenerated;
543 foundNotNull =
false;
544 foundDefault =
false;
545 foundSameGenerated =
false;
546 foundDiffGenerated =
false;
547 for (k = 0; k < numParents; k++)
561 foundDefault |= (parentDef != NULL &&
562 strcmp(parentDef->
adef_expr,
"NULL") != 0 &&
567 if (parentDef != NULL &&
571 foundSameGenerated =
true;
573 foundDiffGenerated =
true;
590 if (foundDefault && tbinfo->
attrdefs[
j] == NULL)
600 attrDef->
dobj.namespace = tbinfo->
dobj.namespace;
626 if (foundSameGenerated && !foundDiffGenerated &&
646 dobj->namespace = NULL;
829 catId.
tableoid = RelationRelationId;
847 catId.
tableoid = RelationRelationId;
884 catId.
tableoid = ProcedureRelationId;
902 catId.
tableoid = OperatorRelationId;
920 catId.
tableoid = CollationRelationId;
938 catId.
tableoid = NamespaceRelationId;
956 catId.
tableoid = ExtensionRelationId;
974 catId.
tableoid = PublicationRelationId;
1048 if (s ==
' ' || s ==
'\0')
1052 if (argNum >= arraysize)
1053 pg_fatal(
"could not parse numeric array \"%s\": too many numbers",
str);
1055 array[argNum++] =
atooid(temp);
1063 if (!(isdigit((
unsigned char) s) || s ==
'-') ||
1064 j >=
sizeof(temp) - 1)
1065 pg_fatal(
"could not parse numeric array \"%s\": invalid character in number",
str);
1070 while (argNum < arraysize)
1087 for (
i = 0;
i < arr_size;
i++)
1089 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)
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)
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