com.revolsys.jdbc.io

Class JdbcQueryIterator

java.lang.Object

com.revolsys.io.AbstractObjectWithProperties

com.revolsys.collection.AbstractIterator<Record>

com.revolsys.jdbc.io.JdbcQueryIterator

All Implemented Interfaces:

RecordIterator, ObjectWithProperties, AutoCloseable, Iterable<Record>, Iterator<Record>

Direct Known Subclasses:

OracleJdbcQueryIterator, PostgreSQLJdbcQueryIterator

public class JdbcQueryIterator
extends AbstractIterator<Record>
implements RecordIterator

Constructor Summary

Constructors

Constructor and Description
JdbcQueryIterator(JdbcRecordStore recordStore, Query query, Map<String,Object> properties)

Method Summary

Methods

Modifier and Type	Method and Description
void	doClose()
protected void	doInit()
protected String	getErrorMessage()
protected Record	getNext()
static Record	getNextObject(JdbcRecordStore recordStore, RecordDefinition recordDefinition, List<FieldDefinition> attributes, RecordFactory recordFactory, ResultSet resultSet)
RecordDefinition	getRecordDefinition()
JdbcRecordStore	getRecordStore()
protected ResultSet	getResultSet()
static ResultSet	getResultSet(RecordDefinition recordDefinition, PreparedStatement statement, Query query)
protected String	getSql(Query query)
protected void	setQuery(Query query)

Methods inherited from class com.revolsys.collection.AbstractIterator

close, finalize, hasNext, init, iterator, next, remove, setLoadNext

Methods inherited from class com.revolsys.io.AbstractObjectWithProperties

clearProperties, getProperties, getProperty, getProperty, removeProperty, setProperties, setProperty, setPropertySoft, setPropertyWeak

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Iterator

hasNext, next, remove

Constructor Detail

JdbcQueryIterator

public JdbcQueryIterator(JdbcRecordStore recordStore,
                 Query query,
                 Map<String,Object> properties)

Method Detail

getNextObject

public static Record getNextObject(JdbcRecordStore recordStore,
                   RecordDefinition recordDefinition,
                   List<FieldDefinition> attributes,
                   RecordFactory recordFactory,
                   ResultSet resultSet)

getResultSet

public static ResultSet getResultSet(RecordDefinition recordDefinition,
                     PreparedStatement statement,
                     Query query)
                              throws SQLException

Throws:

SQLException

doClose

@PreDestroy
public void doClose()

Overrides:

doClose in class AbstractIterator<Record>

doInit

protected void doInit()

Overrides:

doInit in class AbstractIterator<Record>

getErrorMessage

protected String getErrorMessage()

getNext

protected Record getNext()
                  throws NoSuchElementException

Specified by:

getNext in class AbstractIterator<Record>

Throws:

NoSuchElementException

getRecordDefinition

public RecordDefinition getRecordDefinition()

Specified by:

getRecordDefinition in interface RecordIterator

getRecordStore

public JdbcRecordStore getRecordStore()

getResultSet

protected ResultSet getResultSet()

getSql

protected String getSql(Query query)

setQuery

protected void setQuery(Query query)