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

Class CsvTableDataReader

java.lang.Object

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

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

org.jumpmind.symmetric.io.data.reader.CsvTableDataReader

All Implemented Interfaces:

IDataReader, IDataResource

Direct Known Subclasses:

CsvDquoteDataReader

public class CsvTableDataReader
extends AbstractTableDataReader

Read CSV formatted data for a single table. Requires that the column names be the header of the CSV.

Field Summary

Fields

Modifier and Type	Field	Description
protected CsvReader	csvReader

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

batch, context, CTX_LINE_NUMBER, lineNumber, readDataBeforeTable, reader, readingBatch, readingTable, statistics, table

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

log

Constructor Summary

Constructors

Constructor	Description
CsvTableDataReader(BinaryEncoding binaryEncoding, String catalogName, String schemaName, String tableName, InputStream is)
CsvTableDataReader(BinaryEncoding binaryEncoding, String catalogName, String schemaName, String tableName, Reader reader)

Method Summary

Modifier and Type	Method	Description
protected void	finish()
protected void	init()
protected CsvData	readNext()

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

buildCsvData, close, getStatistics, nextBatch, nextData, nextTable, open, toTableName

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

csvReader

protected CsvReader csvReader

Constructor Details

CsvTableDataReader

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

CsvTableDataReader

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

Method Details

init

protected void init()

Specified by:

init in class AbstractTableDataReader

readNext

protected CsvData readNext()

Specified by:

readNext in class AbstractTableDataReader

finish

protected void finish()

Specified by:

finish in class AbstractTableDataReader