Package org.jumpmind.symmetric.extract

Class SelectFromSource

java.lang.Object

org.jumpmind.symmetric.extract.SelectFromSource

All Implemented Interfaces:

IExtractDataReaderSource

Direct Known Subclasses:

SelectFromSymDataSource, SelectFromTableSource

public abstract class SelectFromSource
extends Object
implements IExtractDataReaderSource

Field Summary

Fields

Modifier and Type	Field	Description
protected Batch	batch
protected IConfigurationService	configurationService
protected IDataService	dataService
protected ISymmetricEngine	engine
protected IExtensionService	extensionService
protected INodeService	nodeService
protected IParameterService	parameterService
protected IDatabasePlatform	platform
protected Table	sourceTable
protected ISymmetricDialect	symmetricDialect
protected Table	targetTable
protected ITriggerRouterService	triggerRouterService

Constructor Summary

Constructors

Constructor	Description
SelectFromSource(ISymmetricEngine engine)

Method Summary

Modifier and Type	Method	Description
Batch	getBatch()
Table	getSourceTable()	Return the table with the catalog, schema, and table name of the source table for the last CsvData retrieved by IExtractDataReaderSource.next()
Table	getTargetTable()	Return the table with the catalog, schema, and table name of the target table for the last CsvData retrieved by IExtractDataReaderSource.next()
protected boolean	hasLobsThatNeedExtract(Table table, CsvData data)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.jumpmind.symmetric.io.data.reader.IExtractDataReaderSource

close, next, requiresLobsSelectedFromSource

Field Details

engine

protected ISymmetricEngine engine

platform

protected IDatabasePlatform platform

symmetricDialect

protected ISymmetricDialect symmetricDialect

parameterService

protected IParameterService parameterService

dataService

protected IDataService dataService

triggerRouterService

protected ITriggerRouterService triggerRouterService

configurationService

protected IConfigurationService configurationService

nodeService

protected INodeService nodeService

extensionService

protected IExtensionService extensionService

batch

protected Batch batch

sourceTable

protected Table sourceTable

targetTable

protected Table targetTable

Constructor Details

SelectFromSource

public SelectFromSource(ISymmetricEngine engine)

Method Details

getBatch

public Batch getBatch()

Specified by:

getBatch in interface IExtractDataReaderSource

getSourceTable

public Table getSourceTable()

Description copied from interface: IExtractDataReaderSource

Return the table with the catalog, schema, and table name of the source table for the last CsvData retrieved by IExtractDataReaderSource.next()

Specified by:

getSourceTable in interface IExtractDataReaderSource

getTargetTable

public Table getTargetTable()

Description copied from interface: IExtractDataReaderSource

Return the table with the catalog, schema, and table name of the target table for the last CsvData retrieved by IExtractDataReaderSource.next()

Specified by:

getTargetTable in interface IExtractDataReaderSource

hasLobsThatNeedExtract

protected boolean hasLobsThatNeedExtract(Table table,
 CsvData data)