18#include "catalog/pg_class_d.h"
158 "array length mismatch");
220 cmpval = strcmp(obj1->namespace->dobj.
name,
221 obj2->namespace->dobj.
name);
228 else if (obj2->namespace)
232 cmpval = strcmp(obj1->
name, obj2->
name);
252 if (argtype1 && argtype2)
254 if (argtype1->
dobj.namespace && argtype2->
dobj.namespace)
256 cmpval = strcmp(argtype1->
dobj.namespace->dobj.
name,
257 argtype2->
dobj.namespace->dobj.
name);
351 while (!
TopoSort(objs, numObjs, ordering, &nOrdering))
413 *nOrdering = numObjs;
430 idMap = (
int *)
pg_malloc((maxDumpId + 1) *
sizeof(int));
431 for (
i = 0;
i < numObjs;
i++)
435 if (j <= 0 || j > maxDumpId)
441 if (k <= 0 || k > maxDumpId)
442 pg_fatal(
"invalid dependency %d", k);
455 for (
i = numObjs; --
i >= 0;)
486 for (k = 0; k < obj->
nDeps; k++)
502 for (
j = 1;
j <= maxDumpId;
j++)
505 ordering[k++] = objs[idMap[
j]];
570 for (
i = 0;
i < nObjs;
i++)
589 for (
j = 0;
j < looplen;
j++)
590 processed[workspace[
j]->dumpId] =
true;
600 processed[obj->
dumpId] =
true;
606 pg_fatal(
"could not identify dependency loop");
644 if (processed[obj->
dumpId])
651 if (searchFailed[obj->
dumpId] == startPoint)
660 for (
i = 0;
i < depth;
i++)
662 if (workspace[
i] == obj)
669 workspace[depth++] = obj;
703 searchFailed[obj->
dumpId] = startPoint;
815 if (nextinfo->
relkind == RELKIND_MATVIEW)
822 if (nextinfo->
relkind == RELKIND_MATVIEW)
975 (((
TableInfo *) loop[0])->relkind == RELKIND_VIEW ||
976 ((
TableInfo *) loop[0])->relkind == RELKIND_MATVIEW) &&
977 ((
RuleInfo *) loop[1])->ev_type ==
'1' &&
978 ((
RuleInfo *) loop[1])->is_instead &&
987 (((
TableInfo *) loop[1])->relkind == RELKIND_VIEW ||
988 ((
TableInfo *) loop[1])->relkind == RELKIND_MATVIEW) &&
989 ((
RuleInfo *) loop[0])->ev_type ==
'1' &&
990 ((
RuleInfo *) loop[0])->is_instead &&
1000 for (
i = 0;
i < nLoop;
i++)
1003 ((
TableInfo *) loop[
i])->relkind == RELKIND_VIEW)
1005 for (
j = 0;
j < nLoop;
j++)
1008 ((
RuleInfo *) loop[
j])->ev_type ==
'1' &&
1023 for (
i = 0;
i < nLoop;
i++)
1026 ((
TableInfo *) loop[
i])->relkind == RELKIND_MATVIEW)
1028 for (
j = 0;
j < nLoop;
j++)
1034 nextobj = (
j < nLoop - 1) ? loop[
j + 1] : loop[0];
1043 for (
j = 0;
j < nLoop;
j++)
1049 nextobj = (
j < nLoop - 1) ? loop[
j + 1] : loop[0];
1061 for (
i = 0;
i < nLoop;
i++)
1065 for (
j = 0;
j < nLoop;
j++)
1071 nextobj = (
j < nLoop - 1) ? loop[
j + 1] : loop[0];
1103 for (
i = 0;
i < nLoop;
i++)
1107 for (
j = 0;
j < nLoop;
j++)
1144 if (((
IndxInfo *) loop[0])->parentidx == loop[1]->catId.oid)
1149 else if (((
IndxInfo *) loop[1])->parentidx == loop[0]->catId.oid)
1159 for (
i = 0;
i < nLoop;
i++)
1163 for (
j = 0;
j < nLoop;
j++)
1178 loop[0]->objType ==
DO_TYPE &&
1187 loop[1]->objType ==
DO_TYPE &&
1199 for (
i = 0;
i < nLoop;
i++)
1203 for (
j = 0;
j < nLoop;
j++)
1240 for (
i = 0;
i < nLoop;
i++)
1248 "there are circular foreign-key constraints among these tables:",
1250 for (
i = 0;
i < nLoop;
i++)
1252 pg_log_warning_hint(
"You might not be able to restore the dump without using --disable-triggers or temporarily dropping the constraints.");
1253 pg_log_warning_hint(
"Consider using a full dump instead of a --data-only dump to avoid this problem.");
1265 pg_log_warning(
"could not resolve dependency loop among these items:");
1266 for (
i = 0;
i < nLoop;
i++)
1292 "SCHEMA %s (ID %d OID %u)",
1297 "EXTENSION %s (ID %d OID %u)",
1302 "TYPE %s (ID %d OID %u)",
1307 "SHELL TYPE %s (ID %d OID %u)",
1312 "FUNCTION %s (ID %d OID %u)",
1317 "AGGREGATE %s (ID %d OID %u)",
1322 "OPERATOR %s (ID %d OID %u)",
1327 "ACCESS METHOD %s (ID %d OID %u)",
1332 "OPERATOR CLASS %s (ID %d OID %u)",
1337 "OPERATOR FAMILY %s (ID %d OID %u)",
1342 "COLLATION %s (ID %d OID %u)",
1347 "CONVERSION %s (ID %d OID %u)",
1352 "TABLE %s (ID %d OID %u)",
1357 "TABLE ATTACH %s (ID %d)",
1362 "ATTRDEF %s.%s (ID %d OID %u)",
1365 obj->dumpId, obj->catId.oid);
1369 "INDEX %s (ID %d OID %u)",
1370 obj->name, obj->dumpId, obj->catId.oid);
1374 "INDEX ATTACH %s (ID %d)",
1375 obj->name, obj->dumpId);
1379 "STATISTICS %s (ID %d OID %u)",
1380 obj->name, obj->dumpId, obj->catId.oid);
1384 "REFRESH MATERIALIZED VIEW %s (ID %d OID %u)",
1385 obj->name, obj->dumpId, obj->catId.oid);
1389 "RULE %s (ID %d OID %u)",
1390 obj->name, obj->dumpId, obj->catId.oid);
1394 "TRIGGER %s (ID %d OID %u)",
1395 obj->name, obj->dumpId, obj->catId.oid);
1399 "EVENT TRIGGER %s (ID %d OID %u)",
1400 obj->name, obj->dumpId, obj->catId.oid);
1404 "CONSTRAINT %s (ID %d OID %u)",
1405 obj->name, obj->dumpId, obj->catId.oid);
1409 "FK CONSTRAINT %s (ID %d OID %u)",
1410 obj->name, obj->dumpId, obj->catId.oid);
1414 "PROCEDURAL LANGUAGE %s (ID %d OID %u)",
1415 obj->name, obj->dumpId, obj->catId.oid);
1419 "CAST %u to %u (ID %d OID %u)",
1422 obj->dumpId, obj->catId.oid);
1426 "TRANSFORM %u lang %u (ID %d OID %u)",
1429 obj->dumpId, obj->catId.oid);
1433 "TABLE DATA %s (ID %d OID %u)",
1434 obj->name, obj->dumpId, obj->catId.oid);
1438 "SEQUENCE SET %s (ID %d OID %u)",
1439 obj->name, obj->dumpId, obj->catId.oid);
1443 "DUMMY TYPE %s (ID %d OID %u)",
1444 obj->name, obj->dumpId, obj->catId.oid);
1448 "TEXT SEARCH PARSER %s (ID %d OID %u)",
1449 obj->name, obj->dumpId, obj->catId.oid);
1453 "TEXT SEARCH DICTIONARY %s (ID %d OID %u)",
1454 obj->name, obj->dumpId, obj->catId.oid);
1458 "TEXT SEARCH TEMPLATE %s (ID %d OID %u)",
1459 obj->name, obj->dumpId, obj->catId.oid);
1463 "TEXT SEARCH CONFIGURATION %s (ID %d OID %u)",
1464 obj->name, obj->dumpId, obj->catId.oid);
1468 "FOREIGN DATA WRAPPER %s (ID %d OID %u)",
1469 obj->name, obj->dumpId, obj->catId.oid);
1473 "FOREIGN SERVER %s (ID %d OID %u)",
1474 obj->name, obj->dumpId, obj->catId.oid);
1478 "DEFAULT ACL %s (ID %d OID %u)",
1479 obj->name, obj->dumpId, obj->catId.oid);
1483 "LARGE OBJECT (ID %d OID %u)",
1484 obj->dumpId, obj->catId.oid);
1488 "LARGE OBJECT DATA (ID %d)",
1493 "POLICY (ID %d OID %u)",
1494 obj->dumpId, obj->catId.oid);
1498 "PUBLICATION (ID %d OID %u)",
1499 obj->dumpId, obj->catId.oid);
1503 "PUBLICATION TABLE (ID %d OID %u)",
1504 obj->dumpId, obj->catId.oid);
1508 "PUBLICATION TABLES IN SCHEMA (ID %d OID %u)",
1509 obj->dumpId, obj->catId.oid);
1513 "SUBSCRIPTION (ID %d OID %u)",
1514 obj->dumpId, obj->catId.oid);
1518 "SUBSCRIPTION TABLE (ID %d OID %u)",
1519 obj->dumpId, obj->catId.oid);
1523 "PRE-DATA BOUNDARY (ID %d)",
1528 "POST-DATA BOUNDARY (ID %d)",
1533 "RELATION STATISTICS FOR %s (ID %d OID %u)",
1534 obj->name, obj->dumpId, obj->catId.oid);
1539 "object type %d (ID %d OID %u)",
1548 int ai = (int) (intptr_t)
a;
1549 int bi = (int) (intptr_t)
b;
void addObjectDependency(DumpableObject *dobj, DumpId refId)
DumpableObject * findObjectByDumpId(DumpId dumpId)
TypeInfo * findTypeByOid(Oid oid)
DumpId getMaxDumpId(void)
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)
void binaryheap_free(binaryheap *heap)
void binaryheap_add_unordered(binaryheap *heap, bh_node_type d)
binaryheap * binaryheap_allocate(int capacity, binaryheap_comparator compare, void *arg)
#define binaryheap_empty(h)
#define ngettext(s, p, n)
static int * beforeConstraints
void * pg_malloc(size_t size)
void * pg_malloc0(size_t size)
static int pg_cmp_s32(int32 a, int32 b)
#define pg_log_warning_hint(...)
#define pg_log_warning_detail(...)
#define NUM_DUMPABLE_OBJECT_TYPES
#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)
static void repairTableConstraintLoop(DumpableObject *tableobj, DumpableObject *constraintobj)
StaticAssertDecl(lengthof(dbObjectTypePriority)==NUM_DUMPABLE_OBJECT_TYPES, "array length mismatch")
static void repairTableAttrDefMultiLoop(DumpableObject *tableobj, DumpableObject *attrdefobj)
static const int dbObjectTypePriority[]
@ PRIO_STATISTICS_DATA_DATA
@ 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