Package org.openrefine.extension.database

Class DBQueryResultImportReader

java.lang.Object

org.openrefine.extension.database.DBQueryResultImportReader

All Implemented Interfaces:

AutoCloseable, TabularParserHelper.TableDataReader

public class DBQueryResultImportReader
extends Object
implements TabularParserHelper.TableDataReader

Constructor Summary

Constructors

Constructor	Description
DBQueryResultImportReader(ImportingJob job, DatabaseService databaseService, String querySource, List<DatabaseColumn> columns, DatabaseQueryInfo dbQueryInfo, int batchSize)

Method Summary

Modifier and Type	Method	Description
void	close()
int	getBatchRowStart()
int	getBatchSize()
List<DatabaseColumn>	getColumns()
ImportingJob	getJob()
int	getNextRow()
List<Object>	getNextRowOfCells()
String	getQuerySource()
List<List<Object>>	getRowsOfCells()
boolean	isEnd()
boolean	isUsedHeaders()
void	setBatchRowStart(int batchRowStart)
void	setColumns(List<DatabaseColumn> columns)
void	setEnd(boolean end)
void	setNextRow(int nextRow)
void	setRowsOfCells(List<List<Object>> rowsOfCells)
void	setUsedHeaders(boolean usedHeaders)

Methods inherited from class java.lang.Object

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

Constructor Detail

DBQueryResultImportReader

public DBQueryResultImportReader(ImportingJob job,
                                 DatabaseService databaseService,
                                 String querySource,
                                 List<DatabaseColumn> columns,
                                 DatabaseQueryInfo dbQueryInfo,
                                 int batchSize)

Method Detail

getNextRowOfCells

public List<Object> getNextRowOfCells()
                               throws IOException

Specified by:

getNextRowOfCells in interface TabularParserHelper.TableDataReader

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface TabularParserHelper.TableDataReader

Throws:

IOException

getColumns

public List<DatabaseColumn> getColumns()

setColumns

public void setColumns(List<DatabaseColumn> columns)

getNextRow

public int getNextRow()

setNextRow

public void setNextRow(int nextRow)

getBatchRowStart

public int getBatchRowStart()

setBatchRowStart

public void setBatchRowStart(int batchRowStart)

isEnd

public boolean isEnd()

setEnd

public void setEnd(boolean end)

getRowsOfCells

public List<List<Object>> getRowsOfCells()

setRowsOfCells

public void setRowsOfCells(List<List<Object>> rowsOfCells)

isUsedHeaders

public boolean isUsedHeaders()

setUsedHeaders

public void setUsedHeaders(boolean usedHeaders)

getJob

public ImportingJob getJob()

getQuerySource

public String getQuerySource()

getBatchSize

public int getBatchSize()