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

Class StructureDataWriter

java.lang.Object

org.jumpmind.symmetric.io.data.writer.StructureDataWriter

All Implemented Interfaces:

IDataResource, IDataWriter

public class StructureDataWriter
extends Object
implements IDataWriter

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	StructureDataWriter.PayloadType

Field Summary

Fields

Modifier and Type	Field	Description
protected BinaryEncoding	binaryEncoding
protected long	currentBatch
protected Table	currentTable
protected Map<Long,List<String>>	payloadMap
protected StructureDataWriter.PayloadType	payloadType
protected IDatabasePlatform	platform
protected Map<Batch,Statistics>	statistics
protected String	targetDatabaseName
protected boolean	useJdbcTimestampFormat
protected boolean	useQuotedIdentifiers
protected boolean	useUpsertStatements

Constructor Summary

Constructors

Constructor	Description
StructureDataWriter(IDatabasePlatform platform, String targetDatabaseName, StructureDataWriter.PayloadType payloatType, boolean useQuotedIdentifiers, BinaryEncoding binaryEncoding, boolean useJdbcTimestampFormat, boolean useUpsertStatements)

Method Summary

Modifier and Type	Method	Description
protected String	buildSql(DmlStatement.DmlType dmlType, String[] values, Column[] columns)
void	close()
void	end(Table table)
void	end(Batch batch, boolean inError)
Map<Long,List<String>>	getPayloadMap()
StructureDataWriter.PayloadType	getPayloadType()
Map<Batch,Statistics>	getStatistics()
void	open(DataContext context)
void	setPayloadMap(Map<Long,List<String>> payloadMap)
void	setPayloadType(StructureDataWriter.PayloadType payloadType)
boolean	start(Table table)
void	start(Batch batch)
void	write(CsvData data)

Methods inherited from class java.lang.Object

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

Field Details

platform

protected IDatabasePlatform platform

currentTable

protected Table currentTable

statistics

protected Map<Batch,Statistics> statistics

payloadMap

protected Map<Long,List<String>> payloadMap

payloadType

protected StructureDataWriter.PayloadType payloadType

currentBatch

protected long currentBatch

targetDatabaseName

protected String targetDatabaseName

useQuotedIdentifiers

protected boolean useQuotedIdentifiers

useJdbcTimestampFormat

protected boolean useJdbcTimestampFormat

useUpsertStatements

protected boolean useUpsertStatements

binaryEncoding

protected BinaryEncoding binaryEncoding

Constructor Details

StructureDataWriter

public StructureDataWriter(IDatabasePlatform platform,
 String targetDatabaseName,
 StructureDataWriter.PayloadType payloatType,
 boolean useQuotedIdentifiers,
 BinaryEncoding binaryEncoding,
 boolean useJdbcTimestampFormat,
 boolean useUpsertStatements)

Method Details

open

public void open(DataContext context)

Specified by:

open in interface IDataResource

close

public void close()

Specified by:

close in interface IDataResource

getStatistics

public Map<Batch,Statistics> getStatistics()

Specified by:

getStatistics in interface IDataResource

start

public void start(Batch batch)

Specified by:

start in interface IDataWriter

start

public boolean start(Table table)

Specified by:

start in interface IDataWriter

write

public void write(CsvData data)

Specified by:

write in interface IDataWriter

buildSql

protected String buildSql(DmlStatement.DmlType dmlType,
 String[] values,
 Column[] columns)

end

public void end(Table table)

Specified by:

end in interface IDataWriter

end

public void end(Batch batch,
 boolean inError)

Specified by:

end in interface IDataWriter

getPayloadType

public StructureDataWriter.PayloadType getPayloadType()

setPayloadType

public void setPayloadType(StructureDataWriter.PayloadType payloadType)

getPayloadMap

public Map<Long,List<String>> getPayloadMap()

setPayloadMap

public void setPayloadMap(Map<Long,List<String>> payloadMap)