salto.batch.lanceur.init
Class DaoSqlBatchStart

java.lang.Object
  salto.batch.lanceur.init.AbstractBatchStart
      salto.batch.lanceur.init.AbstractDBBatchStart
          salto.batch.lanceur.init.DaoSqlBatchStart

All Implemented Interfaces:

java.io.Serializable, java.lang.Cloneable, IBatchStart, IDaoBatchStart, IResumableBatchStart

public class DaoSqlBatchStart
extends AbstractDBBatchStart
implements IResumableBatchStart

Class that represents a Data Source for a batch, it returns data based on:

• An SQL Query or a stored Procedure
• Parameters (SqlPameter) to set on query
• An array of classes to which the query result will be mapped

It returns an 2 dimension array in method next.

Author:

Etienne Loiez, Philippe Mouawad

See Also:

SqlParameter, Serialized Form

Field Summary

Fields inherited from class salto.batch.lanceur.init.AbstractDBBatchStart

DEFAULT_BLOCK_SIZE

Constructor Summary

DaoSqlBatchStart()
Initialisation vide

DaoSqlBatchStart(java.lang.String jndiConnName, java.lang.String sqlOrder, int nbTraitement, boolean isPS, java.lang.String[] daoClass)

DaoSqlBatchStart(java.lang.String jndiConnName, java.lang.String sqlOrder, int nbTraitement, boolean isPS, java.lang.String[] daoClass, SqlParameter[] sqlParameters)

Method Summary

java.lang.Object	clone()
void	close() Close all opened resources.
DataObject[]	getDaoClasses() Returns the daoClasses.
java.lang.String[]	getDaoClassTyp()
IdComputer	getIdComputer()
java.lang.String	getJndiConnection()
int	getNbLinesRead()
int	getNbTraitement()
SqlParameter[]	getParameters()
java.lang.String	getSqlOrder()
void	init(BatchExecutionContext context) Initialisation du traitement Récupération de la connection Création et exécution de l'ordre SQL
boolean	isResumed()
boolean	isStoreProc()
java.lang.Object	next() récupère et renvoie les résultats suivants
void	preInit(BatchExecutionContext context) Called before Traitement#initialize(BatchExecutionContext context)
java.lang.String	removeDaoClassType(int indice)
void	setDaoClassTyp(int indice, java.lang.String className) Deprecated.
void	setDaoClassTyp(java.lang.String[] daoClassTyp)
void	setDataOfResumedBatch(DoBatchTrt[] dataBatch) (non-Javadoc)
void	setIdComputer(IdComputer idComputer) (non-Javadoc)
void	setIsStoreProc(boolean isStoreProc)
void	setJndiConnection(java.lang.String jndiConnName)
void	setNbTraitement(int nbTraitement)
void	setParameters(SqlParameter[] parameters)
void	setSqlOrder(java.lang.String sqlOrder)
void	setStoreProc(boolean isStoreProc) Sets the isStoreProc.
void	validate() Validate the configuration

Methods inherited from class salto.batch.lanceur.init.AbstractDBBatchStart

addSqlParameter, displayParameters, getResultSet, removeSqlParameter

Methods inherited from class salto.batch.lanceur.init.AbstractBatchStart

getBatchExecutionContext

Methods inherited from class java.lang.Object

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

Methods inherited from interface salto.batch.lanceur.init.IBatchStart

getBatchExecutionContext

Constructor Detail

DaoSqlBatchStart

public DaoSqlBatchStart()

Initialisation vide

DaoSqlBatchStart

public DaoSqlBatchStart(java.lang.String jndiConnName,
                        java.lang.String sqlOrder,
                        int nbTraitement,
                        boolean isPS,
                        java.lang.String[] daoClass,
                        SqlParameter[] sqlParameters)
                 throws BatchException

Parameters:

jndiConnName - pool de connexion

sqlOrder - Ordre SQL permettant de récupérer données

nbTraitement - Nb de lignes récupérée à chaque next

isPS - booleéan indiquant si Proc stockée

daoClass - String[] contenant classes des DOs récupérés

sqlParameters - SqlParameter[]

Throws:

BatchException

DaoSqlBatchStart

public DaoSqlBatchStart(java.lang.String jndiConnName,
                        java.lang.String sqlOrder,
                        int nbTraitement,
                        boolean isPS,
                        java.lang.String[] daoClass)
                 throws BatchException

Parameters:

jndiConnName - pool de connexion

sqlOrder - Ordre SQL permettant de récupérer données

nbTraitement - Nb de lignes récupérée à chaque next

isPS - booleéan indiquant si Proc stockée

daoClass - String[] contenant classes des DOs récupérés

Throws:

BatchException

Method Detail

init

public void init(BatchExecutionContext context)
          throws BatchException

Initialisation du traitement

1. Récupération de la connection
2. Création et exécution de l'ordre SQL

Specified by:

init in interface IBatchStart

Parameters:

context -

Throws:

BatchException

next

public java.lang.Object next()
                      throws BatchException

récupère et renvoie les résultats suivants

Specified by:

next in interface IBatchStart

Returns:

DataObject[][] le tableau de dataobject spécifié en argument du constructeur

Throws:

