org.waarp.openr66.dao.database

Class StatementExecutor<E>

java.lang.Object

org.waarp.openr66.dao.database.StatementExecutor<E>

All Implemented Interfaces:

Cloneable, AbstractDAO<E>

Direct Known Subclasses:

DBBusinessDAO, DBHostDAO, DBLimitDAO, DBMultipleMonitorDAO, DBRuleDAO, DBTransferDAO

public abstract class StatementExecutor<E>
extends Object
implements AbstractDAO<E>

Field Summary

Fields

Modifier and Type	Field and Description
protected Connection	connection
protected static String	PARAMETER
protected static String	PARAMETER_COMMA
protected static String	SQL_COUNT_ALL_PREFIX
protected static String	WHERE

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	StatementExecutor(Connection con)

Method Summary

Modifier and Type	Method and Description
protected void	addToCache(String key, E elt)
protected void	clearCache()
void	close()
protected void	closeResultSet(ResultSet rs)
protected void	closeStatement(Statement stm)
long	count(List<Filter> filters) Count all objects corresponding to the given filters from the persistance layer
void	delete(E e1) Remove the specified object from the persistance layer
int	delete(List<Filter> filters) Delete all items according to filter
void	deleteAll() Remove all objects from the persistance layer
protected int	executeAction(PreparedStatement stm)
protected ResultSet	executeQuery(PreparedStatement stm)
protected void	executeUpdate(PreparedStatement stm)
boolean	exist(String id) Verify if an object with the specified id exists in the persistance layer
List<E>	find(List<Filter> filters) Retrieve all objects corresponding to the given filters in a List from the persistance layer
List<E>	find(List<Filter> filters, int limit) Retrieve all objects corresponding to the given filters in a List from the persistance layer
List<E>	find(List<Filter> filters, String field, boolean asc) Retrieve all objects corresponding to the given filters in a List from the persistance layer
List<E>	find(List<Filter> filters, String field, boolean asc, int limit) Retrieve all objects corresponding to the given filters in a List from the persistance layer
List<E>	find(List<Filter> filters, String field, boolean asc, int limit, int offset) Retrieve all objects corresponding to the given filters in a List from the persistance layer
List<E>	getAll() Retrieve all objects in a List from the persistance layer
protected SynchronizedLruCache<String,E>	getCache()
Connection	getConnection()
protected abstract String	getCountRequest()
protected abstract String	getDeleteAllRequest()
protected abstract String	getDeleteRequest()
protected abstract String	getExistRequest()
protected E	getFromCache(String key)
abstract E	getFromResultSet(ResultSet set)
protected abstract String	getGetAllRequest()
protected abstract String	getId(E e1)
protected abstract String	getInsertRequest()
protected abstract Object[]	getInsertValues(E e1)
protected abstract String	getSelectRequest()
protected abstract String	getTable()
protected abstract String	getUpdateRequest()
protected abstract Object[]	getUpdateValues(E e1)
void	insert(E e1) Insert the specified object in the persistance layer
protected abstract boolean	isCachedEnable()
protected abstract boolean	isDbTransfer()
protected boolean	isInCache(String key)
protected String	prepareCountQuery(List<Filter> filters, Object[] params)
protected String	prepareDeleteQuery(List<Filter> filters, Object[] params)
protected Object[]	prepareFindParams(List<Filter> filters)
protected String	prepareFindQuery(List<Filter> filters, Object[] params)
protected void	removeFromCache(String key)
E	select(String id) Retrieve the object with the specified id from the persistance layer
protected void	setParameters(PreparedStatement stm, Object... values)
void	update(E e1) Update the specified object in the persistance layer
void	update(List<Filter> filters, String fieldToSet) Update all objects corresponding to the given filters in a List from the persistance layer

Methods inherited from class java.lang.Object

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

Field Detail

WHERE

protected static final String WHERE

See Also:

Constant Field Values

PARAMETER

protected static final String PARAMETER

See Also:

Constant Field Values

PARAMETER_COMMA

protected static final String PARAMETER_COMMA

See Also:

Constant Field Values

SQL_COUNT_ALL_PREFIX

