org.jumpmind.symmetric.load

Class DefaultDataLoaderFactory

java.lang.Object

org.jumpmind.symmetric.load.AbstractDataLoaderFactory

org.jumpmind.symmetric.load.DefaultDataLoaderFactory

All Implemented Interfaces:

org.jumpmind.extension.IBuiltInExtensionPoint, org.jumpmind.extension.IExtensionPoint, ISymmetricEngineAware, IDataLoaderFactory

public class DefaultDataLoaderFactory
extends AbstractDataLoaderFactory
implements IDataLoaderFactory, org.jumpmind.extension.IBuiltInExtensionPoint, ISymmetricEngineAware

Field Summary

Fields

Modifier and Type	Field and Description
protected ISymmetricEngine	engine
protected org.slf4j.Logger	log

Fields inherited from class org.jumpmind.symmetric.load.AbstractDataLoaderFactory

parameterService

Constructor Summary

Constructors

Constructor and Description
DefaultDataLoaderFactory()
DefaultDataLoaderFactory(ISymmetricEngine engine)

Method Summary

Modifier and Type	Method and Description
protected org.jumpmind.symmetric.io.data.writer.DatabaseWriterSettings	buildDatabaseWriterSettings(java.util.List<org.jumpmind.symmetric.io.data.writer.IDatabaseWriterFilter> filters, java.util.List<org.jumpmind.symmetric.io.data.writer.IDatabaseWriterErrorHandler> errorHandlers, java.util.List<? extends org.jumpmind.symmetric.io.data.writer.Conflict> conflictSettings, java.util.List<org.jumpmind.symmetric.io.data.writer.ResolvedData> resolvedDatas)
org.jumpmind.symmetric.io.data.IDataWriter	getDataWriter(java.lang.String sourceNodeId, ISymmetricDialect symmetricDialect, org.jumpmind.symmetric.io.data.writer.TransformWriter transformWriter, java.util.List<org.jumpmind.symmetric.io.data.writer.IDatabaseWriterFilter> filters, java.util.List<org.jumpmind.symmetric.io.data.writer.IDatabaseWriterErrorHandler> errorHandlers, java.util.List<? extends org.jumpmind.symmetric.io.data.writer.Conflict> conflictSettings, java.util.List<org.jumpmind.symmetric.io.data.writer.ResolvedData> resolvedData)
java.lang.String	getTypeName()
boolean	isPlatformSupported(org.jumpmind.db.platform.IDatabasePlatform platform)
void	setSymmetricEngine(ISymmetricEngine engine)

Methods inherited from class org.jumpmind.symmetric.load.AbstractDataLoaderFactory

buildParameterDatabaseWritterSettings

Methods inherited from class java.lang.Object

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

Field Detail

log

protected final org.slf4j.Logger log

engine

protected ISymmetricEngine engine

Constructor Detail

DefaultDataLoaderFactory

public DefaultDataLoaderFactory()

DefaultDataLoaderFactory

public DefaultDataLoaderFactory(ISymmetricEngine engine)

Method Detail

getTypeName

public java.lang.String getTypeName()

Specified by:

getTypeName in interface IDataLoaderFactory

getDataWriter

public org.jumpmind.symmetric.io.data.IDataWriter getDataWriter(java.lang.String sourceNodeId,
                                                                ISymmetricDialect symmetricDialect,
                                                                org.jumpmind.symmetric.io.data.writer.TransformWriter transformWriter,
                                                                java.util.List<org.jumpmind.symmetric.io.data.writer.IDatabaseWriterFilter> filters,
                                                                java.util.List<org.jumpmind.symmetric.io.data.writer.IDatabaseWriterErrorHandler> errorHandlers,
                                                                java.util.List<? extends org.jumpmind.symmetric.io.data.writer.Conflict> conflictSettings,
                                                                java.util.List<org.jumpmind.symmetric.io.data.writer.ResolvedData> resolvedData)

Specified by:

getDataWriter in interface IDataLoaderFactory

isPlatformSupported

public boolean isPlatformSupported(org.jumpmind.db.platform.IDatabasePlatform platform)

Specified by:

isPlatformSupported in interface IDataLoaderFactory

buildDatabaseWriterSettings

protected org.jumpmind.symmetric.io.data.writer.DatabaseWriterSettings buildDatabaseWriterSettings(java.util.List<org.jumpmind.symmetric.io.data.writer.IDatabaseWriterFilter> filters,
                                                                                                   java.util.List<org.jumpmind.symmetric.io.data.writer.IDatabaseWriterErrorHandler> errorHandlers,
                                                                                                   java.util.List<? extends org.jumpmind.symmetric.io.data.writer.Conflict> conflictSettings,
                                                                                                   java.util.List<org.jumpmind.symmetric.io.data.writer.ResolvedData> resolvedDatas)

setSymmetricEngine

public void setSymmetricEngine(ISymmetricEngine engine)

Specified by:

setSymmetricEngine in interface ISymmetricEngineAware