org.jumpmind.symmetric.service.impl

Class DataService

java.lang.Object

org.jumpmind.symmetric.service.impl.AbstractService

org.jumpmind.symmetric.service.impl.DataService

All Implemented Interfaces:

IDataService, IService

public class DataService
extends AbstractService
implements IDataService

See Also:

IDataService

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	DataService.DataMapper
static class	DataService.LastCaptureByChannelMapper
protected class	DataService.TableReloadRequestMapper
protected class	DataService.TableReloadStatusMapper

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.Map<IHeartbeatListener,java.lang.Long>	lastHeartbeatTimestamps

Fields inherited from class org.jumpmind.symmetric.service.impl.AbstractService

log, parameterService, platform, sqlTemplate, sqlTemplateDirty, symmetricDialect, tablePrefix

Constructor Summary

Constructors

Constructor and Description
DataService(ISymmetricEngine engine, IExtensionService extensionService)

Method Summary

Modifier and Type	Method and Description
int	cancelTableReloadRequest(TableReloadRequest request)
protected void	checkInterrupted()
java.util.List<TableReloadRequest>	collapseTableReloadRequestsByLoadId(java.util.List<TableReloadRequest> requests)
protected java.util.Map<java.lang.String,TableReloadRequest>	convertReloadListToMap(java.util.List<TableReloadRequest> reloadRequests, java.util.List<TriggerRouter> triggerRouters, boolean isFullLoad, boolean isChannelLoad)
long	countDataGaps()
int	countDataInRange(long firstDataId, long secondDataId) Count the number of data ids in a range
Data	createData(org.jumpmind.db.sql.ISqlTransaction transaction, java.lang.String catalogName, java.lang.String schemaName, java.lang.String tableName, java.lang.String whereClause)
protected Data	createData(org.jumpmind.db.sql.ISqlTransaction transaction, Trigger trigger, java.lang.String whereClause)
Data	createData(java.lang.String catalogName, java.lang.String schemaName, java.lang.String tableName)
Data	createData(java.lang.String catalogName, java.lang.String schemaName, java.lang.String tableName, java.lang.String whereClause)
protected void	createPurgeEvent(org.jumpmind.db.sql.ISqlTransaction transaction, java.lang.String sql, Node targetNode, Node sourceNode, TriggerRouter triggerRouter, TriggerHistory triggerHistory, boolean isLoad, long loadId, java.lang.String createBy)
void	createTableReloadStatus(org.jumpmind.db.sql.ISqlTransaction transaction, long loadId, java.lang.String sourceNodeId, java.lang.String targetNodeId)
void	deleteAllDataGaps(org.jumpmind.db.sql.ISqlTransaction transaction)
void	deleteCapturedConfigChannelData()
void	deleteDataGap(DataGap gap)
void	deleteDataGap(org.jumpmind.db.sql.ISqlTransaction transaction, DataGap gap)
void	deleteDataGaps(org.jumpmind.db.sql.ISqlTransaction transaction, java.util.Collection<DataGap> gaps)
protected void	deleteTableReloadRequest(org.jumpmind.db.sql.ISqlTransaction sqlTransaction, TableReloadRequest request)
java.util.Date	findCreateTimeOfData(long dataId)
java.util.Date	findCreateTimeOfEvent(long dataId)
Data	findData(long dataId)
java.util.List<DataGap>	findDataGaps()
java.util.List<DataGap>	findDataGapsUnchecked()
long	findMaxDataEventDataId()
long	findMaxDataId()
long	findMinDataId()
java.util.Date	findNextCreateTimeOfDataStartingAt(long dataId)
boolean	fixLastDataGap()
java.util.List<TableReloadStatus>	getActiveTableReloadStatus()
protected java.lang.String	getCsvDataFor(org.jumpmind.db.sql.ISqlTransaction transaction, Trigger trigger, TriggerHistory triggerHistory, java.lang.String whereClause, boolean pkOnly)
protected long	getDataCountForReload(org.jumpmind.db.model.Table table, Node targetNode, java.lang.String selectSql)
org.jumpmind.db.sql.ISqlRowMapper<Data>	getDataMapper()
protected java.lang.String	getDataOrderBy()
protected java.lang.String	getDataSelectByBatchSql(long batchId, long startDataId, java.lang.String channelId)
protected java.lang.String	getDataSelectSql(long batchId, long startDataId, boolean isContainsBigLob)
protected java.lang.String	getDataSelectSql(long batchId, long startDataId, java.lang.String channelId)
protected java.util.List<IHeartbeatListener>	getHeartbeatListeners(boolean force) Get a list of IHeartbeatListeners that are ready for a heartbeat according to IHeartbeatListener.getTimeBetweenHeartbeatsInSeconds()
java.util.Map<java.lang.String,java.util.Date>	getLastDataCaptureByChannel()
TableReloadRequest	getTableReloadRequest(long loadId)
TableReloadRequest	getTableReloadRequest(long loadId, java.lang.String triggerId, java.lang.String routerId)
TableReloadRequest	getTableReloadRequest(TableReloadRequestKey key)
java.util.List<TableReloadRequest>	getTableReloadRequestByLoadId()
java.util.List<TableReloadRequest>	getTableReloadRequests()
java.util.List<TableReloadRequest>	getTableReloadRequestToProcess(java.lang.String sourceNodeId)
java.util.List<TableReloadStatus>	getTableReloadStatus()
TableReloadStatus	getTableReloadStatusByLoadId(long loadId)
java.util.List<TableReloadStatus>	getTableReloadStatusByTarget(java.lang.String targetNodeId)
protected int	getTransformMultiplier(org.jumpmind.db.model.Table table, TriggerRouter triggerRouter)
void	heartbeat(boolean force) Update Node information for this node and call IHeartbeatListeners.
protected void	insertCreateEvent(org.jumpmind.db.sql.ISqlTransaction transaction, Node targetNode, TriggerHistory triggerHistory, boolean isLoad, long loadId, java.lang.String createBy)
void	insertCreateEvent(org.jumpmind.db.sql.ISqlTransaction transaction, Node targetNode, TriggerHistory triggerHistory, java.lang.String channelId, boolean isLoad, long loadId, java.lang.String createBy)
void	insertCreateEvent(Node targetNode, TriggerHistory triggerHistory, boolean isLoad, long loadId, java.lang.String createBy)
void	insertCreateEvent(Node targetNode, TriggerHistory triggerHistory, java.lang.String createBy)
long	insertData(Data data)
long	insertData(org.jumpmind.db.sql.ISqlTransaction transaction, Data data)
long	insertDataAndDataEventAndOutgoingBatch(Data data, java.lang.String nodeId, boolean isLoad, long loadId, java.lang.String createBy)
void	insertDataAndDataEventAndOutgoingBatch(Data data, java.lang.String channelId, java.util.List<Node> nodes, boolean isLoad, long loadId, java.lang.String createBy)
long	insertDataAndDataEventAndOutgoingBatch(org.jumpmind.db.sql.ISqlTransaction transaction, Data data, java.lang.String nodeId, boolean isLoad, long loadId, java.lang.String createBy, AbstractBatch.Status status, long estimatedBatchRowCount)
long	insertDataAndDataEventAndOutgoingBatch(org.jumpmind.db.sql.ISqlTransaction transaction, Data data, java.lang.String nodeId, boolean isLoad, long loadId, java.lang.String createBy, AbstractBatch.Status status, java.lang.String overrideChannelId, long estimatedBatchRowCount)
protected void	insertDataEvent(org.jumpmind.db.sql.ISqlTransaction transaction, DataEvent dataEvent)
protected void	insertDataEvent(org.jumpmind.db.sql.ISqlTransaction transaction, long dataId, long batchId)
protected long	insertDataEventAndOutgoingBatch(org.jumpmind.db.sql.ISqlTransaction transaction, long dataId, java.lang.String channelId, java.lang.String nodeId, org.jumpmind.symmetric.io.data.DataEventType eventType, boolean isLoad, long loadId, java.lang.String createBy, AbstractBatch.Status status, java.lang.String tableName, long estimatedBatchRowCount)
void	insertDataEvents(org.jumpmind.db.sql.ISqlTransaction transaction, java.util.List<DataEvent> events)
void	insertDataGap(DataGap gap)
void	insertDataGap(org.jumpmind.db.sql.ISqlTransaction transaction, DataGap gap)
void	insertDataGaps(org.jumpmind.db.sql.ISqlTransaction transaction, java.util.Collection<DataGap> gaps)
void	insertHeartbeatEvent(Node node, boolean isReload) Because we can't add a trigger on the _node table, we are artificially generating heartbeat events.
protected void	insertPurgeEvent(org.jumpmind.db.sql.ISqlTransaction transaction, Node targetNode, TriggerRouter triggerRouter, TriggerHistory triggerHistory, boolean isLoad, java.lang.String overrideDeleteStatement, long loadId, java.lang.String createBy)
long	insertReloadEvent(org.jumpmind.db.sql.ISqlTransaction transaction, Node targetNode, TriggerRouter triggerRouter, TriggerHistory triggerHistory, java.lang.String overrideInitialLoadSelect, boolean isLoad, long loadId, java.lang.String createBy, AbstractBatch.Status status, long estimatedBatchRowCount)
long	insertReloadEvent(org.jumpmind.db.sql.ISqlTransaction transaction, Node targetNode, TriggerRouter triggerRouter, TriggerHistory triggerHistory, java.lang.String overrideInitialLoadSelect, boolean isLoad, long loadId, java.lang.String createBy, AbstractBatch.Status status, java.lang.String channelId, long estimatedBatchRowCount)
protected long	insertReloadEvent(org.jumpmind.db.sql.ISqlTransaction transaction, Node targetNode, TriggerRouter triggerRouter, TriggerHistory triggerHistory, java.lang.String overrideInitialLoadSelect, boolean isLoad, long loadId, java.lang.String createBy, AbstractBatch.Status status, java.lang.String channelId, long estimatedBatchRowCount, boolean isImmediate)
boolean	insertReloadEvent(TableReloadRequest request, boolean deleteAtClient)
long	insertReloadEventImmediate(org.jumpmind.db.sql.ISqlTransaction transaction, Node targetNode, TriggerRouter triggerRouter, TriggerHistory triggerHistory, java.lang.String overrideInitialLoadSelect, boolean isLoad, long loadId, java.lang.String createBy, AbstractBatch.Status status, java.lang.String channelId, long estimatedBatchRowCount)
java.util.Map<java.lang.Integer,ExtractRequest>	insertReloadEvents(Node targetNode, boolean reverse, java.util.List<TableReloadRequest> reloadRequests, ProcessInfo processInfo, java.util.List<TriggerRouter> triggerRouters, java.util.Map<java.lang.Integer,ExtractRequest> extractRequests, IReloadGenerator reloadGenerator)
protected long	insertRequestedOutgoingBatches(org.jumpmind.db.sql.ISqlTransaction transaction, Node targetNode, TriggerRouter triggerRouter, TriggerHistory triggerHistory, java.lang.String overrideInitialLoadSelect, long loadId, java.lang.String createBy, java.lang.String channelId, long totalRows, long maxRowsPerBatch, long batchCount)
void	insertScriptEvent(org.jumpmind.db.sql.ISqlTransaction transaction, java.lang.String channelId, Node targetNode, java.lang.String script, boolean isLoad, long loadId, java.lang.String createBy)
void	insertScriptEvent(java.lang.String channelId, Node targetNode, java.lang.String script, boolean isLoad, long loadId, java.lang.String createBy)
void	insertSqlEvent(org.jumpmind.db.sql.ISqlTransaction transaction, Node targetNode, java.lang.String sql, boolean isLoad, long loadId, java.lang.String createBy)
void	insertSqlEvent(org.jumpmind.db.sql.ISqlTransaction transaction, TriggerHistory history, java.lang.String channelId, Node targetNode, java.lang.String sql, boolean isLoad, long loadId, java.lang.String createBy)
void	insertSqlEvent(Node targetNode, java.lang.String sql, boolean isLoad, long loadId, java.lang.String createBy)
void	insertTableReloadRequest(org.jumpmind.db.sql.ISqlTransaction transaction, TableReloadRequest request)
void	insertTableReloadRequest(TableReloadRequest request)
java.util.List<Data>	listData(long batchId, java.lang.String nodeId, long startDataId, java.lang.String channelId, int maxRowsToRetrieve)
java.util.List<java.lang.Number>	listDataIds(long batchId, java.lang.String nodeId)
void	reloadMissingForeignKeyRows(java.lang.String nodeId, long dataId)
void	reloadMissingForeignKeyRowsReverse(java.lang.String sourceNodeId, org.jumpmind.db.model.Table table, org.jumpmind.symmetric.io.data.CsvData data, java.lang.String channelId, boolean sendCorrectionToPeers)
java.lang.String	reloadNode(java.lang.String nodeId, boolean reverseLoad, java.lang.String createBy)
java.lang.String	reloadTable(java.lang.String nodeId, java.lang.String catalogName, java.lang.String schemaName, java.lang.String tableName)
java.lang.String	reloadTable(java.lang.String nodeId, java.lang.String catalogName, java.lang.String schemaName, java.lang.String tableName, java.lang.String overrideInitialLoadSelect)
protected java.lang.String	reloadTable(java.lang.String nodeId, java.lang.String catalogName, java.lang.String schemaName, java.lang.String tableName, java.lang.String overrideInitialLoadSelect, java.lang.String overrideChannelId, boolean isImmediate)
java.lang.String	reloadTableImmediate(java.lang.String nodeId, java.lang.String catalogName, java.lang.String schemaName, java.lang.String tableName, java.lang.String overrideInitialLoadSelect, java.lang.String overrideChannelId)
java.util.List<java.lang.String>	resolveTargetTables(java.lang.String sql, TriggerRouter triggerRouter, TriggerHistory triggerHistory, Node targetNode)
org.jumpmind.db.sql.ISqlReadCursor<Data>	selectDataFor(org.jumpmind.symmetric.io.data.Batch batch)
org.jumpmind.db.sql.ISqlReadCursor<Data>	selectDataFor(java.lang.Long batchId, java.lang.String channelId)
org.jumpmind.db.sql.ISqlReadCursor<Data>	selectDataFor(java.lang.Long batchId, java.lang.String targetNodeId, boolean isContainsBigLob)
boolean	sendSchema(java.lang.String nodeId, java.lang.String catalogName, java.lang.String schemaName, java.lang.String tableName, boolean isLoad)
void	sendScript(java.lang.String nodeId, java.lang.String script, boolean isLoad)
java.lang.String	sendSQL(java.lang.String nodeId, java.lang.String sql)
java.lang.String	sendSQL(java.lang.String nodeId, java.lang.String catalogName, java.lang.String schemaName, java.lang.String tableName, java.lang.String sql) Sends a SQL command to the remote node for execution by creating a SQL event that is synced like other data
protected void	updateLastHeartbeatTime(java.util.List<IHeartbeatListener> listeners)
int	updateTableReloadRequestsCancelled(long loadId)
protected int	updateTableReloadRequestsError(long loadId, org.jumpmind.db.sql.SqlException e)
void	updateTableReloadRequestsLoadId(org.jumpmind.db.sql.ISqlTransaction transaction, long loadId, TableReloadRequest request)
void	updateTableReloadStatusDataCounts(org.jumpmind.db.sql.ISqlTransaction transaction, long loadId, long startBatchId, long endBatchId, long dataBatchCount, long rowsCount)
void	updateTableReloadStatusDataLoaded(org.jumpmind.db.sql.ISqlTransaction transaction, long loadId, long batchId, int batchCount)
void	updateTableReloadStatusSetupCount(org.jumpmind.db.sql.ISqlTransaction transaction, long loadId, int setupBatchCount)
void	updateTableReloadStatusTableCount(org.jumpmind.db.sql.ISqlTransaction transaction, long loadId, int tableCount)
protected void	validate(TableReloadRequest reloadRequest, java.util.List<TriggerRouter> triggerRouters)

