Revert to retrieving foreign keys in parallel.

schemacrawler · on Sep 7 · 451a5a5a60c76acb7303ffa734c0fedc6ad7de19 · 451a5a5
1 parent c06131a
commit 451a5a5a60c76acb7303ffa734c0fedc6ad7de19
Showing 1 changed file with 0 additions and 3 deletions.
diff --git a/schemacrawler-api/src/main/java/schemacrawler/crawl/SchemaCrawler.java b/schemacrawler-api/src/main/java/schemacrawler/crawl/SchemaCrawler.java
        .submit();
  }

  private void crawlTables() throws Exception {

    final LimitOptions limitOptions = options.getLimitOptions();
    if (!(infoLevel.is(retrieveTables) && !limitOptions.isExcludeAll(ruleForTableInclusion))) {
      LOGGER.log(Level.INFO, "Not retrieving tables, since this was not requested");
      return;
    }

    final TableRetriever retriever = new TableRetriever(retrieverConnection, catalog, options);
    final TableColumnRetriever columnRetriever =
        new TableColumnRetriever(retrieverConnection, catalog, options);
    final PrimaryKeyRetriever pkRetriever =
        new PrimaryKeyRetriever(retrieverConnection, catalog, options);
    final ForeignKeyRetriever fkRetriever =
        new ForeignKeyRetriever(retrieverConnection, catalog, options);
    final TableConstraintRetriever constraintRetriever =
        new TableConstraintRetriever(retrieverConnection, catalog, options);
    final TableExtRetriever retrieverExtra =
        new TableExtRetriever(retrieverConnection, catalog, options);
    final TablePrivilegeRetriever retrieverPrivilege =
        new TablePrivilegeRetriever(retrieverConnection, catalog, options);
    final IndexRetriever indexRetriever = new IndexRetriever(retrieverConnection, catalog, options);

    taskRunner
        .add(
            retrieveTables,
            () -> {
              LOGGER.log(Level.INFO, "Retrieving table names");
              retriever.retrieveTables(
                  limitOptions.getTableNamePattern(),
                  limitOptions.getTableTypes(),
                  limitOptions.get(ruleForTableInclusion));
            })
        .submit();

    final NamedObjectList<MutableTable> allTables = catalog.getAllTables();
    LOGGER.log(Level.INFO, new StringFormat("Retrieved %d tables", allTables.size()));
    if (allTables.isEmpty()) {
      return;
    }

    taskRunner
        .add(
            retrieveTableColumns,
            () -> {
              if (!limitOptions.isExcludeAll(ruleForColumnInclusion)) {
                columnRetriever.retrieveTableColumns(
                    allTables, limitOptions.get(ruleForColumnInclusion));
              }
            })
        .submit();

    taskRunner
        .add(
            retrievePrimaryKeys,
             () -> pkRetriever.retrievePrimaryKeys(allTables),
             retrieveTableColumns)
         .add(retrieveIndexes, () -> indexRetriever.retrieveIndexes(allTables), retrieveTableColumns)
-        .submit();
-
-    taskRunner
         .add(
             retrieveForeignKeys,
             () -> fkRetriever.retrieveForeignKeys(allTables),
            retrieveTableColumns)
        .submit();

    taskRunner
        .add(
            retrieveTableConstraints,
            constraintRetriever::retrieveTableConstraints,
            retrieveTableColumns)
        .add(retrieveTriggerInformation, retrieverExtra::retrieveTriggerInformation)
        .submit();

    taskRunner
        .add(
            "filterAndSortTables",
            () -> {
              // Filter the list of tables based on grep criteria, and
              // parent-child relationships
              catalog.reduce(Table.class, getTableReducer(options));

              // Sort the remaining tables
              final TablesGraph tablesGraph = new TablesGraph(allTables);
              tablesGraph.setTablesSortIndexes();
            })
        .add(
            "matchTableConstraints",
            () -> constraintRetriever.matchTableConstraints(allTables),
            retrieveTableColumns)
        .submit();

    taskRunner
        .add(
            retrieveTableConstraintDefinitions,
            constraintRetriever::retrieveTableConstraintDefinitions,
            retrieveTableConstraints)
        .add(
            retrieveTableConstraintInformation,
            constraintRetriever::retrieveTableConstraintInformation,
            retrieveTableConstraints)
        .add(retrieveViewInformation, retrieverExtra::retrieveViewInformation, retrieveTables)
        .add(retrieveViewTableUsage, retrieverExtra::retrieveViewTableUsage, retrieveTables)
        .add(
            retrieveTableDefinitionsInformation,
            retrieverExtra::retrieveTableDefinitions,
            retrieveTables)
        .add(
            retrieveIndexInformation,
            () -> retrieverExtra.retrieveIndexInformation(),
            retrieveIndexes)
        .add(
            retrieveAdditionalTableAttributes,
            () -> retrieverExtra.retrieveAdditionalTableAttributes(),
            retrieveTables)
        .add(
            retrieveTablePrivileges,
            () -> retrieverPrivilege.retrieveTablePrivileges(),
            retrieveTables)
        .add(
            retrieveTableColumnPrivileges,
            retrieverPrivilege::retrieveTableColumnPrivileges,
            retrieveTableColumns)
        .add(
            retrieveAdditionalColumnAttributes,
            retrieverExtra::retrieveAdditionalColumnAttributes,
            retrieveTableColumns)
        .submit();

    taskRunner
        .add(
            retrieveAdditionalColumnMetadata,
            retrieverExtra::retrieveAdditionalColumnMetadata,
            retrieveTableColumns)
        .submit();
  }
 }