Package org.jumpmind.symmetric.io.data.reader

Class ExtractDataReader

java.lang.Object

org.jumpmind.symmetric.io.data.reader.ExtractDataReader

All Implemented Interfaces:

IDataReader, IDataResource

public class ExtractDataReader
extends Object
implements IDataReader

Field Summary

Fields

Modifier and Type	Field	Description
protected Batch	batch
protected IExtractDataReaderSource	currentSource
protected CsvData	data
static final String	DATA_CONTEXT_CURRENT_CSV_DATA
protected DataContext	dataContext
protected List<IExtractDataFilter>	filters
protected boolean	isSybaseASE
protected boolean	isUsingUnitypes
protected IDatabasePlatform	platform
protected List<IExtractDataReaderSource>	sourcesToUse
protected Map<Batch,Statistics>	statistics
protected Table	table

Constructor Summary

Constructors

Constructor	Description
ExtractDataReader(IDatabasePlatform platform, List<IExtractDataReaderSource> sources)
ExtractDataReader(IDatabasePlatform platform, IExtractDataReaderSource source)
ExtractDataReader(IDatabasePlatform platform, IExtractDataReaderSource source, List<IExtractDataFilter> filters, boolean isUsingUnitypes)

Method Summary

Modifier and Type	Method	Description
protected String	buildSelect(Table table, List<Column> lobColumns, Column[] pkColumns)
void	close()
protected void	closeCurrentSource()
protected CsvData	convertUtf16toUTF8(Table table, CsvData data)
protected Row	createRowForRequiredLobs(List<Column> lobColumns)	When the row is missing because it was deleted, we need to temporarily satisfy not-null constraint at target
protected CsvData	enhanceWithLobsFromSourceIfNeeded(Table table, CsvData data)
Map<Batch,Statistics>	getStatistics()
List<Column>	getUniColumns(Table table)
boolean	isUniType(String type)
Batch	nextBatch()
CsvData	nextData()
protected CsvData	nextDataFromSource()
Table	nextTable()
void	open(DataContext context)
protected String	substituteVariables(String sourceString)

Methods inherited from class java.lang.Object

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

Field Details

DATA_CONTEXT_CURRENT_CSV_DATA

public static final String DATA_CONTEXT_CURRENT_CSV_DATA

See Also:

• Constant Field Values

statistics

protected Map<Batch,Statistics> statistics

platform

protected IDatabasePlatform platform

sourcesToUse

protected List<IExtractDataReaderSource> sourcesToUse

currentSource

protected IExtractDataReaderSource currentSource

filters

protected List<IExtractDataFilter> filters

batch

protected Batch batch

table

protected Table table

data

protected CsvData data

dataContext

protected DataContext dataContext

isSybaseASE

protected boolean isSybaseASE

isUsingUnitypes

protected boolean isUsingUnitypes

Constructor Details

ExtractDataReader

public ExtractDataReader(IDatabasePlatform platform,
 IExtractDataReaderSource source)

ExtractDataReader

public ExtractDataReader(IDatabasePlatform platform,
 IExtractDataReaderSource source,
 List<IExtractDataFilter> filters,
 boolean isUsingUnitypes)

ExtractDataReader

public ExtractDataReader(IDatabasePlatform platform,
 List<IExtractDataReaderSource> sources)

Method Details

open

public void open(DataContext context)

Specified by:

open in interface IDataResource

nextBatch

public Batch nextBatch()

Specified by:

nextBatch in interface IDataReader

nextTable

public Table nextTable()

Specified by:

nextTable in interface IDataReader

substituteVariables

protected String substituteVariables(String sourceString)

nextData

public CsvData nextData()

Specified by:

nextData in interface IDataReader

nextDataFromSource

protected CsvData nextDataFromSource()

close

public void close()

Specified by:

close in interface IDataResource

closeCurrentSource

protected void closeCurrentSource()

getStatistics

public Map<Batch,Statistics> getStatistics()

Specified by:

getStatistics in interface IDataResource

enhanceWithLobsFromSourceIfNeeded

protected CsvData enhanceWithLobsFromSourceIfNeeded(Table table,
 CsvData data)

convertUtf16toUTF8

protected CsvData convertUtf16toUTF8(Table table,
 CsvData data)

getUniColumns

public List<Column> getUniColumns(Table table)

isUniType

public boolean isUniType(String type)

buildSelect

protected String buildSelect(Table table,
 List<Column> lobColumns,
 Column[] pkColumns)

createRowForRequiredLobs

protected Row createRowForRequiredLobs(List<Column> lobColumns)

When the row is missing because it was deleted, we need to temporarily satisfy not-null constraint at target