Package org.jumpmind.symmetric.io.data.writer

Class TransformWriter

java.lang.Object

org.jumpmind.symmetric.io.data.writer.NestedDataWriter

org.jumpmind.symmetric.io.data.writer.TransformWriter

All Implemented Interfaces:

IDataResource, IDataWriter

Direct Known Subclasses:

TransformDatabaseWriter

public class TransformWriter
extends NestedDataWriter

Field Summary

Fields

Modifier and Type	Field	Description
protected List<TransformTable>	activeTransforms
protected Batch	batch
protected Map<String,IColumnTransform<?>>	columnTransforms
protected Table	lastTransformedTable
protected IDatabasePlatform	platform
protected Table	sourceTable
protected TransformPoint	transformPoint
protected Map<String,List<TransformTable>>	transformsBySourceTable

Fields inherited from class org.jumpmind.symmetric.io.data.writer.NestedDataWriter

context, nestedWriter

Constructor Summary

Constructors

Constructor	Description
TransformWriter(IDatabasePlatform platform, TransformPoint transformPoint, IDataWriter targetWriter, Map<String,IColumnTransform<?>> columnTransforms, TransformTable... transforms)

Method Summary

Modifier and Type	Method	Description
protected void	callWriter(Table transformedTable, CsvData csvData)
protected List<TransformedData>	create(DataContext context, DataEventType dataEventType, TransformTable transformation, Map<String,String> sourceKeyValues, Map<String,String> oldSourceValues, Map<String,String> sourceValues)
void	end(Table table)
protected String[]	getTargetColumnNames(List<TransformColumn> columns)
protected boolean	isTransformable(DataEventType eventType)
protected boolean	perform(DataContext context, TransformedData data, TransformTable transformation, Map<String,String> sourceValues, Map<String,String> oldSourceValues)
boolean	start(Table table)
void	start(Batch batch)
protected final Map<String,List<TransformTable>>	toMap(TransformTable[] transforms)
protected List<TransformedData>	transform(DataEventType eventType, DataContext context, TransformTable transformation, Map<String,String> sourceKeyValues, Map<String,String> oldSourceValues, Map<String,String> sourceValues)
protected Object	transformColumn(DataContext context, TransformedData data, TransformColumn transformColumn, Map<String,String> sourceValues, Map<String,String> oldSourceValues)
void	write(CsvData data)

Methods inherited from class org.jumpmind.symmetric.io.data.writer.NestedDataWriter

close, end, getNestedWriter, getNestedWriterOfType, getStatistics, open, setNestedWriter

Methods inherited from class java.lang.Object

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

Field Details

transformPoint

protected TransformPoint transformPoint

platform

protected IDatabasePlatform platform

transformsBySourceTable

protected Map<String,List<TransformTable>> transformsBySourceTable

sourceTable

protected Table sourceTable

activeTransforms

protected List<TransformTable> activeTransforms

batch

protected Batch batch

columnTransforms

protected Map<String,IColumnTransform<?>> columnTransforms

lastTransformedTable

protected Table lastTransformedTable

Constructor Details

TransformWriter

public TransformWriter(IDatabasePlatform platform,
 TransformPoint transformPoint,
 IDataWriter targetWriter,
 Map<String,IColumnTransform<?>> columnTransforms,
 TransformTable... transforms)

Method Details

toMap

protected final Map<String,List<TransformTable>> toMap(TransformTable[] transforms)

start

public void start(Batch batch)

Specified by:

start in interface IDataWriter

Overrides:

start in class NestedDataWriter

start

public boolean start(Table table)

Specified by:

start in interface IDataWriter

Overrides:

start in class NestedDataWriter

isTransformable

protected boolean isTransformable(DataEventType eventType)

write

public void write(CsvData data)

Specified by:

write in interface IDataWriter

Overrides:

write in class NestedDataWriter

callWriter

protected void callWriter(Table transformedTable,
 CsvData csvData)

getTargetColumnNames

protected String[] getTargetColumnNames(List<TransformColumn> columns)

transform

protected List<TransformedData> transform(DataEventType eventType,
 DataContext context,
 TransformTable transformation,
 Map<String,String> sourceKeyValues,
 Map<String,String> oldSourceValues,
 Map<String,String> sourceValues)

perform

protected boolean perform(DataContext context,
 TransformedData data,
 TransformTable transformation,
 Map<String,String> sourceValues,
 Map<String,String> oldSourceValues)
                   throws IgnoreRowException

Throws:

IgnoreRowException

create

protected List<TransformedData> create(DataContext context,
 DataEventType dataEventType,
 TransformTable transformation,
 Map<String,String> sourceKeyValues,
 Map<String,String> oldSourceValues,
 Map<String,String> sourceValues)
                                throws IgnoreRowException

Throws:

IgnoreRowException

transformColumn

protected Object transformColumn(DataContext context,
 TransformedData data,
 TransformColumn transformColumn,
 Map<String,String> sourceValues,
 Map<String,String> oldSourceValues)
                          throws IgnoreRowException,
IgnoreColumnException

Throws:

IgnoreRowException

IgnoreColumnException

end

public void end(Table table)

Specified by:

end in interface IDataWriter

Overrides:

end in class NestedDataWriter