org.jumpmind.symmetric.service
Interface IDataLoaderService

All Known Implementing Classes:

DataLoaderService

public interface IDataLoaderService

Method Summary

void	addBatchListener(IBatchListener listener)
void	addColumnFilter(java.lang.String tableName, IColumnFilter filter)
void	addDataLoaderFilter(IDataLoaderFilter filter)
boolean	loadData(IIncomingTransport reader)
void	loadData(java.io.InputStream in, java.io.OutputStream out)
boolean	loadData(Node remote, Node local)
IDataLoaderStatistics	loadDataBatch(java.lang.String batchData) This is a convenience method for a client that might need to load CSV formatted data using SymmetricDS's IDataLoader.
IDataLoader	openDataLoader(java.io.BufferedReader reader)
void	removeDataLoaderFilter(IDataLoaderFilter filter)
void	setDataLoaderFilters(java.util.List<IDataLoaderFilter> filters)
void	setTransportManager(ITransportManager transportManager)

Method Detail

loadData

@Transactional
boolean loadData(Node remote,
                               Node local)
                 throws java.io.IOException

Throws:

java.io.IOException

loadData

@Transactional
boolean loadData(IIncomingTransport reader)

loadData

@Transactional
void loadData(java.io.InputStream in,
                            java.io.OutputStream out)
              throws java.io.IOException

Throws:

java.io.IOException

loadDataBatch

@Transactional
IDataLoaderStatistics loadDataBatch(java.lang.String batchData)
                                    throws java.io.IOException

This is a convenience method for a client that might need to load CSV formatted data using SymmetricDS's IDataLoader.

Parameters:

batchData - Data string formatted for the configured loader (the only supported data loader today is the CsvLoader)

Throws:

java.io.IOException

addDataLoaderFilter

void addDataLoaderFilter(IDataLoaderFilter filter)

setDataLoaderFilters

void setDataLoaderFilters(java.util.List<IDataLoaderFilter> filters)

removeDataLoaderFilter

void removeDataLoaderFilter(IDataLoaderFilter filter)

setTransportManager

void setTransportManager(ITransportManager transportManager)

addColumnFilter

void addColumnFilter(java.lang.String tableName,
                     IColumnFilter filter)

addBatchListener

void addBatchListener(IBatchListener listener)

openDataLoader

IDataLoader openDataLoader(java.io.BufferedReader reader)
                           throws java.io.IOException

Throws:

java.io.IOException