ambit2.db.reporters

Class QueryPacketReporter<Q extends net.idea.modbcum.i.IQueryRetrieval<IStructureRecord>,Output>

java.lang.Object

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

net.idea.modbcum.p.AbstractDBProcessor<Q,Output>

net.idea.modbcum.r.QueryAbstractReporter<IStructureRecord,Q,Output>

ambit2.db.reporters.QueryPacketReporter<Q,Output>

All Implemented Interfaces:

Serializable, net.idea.modbcum.i.IDBProcessor<Q,Output>, net.idea.modbcum.i.processors.IProcessor<Q,Output>, net.idea.modbcum.i.reporter.Reporter<Q,Output>

public abstract class QueryPacketReporter<Q extends net.idea.modbcum.i.IQueryRetrieval<IStructureRecord>,Output>
extends net.idea.modbcum.r.QueryAbstractReporter<IStructureRecord,Q,Output>

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected RetrieveProfileValuesAsRow	chunkQuery
protected QueryExecutor	exec
protected int[]	idcompound
protected int[]	idstructure
protected int	index
protected Profile<Property>	template

Fields inherited from class net.idea.modbcum.r.QueryAbstractReporter

autoCommit, batch, licenseURI, maxRecords, output, processors, showFooter, showHeader, startTime, 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
QueryPacketReporter(Profile<Property> template, int chunkSize)

Method Summary

Modifier and Type	Method and Description
void	close()
void	footer(Output output, Q query)
int	getChunkSize()
void	header(Output output, Q query)
void	open()
protected void	processChunks()
void	setChunkSize(int chunkSize)
void	setConnection(Connection connection)
protected void	wrapup()

Methods inherited from class net.idea.modbcum.r.QueryAbstractReporter

createBatch, getFileExtension, getLicenseURI, getMaxRecords, getOutput, getProcessors, getStartTime, getTimeout, isAutoCommit, isShowFooter, isShowHeader, process, processItem, setAutoCommit, setCloseConnection, setLicenseURI, setMaxRecords, setOutput, setProcessors, setShowFooter, setShowHeader, setStartTime, setTimeout

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

getConnection, isCloseConnection, isEnabled

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.processors.IProcessor

getID, isEnabled, setEnabled

Field Detail

exec

protected QueryExecutor exec

chunkQuery

protected RetrieveProfileValuesAsRow chunkQuery

template

protected Profile<Property> template

index

protected int index

idstructure

protected int[] idstructure

idcompound

protected int[] idcompound

Constructor Detail

QueryPacketReporter

public QueryPacketReporter(Profile<Property> template,
                           int chunkSize)

Method Detail

getChunkSize

public int getChunkSize()

setChunkSize

public void setChunkSize(int chunkSize)

setConnection

public void setConnection(Connection connection)
                   throws net.idea.modbcum.i.exceptions.DbAmbitException

Specified by:

setConnection in interface net.idea.modbcum.i.IDBProcessor<Q extends net.idea.modbcum.i.IQueryRetrieval<IStructureRecord>,Output>

Overrides:

setConnection in class net.idea.modbcum.p.AbstractDBProcessor<Q extends net.idea.modbcum.i.IQueryRetrieval<IStructureRecord>,Output>

Throws:

net.idea.modbcum.i.exceptions.DbAmbitException

close

public void close()
           throws Exception

Specified by:

close in interface net.idea.modbcum.i.processors.IProcessor<Q extends net.idea.modbcum.i.IQueryRetrieval<IStructureRecord>,Output>

Specified by:

close in interface net.idea.modbcum.i.reporter.Reporter<Q extends net.idea.modbcum.i.IQueryRetrieval<IStructureRecord>,Output>

Overrides:

close in class net.idea.modbcum.p.AbstractDBProcessor<Q extends net.idea.modbcum.i.IQueryRetrieval<IStructureRecord>,Output>

Throws:

Exception

processChunks

protected void processChunks()
                      throws net.idea.modbcum.i.exceptions.AmbitException

Throws:

net.idea.modbcum.i.exceptions.AmbitException

wrapup

protected void wrapup()
               throws net.idea.modbcum.i.exceptions.AmbitException

Overrides:

wrapup in class net.idea.modbcum.r.QueryAbstractReporter<IStructureRecord,Q extends net.idea.modbcum.i.IQueryRetrieval<IStructureRecord>,Output>

Throws:

net.idea.modbcum.i.exceptions.AmbitException

footer

public void footer(Output output,
                   Q query)

Specified by:

footer in class net.idea.modbcum.r.QueryAbstractReporter<IStructureRecord,Q extends net.idea.modbcum.i.IQueryRetrieval<IStructureRecord>,Output>

header

public void header(Output output,
                   Q query)

Specified by:

header in class net.idea.modbcum.r.QueryAbstractReporter<IStructureRecord,Q extends net.idea.modbcum.i.IQueryRetrieval<IStructureRecord>,Output>

open

public void open()
          throws net.idea.modbcum.i.exceptions.DbAmbitException

Specified by:

open in interface net.idea.modbcum.i.processors.IProcessor<Q extends net.idea.modbcum.i.IQueryRetrieval<IStructureRecord>,Output>

Overrides:

open in class net.idea.modbcum.p.DefaultAmbitProcessor<Q extends net.idea.modbcum.i.IQueryRetrieval<IStructureRecord>,Output>

Throws:

net.idea.modbcum.i.exceptions.DbAmbitException