Package 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	Description
void	clearCache()
void	delete(DataLoaderService.ConflictNodeGroupLink settings)
void	deleteAllConflicts()
List<String>	getAvailableDataLoaderFactories()
List<DataLoaderService.ConflictNodeGroupLink>	getConflictSettingsNodeGroupLinks()
List<DataLoaderService.ConflictNodeGroupLink>	getConflictSettingsNodeGroupLinks(NodeGroupLink link, boolean refreshCache)
List<DataLoaderService.ConflictNodeGroupLink>	getConflictSettinsNodeGroupLinksFromDb(NodeGroupLink link)
IncomingError	getCurrentIncomingError(long batchId, String nodeId)
IncomingError	getIncomingError(long batchId, String nodeId, long rowNumber)
List<IncomingError>	getIncomingErrors(long batchId, String nodeId)
void	insertIncomingError(ISqlTransaction transaction, IncomingError incomingError)
void	insertIncomingError(IncomingError incomingError)
List<IncomingBatch>	loadDataBatch(String batchData)
List<IncomingBatch>	loadDataBatch(String batchData, IProcessInfoListener listener)
void	loadDataFromConfig(Node remote, RemoteNodeStatus status, boolean force)
List<IncomingBatch>	loadDataFromOfflineTransport(Node remote, RemoteNodeStatus status, IIncomingTransport transport)
RemoteNodeStatus	loadDataFromPull(Node remote, String channelId)
void	loadDataFromPull(Node sourceNode, RemoteNodeStatus status)
void	loadDataFromPush(Node sourceNode, InputStream in, OutputStream out)
void	loadDataFromPush(Node sourceNode, String channelId, InputStream in, OutputStream out)
List<IncomingBatch>	loadDataFromTransport(ProcessInfo processInfo, Node sourceNode, IIncomingTransport transport)
boolean	refreshFromDatabase()
void	rename(String oldId, DataLoaderService.ConflictNodeGroupLink settings)
void	save(DataLoaderService.ConflictNodeGroupLink settings)
void	saveAsCopy(DataLoaderService.ConflictNodeGroupLink settings)
void	updateIncomingError(IncomingError incomingError)

Method Details

refreshFromDatabase

boolean refreshFromDatabase()

loadDataFromPull

RemoteNodeStatus loadDataFromPull(Node remote,
 String channelId)
                           throws IOException

Throws:

IOException

loadDataFromPull

void loadDataFromPull(Node sourceNode,
 RemoteNodeStatus status)
               throws IOException

Throws:

IOException

loadDataFromPush

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

Throws:

IOException

loadDataFromPush

void loadDataFromPush(Node sourceNode,
 String channelId,
 InputStream in,
 OutputStream out)
               throws IOException

Throws:

IOException

loadDataFromTransport

List<IncomingBatch> loadDataFromTransport(ProcessInfo processInfo,
 Node sourceNode,
 IIncomingTransport transport)
                                   throws IOException

Throws:

IOException

loadDataFromOfflineTransport

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

Throws:

IOException

loadDataFromConfig

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

Throws:

IOException

getAvailableDataLoaderFactories

List<String> getAvailableDataLoaderFactories()

loadDataBatch

List<IncomingBatch> loadDataBatch(String batchData)

loadDataBatch

List<IncomingBatch> loadDataBatch(String batchData,
 IProcessInfoListener listener)

getConflictSettingsNodeGroupLinks

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

getConflictSettinsNodeGroupLinksFromDb

List<DataLoaderService.ConflictNodeGroupLink> getConflictSettinsNodeGroupLinksFromDb(NodeGroupLink link)

getConflictSettingsNodeGroupLinks

List<DataLoaderService.ConflictNodeGroupLink> getConflictSettingsNodeGroupLinks()

delete

void delete(DataLoaderService.ConflictNodeGroupLink settings)

deleteAllConflicts

void deleteAllConflicts()

save

void save(DataLoaderService.ConflictNodeGroupLink settings)

saveAsCopy

void saveAsCopy(DataLoaderService.ConflictNodeGroupLink settings)

rename

void rename(String oldId,
 DataLoaderService.ConflictNodeGroupLink settings)

clearCache

void clearCache()

getIncomingErrors

List<IncomingError> getIncomingErrors(long batchId,
 String nodeId)

getIncomingError

IncomingError getIncomingError(long batchId,
 String nodeId,
 long rowNumber)

getCurrentIncomingError

IncomingError getCurrentIncomingError(long batchId,
 String nodeId)

insertIncomingError

void insertIncomingError(ISqlTransaction transaction,
 IncomingError incomingError)

insertIncomingError

void insertIncomingError(IncomingError incomingError)

updateIncomingError

void updateIncomingError(IncomingError incomingError)