Package 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 Details

    • insertTableReloadRequest

      void insertTableReloadRequest(ISqlTransaction transaction, TableReloadRequest request)

    • insertTableReloadRequest

      void insertTableReloadRequest(TableReloadRequest request)

    • getTableReloadRequest

      TableReloadRequest getTableReloadRequest(TableReloadRequestKey key)

    • getTableReloadRequest

      TableReloadRequest getTableReloadRequest(long loadId)

    • getTableReloadRequests

      List<TableReloadRequest> getTableReloadRequests(long loadId)

    • getTableReloadRequest

      TableReloadRequest getTableReloadRequest(long loadId, String triggerId, String routerId)

    • getTableReloadRequestToProcess

      List<TableReloadRequest> getTableReloadRequestToProcess(String sourceNodeId)

    • getTableReloadRequestToProcessByTarget

      List<TableReloadRequest> getTableReloadRequestToProcessByTarget(String targetNodeId)

    • getTableReloadRequestByLoadIdMap

      Map<Long,List<TableReloadRequest>> getTableReloadRequestByLoadIdMap()

    • getTableReloadStatus

      List<TableReloadStatus> getTableReloadStatus()

    • getOutgoingTableReloadStatus

      List<TableReloadStatus> getOutgoingTableReloadStatus()

    • getIncomingTableReloadStatus

      List<TableReloadStatus> getIncomingTableReloadStatus()

    • getActiveTableReloadStatus

      List<TableReloadStatus> getActiveTableReloadStatus()

    • getActiveOutgoingTableReloadStatus

      List<TableReloadStatus> getActiveOutgoingTableReloadStatus()

    • getActiveIncomingTableReloadStatus

      List<TableReloadStatus> getActiveIncomingTableReloadStatus()

    • getTableReloadStatusByLoadIdAndSourceNodeId

      TableReloadStatus getTableReloadStatusByLoadIdAndSourceNodeId(long loadId, String sourceNodeId)

    • getTableReloadStatusByTarget

      List<TableReloadStatus> getTableReloadStatusByTarget(String targetNodeId)

    • updateTableReloadStatusDataLoaded

      TableReloadStatus updateTableReloadStatusDataLoaded(ISqlTransaction transcation, long loadId, String sourceNodeId, long batchId, int batchCount, boolean isBulkLoaded)

    • updateTableReloadStatusFailed

      void updateTableReloadStatusFailed(ISqlTransaction transaction, long loadId, String sourceNodeId, long batchId)

    • updateTableReloadRequestsCancelled

      int updateTableReloadRequestsCancelled(long loadId, String sourceNodeId)

    • cancelTableReloadRequest

      int cancelTableReloadRequest(TableReloadRequest request)

    • reloadNode

      String reloadNode(String nodeId, boolean reverseLoad, String createBy)

    • reloadTable

      String reloadTable(String nodeId, String catalogName, String schemaName, String tableName)

    • reloadTable

      String reloadTable(String nodeId, String catalogName, String schemaName, String tableName, String overrideInitialLoadSelect)

    • reloadTableImmediate

      String reloadTableImmediate(String nodeId, String catalogName, String schemaName, String tableName, String overrideInitialLoadSelect, String overrideChannelId)

    • reloadMissingForeignKeyRows

      void reloadMissingForeignKeyRows(long batchId, String nodeId, long dataId, long rowNumber)

    • reloadMissingForeignKeyRowsForLoad

      void reloadMissingForeignKeyRowsForLoad(String sourceNodeId, long batchId, long rowNumber, Table table, CsvData data, String channelId)

    • reloadMissingForeignKeyRowsReverse

      void reloadMissingForeignKeyRowsReverse(String sourceNodeId, Table table, CsvData data, String channelId, boolean sendCorrectionToPeers)

    • sendNewerDataToNode

      void sendNewerDataToNode(ISqlTransaction transaction, String targetNodeId, String tableName, String pkCsvData, Date minCreateTime, String winningNodeId)

    • sendSQL

      String sendSQL(String nodeId, String catalogName, String schemaName, String tableName, 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

      String sendSQL(String nodeId, String sql)

    • insertReloadEvents

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

    • insertReloadEvent

      long insertReloadEvent(ISqlTransaction transaction, Node targetNode, TriggerRouter triggerRouter, TriggerHistory triggerHistory, String overrideInitialLoadSelect, boolean isLoad, long loadId, String createBy, AbstractBatch.Status status, long estimatedBatchRowCount)

    • sendScript

      void sendScript(String nodeId, String script, boolean isLoad)

    • sendSchema

      boolean sendSchema(String nodeId, String catalogName, String schemaName, String tableName, boolean isLoad, boolean excludeIndices, boolean excludeForeignKeys, boolean excludeDefaults)

    • 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(ISqlTransaction transaction, Data data)

    • insertDataEvents

      void insertDataEvents(ISqlTransaction transaction, List<DataEvent> events)

    • insertDataAndDataEventAndOutgoingBatch

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

    • insertDataAndDataEventAndOutgoingBatch

      long insertDataAndDataEventAndOutgoingBatch(ISqlTransaction transaction, Data data, String nodeId, boolean isLoad, long loadId, String createBy, AbstractBatch.Status status, long estimatedBatchRowCount)

    • insertDataAndDataEventAndOutgoingBatch

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

    • insertSqlEvent

      void insertSqlEvent(ISqlTransaction transaction, Node targetNode, String sql, boolean isLoad, long loadId, String createBy)

    • insertSqlEvent

      void insertSqlEvent(ISqlTransaction transaction, TriggerHistory history, String channelId, Node targetNode, String sql, boolean isLoad, long loadId, String createBy)

    • insertSqlEvent

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

    • insertScriptEvent

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

    • insertScriptEvent

      void insertScriptEvent(ISqlTransaction transaction, String channelId, Node targetNode, String script, boolean isLoad, long loadId, String createBy)

    • insertCreateEvent

      void insertCreateEvent(Node targetNode, TriggerHistory triggerHistory, String createBy, boolean excludeIndices, boolean excludeForeignKeys, boolean excludeDefaults)

    • insertCreateEvent

      void insertCreateEvent(Node targetNode, TriggerHistory triggerHistory, boolean isLoad, long loadId, String createBy, boolean excludeIndices, boolean excludeForeignKeys, boolean excludeDefaults)

    • insertCreateEvent

      void insertCreateEvent(ISqlTransaction transaction, Node targetNode, TriggerHistory triggerHistory, String channelId, boolean isLoad, long loadId, String createBy, boolean excludeIndices, boolean excludeForeignKeys, boolean excludeDefaults)

    • countDataInRange

      int countDataInRange(long firstDataId, long secondDataId)
      Count the number of data ids in a range

    • countData

      int countData()

    • countDataGaps

      long countDataGaps()

    • findDataGapsUnchecked

      List<DataGap> findDataGapsUnchecked()

    • findDataGapsExpired

      List<DataGap> findDataGapsExpired()

    • findDataGaps

      List<DataGap> findDataGaps()

    • findCreateTimeOfEvent

      Date findCreateTimeOfEvent(long dataId)

    • findCreateTimeOfData

      Date findCreateTimeOfData(long dataId)

    • findNextCreateTimeOfDataStartingAt

      Date findNextCreateTimeOfDataStartingAt(long dataId)

    • createData

      Data createData(String catalogName, String schemaName, String tableName)

    • createData

      Data createData(String catalogName, String schemaName, String tableName, String whereClause)

    • createData

      Data createData(ISqlTransaction transaction, String catalogName, String schemaName, String tableName, String whereClause)

    • getDataMapper

      ISqlRowMapper<Data> getDataMapper()

    • listDataIds

      List<Number> listDataIds(long batchId, String nodeId)

    • listData

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

    • insertDataGap

      void insertDataGap(DataGap gap)

    • insertDataGap

      void insertDataGap(ISqlTransaction transaction, DataGap gap)

    • insertDataGaps

      void insertDataGaps(ISqlTransaction transaction, Collection<DataGap> gaps)

    • deleteDataGap

      void deleteDataGap(ISqlTransaction transaction, DataGap gap)

    • deleteDataGaps

      void deleteDataGaps(ISqlTransaction transaction, Collection<DataGap> gaps)

    • deleteAllDataGaps

      void deleteAllDataGaps(ISqlTransaction transaction)

    • deleteDataGap

      void deleteDataGap(DataGap gap)

    • expireDataGaps

      void expireDataGaps(ISqlTransaction transaction, Collection<DataGap> gaps)

    • deleteCapturedConfigChannelData

      void deleteCapturedConfigChannelData()

    • fixLastDataGap

      boolean fixLastDataGap()

    • findMaxDataId

      long findMaxDataId()

    • findData

      Data findData(long dataId)

    • findMinDataId

      long findMinDataId()

    • selectDataFor

      ISqlReadCursor<Data> selectDataFor(Batch batch)

    • selectDataFor

      ISqlReadCursor<Data> selectDataFor(Long batchId, String channelId)

    • selectDataFor

      ISqlReadCursor<Data> selectDataFor(Long batchId, String targetNodeId, boolean isContainsBigLob)

    • getLastDataCaptureByChannel

      Map<String,Date> getLastDataCaptureByChannel()

    • findNodeIdsByNodeGroupId

      String findNodeIdsByNodeGroupId()

    • resendBatchAsReload

      int resendBatchAsReload(long batchId, String nodeId)

    • resendDataAsReload

      int resendDataAsReload(long minDataId, long maxDataId)

    • reCaptureData

      int reCaptureData(long minDataId, long maxDataId)