diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/common/TableConstants.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/common/TableConstants.java index 21937f5b37..5a984c8f2f 100644 --- a/symmetric-core/src/main/java/org/jumpmind/symmetric/common/TableConstants.java +++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/common/TableConstants.java @@ -72,6 +72,7 @@ public class TableConstants { public static final String SYM_FILE_SNAPSHOT = "file_snapshot"; public static final String SYM_FILE_INCOMING = "file_incoming"; public static final String SYM_CONSOLE_USER = "console_user"; + public static final String SYM_CONSOLE_EVENT = "console_event"; public static final String SYM_EXTENSION = "extension"; public static final String SYM_MONITOR = "monitor"; public static final String SYM_MONITOR_EVENT = "monitor_event"; @@ -181,6 +182,8 @@ protected static List populateAllTables(String tablePrefix) { tables.add(getTableName(tablePrefix, TableConstants.SYM_FILE_TRIGGER_ROUTER)); tables.add(getTableName(tablePrefix, TableConstants.SYM_FILE_SNAPSHOT)); tables.add(getTableName(tablePrefix, TableConstants.SYM_FILE_INCOMING)); + tables.add(getTableName(tablePrefix, SYM_CONSOLE_USER)); + tables.add(getTableName(tablePrefix, SYM_CONSOLE_EVENT)); tables.add(getTableName(tablePrefix, SYM_EXTENSION)); tables.add(getTableName(tablePrefix, SYM_MONITOR)); tables.add(getTableName(tablePrefix, SYM_MONITOR_EVENT)); diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/io/DbCompare.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/io/DbCompare.java index a4061414fb..b429131017 100644 --- a/symmetric-core/src/main/java/org/jumpmind/symmetric/io/DbCompare.java +++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/io/DbCompare.java @@ -112,6 +112,32 @@ public DbCompareReport compare() { return report; } + + public List compareForList() { + dbValueComparator.setNumericScale(numericScale); + List list = new ArrayList(); + long start = System.currentTimeMillis(); + List tablesToCompare = getTablesToCompare(); + + for (DbCompareTables tables : tablesToCompare) { + try { + TableReport tableReport = compareTables(tables); + list.add(tableReport); + long elapsed = System.currentTimeMillis() - start; + log.info("Completed table {}. Elapsed time: {}", tableReport, + DurationFormatUtils.formatDurationWords((elapsed), true, true)); + } catch (Exception e) { + log.error("Exception while comparing " + tables.getSourceTable() + + " to " + tables.getTargetTable(), e); + } + } + + long totalTime = System.currentTimeMillis() - start; + log.info("dbcompare complete. Total Time: {}", + DurationFormatUtils.formatDurationWords((totalTime), true, true)); + + return list; + } protected TableReport compareTables(DbCompareTables tables) { String sourceSelect = getSourceComparisonSQL(tables, sourceEngine.getDatabasePlatform());