BatchException

close

public final void close()

Description copied from interface: IBatchStart

Close all opened resources.

Specified by:

close in interface IBatchStart

getDaoClassTyp

public java.lang.String[] getDaoClassTyp()

Specified by:

getDaoClassTyp in interface IDaoBatchStart

Returns:

String[] contenant classes des DOs récupérés

isStoreProc

public boolean isStoreProc()

Specified by:

isStoreProc in class AbstractDBBatchStart

Returns:

true si Proc stockée

getJndiConnection

public java.lang.String getJndiConnection()

Specified by:

getJndiConnection in class AbstractDBBatchStart

Returns:

pool de connexion

getNbTraitement

public int getNbTraitement()

Specified by:

getNbTraitement in class AbstractDBBatchStart

Returns:

Nb de lignes récupérée à chaque next

See Also:

Traitement.execute(long, java.lang.Object[], java.lang.String)

getSqlOrder

public java.lang.String getSqlOrder()

Specified by:

getSqlOrder in class AbstractDBBatchStart

Returns:

String ordre SQL permettant de récupérer données de travail

setIsStoreProc

public void setIsStoreProc(boolean isStoreProc)

Parameters:

isStoreProc - booleéan indiquant si Proc stockée

setJndiConnection

public void setJndiConnection(java.lang.String jndiConnName)

Specified by:

setJndiConnection in class AbstractDBBatchStart

Parameters:

jndiConnName - data source

setNbTraitement

public void setNbTraitement(int nbTraitement)

Specified by:

setNbTraitement in class AbstractDBBatchStart

Parameters:

nbTraitement - Nb de lignes récupérées à chaque next

setSqlOrder

public void setSqlOrder(java.lang.String sqlOrder)

Specified by:

setSqlOrder in class AbstractDBBatchStart

Parameters:

sqlOrder - ordre SQL permettant de récupérer données de travail

setStoreProc

public void setStoreProc(boolean isStoreProc)

Sets the isStoreProc.

Specified by:

setStoreProc in class AbstractDBBatchStart

Parameters:

isStoreProc - The isStoreProc to set

setDaoClassTyp

public void setDaoClassTyp(java.lang.String[] daoClassTyp)
                    throws BatchException

Specified by:

setDaoClassTyp in interface IDaoBatchStart

Parameters:

daoClassTyp - String[] contenant classes des DOs récupérés

Throws:

BatchException

setDaoClassTyp

public void setDaoClassTyp(int indice,
                           java.lang.String className)
                    throws BatchInitException

Deprecated.

Parameters:

indice - indice de la classe à positionner ds tableau de daoClassTyp

className - Nom de la classe

Throws:

BatchInitException

removeDaoClassType

public java.lang.String removeDaoClassType(int indice)

Specified by:

removeDaoClassType in interface IDaoBatchStart

Parameters:

indice - indice de la classe à supprimer du tableau de daoClassTyp

Returns:

Nom classe supprimée

getDaoClasses

public DataObject[] getDaoClasses()

Returns the daoClasses.

Returns:

DataObject[]

setDataOfResumedBatch

public void setDataOfResumedBatch(DoBatchTrt[] dataBatch)

(non-Javadoc)

Specified by:

setDataOfResumedBatch in interface IResumableBatchStart

Parameters:

dataBatch - DoBatchTrt[]

See Also:

salto.batch.lanceur.init.IResumableBatchStart#setDataOfResumedBatch(salto.batch.appender.data.DoBatchTrt[])

setIdComputer

public void setIdComputer(IdComputer idComputer)

(non-Javadoc)

Specified by:

setIdComputer in interface IBatchStart

Parameters:

idComputer - IdComputer Computes unique ID per line

See Also:

IBatchStart.setIdComputer(salto.batch.lanceur.init.IdComputer)

getParameters

public SqlParameter[] getParameters()

Specified by:

getParameters in class AbstractDBBatchStart

Returns:

Returns the parameters.

setParameters

public void setParameters(SqlParameter[] parameters)

Specified by:

setParameters in class AbstractDBBatchStart

Parameters:

parameters - The parameters to set.

getIdComputer

public IdComputer getIdComputer()

Returns:

Returns the idComputer.

getNbLinesRead

public int getNbLinesRead()

Specified by:

getNbLinesRead in interface IBatchStart

Returns:

Returns the nbLinesRead.

isResumed

public boolean isResumed()

Returns:

Returns the resumed.

clone

public java.lang.Object clone()

Specified by:

clone in interface IBatchStart

Overrides:

clone in class AbstractDBBatchStart

Returns:

Cloned Object

See Also:

Object.clone()

preInit

public void preInit(BatchExecutionContext context)

Description copied from interface: IBatchStart

Called before Traitement#initialize(BatchExecutionContext context)

Specified by:

preInit in interface IBatchStart

Overrides:

preInit in class AbstractDBBatchStart

Parameters:

context - BatchExecutionContext

See Also:

IBatchStart.preInit(salto.batch.lanceur.thread.BatchExecutionContext)

validate

public void validate()

Description copied from interface: IBatchStart

Validate the configuration

Specified by:

validate in interface IBatchStart

See Also:

IBatchStart.validate()