Package org.apache.openjpa.lib.jdbc
Class DelegatingStatement
- java.lang.Object
-
- org.apache.openjpa.lib.jdbc.DelegatingStatement
-
- All Implemented Interfaces:
AutoCloseable,Statement,Wrapper,Closeable
- Direct Known Subclasses:
LoggingConnectionDecorator.LoggingConnection.LoggingStatement
public class DelegatingStatement extends Object implements Statement, Closeable
Wrapper around an existing statement. Subclasses can override the methods whose behavior they mean to change. TheequalsandhashCodemethods pass through to the base underlying data store statement.- Author:
- Abe White
-
-
Field Summary
-
Fields inherited from interface java.sql.Statement
CLOSE_ALL_RESULTS, CLOSE_CURRENT_RESULT, EXECUTE_FAILED, KEEP_CURRENT_RESULT, NO_GENERATED_KEYS, RETURN_GENERATED_KEYS, SUCCESS_NO_INFO
-
-
Constructor Summary
Constructors Constructor Description DelegatingStatement(Statement stmnt, Connection conn)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidaddBatch(String str)protected voidappendInfo(StringBuffer buf)voidcancel()voidclearBatch()voidclearWarnings()voidclose()voidcloseOnCompletion()booleanequals(Object other)booleanexecute(String str)booleanexecute(String s, int i)booleanexecute(String s, int[] ia)booleanexecute(String s, String[] sa)int[]executeBatch()ResultSetexecuteQuery(String str)protected ResultSetexecuteQuery(String sql, boolean wrap)Execute the query, with the option of not wrapping it in aDelegatingResultSet, which is the default.intexecuteUpdate(String str)intexecuteUpdate(String s, int i)intexecuteUpdate(String s, int[] ia)intexecuteUpdate(String s, String[] sa)ConnectiongetConnection()StatementgetDelegate()Return the wrapped statement.intgetFetchDirection()intgetFetchSize()ResultSetgetGeneratedKeys()StatementgetInnermostDelegate()Return the base underlying data store statement.intgetMaxFieldSize()intgetMaxRows()booleangetMoreResults()booleangetMoreResults(int i)intgetQueryTimeout()ResultSetgetResultSet()protected ResultSetgetResultSet(boolean wrap)Get the last result set, with the option of not wrapping it in aDelegatingResultSet, which is the default.intgetResultSetConcurrency()intgetResultSetHoldability()intgetResultSetType()intgetUpdateCount()SQLWarninggetWarnings()inthashCode()voidinitialize(Statement stmnt, Connection conn)booleanisClosed()booleanisCloseOnCompletion()booleanisPoolable()booleanisWrapperFor(Class<?> iface)voidsetCursorName(String str)voidsetEscapeProcessing(boolean bool)voidsetFetchDirection(int i)voidsetFetchSize(int i)voidsetMaxFieldSize(int i)voidsetMaxRows(int i)voidsetPoolable(boolean b)voidsetQueryTimeout(int i)StringtoString()<T> Tunwrap(Class<T> iface)protected ResultSetwrapResult(ResultSet rs, boolean wrap)-
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface java.sql.Statement
enquoteIdentifier, enquoteLiteral, enquoteNCharLiteral, executeLargeBatch, executeLargeUpdate, executeLargeUpdate, executeLargeUpdate, executeLargeUpdate, getLargeMaxRows, getLargeUpdateCount, isSimpleIdentifier, setLargeMaxRows
-
-
-
-
Constructor Detail
-
DelegatingStatement
public DelegatingStatement(Statement stmnt, Connection conn)
-
-
Method Detail
-
initialize
public void initialize(Statement stmnt, Connection conn)
-
getDelegate
public Statement getDelegate()
Return the wrapped statement.
-
getInnermostDelegate
public Statement getInnermostDelegate()
Return the base underlying data store statement.
-
appendInfo
protected void appendInfo(StringBuffer buf)
-
executeQuery
public ResultSet executeQuery(String str) throws SQLException
- Specified by:
executeQueryin interfaceStatement- Throws:
SQLException
-
executeQuery
protected ResultSet executeQuery(String sql, boolean wrap) throws SQLException
Execute the query, with the option of not wrapping it in aDelegatingResultSet, which is the default.- Throws:
SQLException
-
executeUpdate
public int executeUpdate(String str) throws SQLException
- Specified by:
executeUpdatein interfaceStatement- Throws:
SQLException
-
execute
public boolean execute(String str) throws SQLException
- Specified by:
executein interfaceStatement- Throws:
SQLException
-
close
public void close() throws SQLException- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceCloseable- Specified by:
closein interfaceStatement- Throws:
SQLException
-
getMaxFieldSize
public int getMaxFieldSize() throws SQLException- Specified by:
getMaxFieldSizein interfaceStatement- Throws:
SQLException
-
setMaxFieldSize
public void setMaxFieldSize(int i) throws SQLException- Specified by:
setMaxFieldSizein interfaceStatement- Throws:
SQLException
-
getMaxRows
public int getMaxRows() throws SQLException- Specified by:
getMaxRowsin interfaceStatement- Throws:
SQLException
-
setMaxRows
public void setMaxRows(int i) throws SQLException- Specified by:
setMaxRowsin interfaceStatement- Throws:
SQLException
-
setEscapeProcessing
public void setEscapeProcessing(boolean bool) throws SQLException- Specified by:
setEscapeProcessingin interfaceStatement- Throws:
SQLException
-
getQueryTimeout
public int getQueryTimeout() throws SQLException- Specified by:
getQueryTimeoutin interfaceStatement- Throws:
SQLException
-
setQueryTimeout
public void setQueryTimeout(int i) throws SQLException- Specified by:
setQueryTimeoutin interfaceStatement- Throws:
SQLException
-
cancel
public void cancel() throws SQLException- Specified by:
cancelin interfaceStatement- Throws:
SQLException
-
getWarnings
public SQLWarning getWarnings() throws SQLException
- Specified by:
getWarningsin interfaceStatement- Throws:
SQLException
-
clearWarnings
public void clearWarnings() throws SQLException- Specified by:
clearWarningsin interfaceStatement- Throws:
SQLException
-
setCursorName
public void setCursorName(String str) throws SQLException
- Specified by:
setCursorNamein interfaceStatement- Throws:
SQLException
-
getResultSet
public ResultSet getResultSet() throws SQLException
- Specified by:
getResultSetin interfaceStatement- Throws:
SQLException
-
getResultSet
protected ResultSet getResultSet(boolean wrap) throws SQLException
Get the last result set, with the option of not wrapping it in aDelegatingResultSet, which is the default.- Throws:
SQLException
-
getUpdateCount
public int getUpdateCount() throws SQLException- Specified by:
getUpdateCountin interfaceStatement- Throws:
SQLException
-
getMoreResults
public boolean getMoreResults() throws SQLException- Specified by:
getMoreResultsin interfaceStatement- Throws:
SQLException
-
setFetchDirection
public void setFetchDirection(int i) throws SQLException- Specified by:
setFetchDirectionin interfaceStatement- Throws:
SQLException
-
getFetchDirection
public int getFetchDirection() throws SQLException- Specified by:
getFetchDirectionin interfaceStatement- Throws:
SQLException
-
setFetchSize
public void setFetchSize(int i) throws SQLException- Specified by:
setFetchSizein interfaceStatement- Throws:
SQLException
-
getFetchSize
public int getFetchSize() throws SQLException- Specified by:
getFetchSizein interfaceStatement- Throws:
SQLException
-
getResultSetConcurrency
public int getResultSetConcurrency() throws SQLException- Specified by:
getResultSetConcurrencyin interfaceStatement- Throws:
SQLException
-
getResultSetType
public int getResultSetType() throws SQLException- Specified by:
getResultSetTypein interfaceStatement- Throws:
SQLException
-
addBatch
public void addBatch(String str) throws SQLException
- Specified by:
addBatchin interfaceStatement- Throws:
SQLException
-
clearBatch
public void clearBatch() throws SQLException- Specified by:
clearBatchin interfaceStatement- Throws:
SQLException
-
executeBatch
public int[] executeBatch() throws SQLException- Specified by:
executeBatchin interfaceStatement- Throws:
SQLException
-
getConnection
public Connection getConnection() throws SQLException
- Specified by:
getConnectionin interfaceStatement- Throws:
SQLException
-
getMoreResults
public boolean getMoreResults(int i) throws SQLException- Specified by:
getMoreResultsin interfaceStatement- Throws:
SQLException
-
getGeneratedKeys
public ResultSet getGeneratedKeys() throws SQLException
- Specified by:
getGeneratedKeysin interfaceStatement- Throws:
SQLException
-
executeUpdate
public int executeUpdate(String s, int i) throws SQLException
- Specified by:
executeUpdatein interfaceStatement- Throws:
SQLException
-
executeUpdate
public int executeUpdate(String s, int[] ia) throws SQLException
- Specified by:
executeUpdatein interfaceStatement- Throws:
SQLException
-
executeUpdate
public int executeUpdate(String s, String[] sa) throws SQLException
- Specified by:
executeUpdatein interfaceStatement- Throws:
SQLException
-
execute
public boolean execute(String s, int i) throws SQLException
- Specified by:
executein interfaceStatement- Throws:
SQLException
-
execute
public boolean execute(String s, int[] ia) throws SQLException
- Specified by:
executein interfaceStatement- Throws:
SQLException
-
execute
public boolean execute(String s, String[] sa) throws SQLException
- Specified by:
executein interfaceStatement- Throws:
SQLException
-
getResultSetHoldability
public int getResultSetHoldability() throws SQLException- Specified by:
getResultSetHoldabilityin interfaceStatement- Throws:
SQLException
-
isWrapperFor
public boolean isWrapperFor(Class<?> iface) throws SQLException
- Specified by:
isWrapperForin interfaceWrapper- Throws:
SQLException
-
unwrap
public <T> T unwrap(Class<T> iface) throws SQLException
- Specified by:
unwrapin interfaceWrapper- Throws:
SQLException
-
isClosed
public boolean isClosed() throws SQLException- Specified by:
isClosedin interfaceStatement- Throws:
SQLException
-
setPoolable
public void setPoolable(boolean b) throws SQLException- Specified by:
setPoolablein interfaceStatement- Throws:
SQLException
-
isPoolable
public boolean isPoolable() throws SQLException- Specified by:
isPoolablein interfaceStatement- Throws:
SQLException
-
isCloseOnCompletion
public boolean isCloseOnCompletion() throws SQLException- Specified by:
isCloseOnCompletionin interfaceStatement- Throws:
SQLException
-
closeOnCompletion
public void closeOnCompletion() throws SQLException- Specified by:
closeOnCompletionin interfaceStatement- Throws:
SQLException
-
-