ambit2.db

Class StatementExecutor<Q extends net.idea.modbcum.i.IStatement,Results>

java.lang.Object

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

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

ambit2.db.StatementExecutor<Q,Results>

All Implemented Interfaces:

Serializable, net.idea.modbcum.i.IDBProcessor<Q,Results>, net.idea.modbcum.i.processors.IProcessor<Q,Results>

Direct Known Subclasses:

PreparedStatementBatchExecutor, QueryExecutor, UpdateExecutor

public abstract class StatementExecutor<Q extends net.idea.modbcum.i.IStatement,Results>
extends net.idea.modbcum.p.AbstractDBProcessor<Q,Results>

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected Hashtable<String,PreparedStatement>	cache
protected boolean	useCache

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
StatementExecutor()

Method Summary

Modifier and Type	Method and Description
protected void	addStatementToCache(String sql, PreparedStatement p)
void	close()
void	closeResults(Results rs)
protected abstract Results	execute(Connection c, Q target)
protected PreparedStatement	getCachedStatement(String sql)
boolean	isUseCache() Deprecated.
void	open()
Results	process(Q target)
void	setConnection(Connection connection)
static void	setParameters(PreparedStatement ps, List<net.idea.modbcum.i.query.QueryParam> params)
void	setUseCache(boolean useCache) Deprecated.

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

cache

protected Hashtable<String,PreparedStatement> cache

useCache

protected boolean useCache

Constructor Detail

StatementExecutor

public StatementExecutor()

Method Detail

isUseCache

@Deprecated
public boolean isUseCache()

Deprecated.

setUseCache

@Deprecated
public void setUseCache(boolean useCache)

Deprecated.

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.IStatement,Results>

Overrides:

setConnection in class net.idea.modbcum.p.AbstractDBProcessor<Q extends net.idea.modbcum.i.IStatement,Results>

Throws:

net.idea.modbcum.i.exceptions.DbAmbitException

getCachedStatement

protected PreparedStatement getCachedStatement(String sql)

addStatementToCache

protected void addStatementToCache(String sql,
                                   PreparedStatement p)

setParameters

public static void setParameters(PreparedStatement ps,
                                 List<net.idea.modbcum.i.query.QueryParam> params)
                          throws SQLException

Throws:

SQLException

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.IStatement,Results>

Overrides:

open in class net.idea.modbcum.p.DefaultAmbitProcessor<Q extends net.idea.modbcum.i.IStatement,Results>

Throws:

net.idea.modbcum.i.exceptions.DbAmbitException

process

public Results process(Q target)
                throws net.idea.modbcum.i.exceptions.AmbitException

Throws:

net.idea.modbcum.i.exceptions.AmbitException

execute

protected abstract Results execute(Connection c,
                                   Q target)
                            throws SQLException,
                                   net.idea.modbcum.i.exceptions.AmbitException

Throws:

SQLException

net.idea.modbcum.i.exceptions.AmbitException

closeResults

public void closeResults(Results rs)
                  throws SQLException

Throws:

SQLException

close

public void close()
           throws Exception

Specified by:

close in interface net.idea.modbcum.i.processors.IProcessor<Q extends net.idea.modbcum.i.IStatement,Results>

Overrides:

close in class net.idea.modbcum.p.AbstractDBProcessor<Q extends net.idea.modbcum.i.IStatement,Results>

Throws:

Exception