ambit2.db

Class DbReader<ResultType>

java.lang.Object

net.idea.modbcum.p.DefaultAmbitProcessor<Target,Result>

net.idea.modbcum.p.AbstractDBProcessor<Target,net.idea.modbcum.i.batch.IBatchStatistics>

net.idea.modbcum.p.batch.AbstractBatchProcessor<net.idea.modbcum.i.IQueryRetrieval<ResultType>,ResultType>

ambit2.db.DbReader<ResultType>

All Implemented Interfaces:

Serializable, net.idea.modbcum.i.IDBProcessor<net.idea.modbcum.i.IQueryRetrieval<ResultType>,net.idea.modbcum.i.batch.IBatchStatistics>, net.idea.modbcum.i.processors.IBatchProcessor<net.idea.modbcum.i.IQueryRetrieval<ResultType>,ResultType,net.idea.modbcum.i.batch.IBatchStatistics>, net.idea.modbcum.i.processors.IProcessor<net.idea.modbcum.i.IQueryRetrieval<ResultType>,net.idea.modbcum.i.batch.IBatchStatistics>

Direct Known Subclasses:

DbReaderStructure

public class DbReader<ResultType>
extends net.idea.modbcum.p.batch.AbstractBatchProcessor<net.idea.modbcum.i.IQueryRetrieval<ResultType>,ResultType>
implements net.idea.modbcum.i.IDBProcessor<net.idea.modbcum.i.IQueryRetrieval<ResultType>,net.idea.modbcum.i.batch.IBatchStatistics>

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	DbReader.cached_results

Field Summary

Fields

Modifier and Type	Field and Description
protected QueryExecutor<net.idea.modbcum.i.IQueryObject<ResultType>>	executor
protected boolean	handlePrescreen
protected ResultSet	resultSet

Fields inherited from class net.idea.modbcum.p.batch.AbstractBatchProcessor

batchStatistics, cancelled, now, processor, PROPERTY_BATCHSTATS, timeout

Fields inherited from class net.idea.modbcum.p.AbstractDBProcessor

closeConnection, connection

Fields inherited from class net.idea.modbcum.p.DefaultAmbitProcessor

enabled, logger, propertyChangeSupport

Constructor Summary

Constructors

Constructor and Description
DbReader()

Method Summary

Modifier and Type	Method and Description
void	afterProcessing(net.idea.modbcum.i.IQueryRetrieval<ResultType> target, Iterator<ResultType> iterator)
void	beforeProcessing(net.idea.modbcum.i.IQueryRetrieval<ResultType> target)
protected void	cache(String category, String key, ResultType object, boolean ok) Does nothing, otherwise should cache the query result
void	close()
protected DbReader.cached_results	getCached(String category, String key, ResultType object) Returns cached query results or NOTCACHED if not in the cache.
Iterator<ResultType>	getIterator(net.idea.modbcum.i.IQueryRetrieval<ResultType> query)
protected ResultSet	getResultSet()
boolean	isHandlePrescreen()
protected boolean	prescreen(net.idea.modbcum.i.IQueryRetrieval<ResultType> query, ResultType object)
void	setHandlePrescreen(boolean handlePrescreen)
void	setResultSet(ResultSet resultSet)

Methods inherited from class net.idea.modbcum.p.batch.AbstractBatchProcessor

cancel, getProcessorChain, getResult, getSilentInterval, getTimeout, onError, onItemProcessed, onItemProcessing, onItemRead, onItemSkipped, open, process, setConnection, setProcessorChain, setTimeout, skip

Methods inherited from class net.idea.modbcum.p.AbstractDBProcessor

getConnection, isCloseConnection, isEnabled, setCloseConnection

Methods inherited from class net.idea.modbcum.p.DefaultAmbitProcessor

addPropertyChangeListener, addPropertyChangeListener, getID, removePropertyChangeListener, removePropertyChangeListener, setEnabled, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface net.idea.modbcum.i.IDBProcessor

