org.jumpmind.symmetric.ext
Class AbstractTableDataLoaderFilter

java.lang.Object
  org.jumpmind.symmetric.ext.AbstractTableDataLoaderFilter

All Implemented Interfaces:

IExtensionPoint, INodeGroupExtensionPoint, IDataLoaderFilter, INodeGroupDataLoaderFilter

public abstract class AbstractTableDataLoaderFilter
extends java.lang.Object
implements INodeGroupDataLoaderFilter

Constructor Summary

AbstractTableDataLoaderFilter()

Method Summary

boolean	filterDelete(IDataLoaderContext context, java.lang.String[] keyValues)
protected abstract void	filterDeleteForTable(IDataLoaderContext context, java.lang.String[] keyValues)
boolean	filterInsert(IDataLoaderContext context, java.lang.String[] columnValues)
protected abstract void	filterInsertForTable(IDataLoaderContext context, java.lang.String[] columnValues)
boolean	filterUpdate(IDataLoaderContext context, java.lang.String[] columnValues, java.lang.String[] keyValues)
protected abstract void	filterUpdateForTable(IDataLoaderContext context, java.lang.String[] columnValues, java.lang.String[] keyValues)
java.lang.String[]	getNodeGroupIdsToApplyTo()
boolean	isAutoRegister() Allow the plug-in implementation to specific whether the SymmetricDS runtime should auto register it or if it will register itself.
void	setAutoRegister(boolean autoRegister)
void	setLoadDataInTargetDatabase(boolean loadDataInTargetDatabase)
void	setNodeGroupIdsToApplyTo(java.lang.String[] nodeGroupIdsToApplyTo)
void	setNodeGroupIdToApplyTo(java.lang.String nodeGroupId)
void	setTableName(java.lang.String tableName)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AbstractTableDataLoaderFilter

public AbstractTableDataLoaderFilter()

Method Detail

filterDelete

public boolean filterDelete(IDataLoaderContext context,
                            java.lang.String[] keyValues)

Specified by:

filterDelete in interface IDataLoaderFilter

Returns:

true if the row should be loaded. false if the filter has handled the row and it should be ignored.

filterDeleteForTable

protected abstract void filterDeleteForTable(IDataLoaderContext context,
                                             java.lang.String[] keyValues)

filterInsert

public boolean filterInsert(IDataLoaderContext context,
                            java.lang.String[] columnValues)

Specified by:

filterInsert in interface IDataLoaderFilter

Returns:

true if the row should be loaded. false if the filter has handled the row and it should be ignored.

filterInsertForTable

protected abstract void filterInsertForTable(IDataLoaderContext context,
                                             java.lang.String[] columnValues)

filterUpdate

public boolean filterUpdate(IDataLoaderContext context,
                            java.lang.String[] columnValues,
                            java.lang.String[] keyValues)

Specified by:

filterUpdate in interface IDataLoaderFilter

Returns:

true if the row should be loaded. false if the filter has handled the row and it should be ignored.

filterUpdateForTable

protected abstract void filterUpdateForTable(IDataLoaderContext context,
                                             java.lang.String[] columnValues,
                                             java.lang.String[] keyValues)

isAutoRegister

public boolean isAutoRegister()

Description copied from interface: IExtensionPoint

Allow the plug-in implementation to specific whether the SymmetricDS runtime should auto register it or if it will register itself.

Specified by:

isAutoRegister in interface IExtensionPoint

getNodeGroupIdsToApplyTo

public java.lang.String[] getNodeGroupIdsToApplyTo()

Specified by:

getNodeGroupIdsToApplyTo in interface INodeGroupExtensionPoint

setAutoRegister

public void setAutoRegister(boolean autoRegister)

setNodeGroupIdsToApplyTo

public void setNodeGroupIdsToApplyTo(java.lang.String[] nodeGroupIdsToApplyTo)

setNodeGroupIdToApplyTo

public void setNodeGroupIdToApplyTo(java.lang.String nodeGroupId)

setLoadDataInTargetDatabase

public void setLoadDataInTargetDatabase(boolean loadDataInTargetDatabase)

setTableName

public void setTableName(java.lang.String tableName)