org.jumpmind.symmetric.io.data.transform

Class LookupColumnTransform

java.lang.Object

org.jumpmind.symmetric.io.data.transform.LookupColumnTransform

All Implemented Interfaces:

org.jumpmind.extension.IBuiltInExtensionPoint, org.jumpmind.extension.IExtensionPoint, org.jumpmind.symmetric.io.data.transform.IColumnTransform<org.jumpmind.symmetric.io.data.transform.NewAndOldValue>, org.jumpmind.symmetric.io.data.transform.ISingleNewAndOldValueColumnTransform

public class LookupColumnTransform
extends java.lang.Object
implements org.jumpmind.symmetric.io.data.transform.ISingleNewAndOldValueColumnTransform, org.jumpmind.extension.IBuiltInExtensionPoint

Field Summary

Fields

Modifier and Type	Field and Description
protected org.slf4j.Logger	log
protected static org.jumpmind.db.sql.mapper.StringMapper	lookupColumnRowMapper
static java.lang.String	NAME

Constructor Summary

Constructors

Constructor and Description
LookupColumnTransform()

Method Summary

Modifier and Type	Method and Description
protected java.lang.String	doTokenReplacementOnSql(org.jumpmind.symmetric.io.data.DataContext context, java.lang.String sql)
java.lang.String	getName()
boolean	isExtractColumnTransform()
boolean	isLoadColumnTransform()
org.jumpmind.symmetric.io.data.transform.NewAndOldValue	transform(org.jumpmind.db.platform.IDatabasePlatform platform, org.jumpmind.symmetric.io.data.DataContext context, org.jumpmind.symmetric.io.data.transform.TransformColumn column, org.jumpmind.symmetric.io.data.transform.TransformedData data, java.util.Map<java.lang.String,java.lang.String> sourceValues, java.lang.String newValue, java.lang.String oldValue)

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

NAME

public static final java.lang.String NAME

See Also:

Constant Field Values

lookupColumnRowMapper

protected static final org.jumpmind.db.sql.mapper.StringMapper lookupColumnRowMapper

Constructor Detail

LookupColumnTransform

public LookupColumnTransform()

Method Detail

getName

public java.lang.String getName()

isExtractColumnTransform

public boolean isExtractColumnTransform()

Specified by:

isExtractColumnTransform in interface org.jumpmind.symmetric.io.data.transform.IColumnTransform<org.jumpmind.symmetric.io.data.transform.NewAndOldValue>

isLoadColumnTransform

public boolean isLoadColumnTransform()

Specified by:

isLoadColumnTransform in interface org.jumpmind.symmetric.io.data.transform.IColumnTransform<org.jumpmind.symmetric.io.data.transform.NewAndOldValue>

transform

public org.jumpmind.symmetric.io.data.transform.NewAndOldValue transform(org.jumpmind.db.platform.IDatabasePlatform platform,
                                                                         org.jumpmind.symmetric.io.data.DataContext context,
                                                                         org.jumpmind.symmetric.io.data.transform.TransformColumn column,
                                                                         org.jumpmind.symmetric.io.data.transform.TransformedData data,
                                                                         java.util.Map<java.lang.String,java.lang.String> sourceValues,
                                                                         java.lang.String newValue,
                                                                         java.lang.String oldValue)
                                                                  throws org.jumpmind.symmetric.io.data.transform.IgnoreColumnException,
                                                                         org.jumpmind.symmetric.io.data.transform.IgnoreRowException

Specified by:

transform in interface org.jumpmind.symmetric.io.data.transform.IColumnTransform<org.jumpmind.symmetric.io.data.transform.NewAndOldValue>

Throws:

org.jumpmind.symmetric.io.data.transform.IgnoreColumnException

org.jumpmind.symmetric.io.data.transform.IgnoreRowException

doTokenReplacementOnSql

protected java.lang.String doTokenReplacementOnSql(org.jumpmind.symmetric.io.data.DataContext context,
                                                   java.lang.String sql)