public class DataLoaderService extends AbstractService implements IDataLoaderService
IDataLoaderService| Modifier and Type | Class and Description |
|---|---|
static class |
DataLoaderService.ConflictNodeGroupLink |
log, parameterService, platform, sqlTemplate, sqlTemplateDirty, symmetricDialect, tablePrefix| Constructor and Description |
|---|
DataLoaderService(ISymmetricEngine engine) |
| Modifier and Type | Method and Description |
|---|---|
protected org.jumpmind.symmetric.io.data.IDataWriter |
buildDataWriter(ProcessInfo processInfo,
java.lang.String sourceNodeId,
java.lang.String channelId,
long batchId,
boolean isRetry) |
void |
clearCache() |
void |
delete(DataLoaderService.ConflictNodeGroupLink settings) |
void |
deleteAllConflicts() |
static java.lang.String |
filterDataLoaderType(java.lang.String dataLoaderType) |
java.util.List<java.lang.String> |
getAvailableDataLoaderFactories() |
java.util.List<DataLoaderService.ConflictNodeGroupLink> |
getConflictSettingsNodeGroupLinks() |
java.util.List<DataLoaderService.ConflictNodeGroupLink> |
getConflictSettingsNodeGroupLinks(NodeGroupLink link,
boolean refreshCache) |
IncomingError |
getCurrentIncomingError(long batchId,
java.lang.String nodeId) |
protected java.util.Map<java.lang.String,IDataLoaderFactory> |
getDataLoaderFactories() |
protected IDataLoaderFactory |
getFactory(java.lang.String channelId) |
java.util.List<IncomingError> |
getIncomingErrors(long batchId,
java.lang.String nodeId) |
void |
insertIncomingError(IncomingError incomingError) |
void |
insertIncomingError(org.jumpmind.db.sql.ISqlTransaction transaction,
IncomingError incomingError) |
java.util.List<IncomingBatch> |
loadDataBatch(java.lang.String batchData) |
void |
loadDataFromConfig(Node remote,
RemoteNodeStatus status,
boolean force) |
java.util.List<IncomingBatch> |
loadDataFromOfflineTransport(Node remote,
RemoteNodeStatus status,
IIncomingTransport transport) |
void |
loadDataFromPull(Node remote,
RemoteNodeStatus status) |
RemoteNodeStatus |
loadDataFromPull(Node remote,
java.lang.String queue)
Connect to the remote node and pull data.
|
void |
loadDataFromPush(Node sourceNode,
java.io.InputStream in,
java.io.OutputStream out)
Load database from input stream and write acknowledgment to output
stream.
|
void |
loadDataFromPush(Node sourceNode,
java.lang.String queue,
java.io.InputStream in,
java.io.OutputStream out)
Load database from input stream and write acknowledgment to output
stream.
|
protected java.util.List<IncomingBatch> |
loadDataFromTransport(ProcessInfo transferInfo,
Node sourceNode,
IIncomingTransport transport,
java.io.OutputStream out)
Load database from input stream and return a list of batch statuses.
|
protected void |
logOrRethrow(java.lang.Throwable ex) |
protected void |
purgeLoadBatchesFromStaging(java.util.List<IncomingBatch> batchList) |
boolean |
refreshFromDatabase() |
void |
save(DataLoaderService.ConflictNodeGroupLink setting) |
protected void |
setTransportManager(ITransportManager transportManager)
Used for unit tests
|
protected void |
updateBatchToSendCount(Node remote,
IIncomingTransport transport) |
void |
updateIncomingError(IncomingError incomingError) |
assertNotNull, buildBatchWhere, close, createSqlReplacementTokens, createSqlReplacementTokens, getJdbcTemplate, getParameterService, getSql, getSymmetricDialect, getTablePrefix, getTargetDialect, getTargetPlatform, getTargetPlatform, isCalledFromSymmetricAdminTool, isSet, isStreamClosedByClient, isSymmetricTable, logOnce, maxDate, readAcks, sendAck, setSqlMap, synchronize, toNodeIds, toNodeIdspublic DataLoaderService(ISymmetricEngine engine)
public boolean refreshFromDatabase()
refreshFromDatabase in interface IDataLoaderServicepublic java.util.List<java.lang.String> getAvailableDataLoaderFactories()
getAvailableDataLoaderFactories in interface IDataLoaderServiceprotected java.util.Map<java.lang.String,IDataLoaderFactory> getDataLoaderFactories()
public java.util.List<IncomingBatch> loadDataBatch(java.lang.String batchData)
loadDataBatch in interface IDataLoaderServicepublic RemoteNodeStatus loadDataFromPull(Node remote, java.lang.String queue) throws java.io.IOException
loadDataFromPull in interface IDataLoaderServicejava.io.IOExceptionpublic void loadDataFromPull(Node remote, RemoteNodeStatus status) throws java.io.IOException
loadDataFromPull in interface IDataLoaderServicejava.io.IOExceptionprotected void updateBatchToSendCount(Node remote, IIncomingTransport transport)
public void loadDataFromPush(Node sourceNode, java.io.InputStream in, java.io.OutputStream out) throws java.io.IOException
loadDataFromPush in interface IDataLoaderServicejava.io.IOExceptionpublic void loadDataFromPush(Node sourceNode, java.lang.String queue, java.io.InputStream in, java.io.OutputStream out) throws java.io.IOException
loadDataFromPush in interface IDataLoaderServicejava.io.IOExceptionprotected void purgeLoadBatchesFromStaging(java.util.List<IncomingBatch> batchList)
public java.util.List<IncomingBatch> loadDataFromOfflineTransport(Node remote, RemoteNodeStatus status, IIncomingTransport transport) throws java.io.IOException
loadDataFromOfflineTransport in interface IDataLoaderServicejava.io.IOExceptionpublic void loadDataFromConfig(Node remote, RemoteNodeStatus status, boolean force) throws java.io.IOException
loadDataFromConfig in interface IDataLoaderServicejava.io.IOExceptionprotected java.util.List<IncomingBatch> loadDataFromTransport(ProcessInfo transferInfo, Node sourceNode, IIncomingTransport transport, java.io.OutputStream out) throws java.io.IOException
java.io.IOExceptionprotected void logOrRethrow(java.lang.Throwable ex)
throws java.io.IOException
java.io.IOExceptionprotected org.jumpmind.symmetric.io.data.IDataWriter buildDataWriter(ProcessInfo processInfo, java.lang.String sourceNodeId, java.lang.String channelId, long batchId, boolean isRetry)
protected IDataLoaderFactory getFactory(java.lang.String channelId)
public java.util.List<DataLoaderService.ConflictNodeGroupLink> getConflictSettingsNodeGroupLinks()
getConflictSettingsNodeGroupLinks in interface IDataLoaderServicepublic void clearCache()
clearCache in interface IDataLoaderServicepublic java.util.List<DataLoaderService.ConflictNodeGroupLink> getConflictSettingsNodeGroupLinks(NodeGroupLink link, boolean refreshCache)
getConflictSettingsNodeGroupLinks in interface IDataLoaderServicepublic void delete(DataLoaderService.ConflictNodeGroupLink settings)
delete in interface IDataLoaderServicepublic void deleteAllConflicts()
deleteAllConflicts in interface IDataLoaderServicepublic void save(DataLoaderService.ConflictNodeGroupLink setting)
save in interface IDataLoaderServicepublic java.util.List<IncomingError> getIncomingErrors(long batchId, java.lang.String nodeId)
getIncomingErrors in interface IDataLoaderServicepublic IncomingError getCurrentIncomingError(long batchId, java.lang.String nodeId)
getCurrentIncomingError in interface IDataLoaderServicepublic void insertIncomingError(IncomingError incomingError)
insertIncomingError in interface IDataLoaderServicepublic void insertIncomingError(org.jumpmind.db.sql.ISqlTransaction transaction,
IncomingError incomingError)
insertIncomingError in interface IDataLoaderServicepublic void updateIncomingError(IncomingError incomingError)
updateIncomingError in interface IDataLoaderServiceprotected void setTransportManager(ITransportManager transportManager)
public static java.lang.String filterDataLoaderType(java.lang.String dataLoaderType)