Methods inherited from class org.jumpmind.symmetric.service.impl.AbstractService

assertNotNull, buildBatchWhere, close, createSqlReplacementTokens, createSqlReplacementTokens, getJdbcTemplate, getParameterService, getSql, getSymmetricDialect, getTablePrefix, getTargetDialect, getTargetPlatform, getTargetPlatform, isCalledFromSymmetricAdminTool, isSet, isStreamClosedByClient, isSymmetricTable, logOnce, maxDate, readAcks, sendAck, setSqlMap, synchronize, toNodeIds, toNodeIds

Methods inherited from class java.lang.Object

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

Field Detail

lastHeartbeatTimestamps

protected java.util.Map<IHeartbeatListener,java.lang.Long> lastHeartbeatTimestamps

Constructor Detail

DataService

public DataService(ISymmetricEngine engine,
                   IExtensionService extensionService)

Method Detail

insertReloadEvent

public boolean insertReloadEvent(TableReloadRequest request,
                                 boolean deleteAtClient)

Specified by:

insertReloadEvent in interface IDataService

cancelTableReloadRequest

public int cancelTableReloadRequest(TableReloadRequest request)

Specified by:

cancelTableReloadRequest in interface IDataService

deleteTableReloadRequest

protected void deleteTableReloadRequest(org.jumpmind.db.sql.ISqlTransaction sqlTransaction,
                                        TableReloadRequest request)

