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

Class AbstractTableDataReader

java.lang.Object

org.jumpmind.symmetric.io.data.reader.AbstractDataReader

org.jumpmind.symmetric.io.data.reader.AbstractTableDataReader

All Implemented Interfaces:

IDataReader, IDataResource

Direct Known Subclasses:

CsvTableDataReader, SqlDataReader

public abstract class AbstractTableDataReader
extends AbstractDataReader
implements IDataReader

A data reader that knows it will be reading a single batch and a single table.

Field Summary

Fields

Modifier and Type	Field	Description
protected Batch	batch
protected DataContext	context
static final String	CTX_LINE_NUMBER
protected int	lineNumber
protected boolean	readDataBeforeTable
protected Reader	reader
protected boolean	readingBatch
protected boolean	readingTable
protected Statistics	statistics
protected Table	table

Fields inherited from class org.jumpmind.symmetric.io.data.reader.AbstractDataReader

log

Constructor Summary

Constructors

Constructor	Description
AbstractTableDataReader(BinaryEncoding binaryEncoding, String catalogName, String schemaName, String tableName, InputStream is)
AbstractTableDataReader(BinaryEncoding binaryEncoding, String catalogName, String schemaName, String tableName, Reader reader)
AbstractTableDataReader(Batch batch, String catalogName, String schemaName, String tableName, File file)
AbstractTableDataReader(Batch batch, String catalogName, String schemaName, String tableName, InputStream is)
AbstractTableDataReader(Batch batch, String catalogName, String schemaName, String tableName, Reader reader)
AbstractTableDataReader(Batch batch, String catalogName, String schemaName, String tableName, String input)
AbstractTableDataReader(Batch batch, String catalogName, String schemaName, String tableName, StringBuilder input)

Method Summary

Modifier and Type	Method	Description
protected CsvData	buildCsvData(String[] tokens, DataEventType dml)
void	close()
protected abstract void	finish()
Map<Batch,Statistics>	getStatistics()
protected abstract void	init()
Batch	nextBatch()
CsvData	nextData()
Table	nextTable()
void	open(DataContext context)
protected abstract CsvData	readNext()
protected static String	toTableName(String tableName, File file)

Methods inherited from class org.jumpmind.symmetric.io.data.reader.AbstractDataReader

logDebugAndCountBytes, toBatch, toReader, toReader

Methods inherited from class java.lang.Object

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

Field Details

CTX_LINE_NUMBER

public static final String CTX_LINE_NUMBER

reader

protected Reader reader

statistics

protected Statistics statistics

context

protected DataContext context

batch

protected Batch batch

table

protected Table table

lineNumber

protected int lineNumber

readDataBeforeTable

protected boolean readDataBeforeTable

readingBatch

protected boolean readingBatch

readingTable

protected boolean readingTable

Constructor Details

AbstractTableDataReader

public AbstractTableDataReader(Batch batch,
 String catalogName,
 String schemaName,
 String tableName,
 StringBuilder input)

AbstractTableDataReader

public AbstractTableDataReader(Batch batch,
 String catalogName,
 String schemaName,
 String tableName,
 InputStream is)

AbstractTableDataReader

public AbstractTableDataReader(Batch batch,
 String catalogName,
 String schemaName,
 String tableName,
 String input)

AbstractTableDataReader

public AbstractTableDataReader(Batch batch,
 String catalogName,
 String schemaName,
 String tableName,
 File file)

AbstractTableDataReader

public AbstractTableDataReader(Batch batch,
 String catalogName,
 String schemaName,
 String tableName,
 Reader reader)

AbstractTableDataReader

public AbstractTableDataReader(BinaryEncoding binaryEncoding,
 String catalogName,
 String schemaName,
 String tableName,
 Reader reader)

AbstractTableDataReader

public AbstractTableDataReader(BinaryEncoding binaryEncoding,
 String catalogName,
 String schemaName,
 String tableName,
 InputStream is)

Method Details

toTableName

protected static String toTableName(String tableName,
 File file)

open

public void open(DataContext context)

Specified by:

open in interface IDataResource

init

protected abstract void init()

readNext

protected abstract CsvData readNext()

finish

protected abstract void finish()

buildCsvData

protected CsvData buildCsvData(String[] tokens,
 DataEventType dml)

nextData

public CsvData nextData()

Specified by:

nextData in interface IDataReader

nextBatch

public Batch nextBatch()

Specified by:

nextBatch in interface IDataReader

nextTable

public Table nextTable()

Specified by:

nextTable in interface IDataReader

close

public void close()

Specified by:

close in interface IDataResource

getStatistics

public Map<Batch,Statistics> getStatistics()

Specified by:

getStatistics in interface IDataResource