protected static final String SQL_COUNT_ALL_PREFIX

See Also:

Constant Field Values

connection

protected Connection connection

Constructor Detail

StatementExecutor

protected StatementExecutor(Connection con)

Method Detail

isDbTransfer

protected abstract boolean isDbTransfer()

getFromResultSet

public abstract E getFromResultSet(ResultSet set)
                            throws SQLException,
                                   DAOConnectionException

Throws:

SQLException

DAOConnectionException

isCachedEnable

protected abstract boolean isCachedEnable()

getCache

protected SynchronizedLruCache<String,E> getCache()

clearCache

protected final void clearCache()

addToCache

protected final void addToCache(String key,
                                E elt)

getFromCache

protected final E getFromCache(String key)

removeFromCache

protected final void removeFromCache(String key)

isInCache

protected final boolean isInCache(String key)

getConnection

public Connection getConnection()

setParameters

protected final void setParameters(PreparedStatement stm,
                                   Object... values)
                            throws SQLException

Throws:

SQLException

executeUpdate

protected final void executeUpdate(PreparedStatement stm)
                            throws SQLException

Throws:

SQLException

executeAction

protected final int executeAction(PreparedStatement stm)
                           throws SQLException

Throws:

SQLException

executeQuery

protected final ResultSet executeQuery(PreparedStatement stm)
                                throws SQLException

Throws:

SQLException

closeStatement

protected final void closeStatement(Statement stm)

closeResultSet

protected final void closeResultSet(ResultSet rs)

close

public final void close()

Specified by:

close in interface AbstractDAO<E>

getId

protected abstract String getId(E e1)

getTable

protected abstract String getTable()

getSelectRequest

protected abstract String getSelectRequest()

getCountRequest

protected abstract String getCountRequest()

getGetAllRequest

protected abstract String getGetAllRequest()

getExistRequest

protected abstract String getExistRequest()

getInsertValues

protected abstract Object[] getInsertValues(E e1)
                                     throws WaarpDatabaseSqlException

Throws:

WaarpDatabaseSqlException

getInsertRequest

protected abstract String getInsertRequest()

getUpdateValues

protected abstract Object[] getUpdateValues(E e1)
                                     throws WaarpDatabaseSqlException

Throws:

WaarpDatabaseSqlException

getUpdateRequest

protected abstract String getUpdateRequest()

getDeleteRequest

protected abstract String getDeleteRequest()

getDeleteAllRequest

protected abstract String getDeleteAllRequest()

delete

public void delete(E e1)
            throws DAOConnectionException,
                   DAONoDataException

Description copied from interface: AbstractDAO

Remove the specified object from the persistance layer

Specified by:

delete in interface AbstractDAO<E>

Parameters:

e1 - object to delete

Throws:

DAOConnectionException - If a data access error occurs

DAONoDataException - if no data are available

deleteAll

public final void deleteAll()
                     throws DAOConnectionException

Description copied from interface: AbstractDAO

Remove all objects from the persistance layer

Specified by:

deleteAll in interface AbstractDAO<E>

Throws:

DAOConnectionException - If a data access error occurs

prepareDeleteQuery

protected final String prepareDeleteQuery(List<Filter> filters,
                                          Object[] params)

delete

public final int delete(List<Filter> filters)
                 throws DAOConnectionException

Delete all items according to filter

Parameters:

filters -

Returns:

the number of deleted items

Throws:

DAOConnectionException

getAll

public final List<E> getAll()
                     throws DAOConnectionException

Description copied from interface: AbstractDAO

Retrieve all objects in a List from the persistance layer

Specified by:

getAll in interface AbstractDAO<E>

Throws:

DAOConnectionException - If data access error occurs

prepareFindQuery

protected final String prepareFindQuery(List<Filter> filters,
                                        Object[] params)

prepareFindParams

protected final Object[] prepareFindParams(List<Filter> filters)

find

public final List<E> find(List<Filter> filters)
                   throws DAOConnectionException

Description copied from interface: AbstractDAO

Retrieve all objects corresponding to the given filters in a List from the persistance layer

Specified by:

find in interface AbstractDAO<E>

Parameters:

filters - List of filter

Throws:

DAOConnectionException - If data access error occurs

find

public final List<E> find(List<Filter> filters,
                          int limit)
                   throws DAOConnectionException

Description copied from interface: AbstractDAO

Retrieve all objects corresponding to the given filters in a List from the persistance layer

Specified by:

find in interface AbstractDAO<E>

Parameters:

filters - List of filter

limit - max number of items to get

Throws:

DAOConnectionException - If data access error occurs

find

public final List<E> find(List<Filter> filters,
                          String field,
                          boolean asc)
                   throws DAOConnectionException

Description copied from interface: AbstractDAO

Retrieve all objects corresponding to the given filters in a List from the persistance layer

Specified by:

find in interface AbstractDAO<E>

Parameters:

filters - List of filter

field - field to sort on

asc - True for ascending, False for descending order

Throws:

DAOConnectionException - If data access error occurs

find

public final List<E> find(List<Filter> filters,
                          String field,
                          boolean asc,
                          int limit)
                   throws DAOConnectionException

Description copied from interface: AbstractDAO

Retrieve all objects corresponding to the given filters in a List from the persistance layer

Specified by:

find in interface AbstractDAO<E>

Parameters:

filters - List of filter

field - field to sort on

asc - True for ascending, False for descending order

limit - max number of items to get

Throws:

DAOConnectionException - If data access error occurs

find

public final List<E> find(List<Filter> filters,
                          String field,
                          boolean asc,
                          int limit,
                          int offset)
                   throws DAOConnectionException

Description copied from interface: AbstractDAO

Retrieve all objects corresponding to the given filters in a List from the persistance layer

Specified by:

find in interface AbstractDAO<E>

Parameters:

filters - List of filter

field - field to sort on

asc - True for ascending, False for descending order

limit - max number of items to get

offset - start for items to get

Throws:

DAOConnectionException - If data access error occurs

update

public final void update(List<Filter> filters,
                         String fieldToSet)
                  throws DAOConnectionException

Description copied from interface: AbstractDAO

Update all objects corresponding to the given filters in a List from the persistance layer

Specified by:

update in interface AbstractDAO<E>

Parameters:

filters - List of filter

fieldToSet - field to update as "field1 = value1, field2 = value2, ..."

Throws:

DAOConnectionException - If data access error occurs

prepareCountQuery

protected final String prepareCountQuery(List<Filter> filters,
                                         Object[] params)

count

public final long count(List<Filter> filters)
                 throws DAOConnectionException

Description copied from interface: AbstractDAO

Count all objects corresponding to the given filters from the persistance layer

Specified by:

count in interface AbstractDAO<E>

Parameters:

filters - List of filter

Throws:

DAOConnectionException - If data access error occurs

exist

public final boolean exist(String id)
                    throws DAOConnectionException

Description copied from interface: AbstractDAO

Verify if an object with the specified id exists in the persistance layer

Specified by:

exist in interface AbstractDAO<E>

Parameters:

id - id of the object verified

Returns:

true if a object with the specified id exist; false if no object correspond to the specified id.

Throws:

DAOConnectionException - If a data access error occurs

select

public final E select(String id)
               throws DAOConnectionException,
                      DAONoDataException

Description copied from interface: AbstractDAO

Retrieve the object with the specified id from the persistance layer

Specified by:

select in interface AbstractDAO<E>

Parameters:

id - id of the object requested

Throws:

DAOConnectionException - If a data access error occurs

DAONoDataException - if no data are available

insert

public void insert(E e1)
            throws DAOConnectionException

Description copied from interface: AbstractDAO

Insert the specified object in the persistance layer

Specified by:

insert in interface AbstractDAO<E>

Parameters:

e1 - object to insert

Throws:

DAOConnectionException - If a data access error occurs

update

public final void update(E e1)
                  throws DAOConnectionException,
                         DAONoDataException

Description copied from interface: AbstractDAO

Update the specified object in the persistance layer

Specified by:

update in interface AbstractDAO<E>

Parameters:

e1 - object to update

Throws:

DAOConnectionException - If a data access error occurs

DAONoDataException - if no data are available