org.jumpmind.symmetric.io.data.transform

Class VariableColumnTransform

java.lang.Object

org.jumpmind.symmetric.io.data.transform.VariableColumnTransform

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 VariableColumnTransform
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 static java.lang.String	DATE_PATTERN
static java.lang.String	NAME
protected static java.lang.String	OPTION_BATCH_ID
protected static java.lang.String	OPTION_BATCH_START_TIME
protected static java.lang.String	OPTION_DATE
protected static java.lang.String	OPTION_DELETE_INDICATOR_FLAG
protected static java.lang.String	OPTION_NULL
protected static java.lang.String	OPTION_OLD_VALUE
protected static java.lang.String	OPTION_SOURCE_CATALOG_NAME
protected static java.lang.String	OPTION_SOURCE_DML_TYPE
protected static java.lang.String	OPTION_SOURCE_NODE_ID
protected static java.lang.String	OPTION_SOURCE_SCHEMA_NAME
protected static java.lang.String	OPTION_SOURCE_TABLE_NAME
protected static java.lang.String	OPTION_TARGET_NODE_ID
protected static java.lang.String	OPTION_TIMESTAMP
protected static java.lang.String	OPTION_TIMESTAMP_UTC
protected static java.lang.String	TS_PATTERN

Constructor Summary

Constructors

Constructor and Description
VariableColumnTransform()

Method Summary

Modifier and Type	Method and Description
java.lang.String	getName()
static java.lang.String[]	getOptions()
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

NAME

public static final java.lang.String NAME

See Also:

Constant Field Values

TS_PATTERN

protected static final java.lang.String TS_PATTERN

See Also:

Constant Field Values

DATE_PATTERN

protected static final java.lang.String DATE_PATTERN

See Also:

Constant Field Values

OPTION_TIMESTAMP

protected static final java.lang.String OPTION_TIMESTAMP

See Also:

Constant Field Values

OPTION_TIMESTAMP_UTC

protected static final java.lang.String OPTION_TIMESTAMP_UTC

See Also:

Constant Field Values

OPTION_DATE

protected static final java.lang.String OPTION_DATE

See Also:

Constant Field Values

OPTION_SOURCE_NODE_ID

protected static final java.lang.String OPTION_SOURCE_NODE_ID

See Also:

Constant Field Values

OPTION_TARGET_NODE_ID

protected static final java.lang.String OPTION_TARGET_NODE_ID

See Also:

Constant Field Values

OPTION_NULL

protected static final java.lang.String OPTION_NULL

See Also:

Constant Field Values

OPTION_OLD_VALUE

protected static final java.lang.String OPTION_OLD_VALUE

See Also:

Constant Field Values

OPTION_SOURCE_TABLE_NAME

protected static final java.lang.String OPTION_SOURCE_TABLE_NAME

See Also:

Constant Field Values

OPTION_SOURCE_CATALOG_NAME

protected static final java.lang.String OPTION_SOURCE_CATALOG_NAME

See Also:

Constant Field Values

OPTION_SOURCE_SCHEMA_NAME

protected static final java.lang.String OPTION_SOURCE_SCHEMA_NAME

See Also:

Constant Field Values

OPTION_SOURCE_DML_TYPE

protected static final java.lang.String OPTION_SOURCE_DML_TYPE

See Also:

Constant Field Values

OPTION_BATCH_ID

protected static final java.lang.String OPTION_BATCH_ID

See Also:

Constant Field Values

OPTION_BATCH_START_TIME

protected static final java.lang.String OPTION_BATCH_START_TIME

See Also:

Constant Field Values

OPTION_DELETE_INDICATOR_FLAG

protected static final java.lang.String OPTION_DELETE_INDICATOR_FLAG

See Also:

Constant Field Values

Constructor Detail

VariableColumnTransform

public VariableColumnTransform()

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>

getOptions

public static java.lang.String[] getOptions()

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