org.jumpmind.symmetric.io

Class DbCompare

java.lang.Object

org.jumpmind.symmetric.io.DbCompare

public class DbCompare
extends java.lang.Object

DbCompare has the ability to compare two SQL-based datasources and output a report of of differences, and optionally SQL to bring the target into sync with the source.

Constructor Summary

Constructors

Constructor and Description
DbCompare(ISymmetricEngine sourceEngine, ISymmetricEngine targetEngine, DbCompareConfig config)

Method Summary

Modifier and Type	Method and Description
protected java.lang.String	buildOrderBy(org.jumpmind.db.model.Table table, org.jumpmind.db.model.Column[] sortByColumns, org.jumpmind.db.platform.IDatabasePlatform platform)
protected org.jumpmind.db.model.Table	cloneTable(org.jumpmind.db.model.Table table)
DbCompareReport	compare()
protected int	comparePk(DbCompareTables tables, DbCompareRow sourceCompareRow, DbCompareRow targetCompareRow)
protected boolean	compareTableNames(java.lang.String sourceTableName, java.lang.String targetTableName)
protected DbCompareReport.TableReport	compareTables(DbCompareTables tables, java.io.OutputStream sqlDiffOutput)
protected java.util.List<java.lang.String>	filterTables(java.util.List<java.lang.String> tables)
protected java.lang.String	getComparisonSQL(org.jumpmind.db.model.Table table, org.jumpmind.db.model.Column[] sortByColumns, org.jumpmind.db.platform.IDatabasePlatform platform, java.lang.String whereClause)
DbCompareConfig	getConfig()
protected java.lang.String	getSourceComparisonSQL(DbCompareTables tables, org.jumpmind.db.platform.IDatabasePlatform platform)
protected java.io.OutputStream	getSqlDiffOutputStream()
protected java.io.OutputStream	getSqlDiffOutputStream(DbCompareTables tables)
protected java.util.List<DbCompareTables>	getTablesToCompare()
protected java.lang.String	getTargetComparisonSQL(DbCompareTables tables, org.jumpmind.db.platform.IDatabasePlatform platform)
protected TransformService.TransformTableNodeGroupLink	getTransformFor(org.jumpmind.db.model.Table sourceTable)
protected TriggerRouter	getTriggerRouterFor(org.jumpmind.db.model.Table sourceTable)
protected java.util.List<DbCompareTables>	loadTables(java.util.List<java.lang.String> tableNames, java.util.List<java.lang.String> targetTableNames)
protected java.util.List<DbCompareTables>	loadTablesFromArguments()
protected java.util.List<DbCompareTables>	loadTablesFromConfig()
protected org.jumpmind.db.model.Table	loadTargetTable(DbCompareTables tables, java.lang.String targetTableNameOverride)
protected org.jumpmind.db.model.Table	loadTargetTableUsingTransform(TransformService.TransformTableNodeGroupLink transform)
protected boolean	mapPrimaryKey(DbCompareTables tables)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DbCompare

public DbCompare(ISymmetricEngine sourceEngine,
                 ISymmetricEngine targetEngine,
                 DbCompareConfig config)

Method Detail

compare

public DbCompareReport compare()

getSqlDiffOutputStream

protected java.io.OutputStream getSqlDiffOutputStream()

getSqlDiffOutputStream

protected java.io.OutputStream getSqlDiffOutputStream(DbCompareTables tables)

compareTables

protected DbCompareReport.TableReport compareTables(DbCompareTables tables,
                                                    java.io.OutputStream sqlDiffOutput)

comparePk

protected int comparePk(DbCompareTables tables,
                        DbCompareRow sourceCompareRow,
                        DbCompareRow targetCompareRow)

getSourceComparisonSQL

protected java.lang.String getSourceComparisonSQL(DbCompareTables tables,
                                                  org.jumpmind.db.platform.IDatabasePlatform platform)

getTargetComparisonSQL

protected java.lang.String getTargetComparisonSQL(DbCompareTables tables,
                                                  org.jumpmind.db.platform.IDatabasePlatform platform)

getComparisonSQL

protected java.lang.String getComparisonSQL(org.jumpmind.db.model.Table table,
                                            org.jumpmind.db.model.Column[] sortByColumns,
                                            org.jumpmind.db.platform.IDatabasePlatform platform,
                                            java.lang.String whereClause)

buildOrderBy

protected java.lang.String buildOrderBy(org.jumpmind.db.model.Table table,
                                        org.jumpmind.db.model.Column[] sortByColumns,
                                        org.jumpmind.db.platform.IDatabasePlatform platform)

getTablesToCompare

protected java.util.List<DbCompareTables> getTablesToCompare()

loadTablesFromConfig

protected java.util.List<DbCompareTables> loadTablesFromConfig()

loadTables

protected java.util.List<DbCompareTables> loadTables(java.util.List<java.lang.String> tableNames,
                                                     java.util.List<java.lang.String> targetTableNames)

mapPrimaryKey

protected boolean mapPrimaryKey(DbCompareTables tables)

loadTargetTable

protected org.jumpmind.db.model.Table loadTargetTable(DbCompareTables tables,
                                                      java.lang.String targetTableNameOverride)

getTriggerRouterFor

protected TriggerRouter getTriggerRouterFor(org.jumpmind.db.model.Table sourceTable)

getTransformFor

protected TransformService.TransformTableNodeGroupLink getTransformFor(org.jumpmind.db.model.Table sourceTable)

loadTargetTableUsingTransform

protected org.jumpmind.db.model.Table loadTargetTableUsingTransform(TransformService.TransformTableNodeGroupLink transform)

cloneTable

protected org.jumpmind.db.model.Table cloneTable(org.jumpmind.db.model.Table table)

loadTablesFromArguments

protected java.util.List<DbCompareTables> loadTablesFromArguments()

filterTables

protected java.util.List<java.lang.String> filterTables(java.util.List<java.lang.String> tables)

compareTableNames

protected boolean compareTableNames(java.lang.String sourceTableName,
                                    java.lang.String targetTableName)

getConfig

public DbCompareConfig getConfig()