org.julp.db

Class DBServices

java.lang.Object

org.julp.db.DBServices

All Implemented Interfaces:

java.io.Serializable

public class DBServices
extends java.lang.Object
implements java.io.Serializable

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DBServices.StoredProcedureResult
static class	DBServices.TransactionOnCloseConnection

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	audit
protected java.util.List<StatementHolder>	auditTrail
protected java.lang.String	cachedRowSetClassName
protected BasicStatementCache	cachedStatements
protected boolean	cacheStatements
protected java.sql.CallableStatement	callStatement
protected static java.util.Map<java.lang.String,java.lang.Class<?>>	classSubstitute
protected boolean	closeResultSet
protected boolean	closeStatementAfterExecute
protected int	concurrency
protected java.sql.Connection	connection
protected boolean	connectionClosed
protected java.lang.String	connectionId
protected java.util.Properties	connectionProperties
protected Converter	converter
protected java.lang.String	cursorName
protected javax.sql.DataSource	dataSource
protected boolean	escapeProcessing
protected int	fetchDirection
protected int	fetchSize
protected int	maxFieldSize
protected int	maxNumberOfParams
protected int	maxRows
protected int	maxRowsToProcessInTransaction
protected int	maxStatementCacheSize
protected java.lang.String	placeHolder
protected java.sql.PreparedStatement	preparedStatement
protected DBServices.StoredProcedureResult	processResult
protected boolean	processStoredProc
protected boolean	processWarnings
protected int	queryTimeout
protected boolean	readOnly
protected boolean	resetDataSource
protected java.sql.ResultSet	resultSet
protected java.util.List<java.sql.ResultSet>	resultSets
protected int	resultSetType
protected int	rowsAffectedInTransaction
protected boolean	setConnectionToNullOnRelease
protected java.sql.Statement	statement
protected boolean	tranInProcess
protected DBServices.TransactionOnCloseConnection	transactionOnCloseConnection
protected java.util.List<DataHolder>	warnings

Constructor Summary

Constructors

Constructor and Description
DBServices()

Method Summary