getConnection, setConnection

Methods inherited from interface net.idea.modbcum.i.processors.IProcessor

getID, isEnabled, open, process, setEnabled

Field Detail

resultSet

protected ResultSet resultSet

executor

protected QueryExecutor<net.idea.modbcum.i.IQueryObject<ResultType>> executor

handlePrescreen

protected boolean handlePrescreen

Constructor Detail

DbReader

public DbReader()

Method Detail

isHandlePrescreen

public boolean isHandlePrescreen()

setHandlePrescreen

public void setHandlePrescreen(boolean handlePrescreen)

getCached

protected DbReader.cached_results getCached(String category,
                                            String key,
                                            ResultType object)

Returns cached query results or NOTCACHED if not in the cache. Default implementation returns NOTCACHED.

Parameters:

query_effectrecord -

object -

Returns:

cache

protected void cache(String category,
                     String key,
                     ResultType object,
                     boolean ok)

Does nothing, otherwise should cache the query result

Parameters:

query_effectrecord -

object -

prescreen

protected boolean prescreen(net.idea.modbcum.i.IQueryRetrieval<ResultType> query,
                            ResultType object)
                     throws net.idea.modbcum.i.exceptions.AmbitException

Parameters:

query -

object -

Returns:

Throws:

net.idea.modbcum.i.exceptions.AmbitException

getIterator

public Iterator<ResultType> getIterator(net.idea.modbcum.i.IQueryRetrieval<ResultType> query)
                                 throws net.idea.modbcum.i.exceptions.AmbitException

Specified by:

getIterator in interface net.idea.modbcum.i.processors.IBatchProcessor<net.idea.modbcum.i.IQueryRetrieval<ResultType>,ResultType,net.idea.modbcum.i.batch.IBatchStatistics>

Throws:

net.idea.modbcum.i.exceptions.AmbitException

beforeProcessing

public void beforeProcessing(net.idea.modbcum.i.IQueryRetrieval<ResultType> target)
                      throws net.idea.modbcum.i.exceptions.AmbitException

Specified by:

beforeProcessing in interface net.idea.modbcum.i.processors.IBatchProcessor<net.idea.modbcum.i.IQueryRetrieval<ResultType>,ResultType,net.idea.modbcum.i.batch.IBatchStatistics>

Overrides:

beforeProcessing in class net.idea.modbcum.p.batch.AbstractBatchProcessor<net.idea.modbcum.i.IQueryRetrieval<ResultType>,ResultType>

Throws:

net.idea.modbcum.i.exceptions.AmbitException

afterProcessing

public void afterProcessing(net.idea.modbcum.i.IQueryRetrieval<ResultType> target,
                            Iterator<ResultType> iterator)
                     throws net.idea.modbcum.i.exceptions.AmbitException

Specified by:

afterProcessing in interface net.idea.modbcum.i.processors.IBatchProcessor<net.idea.modbcum.i.IQueryRetrieval<ResultType>,ResultType,net.idea.modbcum.i.batch.IBatchStatistics>

Overrides:

afterProcessing in class net.idea.modbcum.p.batch.AbstractBatchProcessor<net.idea.modbcum.i.IQueryRetrieval<ResultType>,ResultType>

Throws:

net.idea.modbcum.i.exceptions.AmbitException

close

public void close()
           throws Exception

Specified by:

close in interface net.idea.modbcum.i.processors.IProcessor<net.idea.modbcum.i.IQueryRetrieval<ResultType>,net.idea.modbcum.i.batch.IBatchStatistics>

Overrides:

close in class net.idea.modbcum.p.batch.AbstractBatchProcessor<net.idea.modbcum.i.IQueryRetrieval<ResultType>,ResultType>

Throws:

Exception

getResultSet

protected ResultSet getResultSet()

setResultSet

public void setResultSet(ResultSet resultSet)