Package org.jumpmind.symmetric.extract

Class SelectFromTableSource

java.lang.Object

org.jumpmind.symmetric.extract.SelectFromSource

org.jumpmind.symmetric.extract.SelectFromTableSource

All Implemented Interfaces:

IExtractDataReaderSource

public class SelectFromTableSource
extends SelectFromSource

Field Summary

Fields

Modifier and Type	Field	Description
protected ColumnsAccordingToTriggerHistory	columnsAccordingToTriggerHistory
protected SelectFromTableEvent	currentInitialLoadEvent
protected ISqlReadCursor<Data>	cursor
protected IDataRouter	dataRouter
protected boolean	initialLoadSelectUsed
protected boolean	isConfiguration
protected boolean	isDefaultRouter
protected boolean	isFirstRow
protected boolean	isInitialLoadUseColumnTemplates
protected boolean	isLobFirstPass
protected boolean	isSelfReferencingFk
protected Node	node
protected Set<Node>	nodeSet
protected OutgoingBatch	outgoingBatch
protected String	overrideSelectSql
protected Map<String,IDataRouter>	routers
protected SimpleRouterContext	routingContext
protected List<SelectFromTableEvent>	selectFromTableEventsToSend
protected String	selfRefChildColumnName
protected int	selfRefLevel
protected String	selfRefParentColumnName
protected TriggerRouter	triggerRouter

Fields inherited from class org.jumpmind.symmetric.extract.SelectFromSource

batch, configurationService, dataService, engine, extensionService, nodeService, parameterService, platform, sourceTable, symmetricDialect, targetTable, triggerRouterService

Constructor Summary

Constructors

Constructor	Description
SelectFromTableSource(ISymmetricEngine engine, Batch batch, List<SelectFromTableEvent> initialLoadEvents)
SelectFromTableSource(ISymmetricEngine engine, OutgoingBatch outgoingBatch, Batch batch, SelectFromTableEvent event)

Method Summary

Modifier and Type	Method	Description
void	close()
protected void	closeCursor()
protected ISqlReadCursor<Data>	createCursor(ISymmetricDialect symmetricDialectToUse, SelectFromTableOptions options)
ISymmetricDialect	getSymmetricDialect()
protected final void	init(Batch batch, List<SelectFromTableEvent> initialLoadEvents)
CsvData	next()
boolean	requiresLobsSelectedFromSource(CsvData data)
protected CsvData	selectNext()
void	setConfiguration(boolean isConfiguration)
boolean	shouldDataBeRouted(CsvData data)
protected void	startNewCursor(TriggerHistory triggerHistory, TriggerRouter triggerRouter)

Methods inherited from class org.jumpmind.symmetric.extract.SelectFromSource

getBatch, getSourceTable, getTargetTable, hasLobsThatNeedExtract

Methods inherited from class java.lang.Object

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

Field Details

outgoingBatch

protected OutgoingBatch outgoingBatch

selectFromTableEventsToSend

protected List<SelectFromTableEvent> selectFromTableEventsToSend

currentInitialLoadEvent

protected SelectFromTableEvent currentInitialLoadEvent

cursor

protected ISqlReadCursor<Data> cursor

routingContext

protected SimpleRouterContext routingContext

node

protected Node node

nodeSet

protected Set<Node> nodeSet

triggerRouter

protected TriggerRouter triggerRouter

routers

protected Map<String,IDataRouter> routers

dataRouter

protected IDataRouter dataRouter

isDefaultRouter

protected boolean isDefaultRouter

columnsAccordingToTriggerHistory

protected ColumnsAccordingToTriggerHistory columnsAccordingToTriggerHistory

overrideSelectSql

protected String overrideSelectSql

initialLoadSelectUsed

protected boolean initialLoadSelectUsed

isSelfReferencingFk

protected boolean isSelfReferencingFk

selfRefLevel

protected int selfRefLevel

selfRefParentColumnName

protected String selfRefParentColumnName

selfRefChildColumnName

protected String selfRefChildColumnName

isFirstRow

protected boolean isFirstRow

isLobFirstPass

protected boolean isLobFirstPass

isConfiguration

protected boolean isConfiguration

isInitialLoadUseColumnTemplates

protected boolean isInitialLoadUseColumnTemplates

Constructor Details

SelectFromTableSource

public SelectFromTableSource(ISymmetricEngine engine,
 OutgoingBatch outgoingBatch,
 Batch batch,
 SelectFromTableEvent event)

SelectFromTableSource

public SelectFromTableSource(ISymmetricEngine engine,
 Batch batch,
 List<SelectFromTableEvent> initialLoadEvents)

Method Details

init

protected final void init(Batch batch,
 List<SelectFromTableEvent> initialLoadEvents)

setConfiguration

public void setConfiguration(boolean isConfiguration)

next

public CsvData next()

shouldDataBeRouted

public boolean shouldDataBeRouted(CsvData data)

selectNext

protected CsvData selectNext()

closeCursor

protected void closeCursor()

getSymmetricDialect

public ISymmetricDialect getSymmetricDialect()

startNewCursor

protected void startNewCursor(TriggerHistory triggerHistory,
 TriggerRouter triggerRouter)

createCursor

protected ISqlReadCursor<Data> createCursor(ISymmetricDialect symmetricDialectToUse,
 SelectFromTableOptions options)

requiresLobsSelectedFromSource

public boolean requiresLobsSelectedFromSource(CsvData data)

close

public void close()