Package com.alibaba.druid.proxy.jdbc
Class StatementProxyImpl
- java.lang.Object
-
- com.alibaba.druid.proxy.jdbc.WrapperProxyImpl
-
- com.alibaba.druid.proxy.jdbc.StatementProxyImpl
-
- All Implemented Interfaces:
StatementProxy,WrapperProxy,AutoCloseable,Statement,Wrapper
- Direct Known Subclasses:
PreparedStatementProxyImpl
public class StatementProxyImpl extends WrapperProxyImpl implements StatementProxy
- Author:
- wenshao [szujobs@hotmail.com]
-
-
Field Summary
Fields Modifier and Type Field Description protected ArrayList<String>batchSqlListprotected booleanfirstResultSetprotected StringlastExecuteSqlprotected longlastExecuteStartNanoprotected longlastExecuteTimeNanoprotected StatementExecuteTypelastExecuteTypeprotected JdbcSqlStatsqlStatprotected Statementstatementprotected IntegerupdateCount-
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 StatementProxyImpl(ConnectionProxy connection, Statement statement, long id)
-
Method Summary
-
Methods inherited from class com.alibaba.druid.proxy.jdbc.WrapperProxyImpl
clearAttributes, getAttribute, getAttributes, getAttributesSize, getId, putAttribute
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface java.sql.Statement
enquoteIdentifier, enquoteLiteral, enquoteNCharLiteral, executeLargeBatch, executeLargeUpdate, executeLargeUpdate, executeLargeUpdate, executeLargeUpdate, getLargeMaxRows, getLargeUpdateCount, isSimpleIdentifier, setLargeMaxRows
-
Methods inherited from interface com.alibaba.druid.proxy.jdbc.WrapperProxy
clearAttributes, getAttribute, getAttributes, getAttributesSize, getId, putAttribute
-
-
-
-
Field Detail
-
statement
protected Statement statement
-
lastExecuteSql
protected String lastExecuteSql
-
lastExecuteStartNano
protected long lastExecuteStartNano
-
lastExecuteTimeNano
protected long lastExecuteTimeNano
-
sqlStat
protected JdbcSqlStat sqlStat
-
firstResultSet
protected boolean firstResultSet
-
lastExecuteType
protected StatementExecuteType lastExecuteType
-
updateCount
protected Integer updateCount
-
-
Constructor Detail
-
StatementProxyImpl
public StatementProxyImpl(ConnectionProxy connection, Statement statement, long id)
-
-
Method Detail
-
getConnectionProxy
public ConnectionProxy getConnectionProxy()
- Specified by:
getConnectionProxyin interfaceStatementProxy
-
getRawObject
public Statement getRawObject()
- Specified by:
getRawObjectin interfaceStatementProxy- Specified by:
getRawObjectin interfaceWrapperProxy- Overrides:
getRawObjectin classWrapperProxyImpl
-
createChain
public final FilterChainImpl createChain()
- Specified by:
createChainin classWrapperProxyImpl
-
recycleFilterChain
public final void recycleFilterChain(FilterChainImpl chain)
-
addBatch
public void addBatch(String sql) throws SQLException
- Specified by:
addBatchin interfaceStatement- Throws:
SQLException
-
cancel
public void cancel() throws SQLException- Specified by:
cancelin interfaceStatement- Throws:
SQLException
-
clearBatch
public void clearBatch() throws SQLException- Specified by:
clearBatchin interfaceStatement- Throws:
SQLException
-
clearWarnings
public void clearWarnings() throws SQLException- Specified by:
clearWarningsin interfaceStatement- Throws:
SQLException
-
close
public void close() throws SQLException- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceStatement- Throws:
SQLException
-
execute
public boolean execute(String sql) throws SQLException
- Specified by:
executein interfaceStatement- Throws:
SQLException
-
execute
public boolean execute(String sql, int autoGeneratedKeys) throws SQLException
- Specified by:
executein interfaceStatement- Throws:
SQLException
-
execute
public boolean execute(String sql, int[] columnIndexes) throws SQLException
- Specified by:
executein interfaceStatement- Throws:
SQLException
-
execute
public boolean execute(String sql, String[] columnNames) throws SQLException
- Specified by:
executein interfaceStatement- Throws:
SQLException
-
executeBatch
public int[] executeBatch() throws SQLException- Specified by:
executeBatchin interfaceStatement- Throws:
SQLException
-
executeQuery
public ResultSet executeQuery(String sql) throws SQLException
- Specified by:
executeQueryin interfaceStatement- Throws:
SQLException
-
executeUpdate
public int executeUpdate(String sql) throws SQLException
- Specified by:
executeUpdatein interfaceStatement- Throws:
SQLException
-
executeUpdate
public int executeUpdate(String sql, int autoGeneratedKeys) throws SQLException
- Specified by:
executeUpdatein interfaceStatement- Throws:
SQLException
-
executeUpdate
public int executeUpdate(String sql, int[] columnIndexes) throws SQLException
- Specified by:
executeUpdatein interfaceStatement- Throws:
SQLException
-
executeUpdate
public int executeUpdate(String sql, String[] columnNames) throws SQLException
- Specified by:
executeUpdatein interfaceStatement- Throws:
SQLException
-
getConnection
public Connection getConnection() throws SQLException
- Specified by:
getConnectionin interfaceStatement- Throws:
SQLException
-
getFetchDirection
public int getFetchDirection() throws SQLException- Specified by:
getFetchDirectionin interfaceStatement- Throws:
SQLException
-
getFetchSize
public int getFetchSize() throws SQLException- Specified by:
getFetchSizein interfaceStatement- Throws:
SQLException
-
getGeneratedKeys
public ResultSet getGeneratedKeys() throws SQLException
- Specified by:
getGeneratedKeysin interfaceStatement- Throws:
SQLException
-
getMaxFieldSize
public int getMaxFieldSize() throws SQLException- Specified by:
getMaxFieldSizein interfaceStatement- Throws:
SQLException
-
getMaxRows
public int getMaxRows() throws SQLException- Specified by:
getMaxRowsin interfaceStatement- Throws:
SQLException
-
getMoreResults
public boolean getMoreResults() throws SQLException- Specified by:
getMoreResultsin interfaceStatement- Throws:
SQLException
-
getMoreResults
public boolean getMoreResults(int current) throws SQLException- Specified by:
getMoreResultsin interfaceStatement- Throws:
SQLException
-
getQueryTimeout
public int getQueryTimeout() throws SQLException- Specified by:
getQueryTimeoutin interfaceStatement- Throws:
SQLException
-
getResultSet
public ResultSet getResultSet() throws SQLException
- Specified by:
getResultSetin interfaceStatement- Throws:
SQLException
-
getResultSetConcurrency
public int getResultSetConcurrency() throws SQLException- Specified by:
getResultSetConcurrencyin interfaceStatement- Throws:
SQLException
-
getResultSetHoldability
public int getResultSetHoldability() throws SQLException- Specified by:
getResultSetHoldabilityin interfaceStatement- Throws:
SQLException
-
getResultSetType
public int getResultSetType() throws SQLException- Specified by:
getResultSetTypein interfaceStatement- Throws:
SQLException
-
getUpdateCount
public int getUpdateCount() throws SQLException- Specified by:
getUpdateCountin interfaceStatement- Throws:
SQLException
-
getWarnings
public SQLWarning getWarnings() throws SQLException
- Specified by:
getWarningsin interfaceStatement- Throws:
SQLException
-
isClosed
public boolean isClosed() throws SQLException- Specified by:
isClosedin interfaceStatement- Throws:
SQLException
-
isPoolable
public boolean isPoolable() throws SQLException- Specified by:
isPoolablein interfaceStatement- Throws:
SQLException
-
setCursorName
public void setCursorName(String name) throws SQLException
- Specified by:
setCursorNamein interfaceStatement- Throws:
SQLException
-
setEscapeProcessing
public void setEscapeProcessing(boolean enable) throws SQLException- Specified by:
setEscapeProcessingin interfaceStatement- Throws:
SQLException
-
setFetchDirection
public void setFetchDirection(int direction) throws SQLException- Specified by:
setFetchDirectionin interfaceStatement- Throws:
SQLException
-
setFetchSize
public void setFetchSize(int rows) throws SQLException- Specified by:
setFetchSizein interfaceStatement- Throws:
SQLException
-
setMaxFieldSize
public void setMaxFieldSize(int max) throws SQLException- Specified by:
setMaxFieldSizein interfaceStatement- Throws:
SQLException
-
setMaxRows
public void setMaxRows(int max) throws SQLException- Specified by:
setMaxRowsin interfaceStatement- Throws:
SQLException
-
setPoolable
public void setPoolable(boolean poolable) throws SQLException- Specified by:
setPoolablein interfaceStatement- Throws:
SQLException
-
setQueryTimeout
public void setQueryTimeout(int seconds) throws SQLException- Specified by:
setQueryTimeoutin interfaceStatement- Throws:
SQLException
-
getBatchSqlList
public List<String> getBatchSqlList()
- Specified by:
getBatchSqlListin interfaceStatementProxy
-
getBatchSql
public String getBatchSql()
- Specified by:
getBatchSqlin interfaceStatementProxy
-
getLastExecuteSql
public String getLastExecuteSql()
- Specified by:
getLastExecuteSqlin interfaceStatementProxy
-
closeOnCompletion
public void closeOnCompletion() throws SQLException- Specified by:
closeOnCompletionin interfaceStatement- Throws:
SQLException
-
isCloseOnCompletion
public boolean isCloseOnCompletion() throws SQLException- Specified by:
isCloseOnCompletionin interfaceStatement- Throws:
SQLException
-
getParameters
public Map<Integer,JdbcParameter> getParameters()
- Specified by:
getParametersin interfaceStatementProxy
-
getSqlStat
public JdbcSqlStat getSqlStat()
- Specified by:
getSqlStatin interfaceStatementProxy
-
setSqlStat
public void setSqlStat(JdbcSqlStat sqlStat)
- Specified by:
setSqlStatin interfaceStatementProxy
-
getLastExecuteTimeNano
public long getLastExecuteTimeNano()
- Specified by:
getLastExecuteTimeNanoin interfaceStatementProxy
-
setLastExecuteTimeNano
public void setLastExecuteTimeNano(long lastExecuteTimeNano)
- Specified by:
setLastExecuteTimeNanoin interfaceStatementProxy
-
setLastExecuteTimeNano
public void setLastExecuteTimeNano()
- Specified by:
setLastExecuteTimeNanoin interfaceStatementProxy
-
getLastExecuteStartNano
public long getLastExecuteStartNano()
- Specified by:
getLastExecuteStartNanoin interfaceStatementProxy
-
setLastExecuteStartNano
public void setLastExecuteStartNano(long lastExecuteStartNano)
- Specified by:
setLastExecuteStartNanoin interfaceStatementProxy
-
setLastExecuteStartNano
public void setLastExecuteStartNano()
- Specified by:
setLastExecuteStartNanoin interfaceStatementProxy
-
getLastExecuteType
public StatementExecuteType getLastExecuteType()
- Specified by:
getLastExecuteTypein interfaceStatementProxy
-
isFirstResultSet
public boolean isFirstResultSet()
- Specified by:
isFirstResultSetin interfaceStatementProxy
-
unwrap
public <T> T unwrap(Class<T> iface) throws SQLException
- Specified by:
unwrapin interfaceWrapper- Overrides:
unwrapin classWrapperProxyImpl- Throws:
SQLException
-
isWrapperFor
public boolean isWrapperFor(Class<?> iface) throws SQLException
- Specified by:
isWrapperForin interfaceWrapper- Overrides:
isWrapperForin classWrapperProxyImpl- Throws:
SQLException
-
getParametersSize
public int getParametersSize()
- Specified by:
getParametersSizein interfaceStatementProxy
-
getParameter
public JdbcParameter getParameter(int i)
- Specified by:
getParameterin interfaceStatementProxy
-
-