insertTableReloadRequest

public void insertTableReloadRequest(TableReloadRequest request)

Specified by:

insertTableReloadRequest in interface IDataService

insertTableReloadRequest

public void insertTableReloadRequest(org.jumpmind.db.sql.ISqlTransaction transaction,
                                     TableReloadRequest request)

Specified by:

insertTableReloadRequest in interface IDataService

getTableReloadRequest

public TableReloadRequest getTableReloadRequest(TableReloadRequestKey key)

Specified by:

getTableReloadRequest in interface IDataService

getTableReloadRequest

public TableReloadRequest getTableReloadRequest(long loadId)

Specified by:

getTableReloadRequest in interface IDataService

getTableReloadRequest

public TableReloadRequest getTableReloadRequest(long loadId,
                                                java.lang.String triggerId,
                                                java.lang.String routerId)

Specified by:

getTableReloadRequest in interface IDataService

getTableReloadRequestToProcess

public java.util.List<TableReloadRequest> getTableReloadRequestToProcess(java.lang.String sourceNodeId)

Specified by:

getTableReloadRequestToProcess in interface IDataService

getTableReloadRequests

public java.util.List<TableReloadRequest> getTableReloadRequests()

getTableReloadStatus

public java.util.List<TableReloadStatus> getTableReloadStatus()

