Package org.jumpmind.symmetric.io

Class DbCompare

java.lang.Object

org.jumpmind.symmetric.io.DbCompare

public class DbCompare
extends 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	Description
DbCompare(ISymmetricEngine sourceEngine, ISymmetricEngine targetEngine, DbCompareConfig config)

Method Summary

Modifier and Type	Method	Description
protected String	buildOrderBy(Table table, Column[] sortByColumns, IDatabasePlatform platform, boolean isSource)
protected Table	cloneTable(Table table)
DbCompareReport	compare()
protected int	comparePk(DbCompareTables tables, DbCompareRow sourceCompareRow, DbCompareRow targetCompareRow)
protected boolean	compareTableNames(String sourceTableName, String targetTableName)
protected DbCompareReport.TableReport	compareTables(DbCompareTables tables, OutputStream sqlDiffOutput)
protected List<String>	filterTables(List<String> tables)
protected String	getComparisonSQL(Table table, Column[] sortByColumns, IDatabasePlatform platform, String whereClause, boolean isSource)
DbCompareConfig	getConfig()
protected String	getSourceComparisonSQL(DbCompareTables tables, IDatabasePlatform platform)
protected OutputStream	getSqlDiffOutputStream()
protected OutputStream	getSqlDiffOutputStream(DbCompareTables tables)
protected List<DbCompareTables>	getTablesToCompare()
protected String	getTargetComparisonSQL(DbCompareTables tables, IDatabasePlatform platform)
protected TransformService.TransformTableNodeGroupLink	getTransformFor(Table sourceTable)
protected TriggerRouter	getTriggerRouterFor(Table sourceTable)
boolean	isUniType(String type)
protected List<DbCompareTables>	loadTables(List<String> tableNames, List<String> targetTableNames)
protected List<DbCompareTables>	loadTablesFromArguments()
protected List<DbCompareTables>	loadTablesFromConfig()
protected Table	loadTargetTable(DbCompareTables tables, String targetTableName)
protected Table	loadTargetTableUsingTransform(TransformService.TransformTableNodeGroupLink transform)
protected boolean	mapPrimaryKey(DbCompareTables tables)
protected void	modifyRowForUnitypes(Row originalRow, Map<String,Object> records, Boolean isInserting)

Methods inherited from class java.lang.Object

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

Constructor Details

DbCompare

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

Method Details

compare

public DbCompareReport compare()

getSqlDiffOutputStream

protected OutputStream getSqlDiffOutputStream()

getSqlDiffOutputStream

protected OutputStream getSqlDiffOutputStream(DbCompareTables tables)

compareTables

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

modifyRowForUnitypes

protected void modifyRowForUnitypes(Row originalRow,
 Map<String,Object> records,
 Boolean isInserting)

comparePk

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

getSourceComparisonSQL

protected String getSourceComparisonSQL(DbCompareTables tables,
 IDatabasePlatform platform)

getTargetComparisonSQL

protected String getTargetComparisonSQL(DbCompareTables tables,
 IDatabasePlatform platform)

getComparisonSQL

protected String getComparisonSQL(Table table,
 Column[] sortByColumns,
 IDatabasePlatform platform,
 String whereClause,
 boolean isSource)

buildOrderBy

protected String buildOrderBy(Table table,
 Column[] sortByColumns,
 IDatabasePlatform platform,
 boolean isSource)

getTablesToCompare

protected List<DbCompareTables> getTablesToCompare()

loadTablesFromConfig

protected List<DbCompareTables> loadTablesFromConfig()

loadTables

protected List<DbCompareTables> loadTables(List<String> tableNames,
 List<String> targetTableNames)

mapPrimaryKey

protected boolean mapPrimaryKey(DbCompareTables tables)

loadTargetTable

protected Table loadTargetTable(DbCompareTables tables,
 String targetTableName)

getTriggerRouterFor

protected TriggerRouter getTriggerRouterFor(Table sourceTable)

getTransformFor

protected TransformService.TransformTableNodeGroupLink getTransformFor(Table sourceTable)

loadTargetTableUsingTransform

protected Table loadTargetTableUsingTransform(TransformService.TransformTableNodeGroupLink transform)

cloneTable

protected Table cloneTable(Table table)

loadTablesFromArguments

protected List<DbCompareTables> loadTablesFromArguments()

filterTables

protected List<String> filterTables(List<String> tables)

compareTableNames

protected boolean compareTableNames(String sourceTableName,
 String targetTableName)

isUniType

public boolean isUniType(String type)

getConfig

public DbCompareConfig getConfig()