org.jumpmind.symmetric.service

Interface IDataService

All Known Implementing Classes:

DataService

public interface IDataService

This service provides an API to access and update Data.

Method Summary

Modifier and Type	Method and Description
int	cancelTableReloadRequest(TableReloadRequest request)
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)
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)
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)
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	findMaxDataId()
long	findMinDataId()
java.util.Date	findNextCreateTimeOfDataStartingAt(long dataId)
boolean	fixLastDataGap()
java.util.List<TableReloadStatus>	getActiveTableReloadStatus()
org.jumpmind.db.sql.ISqlRowMapper<Data>	getDataMapper()
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>	getTableReloadRequestToProcess(java.lang.String sourceNodeId)
java.util.List<TableReloadStatus>	getTableReloadStatus()
TableReloadStatus	getTableReloadStatusByLoadId(long loadId)
java.util.List<TableReloadStatus>	getTableReloadStatusByTarget(java.lang.String targetNodeId)
void	heartbeat(boolean force) Update Node information for this node and call IHeartbeatListeners.
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)
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)
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)
boolean	insertReloadEvent(TableReloadRequest request, boolean deleteAtClient)
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)
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)
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)
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
int	updateTableReloadRequestsCancelled(long loadId)
void	updateTableReloadStatusDataLoaded(org.jumpmind.db.sql.ISqlTransaction transcation, long loadId, long batchId, int batchCount)

Method Detail

insertTableReloadRequest

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

insertTableReloadRequest

void insertTableReloadRequest(TableReloadRequest request)

getTableReloadRequest

TableReloadRequest getTableReloadRequest(TableReloadRequestKey key)

getTableReloadRequest

TableReloadRequest getTableReloadRequest(long loadId)

getTableReloadRequest

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

getTableReloadRequestToProcess

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

getTableReloadStatus

java.util.List<TableReloadStatus> getTableReloadStatus()

getActiveTableReloadStatus

java.util.List<TableReloadStatus> getActiveTableReloadStatus()

getTableReloadStatusByLoadId

TableReloadStatus getTableReloadStatusByLoadId(long loadId)

getTableReloadStatusByTarget

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

updateTableReloadStatusDataLoaded

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

updateTableReloadRequestsCancelled

int updateTableReloadRequestsCancelled(long loadId)

cancelTableReloadRequest

int cancelTableReloadRequest(TableReloadRequest request)

reloadNode

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

reloadTable

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

reloadTable

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

reloadTableImmediate

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)

reloadMissingForeignKeyRows

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

reloadMissingForeignKeyRowsReverse

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)

sendSQL

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

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

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

insertReloadEvents

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)

insertReloadEvent

boolean insertReloadEvent(TableReloadRequest request,
                          boolean deleteAtClient)

insertReloadEvent

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)

sendScript

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

sendSchema

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

heartbeat

void heartbeat(boolean force)

Update Node information for this node and call IHeartbeatListeners.

insertHeartbeatEvent

void insertHeartbeatEvent(Node node,
                          boolean isReload)

insertData

long insertData(Data data)

insertData

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

insertDataEvents

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

insertDataAndDataEventAndOutgoingBatch

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

insertDataAndDataEventAndOutgoingBatch

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)

insertDataAndDataEventAndOutgoingBatch

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

insertSqlEvent

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

insertSqlEvent

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)

insertSqlEvent

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

insertScriptEvent

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

insertScriptEvent

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)

insertCreateEvent

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

insertCreateEvent

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

insertCreateEvent

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

countDataInRange

int countDataInRange(long firstDataId,
                     long secondDataId)

Count the number of data ids in a range

countDataGaps

long countDataGaps()

findDataGapsUnchecked

java.util.List<DataGap> findDataGapsUnchecked()

findDataGaps

java.util.List<DataGap> findDataGaps()

findCreateTimeOfEvent

java.util.Date findCreateTimeOfEvent(long dataId)

findCreateTimeOfData

java.util.Date findCreateTimeOfData(long dataId)

findNextCreateTimeOfDataStartingAt

java.util.Date findNextCreateTimeOfDataStartingAt(long dataId)

createData

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

createData

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

createData

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

getDataMapper

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

listDataIds

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

listData

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

insertDataGap

void insertDataGap(DataGap gap)

insertDataGap

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

insertDataGaps

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

deleteDataGap

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

deleteDataGaps

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

deleteAllDataGaps

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

deleteDataGap

void deleteDataGap(DataGap gap)

deleteCapturedConfigChannelData

void deleteCapturedConfigChannelData()

fixLastDataGap

boolean fixLastDataGap()

findMaxDataId

long findMaxDataId()

findData

Data findData(long dataId)

findMinDataId

long findMinDataId()

selectDataFor

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

selectDataFor

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

selectDataFor

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

getLastDataCaptureByChannel

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