Specified by:

getTableReloadStatus in interface IDataService

getActiveTableReloadStatus

public java.util.List<TableReloadStatus> getActiveTableReloadStatus()

Specified by:

getActiveTableReloadStatus in interface IDataService

getTableReloadStatusByLoadId

public TableReloadStatus getTableReloadStatusByLoadId(long loadId)

Specified by:

getTableReloadStatusByLoadId in interface IDataService

getTableReloadStatusByTarget

public java.util.List<TableReloadStatus> getTableReloadStatusByTarget(java.lang.String targetNodeId)

Specified by:

getTableReloadStatusByTarget in interface IDataService

getTableReloadRequestByLoadId

public java.util.List<TableReloadRequest> getTableReloadRequestByLoadId()

collapseTableReloadRequestsByLoadId

public java.util.List<TableReloadRequest> collapseTableReloadRequestsByLoadId(java.util.List<TableReloadRequest> requests)

updateTableReloadStatusDataLoaded

public void updateTableReloadStatusDataLoaded(org.jumpmind.db.sql.ISqlTransaction transaction,
                                              long loadId,
                                              long batchId,
                                              int batchCount)

Specified by:

updateTableReloadStatusDataLoaded in interface IDataService

updateTableReloadStatusDataCounts

public void updateTableReloadStatusDataCounts(org.jumpmind.db.sql.ISqlTransaction transaction,
                                              long loadId,
                                              long startBatchId,
                                              long endBatchId,
                                              long dataBatchCount,
                                              long rowsCount)

updateTableReloadRequestsLoadId

public void updateTableReloadRequestsLoadId(org.jumpmind.db.sql.ISqlTransaction transaction,
                                            long loadId,
                                            TableReloadRequest request)

updateTableReloadStatusTableCount

public void updateTableReloadStatusTableCount(org.jumpmind.db.sql.ISqlTransaction transaction,
                                              long loadId,
                                              int tableCount)

createTableReloadStatus

public void createTableReloadStatus(org.jumpmind.db.sql.ISqlTransaction transaction,
                                    long loadId,
                                    java.lang.String sourceNodeId,
                                    java.lang.String targetNodeId)

updateTableReloadStatusSetupCount

public void updateTableReloadStatusSetupCount(org.jumpmind.db.sql.ISqlTransaction transaction,
                                              long loadId,
                                              int setupBatchCount)

updateTableReloadRequestsCancelled

