Package org.jumpmind.symmetric.extract

Class SelectFromSymDataSource

java.lang.Object

org.jumpmind.symmetric.extract.SelectFromSource

org.jumpmind.symmetric.extract.SelectFromSymDataSource

All Implemented Interfaces:

IExtractDataReaderSource

public class SelectFromSymDataSource
extends SelectFromSource

Field Summary

Fields

Modifier and Type	Field	Description
protected ColumnsAccordingToTriggerHistory	columnsAccordingToTriggerHistory
protected boolean	containsBigLob
protected ISqlReadCursor<Data>	cursor
protected boolean	dialectHasNoOldBinaryData
protected String	lastRouterId
protected TriggerHistory	lastTriggerHistory
protected Map<Integer,CounterStat>	missingTriggerRoutersByTriggerHist
protected OutgoingBatch	outgoingBatch
protected ProcessInfo	processInfo
protected SelectFromTableSource	reloadSource
protected boolean	requiresLobSelectedFromSource
protected Node	targetNode
protected Map<Integer,TriggerRouter>	triggerRoutersByTriggerHist

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
SelectFromSymDataSource(ISymmetricEngine engine, OutgoingBatch outgoingBatch, Node sourceNode, Node targetNode, ProcessInfo processInfo, boolean containsBigLob)

Method Summary

Modifier and Type	Method	Description
void	close()
protected void	closeCursor()
protected SelectFromTableSource	createSelectFromTableSource(SelectFromTableEvent event)
protected boolean	evaluateDeferTableLogging(OutgoingBatch batch, boolean deferIndices)	Determines whether target table should have transaction logging deferred, until after load is complete (to speed up data import).
CsvData	next()
protected boolean	processCreateEvent(TriggerHistory triggerHistory, String routerId, Data data)
protected Data	processReloadEvent(TriggerHistory triggerHistory, TriggerRouter triggerRouter, Data data)
boolean	requiresLobsSelectedFromSource(CsvData data)

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

lastTriggerHistory

protected TriggerHistory lastTriggerHistory

lastRouterId

protected String lastRouterId

requiresLobSelectedFromSource

protected boolean requiresLobSelectedFromSource

cursor

protected ISqlReadCursor<Data> cursor

reloadSource

protected SelectFromTableSource reloadSource

targetNode

protected Node targetNode

processInfo

protected ProcessInfo processInfo

columnsAccordingToTriggerHistory

protected ColumnsAccordingToTriggerHistory columnsAccordingToTriggerHistory

triggerRoutersByTriggerHist

protected Map<Integer,TriggerRouter> triggerRoutersByTriggerHist

missingTriggerRoutersByTriggerHist

protected Map<Integer,CounterStat> missingTriggerRoutersByTriggerHist

containsBigLob

protected boolean containsBigLob

dialectHasNoOldBinaryData

protected boolean dialectHasNoOldBinaryData

Constructor Details

SelectFromSymDataSource

public SelectFromSymDataSource(ISymmetricEngine engine,
 OutgoingBatch outgoingBatch,
 Node sourceNode,
 Node targetNode,
 ProcessInfo processInfo,
 boolean containsBigLob)

Method Details

next

public CsvData next()

processReloadEvent

protected Data processReloadEvent(TriggerHistory triggerHistory,
 TriggerRouter triggerRouter,
 Data data)

createSelectFromTableSource

protected SelectFromTableSource createSelectFromTableSource(SelectFromTableEvent event)

evaluateDeferTableLogging

protected boolean evaluateDeferTableLogging(OutgoingBatch batch,
 boolean deferIndices)

Determines whether target table should have transaction logging deferred, until after load is complete (to speed up data import). Batch must be part of a load request, which requests table manipulation to speed up import.

Parameters:

batch -

excludeIndices -

Returns:

true for deferring logging for target table

processCreateEvent

protected boolean processCreateEvent(TriggerHistory triggerHistory,
 String routerId,
 Data data)

requiresLobsSelectedFromSource

public boolean requiresLobsSelectedFromSource(CsvData data)

closeCursor

protected void closeCursor()

close

public void close()