org.jumpmind.symmetric.service

Interface IDataLoaderService

All Known Implementing Classes:

DataLoaderService

public interface IDataLoaderService

This service provides an API to load data into a SymmetricDS node's database from a transport

Method Summary

Modifier and Type	Method and Description
void	clearCache()
void	delete(DataLoaderService.ConflictNodeGroupLink settings)
void	deleteAllConflicts()
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)
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 sourceNode, RemoteNodeStatus status)
RemoteNodeStatus	loadDataFromPull(Node remote, java.lang.String channelId)
void	loadDataFromPush(Node sourceNode, java.io.InputStream in, java.io.OutputStream out)
void	loadDataFromPush(Node sourceNode, java.lang.String channelId, java.io.InputStream in, java.io.OutputStream out)
boolean	refreshFromDatabase()
void	save(DataLoaderService.ConflictNodeGroupLink settings)
void	updateIncomingError(IncomingError incomingError)

Method Detail

refreshFromDatabase

boolean refreshFromDatabase()

loadDataFromPull

RemoteNodeStatus loadDataFromPull(Node remote,
                                  java.lang.String channelId)
                           throws java.io.IOException

Throws:

java.io.IOException

loadDataFromPull

void loadDataFromPull(Node sourceNode,
                      RemoteNodeStatus status)
               throws java.io.IOException

Throws:

java.io.IOException

loadDataFromPush

void loadDataFromPush(Node sourceNode,
                      java.io.InputStream in,
                      java.io.OutputStream out)
               throws java.io.IOException

Throws:

java.io.IOException

loadDataFromPush

void loadDataFromPush(Node sourceNode,
                      java.lang.String channelId,
                      java.io.InputStream in,
                      java.io.OutputStream out)
               throws java.io.IOException

Throws:

java.io.IOException

loadDataFromOfflineTransport

java.util.List<IncomingBatch> loadDataFromOfflineTransport(Node remote,
                                                           RemoteNodeStatus status,
                                                           IIncomingTransport transport)
                                                    throws java.io.IOException

Throws:

java.io.IOException

loadDataFromConfig

void loadDataFromConfig(Node remote,
                        RemoteNodeStatus status,
                        boolean force)
                 throws java.io.IOException

Throws:

java.io.IOException

getAvailableDataLoaderFactories

java.util.List<java.lang.String> getAvailableDataLoaderFactories()

loadDataBatch

java.util.List<IncomingBatch> loadDataBatch(java.lang.String batchData)

getConflictSettingsNodeGroupLinks

java.util.List<DataLoaderService.ConflictNodeGroupLink> getConflictSettingsNodeGroupLinks(NodeGroupLink link,
                                                                                          boolean refreshCache)

getConflictSettingsNodeGroupLinks

java.util.List<DataLoaderService.ConflictNodeGroupLink> getConflictSettingsNodeGroupLinks()

delete

void delete(DataLoaderService.ConflictNodeGroupLink settings)

deleteAllConflicts

void deleteAllConflicts()

save

void save(DataLoaderService.ConflictNodeGroupLink settings)

clearCache

void clearCache()

getIncomingErrors

java.util.List<IncomingError> getIncomingErrors(long batchId,
                                                java.lang.String nodeId)

getCurrentIncomingError

IncomingError getCurrentIncomingError(long batchId,
                                      java.lang.String nodeId)

insertIncomingError

void insertIncomingError(org.jumpmind.db.sql.ISqlTransaction transaction,
                         IncomingError incomingError)

insertIncomingError

void insertIncomingError(IncomingError incomingError)

updateIncomingError

void updateIncomingError(IncomingError incomingError)