ambit2.db.processors

Class BatchDBProcessor<ITEMTYPE>

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<IInputState,ITEMTYPE>

ambit2.db.processors.BatchDBProcessor<ITEMTYPE>

Type Parameters:

ItemOutput -

All Implemented Interfaces:

Serializable, net.idea.modbcum.i.IDBProcessor<IInputState,net.idea.modbcum.i.batch.IBatchStatistics>, net.idea.modbcum.i.processors.IBatchProcessor<IInputState,ITEMTYPE,net.idea.modbcum.i.batch.IBatchStatistics>, net.idea.modbcum.i.processors.IProcessor<IInputState,net.idea.modbcum.i.batch.IBatchStatistics>

Direct Known Subclasses:

QuickImportBatchProcessor

public class BatchDBProcessor<ITEMTYPE>
extends net.idea.modbcum.p.batch.AbstractBatchProcessor<IInputState,ITEMTYPE>

Reads file

Author:

nina

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected ILiteratureEntry	reference

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
BatchDBProcessor()
BatchDBProcessor(net.idea.modbcum.i.processors.ProcessorsChain<ITEMTYPE,net.idea.modbcum.i.batch.IBatchStatistics,net.idea.modbcum.i.processors.IProcessor> processor)

Method Summary

Modifier and Type	Method and Description
void	afterProcessing(IInputState target, Iterator<ITEMTYPE> iterator)
protected void	configureReader(RawIteratingCSVReader reader, IInputState target, File file)
Iterator<ITEMTYPE>	getIterator(IInputState target)
ILiteratureEntry	getReference()
void	setReference(ILiteratureEntry reference)

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

beforeProcessing, cancel, close, 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.processors.IProcessor

getID, setEnabled

Field Detail

reference

protected ILiteratureEntry reference

Constructor Detail

BatchDBProcessor

public BatchDBProcessor()

BatchDBProcessor

public BatchDBProcessor(net.idea.modbcum.i.processors.ProcessorsChain<ITEMTYPE,net.idea.modbcum.i.batch.IBatchStatistics,net.idea.modbcum.i.processors.IProcessor> processor)

Method Detail

getReference

public ILiteratureEntry getReference()

setReference

public void setReference(ILiteratureEntry reference)

getIterator

public Iterator<ITEMTYPE> getIterator(IInputState target)
                               throws net.idea.modbcum.i.exceptions.AmbitException

Throws:

net.idea.modbcum.i.exceptions.AmbitException

configureReader

protected void configureReader(RawIteratingCSVReader reader,
                               IInputState target,
                               File file)

afterProcessing

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

Specified by:

afterProcessing in interface net.idea.modbcum.i.processors.IBatchProcessor<IInputState,ITEMTYPE,net.idea.modbcum.i.batch.IBatchStatistics>

Overrides:

afterProcessing in class net.idea.modbcum.p.batch.AbstractBatchProcessor<IInputState,ITEMTYPE>

Throws:

net.idea.modbcum.i.exceptions.AmbitException