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. Theequals
andhashCode
methods 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 void
addBatch(String str)
protected void
appendInfo(StringBuffer buf)
void
cancel()
void
clearBatch()
void
clearWarnings()
void
close()
void
closeOnCompletion()
boolean
equals(Object other)
boolean
execute(String str)
boolean
execute(String s, int i)
boolean
execute(String s, int[] ia)
boolean
execute(String s, String[] sa)
int[]
executeBatch()
ResultSet
executeQuery(String str)
protected ResultSet
executeQuery(String sql, boolean wrap)
Execute the query, with the option of not wrapping it in aDelegatingResultSet
, which is the default.int
executeUpdate(String str)
int
executeUpdate(String s, int i)
int
executeUpdate(String s, int[] ia)
int
executeUpdate(String s, String[] sa)
Connection
getConnection()
Statement
getDelegate()
Return the wrapped statement.int
getFetchDirection()
int
getFetchSize()
ResultSet
getGeneratedKeys()
Statement
getInnermostDelegate()
Return the base underlying data store statement.int
getMaxFieldSize()
int
getMaxRows()
boolean
getMoreResults()
boolean
getMoreResults(int i)
int
getQueryTimeout()
ResultSet
getResultSet()
protected ResultSet
getResultSet(boolean wrap)
Get the last result set, with the option of not wrapping it in aDelegatingResultSet
, which is the default.int
getResultSetConcurrency()
int
getResultSetHoldability()
int
getResultSetType()
int
getUpdateCount()
SQLWarning
getWarnings()
int
hashCode()
void
initialize(Statement stmnt, Connection conn)
boolean
isClosed()
boolean
isCloseOnCompletion()
boolean
isPoolable()
boolean
isWrapperFor(Class<?> iface)
void
setCursorName(String str)
void
setEscapeProcessing(boolean bool)
void
setFetchDirection(int i)
void
setFetchSize(int i)
void
setMaxFieldSize(int i)
void
setMaxRows(int i)
void
setPoolable(boolean b)
void
setQueryTimeout(int i)
String
toString()
<T> T
unwrap(Class<T> iface)
protected ResultSet
wrapResult(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:
executeQuery
in 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:
executeUpdate
in interfaceStatement
- Throws:
SQLException
-
execute
public boolean execute(String str) throws SQLException
- Specified by:
execute
in interfaceStatement
- Throws:
SQLException
-
close
public void close() throws SQLException
- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceCloseable
- Specified by:
close
in interfaceStatement
- Throws:
SQLException
-
getMaxFieldSize
public int getMaxFieldSize() throws SQLException
- Specified by:
getMaxFieldSize
in interfaceStatement
- Throws:
SQLException
-
setMaxFieldSize
public void setMaxFieldSize(int i) throws SQLException
- Specified by:
setMaxFieldSize
in interfaceStatement
- Throws:
SQLException
-
getMaxRows
public int getMaxRows() throws SQLException
- Specified by:
getMaxRows
in interfaceStatement
- Throws:
SQLException
-
setMaxRows
public void setMaxRows(int i) throws SQLException
- Specified by:
setMaxRows
in interfaceStatement
- Throws:
SQLException
-
setEscapeProcessing
public void setEscapeProcessing(boolean bool) throws SQLException
- Specified by:
setEscapeProcessing
in interfaceStatement
- Throws:
SQLException
-
getQueryTimeout
public int getQueryTimeout() throws SQLException
- Specified by:
getQueryTimeout
in interfaceStatement
- Throws:
SQLException
-
setQueryTimeout
public void setQueryTimeout(int i) throws SQLException
- Specified by:
setQueryTimeout
in interfaceStatement
- Throws:
SQLException
-
cancel
public void cancel() throws SQLException
- Specified by:
cancel
in interfaceStatement
- Throws:
SQLException
-
getWarnings
public SQLWarning getWarnings() throws SQLException
- Specified by:
getWarnings
in interfaceStatement
- Throws:
SQLException
-
clearWarnings
public void clearWarnings() throws SQLException
- Specified by:
clearWarnings
in interfaceStatement
- Throws:
SQLException
-
setCursorName
public void setCursorName(String str) throws SQLException
- Specified by:
setCursorName
in interfaceStatement
- Throws:
SQLException
-
getResultSet
public ResultSet getResultSet() throws SQLException
- Specified by:
getResultSet
in 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:
getUpdateCount
in interfaceStatement
- Throws:
SQLException
-
getMoreResults
public boolean getMoreResults() throws SQLException
- Specified by:
getMoreResults
in interfaceStatement
- Throws:
SQLException
-
setFetchDirection
public void setFetchDirection(int i) throws SQLException
- Specified by:
setFetchDirection
in interfaceStatement
- Throws:
SQLException
-
getFetchDirection
public int getFetchDirection() throws SQLException
- Specified by:
getFetchDirection
in interfaceStatement
- Throws:
SQLException
-
setFetchSize
public void setFetchSize(int i) throws SQLException
- Specified by:
setFetchSize
in interfaceStatement
- Throws:
SQLException
-
getFetchSize
public int getFetchSize() throws SQLException
- Specified by:
getFetchSize
in interfaceStatement
- Throws:
SQLException
-
getResultSetConcurrency
public int getResultSetConcurrency() throws SQLException
- Specified by:
getResultSetConcurrency
in interfaceStatement
- Throws:
SQLException
-
getResultSetType
public int getResultSetType() throws SQLException
- Specified by:
getResultSetType
in interfaceStatement
- Throws:
SQLException
-
addBatch
public void addBatch(String str) throws SQLException
- Specified by:
addBatch
in interfaceStatement
- Throws:
SQLException
-
clearBatch
public void clearBatch() throws SQLException
- Specified by:
clearBatch
in interfaceStatement
- Throws:
SQLException
-
executeBatch
public int[] executeBatch() throws SQLException
- Specified by:
executeBatch
in interfaceStatement
- Throws:
SQLException
-
getConnection
public Connection getConnection() throws SQLException
- Specified by:
getConnection
in interfaceStatement
- Throws:
SQLException
-
getMoreResults
public boolean getMoreResults(int i) throws SQLException
- Specified by:
getMoreResults
in interfaceStatement
- Throws:
SQLException
-
getGeneratedKeys
public ResultSet getGeneratedKeys() throws SQLException
- Specified by:
getGeneratedKeys
in interfaceStatement
- Throws:
SQLException
-
executeUpdate
public int executeUpdate(String s, int i) throws SQLException
- Specified by:
executeUpdate
in interfaceStatement
- Throws:
SQLException
-
executeUpdate
public int executeUpdate(String s, int[] ia) throws SQLException
- Specified by:
executeUpdate
in interfaceStatement
- Throws:
SQLException
-
executeUpdate
public int executeUpdate(String s, String[] sa) throws SQLException
- Specified by:
executeUpdate
in interfaceStatement
- Throws:
SQLException
-
execute
public boolean execute(String s, int i) throws SQLException
- Specified by:
execute
in interfaceStatement
- Throws:
SQLException
-
execute
public boolean execute(String s, int[] ia) throws SQLException
- Specified by:
execute
in interfaceStatement
- Throws:
SQLException
-
execute
public boolean execute(String s, String[] sa) throws SQLException
- Specified by:
execute
in interfaceStatement
- Throws:
SQLException
-
getResultSetHoldability
public int getResultSetHoldability() throws SQLException
- Specified by:
getResultSetHoldability
in interfaceStatement
- Throws:
SQLException
-
isWrapperFor
public boolean isWrapperFor(Class<?> iface) throws SQLException
- Specified by:
isWrapperFor
in interfaceWrapper
- Throws:
SQLException
-
unwrap
public <T> T unwrap(Class<T> iface) throws SQLException
- Specified by:
unwrap
in interfaceWrapper
- Throws:
SQLException
-
isClosed
public boolean isClosed() throws SQLException
- Specified by:
isClosed
in interfaceStatement
- Throws:
SQLException
-
setPoolable
public void setPoolable(boolean b) throws SQLException
- Specified by:
setPoolable
in interfaceStatement
- Throws:
SQLException
-
isPoolable
public boolean isPoolable() throws SQLException
- Specified by:
isPoolable
in interfaceStatement
- Throws:
SQLException
-
isCloseOnCompletion
public boolean isCloseOnCompletion() throws SQLException
- Specified by:
isCloseOnCompletion
in interfaceStatement
- Throws:
SQLException
-
closeOnCompletion
public void closeOnCompletion() throws SQLException
- Specified by:
closeOnCompletion
in interfaceStatement
- Throws:
SQLException
-
-