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

Class TableExtractDataReaderSource

java.lang.Object

org.jumpmind.symmetric.io.data.reader.TableExtractDataReaderSource

All Implemented Interfaces:

IExtractDataReaderSource

public class TableExtractDataReaderSource
extends Object
implements IExtractDataReaderSource

Convert a source table's rows to CsvData

Field Summary

Fields

Modifier and Type	Field	Description
protected Batch	batch
protected ISqlReadCursor<CsvData>	cursor
protected IDatabasePlatform	platform
protected boolean	streamLobs
protected Table	table
protected String	whereClause

Constructor Summary

Constructors

Constructor	Description
TableExtractDataReaderSource(IDatabasePlatform platform, String catalogName, String schemaName, String tableName, String whereClause, boolean streamLobs, String sourceNodeId, String targetNodeId)

Method Summary

Modifier and Type	Method	Description
void	close()
protected void	closeCursor()
Batch	getBatch()
Table	getSourceTable()	Return the table with the catalog, schema, and table name of the source table for the last CsvData retrieved by IExtractDataReaderSource.next()
Table	getTargetTable()	Return the table with the catalog, schema, and table name of the target table for the last CsvData retrieved by IExtractDataReaderSource.next()
CsvData	next()
boolean	requiresLobsSelectedFromSource(CsvData data)
protected void	startNewCursor()
protected String[]	toStringData(Row row, Column[] columns)

Methods inherited from class java.lang.Object

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

Field Details

platform

protected IDatabasePlatform platform

whereClause

protected String whereClause

batch

protected Batch batch

table

protected Table table

cursor

protected ISqlReadCursor<CsvData> cursor

streamLobs

protected boolean streamLobs

Constructor Details

TableExtractDataReaderSource

public TableExtractDataReaderSource(IDatabasePlatform platform,
 String catalogName,
 String schemaName,
 String tableName,
 String whereClause,
 boolean streamLobs,
 String sourceNodeId,
 String targetNodeId)

Method Details

getBatch

public Batch getBatch()

Specified by:

getBatch in interface IExtractDataReaderSource

getTargetTable

public Table getTargetTable()

Description copied from interface: IExtractDataReaderSource

Return the table with the catalog, schema, and table name of the target table for the last CsvData retrieved by IExtractDataReaderSource.next()

Specified by:

getTargetTable in interface IExtractDataReaderSource

getSourceTable

public Table getSourceTable()

Description copied from interface: IExtractDataReaderSource

Return the table with the catalog, schema, and table name of the source table for the last CsvData retrieved by IExtractDataReaderSource.next()

Specified by:

getSourceTable in interface IExtractDataReaderSource

next

public CsvData next()

Specified by:

next in interface IExtractDataReaderSource

startNewCursor

protected void startNewCursor()

toStringData

protected String[] toStringData(Row row,
 Column[] columns)

requiresLobsSelectedFromSource

public boolean requiresLobsSelectedFromSource(CsvData data)

Specified by:

requiresLobsSelectedFromSource in interface IExtractDataReaderSource

close

public void close()

Specified by:

close in interface IExtractDataReaderSource

closeCursor

protected void closeCursor()