18 #include "catalog/pg_class_d.h"
154 "array length mismatch");
216 cmpval = strcmp(obj1->namespace->dobj.
name,
217 obj2->namespace->dobj.
name);
224 else if (obj2->namespace)
228 cmpval = strcmp(obj1->
name, obj2->
name);
248 if (argtype1 && argtype2)
250 if (argtype1->
dobj.namespace && argtype2->
dobj.namespace)
252 cmpval = strcmp(argtype1->
dobj.namespace->dobj.
name,
253 argtype2->
dobj.namespace->dobj.
name);
336 while (!
TopoSort(objs, numObjs, ordering, &nOrdering))
398 *nOrdering = numObjs;
415 idMap = (
int *)
pg_malloc((maxDumpId + 1) *
sizeof(int));
416 for (
i = 0;
i < numObjs;
i++)
420 if (j <= 0 || j > maxDumpId)
426 if (k <= 0 || k > maxDumpId)
427 pg_fatal(
"invalid dependency %d", k);
440 for (
i = numObjs; --
i >= 0;)
471 for (k = 0; k < obj->
nDeps; k++)
487 for (
j = 1;
j <= maxDumpId;
j++)
490 ordering[k++] = objs[idMap[
j]];
555 for (
i = 0;
i < nObjs;
i++)
574 for (
j = 0;
j < looplen;
j++)
575 processed[workspace[
j]->dumpId] =
true;
585 processed[obj->
dumpId] =
true;
591 pg_fatal(
"could not identify dependency loop");
629 if (processed[obj->
dumpId])
636 if (searchFailed[obj->
dumpId] == startPoint)
645 for (
i = 0;
i < depth;
i++)
647 if (workspace[
i] == obj)
654 workspace[depth++] = obj;
688 searchFailed[obj->
dumpId] = startPoint;
796 if (nextinfo->
relkind == RELKIND_MATVIEW)
949 (((
TableInfo *) loop[0])->relkind == RELKIND_VIEW ||
950 ((
TableInfo *) loop[0])->relkind == RELKIND_MATVIEW) &&
951 ((
RuleInfo *) loop[1])->ev_type ==
'1' &&
952 ((
RuleInfo *) loop[1])->is_instead &&
961 (((
TableInfo *) loop[1])->relkind == RELKIND_VIEW ||
962 ((
TableInfo *) loop[1])->relkind == RELKIND_MATVIEW) &&
963 ((
RuleInfo *) loop[0])->ev_type ==
'1' &&
964 ((
RuleInfo *) loop[0])->is_instead &&
974 for (
i = 0;
i < nLoop;
i++)
977 ((
TableInfo *) loop[
i])->relkind == RELKIND_VIEW)
979 for (
j = 0;
j < nLoop;
j++)
982 ((
RuleInfo *) loop[
j])->ev_type ==
'1' &&
997 for (
i = 0;
i < nLoop;
i++)
1000 ((
TableInfo *) loop[
i])->relkind == RELKIND_MATVIEW)
1002 for (
j = 0;
j < nLoop;
j++)
1008 nextobj = (
j < nLoop - 1) ? loop[
j + 1] : loop[0];
1020 for (
i = 0;
i < nLoop;
i++)
1024 for (
j = 0;
j < nLoop;
j++)
1030 nextobj = (
j < nLoop - 1) ? loop[
j + 1] : loop[0];
1062 for (
i = 0;
i < nLoop;
i++)
1066 for (
j = 0;
j < nLoop;
j++)
1103 if (((
IndxInfo *) loop[0])->parentidx == loop[1]->catId.oid)
1108 else if (((
IndxInfo *) loop[1])->parentidx == loop[0]->catId.oid)
1118 for (
i = 0;
i < nLoop;
i++)
1122 for (
j = 0;
j < nLoop;
j++)
1137 loop[0]->objType ==
DO_TYPE &&
1146 loop[1]->objType ==
DO_TYPE &&
1158 for (
i = 0;
i < nLoop;
i++)
1162 for (
j = 0;
j < nLoop;
j++)
1199 for (
i = 0;
i < nLoop;
i++)
1207 "there are circular foreign-key constraints among these tables:",
1209 for (
i = 0;
i < nLoop;
i++)
1211 pg_log_warning_hint(
"You might not be able to restore the dump without using --disable-triggers or temporarily dropping the constraints.");
1212 pg_log_warning_hint(
"Consider using a full dump instead of a --data-only dump to avoid this problem.");
1224 pg_log_warning(
"could not resolve dependency loop among these items:");
1225 for (
i = 0;
i < nLoop;
i++)
1251 "SCHEMA %s (ID %d OID %u)",
1256 "EXTENSION %s (ID %d OID %u)",
1261 "TYPE %s (ID %d OID %u)",
1266 "SHELL TYPE %s (ID %d OID %u)",
1271 "FUNCTION %s (ID %d OID %u)",
1276 "AGGREGATE %s (ID %d OID %u)",
1281 "OPERATOR %s (ID %d OID %u)",
1286 "ACCESS METHOD %s (ID %d OID %u)",
1291 "OPERATOR CLASS %s (ID %d OID %u)",
1296 "OPERATOR FAMILY %s (ID %d OID %u)",
1301 "COLLATION %s (ID %d OID %u)",
1306 "CONVERSION %s (ID %d OID %u)",
1311 "TABLE %s (ID %d OID %u)",
1316 "TABLE ATTACH %s (ID %d)",
1321 "ATTRDEF %s.%s (ID %d OID %u)",
1324 obj->dumpId, obj->catId.oid);
1328 "INDEX %s (ID %d OID %u)",
1329 obj->name, obj->dumpId, obj->catId.oid);
1333 "INDEX ATTACH %s (ID %d)",
1334 obj->name, obj->dumpId);
1338 "STATISTICS %s (ID %d OID %u)",
1339 obj->name, obj->dumpId, obj->catId.oid);
1343 "REFRESH MATERIALIZED VIEW %s (ID %d OID %u)",
1344 obj->name, obj->dumpId, obj->catId.oid);
1348 "RULE %s (ID %d OID %u)",
1349 obj->name, obj->dumpId, obj->catId.oid);
1353 "TRIGGER %s (ID %d OID %u)",
1354 obj->name, obj->dumpId, obj->catId.oid);
1358 "EVENT TRIGGER %s (ID %d OID %u)",
1359 obj->name, obj->dumpId, obj->catId.oid);
1363 "CONSTRAINT %s (ID %d OID %u)",
1364 obj->name, obj->dumpId, obj->catId.oid);
1368 "FK CONSTRAINT %s (ID %d OID %u)",
1369 obj->name, obj->dumpId, obj->catId.oid);
1373 "PROCEDURAL LANGUAGE %s (ID %d OID %u)",
1374 obj->name, obj->dumpId, obj->catId.oid);
1378 "CAST %u to %u (ID %d OID %u)",
1381 obj->dumpId, obj->catId.oid);
1385 "TRANSFORM %u lang %u (ID %d OID %u)",
1388 obj->dumpId, obj->catId.oid);
1392 "TABLE DATA %s (ID %d OID %u)",
1393 obj->name, obj->dumpId, obj->catId.oid);
1397 "SEQUENCE SET %s (ID %d OID %u)",
1398 obj->name, obj->dumpId, obj->catId.oid);
1402 "DUMMY TYPE %s (ID %d OID %u)",
1403 obj->name, obj->dumpId, obj->catId.oid);
1407 "TEXT SEARCH PARSER %s (ID %d OID %u)",
1408 obj->name, obj->dumpId, obj->catId.oid);
1412 "TEXT SEARCH DICTIONARY %s (ID %d OID %u)",
1413 obj->name, obj->dumpId, obj->catId.oid);
1417 "TEXT SEARCH TEMPLATE %s (ID %d OID %u)",
1418 obj->name, obj->dumpId, obj->catId.oid);
1422 "TEXT SEARCH CONFIGURATION %s (ID %d OID %u)",
1423 obj->name, obj->dumpId, obj->catId.oid);
1427 "FOREIGN DATA WRAPPER %s (ID %d OID %u)",
1428 obj->name, obj->dumpId, obj->catId.oid);
1432 "FOREIGN SERVER %s (ID %d OID %u)",
1433 obj->name, obj->dumpId, obj->catId.oid);
1437 "DEFAULT ACL %s (ID %d OID %u)",
1438 obj->name, obj->dumpId, obj->catId.oid);
1442 "LARGE OBJECT (ID %d OID %u)",
1443 obj->dumpId, obj->catId.oid);
1447 "LARGE OBJECT DATA (ID %d)",
1452 "POLICY (ID %d OID %u)",
1453 obj->dumpId, obj->catId.oid);
1457 "PUBLICATION (ID %d OID %u)",
1458 obj->dumpId, obj->catId.oid);
1462 "PUBLICATION TABLE (ID %d OID %u)",
1463 obj->dumpId, obj->catId.oid);
1467 "PUBLICATION TABLES IN SCHEMA (ID %d OID %u)",
1468 obj->dumpId, obj->catId.oid);
1472 "SUBSCRIPTION (ID %d OID %u)",
1473 obj->dumpId, obj->catId.oid);
1477 "PRE-DATA BOUNDARY (ID %d)",
1482 "POST-DATA BOUNDARY (ID %d)",
1488 "object type %d (ID %d OID %u)",
1497 int ai = (int) (intptr_t)
a;
1498 int bi = (int) (intptr_t)
b;
void addObjectDependency(DumpableObject *dobj, DumpId refId)
DumpableObject * findObjectByDumpId(DumpId dumpId)
DumpId getMaxDumpId(void)
TypeInfo * findTypeByOid(Oid oid)
void removeObjectDependency(DumpableObject *dobj, DumpId refId)
void binaryheap_build(binaryheap *heap)
void binaryheap_add(binaryheap *heap, bh_node_type d)
bh_node_type binaryheap_remove_first(binaryheap *heap)
binaryheap * binaryheap_allocate(int capacity, binaryheap_comparator compare, void *arg)
void binaryheap_free(binaryheap *heap)
void binaryheap_add_unordered(binaryheap *heap, bh_node_type d)
#define binaryheap_empty(h)
#define ngettext(s, p, n)
static void PGresult const char * p2
static int * beforeConstraints
void * pg_malloc0(size_t size)
void * pg_malloc(size_t size)
#define pg_log_warning_hint(...)
#define pg_log_warning_detail(...)
#define DUMP_COMPONENT_DEFINITION
@ DO_PUBLICATION_TABLE_IN_SCHEMA
static void repairMatViewBoundaryMultiLoop(DumpableObject *boundaryobj, DumpableObject *nextobj)
static void repairTableAttrDefLoop(DumpableObject *tableobj, DumpableObject *attrdefobj)
static int findLoop(DumpableObject *obj, DumpId startPoint, bool *processed, DumpId *searchFailed, DumpableObject **workspace, int depth)
static void findDependencyLoops(DumpableObject **objs, int nObjs, int totObjs)
StaticAssertDecl(lengthof(dbObjectTypePriority)==(DO_SUBSCRIPTION+1), "array length mismatch")
static void repairTableConstraintLoop(DumpableObject *tableobj, DumpableObject *constraintobj)
static void repairTableAttrDefMultiLoop(DumpableObject *tableobj, DumpableObject *attrdefobj)
static const int dbObjectTypePriority[]
@ PRIO_POST_DATA_BOUNDARY
@ PRIO_PUBLICATION_TABLE_IN_SCHEMA
static int DOTypeNameCompare(const void *p1, const void *p2)
static void repairViewRuleMultiLoop(DumpableObject *viewobj, DumpableObject *ruleobj)
static void repairDomainConstraintLoop(DumpableObject *domainobj, DumpableObject *constraintobj)
static void repairTableConstraintMultiLoop(DumpableObject *tableobj, DumpableObject *constraintobj)
void sortDumpableObjects(DumpableObject **objs, int numObjs, DumpId preBoundaryId, DumpId postBoundaryId)
static DumpId preDataBoundId
static void describeDumpableObject(DumpableObject *obj, char *buf, int bufsize)
static void repairTypeFuncLoop(DumpableObject *typeobj, DumpableObject *funcobj)
static void repairDomainConstraintMultiLoop(DumpableObject *domainobj, DumpableObject *constraintobj)
static int int_cmp(void *a, void *b, void *arg)
static void repairIndexLoop(DumpableObject *partedindex, DumpableObject *partindex)
void sortDumpableObjectsByTypeName(DumpableObject **objs, int numObjs)
static void repairViewRuleLoop(DumpableObject *viewobj, DumpableObject *ruleobj)
static void repairFunctionBoundaryMultiLoop(DumpableObject *boundaryobj, DumpableObject *nextobj)
static void repairDependencyLoop(DumpableObject **loop, int nLoop)
static bool TopoSort(DumpableObject **objs, int numObjs, DumpableObject **ordering, int *nOrdering)
static DumpId postDataBoundId
#define pg_log_warning(...)
#define qsort(a, b, c, d)
DumpableObjectType objType
struct _shellTypeInfo * shellType