public int updateTableReloadRequestsCancelled(long loadId)

Specified by:

updateTableReloadRequestsCancelled in interface IDataService

updateTableReloadRequestsError

protected int updateTableReloadRequestsError(long loadId,
                                             org.jumpmind.db.sql.SqlException e)

insertRequestedOutgoingBatches

protected long insertRequestedOutgoingBatches(org.jumpmind.db.sql.ISqlTransaction transaction,
                                              Node targetNode,
                                              TriggerRouter triggerRouter,
                                              TriggerHistory triggerHistory,
                                              java.lang.String overrideInitialLoadSelect,
                                              long loadId,
                                              java.lang.String createBy,
                                              java.lang.String channelId,
                                              long totalRows,
                                              long maxRowsPerBatch,
                                              long batchCount)

insertReloadEvent

public long insertReloadEvent(org.jumpmind.db.sql.ISqlTransaction transaction,
                              Node targetNode,
                              TriggerRouter triggerRouter,
                              TriggerHistory triggerHistory,
                              java.lang.String overrideInitialLoadSelect,
                              boolean isLoad,
                              long loadId,
                              java.lang.String createBy,
                              AbstractBatch.Status status,
                              long estimatedBatchRowCount)

Specified by:

insertReloadEvent in interface IDataService

Returns:

If isLoad then return the inserted batch id otherwise return the data id

insertReloadEvent

public long insertReloadEvent(org.jumpmind.db.sql.ISqlTransaction transaction,
                              Node targetNode,
                              TriggerRouter triggerRouter,
                              TriggerHistory triggerHistory,
                              java.lang.String overrideInitialLoadSelect,
                              boolean isLoad,
                              long loadId,
                              java.lang.String createBy,
                              AbstractBatch.Status status,
                              java.lang.String channelId,
                              long estimatedBatchRowCount)

Parameters:

estimatedBatchRowCount - TODO

Returns:

If isLoad then return the inserted batch id otherwise return the data id

insertReloadEventImmediate

public long insertReloadEventImmediate(org.jumpmind.db.sql.ISqlTransaction transaction,
                                       Node targetNode,
                                       TriggerRouter triggerRouter,
                                       TriggerHistory triggerHistory,
                                       java.lang.String overrideInitialLoadSelect,
                                       boolean isLoad,
                                       long loadId,
                                       java.lang.String createBy,
                                       AbstractBatch.Status status,
                                       java.lang.String channelId,
                                       long estimatedBatchRowCount)

insertReloadEvent

protected long insertReloadEvent(org.jumpmind.db.sql.ISqlTransaction transaction,
                                 Node targetNode,
                                 TriggerRouter triggerRouter,
                                 TriggerHistory triggerHistory,
                                 java.lang.String overrideInitialLoadSelect,
                                 boolean isLoad,
                                 long loadId,
                                 java.lang.String createBy,
                                 AbstractBatch.Status status,
                                 java.lang.String channelId,
                                 long estimatedBatchRowCount,
                                 boolean isImmediate)

insertReloadEvents

public java.util.Map<java.lang.Integer,ExtractRequest> insertReloadEvents(Node targetNode,
                                                                          boolean reverse,
                                                                          java.util.List<TableReloadRequest> reloadRequests,
                                                                          ProcessInfo processInfo,
                                                                          java.util.List<TriggerRouter> triggerRouters,
                                                                          java.util.Map<java.lang.Integer,ExtractRequest> extractRequests,
                                                                          IReloadGenerator reloadGenerator)

Specified by:

insertReloadEvents in interface IDataService

convertReloadListToMap

protected java.util.Map<java.lang.String,TableReloadRequest> convertReloadListToMap(java.util.List<TableReloadRequest> reloadRequests,
                                                                                    java.util.List<TriggerRouter> triggerRouters,
                                                                                    boolean isFullLoad,
                                                                                    boolean isChannelLoad)

validate

protected void validate(TableReloadRequest reloadRequest,
                        java.util.List<TriggerRouter> triggerRouters)

getDataCountForReload

protected long getDataCountForReload(org.jumpmind.db.model.Table table,
                                     Node targetNode,
                                     java.lang.String selectSql)
                              throws org.jumpmind.db.sql.SqlException

Throws:

org.jumpmind.db.sql.SqlException

getTransformMultiplier

protected int getTransformMultiplier(org.jumpmind.db.model.Table table,
                                     TriggerRouter triggerRouter)

insertPurgeEvent

protected void insertPurgeEvent(org.jumpmind.db.sql.ISqlTransaction transaction,
                                Node targetNode,
                                TriggerRouter triggerRouter,
                                TriggerHistory triggerHistory,
                                boolean isLoad,
                                java.lang.String overrideDeleteStatement,
                                long loadId,
                                java.lang.String createBy)

resolveTargetTables

public java.util.List<java.lang.String> resolveTargetTables(java.lang.String sql,
                                                            TriggerRouter triggerRouter,
                                                            TriggerHistory triggerHistory,
                                                            Node targetNode)

createPurgeEvent

protected void createPurgeEvent(org.jumpmind.db.sql.ISqlTransaction transaction,
                                java.lang.String sql,
                                Node targetNode,
                                Node sourceNode,
                                TriggerRouter triggerRouter,
                                TriggerHistory triggerHistory,
                                boolean isLoad,
                                long loadId,
                                java.lang.String createBy)

