in src/main/java/com/datacompare/service/ExecuteChunk.java [77:115]
public ExecuteChunk(String sourceDBType, String targetDBType, String sourceChunk, String targetChunk,
String sourceSql, String targetSql, int chunkNo, int numberOfChunks, Connection sourceConnection,
Connection targetConnection, Map<String, TableColumnMetadata> sourceTableMetadata,
Map<String, TableColumnMetadata> targetTableMetadata, AppProperties appProperties) {
setSourceDBType(sourceDBType);
setTargetDBType(targetDBType);
setSourceChunk(sourceChunk);
setTargetChunk(targetChunk);
setSourceSql(sourceSql);
setTargetSql(targetSql);
setAppProperties(appProperties);
setChunkNo(chunkNo);
setNumberOfChunks(numberOfChunks);
setSourceConnection(sourceConnection);
setTargetConnection(targetConnection);
setSourceTableMetadata(sourceTableMetadata);
setTargetTableMetadata(targetTableMetadata);
Thread.currentThread().setName("Executing Chunk No " + getChunkNo()+1);
StringBuilder info = new StringBuilder();
info.append("SOURCE Chunk No = ");
info.append((getChunkNo()+1));
info.append(" ::: ");
info.append(getSourceChunk());
logger.info(info.toString());
info = new StringBuilder();
info.append("TARGET Chunk No = ");
info.append((getChunkNo()+1));
info.append(" ::: ");
info.append(getTargetChunk());
logger.info(info.toString());
}