Modifier and Type	Method and Description
protected void	addCachedStatement(java.lang.String statementId, java.sql.Statement statementToCache)
void	beginTran()
java.util.List<DataHolder>	calcAffectedRows(int[] batchUpdates)
void	clearStatementCache()
protected void	closeResults()
void	commitTran()
protected void	createStatement()
int	execute(java.lang.String sql)
int	execute(java.lang.String sql, java.util.Collection params)
int[]	executeBatch(java.util.Collection<java.lang.String> batch)
int[]	executeBatch(java.lang.String sql, java.util.Collection<java.util.Collection> batch)
java.util.List	executeStoredProcedure(java.lang.String sql, Parameters params, DBServices.StoredProcedureResult processResult)
java.util.List<StatementHolder>	getAuditTrail()
java.lang.String	getCachedRowSetClassName()
java.util.Map<java.lang.String,java.lang.Class<?>>	getClassSubstitute()
int	getConcurrency() Getter for property concurrency.
java.sql.Connection	getConnection() Getter for property connection.
java.lang.String	getConnectionId() Getter for property connectionId.
java.util.Properties	getConnectionProperties() Getter for property connectionProperties.
Converter	getConverter()
java.sql.ResultSet	getCurrentResultSet()
java.util.List<java.sql.ResultSet>	getCurrentResultSets()
java.lang.String	getCursorName()
javax.sql.DataSource	getDataSource() Getter for property dataSource.
boolean	getEscapeProcessing() Getter for property escapeProcessing.
int	getFetchDirection() Getter for property fetchDirection.
int	getFetchSize() Getter for property fetchSize.
int	getMaxFieldSize() Getter for property maxFieldSize.
int	getMaxNumberOfParams()
int	getMaxRows() Getter for property maxRows.
int	getMaxRowsToProcessInTransaction() Getter for property maxRowsToProcessInTransaction.
int	getMaxStatementCacheSize()
java.lang.String	getPlaceHolder()
java.sql.PreparedStatement	getPreparedStatement(java.lang.String sql, java.util.Collection<?> params) Getter for property preparedStatement.
DBServices.TransactionOnCloseConnection	getProcessTransactionOnCloseConnection()
int	getQueryTimeout() Getter for property queryTimeout.
java.sql.ResultSet	getResultSet(java.lang.String sql) Getter for property resultSet.
java.sql.ResultSet	getResultSet(java.lang.String sql, java.util.Collection<?> params)
java.sql.ResultSet[]	getResultSets(java.lang.String sql, java.util.Collection<?> params)
java.sql.ResultSet[]	getResultSets(java.lang.String sql, java.util.Collection<?> params, int maxNumberOfParams, java.lang.String placeHolder)
int	getResultSetType() Getter for property resultSetType.
int	getRowsAffectedInTransaction() Getter for property rowsAffectedInTransaction.
java.sql.Statement	getStatement(java.lang.String sql) Getter for property statement.
java.util.List<DataHolder>	getWarnings()
boolean	isAudit()
boolean	isCacheStatements()
boolean	isCloseResultSet()
boolean	isCloseStatementAfterExecute() Getter for property closeStatementAfterExecute.
boolean	isConnectionClosed() Getter for property connectionClosed.
boolean	isProcessWarnings()
boolean	isResetDataSource() Getter for property resetDataSource.
boolean	isSetConnectionToNullOnRelease()
boolean	isTranInProcess() Getter for property tranInProcess.
void	populateWarnings(java.sql.SQLWarning warn) Make sure to read warnings before release()
protected void	prepareStatement(java.lang.String sql)
void	release(boolean closeConnection)
void	rollbackTran()
void	setAudit(boolean audit)
void	setCachedRowSetClassName(java.lang.String cachedRowSetClassName)
void	setCacheStatements(boolean cacheStatements)
void	setCloseResultSet(boolean closeResultSet)
void	setCloseStatementAfterExecute(boolean closeStatementAfterExecute) Setter for property closeStatementAfterExecute.
void	setConcurrency(int concurrency) Setter for property concurrency.
void	setConnection(java.sql.Connection connection) Setter for property connection.
protected void	setConnectionClosed(boolean connectionClosed) Setter for property connectionClosed.
void	setConnectionId(java.lang.String connectionId) Setter for property connectionId.
void	setConnectionProperties(java.util.Properties connectionProperties) Setter for property connectionProperties.
void	setConverter(Converter converter)
void	setCursorName(java.lang.String cursorName)
void	setDataSource(javax.sql.DataSource dataSource) Setter for property dataSource.
void	setEscapeProcessing(boolean escapeProcessing) Setter for property escapeProcessing.
void	setFetchDirection(int fetchDirection) Setter for property fetchDirection.
void	setFetchSize(int fetchSize) Setter for property fetchSize.
void	setMaxFieldSize(int maxFieldSize) Setter for property maxFieldSize.
void	setMaxNumberOfParams(int maxNumberOfParams)
void	setMaxRows(int maxRows) Setter for property maxRows.
void	setMaxRowsToProcessInTransaction(int maxRowsToProcessInTransaction) Setter for property maxRowsToProcessInTransaction.
void	setMaxStatementCacheSize(int maxStatementCacheSize)
void	setPlaceHolder(java.lang.String placeHolder)
void	setPreparedStatement(java.sql.PreparedStatement preparedStatement) Setter for property preparedStatement.
void	setProcessWarnings(boolean processWarnings)
void	setQueryTimeout(int queryTimeout) Setter for property queryTimeout.
void	setResetDataSource(boolean resetDataSource) Setter for property resetDataSource.
void	setResultSet(java.sql.ResultSet resultSet) Setter for property resultSet.
void	setResultSetType(int resultSetType) Setter for property resultSetType.
void	setRowsAffectedInTransaction(int rowsAffectedInTransaction) Setter for property rowsAffectedInTransaction.
void	setSetConnectionToNullOnRelease(boolean setConnectionToNullOnRelease)
void	setStatement(java.sql.Statement statement) Setter for property statement.
void	setTranInProcess(boolean tranInProcess) Setter for property tranInProcess.
void	setTransactionOnCloseConnection(DBServices.TransactionOnCloseConnection transactionOnCloseConnection)

Methods inherited from class java.lang.Object

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

Field Detail

connectionClosed

protected boolean connectionClosed

setConnectionToNullOnRelease

protected boolean setConnectionToNullOnRelease

dataSource

protected transient javax.sql.DataSource dataSource

connection

protected transient java.sql.Connection connection

statement

protected transient java.sql.Statement statement

preparedStatement

protected transient java.sql.PreparedStatement preparedStatement

callStatement

protected transient java.sql.CallableStatement callStatement

resultSet

protected transient java.sql.ResultSet resultSet

connectionProperties

protected java.util.Properties connectionProperties

cursorName

protected java.lang.String cursorName

maxFieldSize

protected int maxFieldSize

maxRows

protected int maxRows

queryTimeout

protected int queryTimeout

fetchDirection

protected int fetchDirection

fetchSize

protected int fetchSize

resultSetType

protected int resultSetType

concurrency

protected int concurrency

readOnly

protected boolean readOnly

closeStatementAfterExecute

protected boolean closeStatementAfterExecute

escapeProcessing

protected boolean escapeProcessing

tranInProcess

protected boolean tranInProcess

resetDataSource

protected boolean resetDataSource

processWarnings

protected boolean processWarnings

processStoredProc

protected boolean processStoredProc

closeResultSet

protected boolean closeResultSet

transactionOnCloseConnection

protected DBServices.TransactionOnCloseConnection transactionOnCloseConnection

maxRowsToProcessInTransaction

protected int maxRowsToProcessInTransaction

rowsAffectedInTransaction

protected int rowsAffectedInTransaction

connectionId

protected java.lang.String connectionId

placeHolder

protected java.lang.String placeHolder

maxNumberOfParams

protected int maxNumberOfParams

resultSets

protected transient java.util.List<java.sql.ResultSet> resultSets

warnings

protected java.util.List<DataHolder> warnings

processResult

protected DBServices.StoredProcedureResult processResult

converter

protected Converter converter

cacheStatements

protected boolean cacheStatements

maxStatementCacheSize

protected int maxStatementCacheSize

cachedRowSetClassName

protected java.lang.String cachedRowSetClassName

auditTrail

protected java.util.List<StatementHolder> auditTrail

audit

protected boolean audit

cachedStatements

protected BasicStatementCache cachedStatements

classSubstitute

protected static final java.util.Map<java.lang.String,java.lang.Class<?>> classSubstitute

Constructor Detail

DBServices

public DBServices()

Method Detail

getConnection

public java.sql.Connection getConnection()
                                  throws java.sql.SQLException

Getter for property connection.

Returns:

Value of property connection.

Throws:

java.sql.SQLException

setConnection

public void setConnection(java.sql.Connection connection)

Setter for property connection.

Parameters:

connection - New value of property connection.

getDataSource

public javax.sql.DataSource getDataSource()
                                   throws java.sql.SQLException

Getter for property dataSource.

Returns:

Value of property dataSource.

Throws:

java.sql.SQLException

setDataSource

public void setDataSource(javax.sql.DataSource dataSource)

Setter for property dataSource.

Parameters:

dataSource - New value of property dataSource.

prepareStatement

protected void prepareStatement(java.lang.String sql)
                         throws java.sql.SQLException

Throws:

java.sql.SQLException

getPreparedStatement

public java.sql.PreparedStatement getPreparedStatement(java.lang.String sql,
                                                       java.util.Collection<?> params)
                                                throws java.sql.SQLException

Getter for property preparedStatement.

Returns:

Value of property preparedStatement.

Throws:

java.sql.SQLException

setPreparedStatement

public void setPreparedStatement(java.sql.PreparedStatement preparedStatement)

Setter for property preparedStatement.

Parameters:

preparedStatement - New value of property preparedStatement.

getCurrentResultSet

public java.sql.ResultSet getCurrentResultSet()

getCurrentResultSets

public java.util.List<java.sql.ResultSet> getCurrentResultSets()

getResultSet

public java.sql.ResultSet getResultSet(java.lang.String sql)
                                throws java.sql.SQLException

Getter for property resultSet.

Returns:

value of property resultSet.

Throws:

java.sql.SQLException

getResultSet

public java.sql.ResultSet getResultSet(java.lang.String sql,
                                       java.util.Collection<?> params)
                                throws java.sql.SQLException

Throws:

java.sql.SQLException

getResultSets

public java.sql.ResultSet[] getResultSets(java.lang.String sql,
                                          java.util.Collection<?> params,
                                          int maxNumberOfParams,
                                          java.lang.String placeHolder)
                                   throws java.sql.SQLException

Throws:

java.sql.SQLException

getResultSets

public java.sql.ResultSet[] getResultSets(java.lang.String sql,
                                          java.util.Collection<?> params)
                                   throws java.sql.SQLException

Throws:

java.sql.SQLException

executeStoredProcedure

public java.util.List executeStoredProcedure(java.lang.String sql,
                                             Parameters params,
                                             DBServices.StoredProcedureResult processResult)
                                      throws java.sql.SQLException

Throws:

java.sql.SQLException

executeBatch

public int[] executeBatch(java.lang.String sql,
                          java.util.Collection<java.util.Collection> batch)
                   throws java.sql.SQLException

Throws:

java.sql.SQLException

executeBatch

public int[] executeBatch(java.util.Collection<java.lang.String> batch)
                   throws java.sql.SQLException

Throws:

java.sql.SQLException

calcAffectedRows

public java.util.List<DataHolder> calcAffectedRows(int[] batchUpdates)

execute

public int execute(java.lang.String sql)
            throws java.sql.SQLException

Throws:

java.sql.SQLException

execute

public int execute(java.lang.String sql,
                   java.util.Collection params)
            throws java.sql.SQLException

Throws:

java.sql.SQLException

setResultSet

public void setResultSet(java.sql.ResultSet resultSet)

Setter for property resultSet.

Parameters:

resultSet - New value of property resultSet.

createStatement

protected void createStatement()
                        throws java.sql.SQLException

Throws:

java.sql.SQLException

getStatement

public java.sql.Statement getStatement(java.lang.String sql)
                                throws java.sql.SQLException

Getter for property statement.

Returns:

Value of property statement.

Throws:

java.sql.SQLException

closeResults

protected void closeResults()
                     throws java.sql.SQLException

Throws:

java.sql.SQLException

setStatement

public void setStatement(java.sql.Statement statement)

Setter for property statement.

Parameters:

statement - New value of property statement.

release

public void release(boolean closeConnection)
             throws java.sql.SQLException

Throws:

java.sql.SQLException

beginTran

public void beginTran()
               throws java.sql.SQLException

Throws:

java.sql.SQLException

commitTran

public void commitTran()
                throws java.sql.SQLException

Throws:

java.sql.SQLException

rollbackTran

public void rollbackTran()
                  throws java.sql.SQLException

Throws:

java.sql.SQLException

getFetchSize

public int getFetchSize()

Getter for property fetchSize.

Returns:

Value of property fetchSize.

setFetchSize

public void setFetchSize(int fetchSize)

Setter for property fetchSize.

Parameters:

fetchSize - New value of property fetchSize.

getFetchDirection

public int getFetchDirection()

Getter for property fetchDirection.

Returns:

Value of property fetchDirection.

setFetchDirection

public void setFetchDirection(int fetchDirection)

Setter for property fetchDirection.

Parameters:

fetchDirection - New value of property fetchDirection.

getQueryTimeout

public int getQueryTimeout()

Getter for property queryTimeout.

Returns:

Value of property queryTimeout.

setQueryTimeout

public void setQueryTimeout(int queryTimeout)

Setter for property queryTimeout.

Parameters:

queryTimeout - New value of property queryTimeout.

getMaxRows

public int getMaxRows()

Getter for property maxRows.

Returns:

Value of property maxRows.

setMaxRows

public void setMaxRows(int maxRows)

Setter for property maxRows.

Parameters:

maxRows - New value of property maxRows.

getMaxFieldSize

public int getMaxFieldSize()

Getter for property maxFieldSize.

Returns:

Value of property maxFieldSize.

setMaxFieldSize

public void setMaxFieldSize(int maxFieldSize)

Setter for property maxFieldSize.

Parameters:

maxFieldSize - New value of property maxFieldSize.

getEscapeProcessing

public boolean getEscapeProcessing()

Getter for property escapeProcessing.

Returns:

Value of property escapeProcessing.

setEscapeProcessing

public void setEscapeProcessing(boolean escapeProcessing)

Setter for property escapeProcessing.

Parameters:

escapeProcessing - New value of property escapeProcessing.

getResultSetType

public int getResultSetType()

Getter for property resultSetType.

Returns:

Value of property resultSetType.

setResultSetType

public void setResultSetType(int resultSetType)

Setter for property resultSetType.

Parameters:

resultSetType - New value of property resultSetType.

getConcurrency

public int getConcurrency()

Getter for property concurrency.

Returns:

Value of property concurrency.

setConcurrency

public void setConcurrency(int concurrency)

Setter for property concurrency.

Parameters:

concurrency - New value of property concurrency.

isConnectionClosed

public boolean isConnectionClosed()

Getter for property connectionClosed.

Returns:

Value of property connectionClosed.

setConnectionClosed

protected void setConnectionClosed(boolean connectionClosed)

Setter for property connectionClosed.

Parameters:

connectionClosed - New value of property connectionClosed.

getMaxRowsToProcessInTransaction

public int getMaxRowsToProcessInTransaction()

Getter for property maxRowsToProcessInTransaction.

Returns:

Value of property maxRowsToProcessInTransaction.

setMaxRowsToProcessInTransaction

public void setMaxRowsToProcessInTransaction(int maxRowsToProcessInTransaction)
                                      throws java.sql.SQLException

Setter for property maxRowsToProcessInTransaction.

Parameters:

maxRowsToProcessInTransaction - New value of property maxRowsToProcessInTransaction.

Throws:

java.sql.SQLException

getRowsAffectedInTransaction

public int getRowsAffectedInTransaction()

Getter for property rowsAffectedInTransaction.

Returns:

Value of property rowsAffectedInTransaction.

setRowsAffectedInTransaction

public void setRowsAffectedInTransaction(int rowsAffectedInTransaction)
                                  throws java.sql.SQLException

Setter for property rowsAffectedInTransaction.

Parameters:

rowsAffectedInTransaction - New value of property rowsAffectedInTransaction.

Throws:

java.sql.SQLException

getConnectionProperties

public java.util.Properties getConnectionProperties()

Getter for property connectionProperties.

Returns:

Value of property connectionProperties.

setConnectionProperties

public void setConnectionProperties(java.util.Properties connectionProperties)

Setter for property connectionProperties.

Parameters:

connectionProperties - New value of property connectionProperties.

isCloseStatementAfterExecute

public boolean isCloseStatementAfterExecute()

Getter for property closeStatementAfterExecute.

Returns:

Value of property closeStatementAfterExecute.

setCloseStatementAfterExecute

public void setCloseStatementAfterExecute(boolean closeStatementAfterExecute)

Setter for property closeStatementAfterExecute.

Parameters:

closeStatementAfterExecute - New value of property closeStatementAfterExecute.

getConnectionId

public java.lang.String getConnectionId()

Getter for property connectionId.

Returns:

Value of property connectionId.

setConnectionId

public void setConnectionId(java.lang.String connectionId)

Setter for property connectionId.

Parameters:

connectionId - New value of property connectionId.

isTranInProcess

public boolean isTranInProcess()

Getter for property tranInProcess.

Returns:

Value of property tranInProcess.

setTranInProcess

public void setTranInProcess(boolean tranInProcess)

Setter for property tranInProcess.

Parameters:

tranInProcess - New value of property tranInProcess.

isResetDataSource

public boolean isResetDataSource()

Getter for property resetDataSource.

Returns:

Value of property resetDataSource.

setResetDataSource

public void setResetDataSource(boolean resetDataSource)

Setter for property resetDataSource.

Parameters:

resetDataSource - New value of property resetDataSource.

getPlaceHolder

public java.lang.String getPlaceHolder()

setPlaceHolder

public void setPlaceHolder(java.lang.String placeHolder)

getMaxNumberOfParams

public int getMaxNumberOfParams()

setMaxNumberOfParams

public void setMaxNumberOfParams(int maxNumberOfParams)

getWarnings

public java.util.List<DataHolder> getWarnings()

setProcessWarnings

public void setProcessWarnings(boolean processWarnings)

isProcessWarnings

public boolean isProcessWarnings()

populateWarnings

public void populateWarnings(java.sql.SQLWarning warn)

Make sure to read warnings before release()

Parameters:

warn -

isCacheStatements

public boolean isCacheStatements()

clearStatementCache

public void clearStatementCache()

setCacheStatements

public void setCacheStatements(boolean cacheStatements)

getMaxStatementCacheSize

public int getMaxStatementCacheSize()

setMaxStatementCacheSize

public void setMaxStatementCacheSize(int maxStatementCacheSize)

addCachedStatement

protected void addCachedStatement(java.lang.String statementId,
                                  java.sql.Statement statementToCache)
                           throws java.sql.SQLException

Throws:

java.sql.SQLException

getCachedRowSetClassName

public java.lang.String getCachedRowSetClassName()

setCachedRowSetClassName

public void setCachedRowSetClassName(java.lang.String cachedRowSetClassName)

setCloseResultSet

public void setCloseResultSet(boolean closeResultSet)

isCloseResultSet

public boolean isCloseResultSet()

getCursorName

public java.lang.String getCursorName()

setCursorName

public void setCursorName(java.lang.String cursorName)

getProcessTransactionOnCloseConnection

public DBServices.TransactionOnCloseConnection getProcessTransactionOnCloseConnection()

setTransactionOnCloseConnection

public void setTransactionOnCloseConnection(DBServices.TransactionOnCloseConnection transactionOnCloseConnection)

isSetConnectionToNullOnRelease

public boolean isSetConnectionToNullOnRelease()

setSetConnectionToNullOnRelease

public void setSetConnectionToNullOnRelease(boolean setConnectionToNullOnRelease)

isAudit

public boolean isAudit()

setAudit

public void setAudit(boolean audit)

getAuditTrail

public java.util.List<StatementHolder> getAuditTrail()

getConverter

public Converter getConverter()

setConverter

public void setConverter(Converter converter)

getClassSubstitute

public java.util.Map<java.lang.String,java.lang.Class<?>> getClassSubstitute()