insertSqlEvent

public void insertSqlEvent(Node targetNode,
                           java.lang.String sql,
                           boolean isLoad,
                           long loadId,
                           java.lang.String createBy)

Specified by:

insertSqlEvent in interface IDataService

insertSqlEvent

public void insertSqlEvent(org.jumpmind.db.sql.ISqlTransaction transaction,
                           Node targetNode,
                           java.lang.String sql,
                           boolean isLoad,
                           long loadId,
                           java.lang.String createBy)

Specified by:

insertSqlEvent in interface IDataService

insertSqlEvent

public void insertSqlEvent(org.jumpmind.db.sql.ISqlTransaction transaction,
                           TriggerHistory history,
                           java.lang.String channelId,
                           Node targetNode,
                           java.lang.String sql,
                           boolean isLoad,
                           long loadId,
                           java.lang.String createBy)

Specified by:

insertSqlEvent in interface IDataService

insertScriptEvent

public void insertScriptEvent(java.lang.String channelId,
                              Node targetNode,
                              java.lang.String script,
                              boolean isLoad,
                              long loadId,
                              java.lang.String createBy)

Specified by:

insertScriptEvent in interface IDataService

insertScriptEvent

public void insertScriptEvent(org.jumpmind.db.sql.ISqlTransaction transaction,
                              java.lang.String channelId,
                              Node targetNode,
                              java.lang.String script,
                              boolean isLoad,
                              long loadId,
                              java.lang.String createBy)

Specified by:

insertScriptEvent in interface IDataService

countDataInRange

public int countDataInRange(long firstDataId,
                            long secondDataId)

Description copied from interface: IDataService

Count the number of data ids in a range

Specified by:

countDataInRange in interface IDataService

insertCreateEvent

public void insertCreateEvent(Node targetNode,
                              TriggerHistory triggerHistory,
                              boolean isLoad,
                              long loadId,
                              java.lang.String createBy)

Specified by:

insertCreateEvent in interface IDataService

insertCreateEvent

public void insertCreateEvent(Node targetNode,
                              TriggerHistory triggerHistory,
                              java.lang.String createBy)

Specified by:

insertCreateEvent in interface IDataService

insertCreateEvent

protected void insertCreateEvent(org.jumpmind.db.sql.ISqlTransaction transaction,
                                 Node targetNode,
                                 TriggerHistory triggerHistory,
                                 boolean isLoad,
                                 long loadId,
                                 java.lang.String createBy)

insertCreateEvent

public void insertCreateEvent(org.jumpmind.db.sql.ISqlTransaction transaction,
                              Node targetNode,
                              TriggerHistory triggerHistory,
                              java.lang.String channelId,
                              boolean isLoad,
                              long loadId,
                              java.lang.String createBy)

Specified by:

insertCreateEvent in interface IDataService

insertData

public long insertData(Data data)

Specified by:

insertData in interface IDataService

insertData

public long insertData(org.jumpmind.db.sql.ISqlTransaction transaction,
                       Data data)

Specified by:

insertData in interface IDataService

insertDataEvent

protected void insertDataEvent(org.jumpmind.db.sql.ISqlTransaction transaction,
                               DataEvent dataEvent)

insertDataEvent

protected void insertDataEvent(org.jumpmind.db.sql.ISqlTransaction transaction,
                               long dataId,
                               long batchId)

insertDataEvents

public void insertDataEvents(org.jumpmind.db.sql.ISqlTransaction transaction,
                             java.util.List<DataEvent> events)

Specified by:

insertDataEvents in interface IDataService

insertDataAndDataEventAndOutgoingBatch

public void insertDataAndDataEventAndOutgoingBatch(Data data,
                                                   java.lang.String channelId,
                                                   java.util.List<Node> nodes,
                                                   boolean isLoad,
                                                   long loadId,
                                                   java.lang.String createBy)

Specified by:

insertDataAndDataEventAndOutgoingBatch in interface IDataService

insertDataAndDataEventAndOutgoingBatch

public long insertDataAndDataEventAndOutgoingBatch(Data data,
                                                   java.lang.String nodeId,
                                                   boolean isLoad,
                                                   long loadId,
                                                   java.lang.String createBy)

Specified by:

insertDataAndDataEventAndOutgoingBatch in interface IDataService

Returns:

The inserted batch id

insertDataAndDataEventAndOutgoingBatch

public long insertDataAndDataEventAndOutgoingBatch(org.jumpmind.db.sql.ISqlTransaction transaction,
                                                   Data data,
                                                   java.lang.String nodeId,
                                                   boolean isLoad,
                                                   long loadId,
                                                   java.lang.String createBy,
                                                   AbstractBatch.Status status,
                                                   java.lang.String overrideChannelId,
                                                   long estimatedBatchRowCount)

Parameters:

estimatedBatchRowCount - TODO

Returns:

The inserted batch id

insertDataAndDataEventAndOutgoingBatch

public long insertDataAndDataEventAndOutgoingBatch(org.jumpmind.db.sql.ISqlTransaction transaction,
                                                   Data data,
                                                   java.lang.String nodeId,
                                                   boolean isLoad,
                                                   long loadId,
                                                   java.lang.String createBy,
                                                   AbstractBatch.Status status,
                                                   long estimatedBatchRowCount)

Specified by:

insertDataAndDataEventAndOutgoingBatch in interface IDataService

insertDataEventAndOutgoingBatch

protected long insertDataEventAndOutgoingBatch(org.jumpmind.db.sql.ISqlTransaction transaction,
                                               long dataId,
                                               java.lang.String channelId,
                                               java.lang.String nodeId,
                                               org.jumpmind.symmetric.io.data.DataEventType eventType,
                                               boolean isLoad,
                                               long loadId,
                                               java.lang.String createBy,
                                               AbstractBatch.Status status,
                                               java.lang.String tableName,
                                               long estimatedBatchRowCount)

reloadNode

public java.lang.String reloadNode(java.lang.String nodeId,
                                   boolean reverseLoad,
                                   java.lang.String createBy)

Specified by:

reloadNode in interface IDataService

sendScript

public void sendScript(java.lang.String nodeId,
                       java.lang.String script,
                       boolean isLoad)

Specified by:

sendScript in interface IDataService

sendSchema

public boolean sendSchema(java.lang.String nodeId,
                          java.lang.String catalogName,
                          java.lang.String schemaName,
                          java.lang.String tableName,
                          boolean isLoad)

Specified by:

sendSchema in interface IDataService

sendSQL

public java.lang.String sendSQL(java.lang.String nodeId,
                                java.lang.String catalogName,
                                java.lang.String schemaName,
                                java.lang.String tableName,
                                java.lang.String sql)

Description copied from interface: IDataService

Sends a SQL command to the remote node for execution by creating a SQL event that is synced like other data

Specified by:

sendSQL in interface IDataService

Parameters:

nodeId - the remote node where the SQL statement will be executed

catalogName - used to find the sym_trigger entry for table that will be associated with this event

schemaName - used to find the sym_trigger entry for table that will be associated with this event

tableName - used to find the sym_trigger entry for table that will be associated with this event

sql - the SQL statement to run on the remote node database

Returns:

message string indicating success or error

sendSQL

public java.lang.String sendSQL(java.lang.String nodeId,
                                java.lang.String sql)

Specified by:

sendSQL in interface IDataService

reloadTable

public java.lang.String reloadTable(java.lang.String nodeId,
                                    java.lang.String catalogName,
                                    java.lang.String schemaName,
                                    java.lang.String tableName)

Specified by:

reloadTable in interface IDataService

reloadTable

public java.lang.String reloadTable(java.lang.String nodeId,
                                    java.lang.String catalogName,
                                    java.lang.String schemaName,
                                    java.lang.String tableName,
                                    java.lang.String overrideInitialLoadSelect)

Specified by:

reloadTable in interface IDataService

reloadTableImmediate

public java.lang.String reloadTableImmediate(java.lang.String nodeId,
                                             java.lang.String catalogName,
                                             java.lang.String schemaName,
                                             java.lang.String tableName,
                                             java.lang.String overrideInitialLoadSelect,
                                             java.lang.String overrideChannelId)

Specified by:

reloadTableImmediate in interface IDataService

reloadTable

protected java.lang.String reloadTable(java.lang.String nodeId,
                                       java.lang.String catalogName,
                                       java.lang.String schemaName,
                                       java.lang.String tableName,
                                       java.lang.String overrideInitialLoadSelect,
                                       java.lang.String overrideChannelId,
                                       boolean isImmediate)

reloadMissingForeignKeyRowsReverse

public void reloadMissingForeignKeyRowsReverse(java.lang.String sourceNodeId,
                                               org.jumpmind.db.model.Table table,
                                               org.jumpmind.symmetric.io.data.CsvData data,
                                               java.lang.String channelId,
                                               boolean sendCorrectionToPeers)

Specified by:

reloadMissingForeignKeyRowsReverse in interface IDataService

reloadMissingForeignKeyRows

public void reloadMissingForeignKeyRows(java.lang.String nodeId,
                                        long dataId)

Specified by:

reloadMissingForeignKeyRows in interface IDataService

insertHeartbeatEvent

public void insertHeartbeatEvent(Node node,
                                 boolean isReload)

Because we can't add a trigger on the _node table, we are artificially generating heartbeat events.

Specified by:

insertHeartbeatEvent in interface IDataService

Parameters:

node -

createData

public Data createData(java.lang.String catalogName,
                       java.lang.String schemaName,
                       java.lang.String tableName)

Specified by:

createData in interface IDataService

createData

public Data createData(java.lang.String catalogName,
                       java.lang.String schemaName,
                       java.lang.String tableName,
                       java.lang.String whereClause)

Specified by:

createData in interface IDataService

createData

public Data createData(org.jumpmind.db.sql.ISqlTransaction transaction,
                       java.lang.String catalogName,
                       java.lang.String schemaName,
                       java.lang.String tableName,
                       java.lang.String whereClause)

Specified by:

createData in interface IDataService

createData

protected Data createData(org.jumpmind.db.sql.ISqlTransaction transaction,
                          Trigger trigger,
                          java.lang.String whereClause)

getCsvDataFor

protected java.lang.String getCsvDataFor(org.jumpmind.db.sql.ISqlTransaction transaction,
                                         Trigger trigger,
                                         TriggerHistory triggerHistory,
                                         java.lang.String whereClause,
                                         boolean pkOnly)

countDataGaps

public long countDataGaps()

Specified by:

countDataGaps in interface IDataService

findDataGapsUnchecked

public java.util.List<DataGap> findDataGapsUnchecked()

Specified by:

findDataGapsUnchecked in interface IDataService

findDataGaps

public java.util.List<DataGap> findDataGaps()

Specified by:

findDataGaps in interface IDataService

findMaxDataEventDataId

public long findMaxDataEventDataId()

insertDataGap

public void insertDataGap(DataGap gap)

Specified by:

insertDataGap in interface IDataService

insertDataGap

public void insertDataGap(org.jumpmind.db.sql.ISqlTransaction transaction,
                          DataGap gap)

Specified by:

insertDataGap in interface IDataService

insertDataGaps

public void insertDataGaps(org.jumpmind.db.sql.ISqlTransaction transaction,
                           java.util.Collection<DataGap> gaps)

Specified by:

insertDataGaps in interface IDataService

deleteDataGap

public void deleteDataGap(DataGap gap)

Specified by:

deleteDataGap in interface IDataService

deleteDataGap

public void deleteDataGap(org.jumpmind.db.sql.ISqlTransaction transaction,
                          DataGap gap)

Specified by:

deleteDataGap in interface IDataService

deleteDataGaps

public void deleteDataGaps(org.jumpmind.db.sql.ISqlTransaction transaction,
                           java.util.Collection<DataGap> gaps)

Specified by:

deleteDataGaps in interface IDataService

deleteAllDataGaps

public void deleteAllDataGaps(org.jumpmind.db.sql.ISqlTransaction transaction)

Specified by:

deleteAllDataGaps in interface IDataService

findCreateTimeOfEvent

public java.util.Date findCreateTimeOfEvent(long dataId)

Specified by:

findCreateTimeOfEvent in interface IDataService

findCreateTimeOfData

public java.util.Date findCreateTimeOfData(long dataId)

Specified by:

findCreateTimeOfData in interface IDataService

findNextCreateTimeOfDataStartingAt

public java.util.Date findNextCreateTimeOfDataStartingAt(long dataId)

Specified by:

findNextCreateTimeOfDataStartingAt in interface IDataService

getHeartbeatListeners

protected java.util.List<IHeartbeatListener> getHeartbeatListeners(boolean force)

Get a list of IHeartbeatListeners that are ready for a heartbeat according to IHeartbeatListener.getTimeBetweenHeartbeatsInSeconds()

Parameters:

force - if true, then return the entire list of IHeartbeatListeners

updateLastHeartbeatTime

protected void updateLastHeartbeatTime(java.util.List<IHeartbeatListener> listeners)

heartbeat

public void heartbeat(boolean force)

Description copied from interface: IDataService

Update Node information for this node and call IHeartbeatListeners.

Specified by:

heartbeat in interface IDataService

See Also:

IDataService#heartbeat()

listDataIds

public java.util.List<java.lang.Number> listDataIds(long batchId,
                                                    java.lang.String nodeId)

Specified by:

listDataIds in interface IDataService

listData

public java.util.List<Data> listData(long batchId,
                                     java.lang.String nodeId,
                                     long startDataId,
                                     java.lang.String channelId,
                                     int maxRowsToRetrieve)

Specified by:

listData in interface IDataService

findData

public Data findData(long dataId)

Specified by:

findData in interface IDataService

getDataMapper

public org.jumpmind.db.sql.ISqlRowMapper<Data> getDataMapper()

Specified by:

getDataMapper in interface IDataService

selectDataFor

public org.jumpmind.db.sql.ISqlReadCursor<Data> selectDataFor(org.jumpmind.symmetric.io.data.Batch batch)

Specified by:

selectDataFor in interface IDataService

selectDataFor

public org.jumpmind.db.sql.ISqlReadCursor<Data> selectDataFor(java.lang.Long batchId,
                                                              java.lang.String targetNodeId,
                                                              boolean isContainsBigLob)

Specified by:

selectDataFor in interface IDataService

selectDataFor

public org.jumpmind.db.sql.ISqlReadCursor<Data> selectDataFor(java.lang.Long batchId,
                                                              java.lang.String channelId)

Specified by:

selectDataFor in interface IDataService

getDataSelectByBatchSql

protected java.lang.String getDataSelectByBatchSql(long batchId,
                                                   long startDataId,
                                                   java.lang.String channelId)

getDataSelectSql

protected java.lang.String getDataSelectSql(long batchId,
                                            long startDataId,
                                            java.lang.String channelId)

getDataSelectSql

protected java.lang.String getDataSelectSql(long batchId,
                                            long startDataId,
                                            boolean isContainsBigLob)

getDataOrderBy

protected java.lang.String getDataOrderBy()

findMaxDataId

public long findMaxDataId()

Specified by:

findMaxDataId in interface IDataService

findMinDataId

public long findMinDataId()

Specified by:

findMinDataId in interface IDataService

deleteCapturedConfigChannelData

public void deleteCapturedConfigChannelData()

Specified by:

deleteCapturedConfigChannelData in interface IDataService

getLastDataCaptureByChannel

public java.util.Map<java.lang.String,java.util.Date> getLastDataCaptureByChannel()

Specified by:

getLastDataCaptureByChannel in interface IDataService

fixLastDataGap

public boolean fixLastDataGap()

Specified by:

fixLastDataGap in interface IDataService

checkInterrupted

protected void checkInterrupted()
                         throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException