Package com.alibaba.druid.filter.stat

Class StatFilter

java.lang.Object

javax.management.NotificationBroadcasterSupport

com.alibaba.druid.filter.FilterAdapter

com.alibaba.druid.filter.FilterEventAdapter

com.alibaba.druid.filter.stat.StatFilter

All Implemented Interfaces:

Filter, StatFilterMBean, Wrapper, NotificationBroadcaster, NotificationEmitter

Direct Known Subclasses:

MergeStatFilter

public class StatFilter
extends FilterEventAdapter
implements StatFilterMBean

Author:

wenshao [szujobs@hotmail.com]

Field Summary

Fields

Modifier and Type	Field	Description
static String	ATTR_NAME_CONNECTION_STAT
static String	ATTR_TRANSACTION
protected boolean	logSlowSql
protected JdbcResultSetStat	resultSetStat	Deprecated.
protected String	slowSqlLogLevel
protected long	slowSqlMillis
protected JdbcStatementStat	statementStat	Deprecated.

Constructor Summary

Constructors

Constructor	Description
StatFilter()

Method Summary

Modifier and Type	Method	Description
protected String	buildSlowParameters(StatementProxy statement)
Blob	callableStatement_getBlob(FilterChain chain, CallableStatementProxy statement, int parameterIndex)
Blob	callableStatement_getBlob(FilterChain chain, CallableStatementProxy statement, String parameterName)
Clob	callableStatement_getClob(FilterChain chain, CallableStatementProxy statement, int parameterIndex)
Clob	callableStatement_getClob(FilterChain chain, CallableStatementProxy statement, String parameterName)
Object	callableStatement_getObject(FilterChain chain, CallableStatementProxy statement, int parameterIndex)
Object	callableStatement_getObject(FilterChain chain, CallableStatementProxy statement, int parameterIndex, Map<String,Class<?>> map)
Object	callableStatement_getObject(FilterChain chain, CallableStatementProxy statement, String parameterName)
Object	callableStatement_getObject(FilterChain chain, CallableStatementProxy statement, String parameterName, Map<String,Class<?>> map)
void	configFromProperties(Properties properties)
void	connection_close(FilterChain chain, ConnectionProxy connection)
void	connection_commit(FilterChain chain, ConnectionProxy connection)
ConnectionProxy	connection_connect(FilterChain chain, Properties info)
void	connection_rollback(FilterChain chain, ConnectionProxy connection)
void	connection_rollback(FilterChain chain, ConnectionProxy connection, Savepoint savepoint)
JdbcSqlStat	createSqlStat(StatementProxy statement, String sql)
DruidPooledConnection	dataSource_getConnection(FilterChain chain, DruidDataSource dataSource, long maxWaitMillis)
void	dataSource_releaseConnection(FilterChain chain, DruidPooledConnection conn)
JdbcConnectionStat.Entry	getConnectionInfo(ConnectionProxy connection)
DbType	getDbType()
String	getSlowSqlLogLevel()
long	getSlowSqlMillis()
static StatFilter	getStatFilter(DataSourceProxy dataSource)
protected void	handleSlowSql(StatementProxy statementProxy)
void	init(DataSourceProxy dataSource)
boolean	isConnectionStackTraceEnable()
boolean	isLogSlowSql()
boolean	isMergeSql()
String	mergeSql(String sql)	Deprecated.
String	mergeSql(String sql, DbType dbType)
String	mergeSql(String sql, String dbType)
void	resultSet_close(FilterChain chain, ResultSetProxy resultSet)
InputStream	resultSet_getAsciiStream(FilterChain chain, ResultSetProxy result, int columnIndex)
InputStream	resultSet_getAsciiStream(FilterChain chain, ResultSetProxy result, String columnLabel)
InputStream	resultSet_getBinaryStream(FilterChain chain, ResultSetProxy result, int columnIndex)
InputStream	resultSet_getBinaryStream(FilterChain chain, ResultSetProxy result, String columnLabel)
Blob	resultSet_getBlob(FilterChain chain, ResultSetProxy result, int columnIndex)
Blob	resultSet_getBlob(FilterChain chain, ResultSetProxy result, String columnLabel)
byte[]	resultSet_getBytes(FilterChain chain, ResultSetProxy result, int columnIndex)
byte[]	resultSet_getBytes(FilterChain chain, ResultSetProxy result, String columnLabel)
Reader	resultSet_getCharacterStream(FilterChain chain, ResultSetProxy result, int columnIndex)
Reader	resultSet_getCharacterStream(FilterChain chain, ResultSetProxy result, String columnLabel)
Clob	resultSet_getClob(FilterChain chain, ResultSetProxy resultSet, int columnIndex)
Clob	resultSet_getClob(FilterChain chain, ResultSetProxy resultSet, String columnLabel)
Object	resultSet_getObject(FilterChain chain, ResultSetProxy result, int columnIndex)
<T> T	resultSet_getObject(FilterChain chain, ResultSetProxy result, int columnIndex, Class<T> type)
Object	resultSet_getObject(FilterChain chain, ResultSetProxy result, int columnIndex, Map<String,Class<?>> map)
Object	resultSet_getObject(FilterChain chain, ResultSetProxy result, String columnLabel)
<T> T	resultSet_getObject(FilterChain chain, ResultSetProxy result, String columnLabel, Class<T> type)
Object	resultSet_getObject(FilterChain chain, ResultSetProxy result, String columnLabel, Map<String,Class<?>> map)
String	resultSet_getString(FilterChain chain, ResultSetProxy result, int columnIndex)
String	resultSet_getString(FilterChain chain, ResultSetProxy result, String columnLabel)
protected void	resultSetOpenAfter(ResultSetProxy resultSet)
void	setConnectionStackTraceEnable(boolean connectionStackTraceEnable)
void	setDbType(DbType dbType)
void	setDbType(String dbType)
void	setLogSlowSql(boolean logSlowSql)
void	setMergeSql(boolean mergeSql)
void	setSlowSqlLogLevel(String slowSqlLogLevel)
void	setSlowSqlMillis(long slowSqlMillis)
void	statement_close(FilterChain chain, StatementProxy statement)
protected void	statement_executeErrorAfter(StatementProxy statement, String sql, Throwable error)
void	statementCreateAfter(StatementProxy statement)
protected void	statementExecuteAfter(StatementProxy statement, String sql, boolean firstResult)
protected void	statementExecuteBatchAfter(StatementProxy statement, int[] result)
protected void	statementExecuteBatchBefore(StatementProxy statement)
protected void	statementExecuteBefore(StatementProxy statement, String sql)
protected void	statementExecuteQueryAfter(StatementProxy statement, String sql, ResultSetProxy resultSet)
protected void	statementExecuteQueryBefore(StatementProxy statement, String sql)
protected void	statementExecuteUpdateAfter(StatementProxy statement, String sql, int updateCount)
protected void	statementExecuteUpdateBefore(StatementProxy statement, String sql)
void	statementPrepareAfter(PreparedStatementProxy statement)
void	statementPrepareCallAfter(CallableStatementProxy statement)

Methods inherited from class com.alibaba.druid.filter.FilterEventAdapter

connection_connectAfter, connection_connectBefore, connection_createStatement, connection_createStatement, connection_createStatement, connection_prepareCall, connection_prepareCall, connection_prepareCall, connection_prepareStatement, connection_prepareStatement, connection_prepareStatement, connection_prepareStatement, connection_prepareStatement, connection_prepareStatement, preparedStatement_execute, preparedStatement_executeQuery, preparedStatement_executeUpdate, statement_execute, statement_execute, statement_execute, statement_execute, statement_executeBatch, statement_executeQuery, statement_executeUpdate, statement_executeUpdate, statement_executeUpdate, statement_executeUpdate, statement_getGeneratedKeys, statement_getResultSet

Methods inherited from class com.alibaba.druid.filter.FilterAdapter

callableStatement_getArray, callableStatement_getArray, callableStatement_getBigDecimal, callableStatement_getBigDecimal, callableStatement_getBigDecimal, callableStatement_getBoolean, callableStatement_getBoolean, callableStatement_getByte, callableStatement_getByte, callableStatement_getBytes, callableStatement_getBytes, callableStatement_getCharacterStream, callableStatement_getCharacterStream, callableStatement_getDate, callableStatement_getDate, callableStatement_getDate, callableStatement_getDate, callableStatement_getDouble, callableStatement_getDouble, callableStatement_getFloat, callableStatement_getFloat, callableStatement_getInt, callableStatement_getInt, callableStatement_getLong, callableStatement_getLong, callableStatement_getNCharacterStream, callableStatement_getNCharacterStream, callableStatement_getNClob, callableStatement_getNClob, callableStatement_getNString, callableStatement_getNString, callableStatement_getRef, callableStatement_getRef, callableStatement_getRowId, callableStatement_getRowId, callableStatement_getShort, callableStatement_getShort, callableStatement_getSQLXML, callableStatement_getSQLXML, callableStatement_getString, callableStatement_getString, callableStatement_getTime, callableStatement_getTime, callableStatement_getTime, callableStatement_getTime, callableStatement_getTimestamp, callableStatement_getTimestamp, callableStatement_getTimestamp, callableStatement_getTimestamp, callableStatement_getURL, callableStatement_getURL, callableStatement_registerOutParameter, callableStatement_registerOutParameter, callableStatement_registerOutParameter, callableStatement_registerOutParameter, callableStatement_registerOutParameter, callableStatement_registerOutParameter, callableStatement_setAsciiStream, callableStatement_setAsciiStream, callableStatement_setAsciiStream, callableStatement_setBigDecimal, callableStatement_setBinaryStream, callableStatement_setBinaryStream, callableStatement_setBinaryStream, callableStatement_setBlob, callableStatement_setBlob, callableStatement_setBlob, callableStatement_setBoolean, callableStatement_setByte, callableStatement_setBytes, callableStatement_setCharacterStream, callableStatement_setCharacterStream, callableStatement_setCharacterStream, callableStatement_setClob, callableStatement_setClob, callableStatement_setClob, callableStatement_setDate, callableStatement_setDate, callableStatement_setDouble, callableStatement_setFloat, callableStatement_setInt, callableStatement_setLong, callableStatement_setNCharacterStream, callableStatement_setNCharacterStream, callableStatement_setNClob, callableStatement_setNClob, callableStatement_setNClob, callableStatement_setNString, callableStatement_setNull, callableStatement_setNull, callableStatement_setObject, callableStatement_setObject, callableStatement_setObject, callableStatement_setRowId, callableStatement_setShort, callableStatement_setSQLXML, callableStatement_setString, callableStatement_setTime, callableStatement_setTime, callableStatement_setTimestamp, callableStatement_setTimestamp, callableStatement_setURL, callableStatement_wasNull, clob_free, clob_getAsciiStream, clob_getCharacterStream, clob_getCharacterStream, clob_getSubString, clob_length, clob_position, clob_position, clob_setAsciiStream, clob_setCharacterStream, clob_setString, clob_setString, clob_truncate, connection_abort, connection_clearWarnings, connection_createArrayOf, connection_createBlob, connection_createClob, connection_createNClob, connection_createSQLXML, connection_createStruct, connection_getAutoCommit, connection_getCatalog, connection_getClientInfo, connection_getClientInfo, connection_getHoldability, connection_getMetaData, connection_getNetworkTimeout, connection_getSchema, connection_getTransactionIsolation, connection_getTypeMap, connection_getWarnings, connection_isClosed, connection_isReadOnly, connection_isValid, connection_nativeSQL, connection_releaseSavepoint, connection_setAutoCommit, connection_setCatalog, connection_setClientInfo, connection_setClientInfo, connection_setHoldability, connection_setNetworkTimeout, connection_setReadOnly, connection_setSavepoint, connection_setSavepoint, connection_setSchema, connection_setTransactionIsolation, connection_setTypeMap, destroy, isWrapperFor, isWrapperFor, preparedStatement_addBatch, preparedStatement_clearParameters, preparedStatement_getMetaData, preparedStatement_getParameterMetaData, preparedStatement_setArray, preparedStatement_setAsciiStream, preparedStatement_setAsciiStream, preparedStatement_setAsciiStream, preparedStatement_setBigDecimal, preparedStatement_setBinaryStream, preparedStatement_setBinaryStream, preparedStatement_setBinaryStream, preparedStatement_setBlob, preparedStatement_setBlob, preparedStatement_setBlob, preparedStatement_setBoolean, preparedStatement_setByte, preparedStatement_setBytes, preparedStatement_setCharacterStream, preparedStatement_setCharacterStream, preparedStatement_setCharacterStream, preparedStatement_setClob, preparedStatement_setClob, preparedStatement_setClob, preparedStatement_setDate, preparedStatement_setDate, preparedStatement_setDouble, preparedStatement_setFloat, preparedStatement_setInt, preparedStatement_setLong, preparedStatement_setNCharacterStream, preparedStatement_setNCharacterStream, preparedStatement_setNClob, preparedStatement_setNClob, preparedStatement_setNClob, preparedStatement_setNString, preparedStatement_setNull, preparedStatement_setNull, preparedStatement_setObject, preparedStatement_setObject, preparedStatement_setObject, preparedStatement_setRef, preparedStatement_setRowId, preparedStatement_setShort, preparedStatement_setSQLXML, preparedStatement_setString, preparedStatement_setTime, preparedStatement_setTime, preparedStatement_setTimestamp, preparedStatement_setTimestamp, preparedStatement_setUnicodeStream, preparedStatement_setURL, resultSet_absolute, resultSet_afterLast, resultSet_beforeFirst, resultSet_cancelRowUpdates, resultSet_clearWarnings, resultSet_deleteRow, resultSet_findColumn, resultSet_first, resultSet_getArray, resultSet_getArray, resultSet_getBigDecimal, resultSet_getBigDecimal, resultSet_getBigDecimal, resultSet_getBigDecimal, resultSet_getBoolean, resultSet_getBoolean, resultSet_getByte, resultSet_getByte, resultSet_getConcurrency, resultSet_getCursorName, resultSet_getDate, resultSet_getDate, resultSet_getDate, resultSet_getDate, resultSet_getDouble, resultSet_getDouble, resultSet_getFetchDirection, resultSet_getFetchSize, resultSet_getFloat, resultSet_getFloat, resultSet_getHoldability, resultSet_getInt, resultSet_getInt, resultSet_getLong, resultSet_getLong, resultSet_getMetaData, resultSet_getNCharacterStream, resultSet_getNCharacterStream, resultSet_getNClob, resultSet_getNClob, resultSet_getNString, resultSet_getNString, resultSet_getRef, resultSet_getRef, resultSet_getRow, resultSet_getRowId, resultSet_getRowId, resultSet_getShort, resultSet_getShort, resultSet_getSQLXML, resultSet_getSQLXML, resultSet_getStatement, resultSet_getTime, resultSet_getTime, resultSet_getTime, resultSet_getTime, resultSet_getTimestamp, resultSet_getTimestamp, resultSet_getTimestamp, resultSet_getTimestamp, resultSet_getType, resultSet_getUnicodeStream, resultSet_getUnicodeStream, resultSet_getURL, resultSet_getURL, resultSet_getWarnings, resultSet_insertRow, resultSet_isAfterLast, resultSet_isBeforeFirst, resultSet_isClosed, resultSet_isFirst, resultSet_isLast, resultSet_last, resultSet_moveToCurrentRow, resultSet_moveToInsertRow, resultSet_next, resultSet_previous, resultSet_refreshRow, resultSet_relative, resultSet_rowDeleted, resultSet_rowInserted, resultSet_rowUpdated, resultSet_setFetchDirection, resultSet_setFetchSize, resultSet_updateArray, resultSet_updateArray, resultSet_updateAsciiStream, resultSet_updateAsciiStream, resultSet_updateAsciiStream, resultSet_updateAsciiStream, resultSet_updateAsciiStream, resultSet_updateAsciiStream, resultSet_updateBigDecimal, resultSet_updateBigDecimal, resultSet_updateBinaryStream, resultSet_updateBinaryStream, resultSet_updateBinaryStream, resultSet_updateBinaryStream, resultSet_updateBinaryStream, resultSet_updateBinaryStream, resultSet_updateBlob, resultSet_updateBlob, resultSet_updateBlob, resultSet_updateBlob, resultSet_updateBlob, resultSet_updateBlob, resultSet_updateBoolean, resultSet_updateBoolean, resultSet_updateByte, resultSet_updateByte, resultSet_updateBytes, resultSet_updateBytes, resultSet_updateCharacterStream, resultSet_updateCharacterStream, resultSet_updateCharacterStream, resultSet_updateCharacterStream, resultSet_updateCharacterStream, resultSet_updateCharacterStream, resultSet_updateClob, resultSet_updateClob, resultSet_updateClob, resultSet_updateClob, resultSet_updateClob, resultSet_updateClob, resultSet_updateDate, resultSet_updateDate, resultSet_updateDouble, resultSet_updateDouble, resultSet_updateFloat, resultSet_updateFloat, resultSet_updateInt, resultSet_updateInt, resultSet_updateLong, resultSet_updateLong, resultSet_updateNCharacterStream, resultSet_updateNCharacterStream, resultSet_updateNCharacterStream, resultSet_updateNCharacterStream, resultSet_updateNClob, resultSet_updateNClob, resultSet_updateNClob, resultSet_updateNClob, resultSet_updateNClob, resultSet_updateNClob, resultSet_updateNString, resultSet_updateNString, resultSet_updateNull, resultSet_updateNull, resultSet_updateObject, resultSet_updateObject, resultSet_updateObject, resultSet_updateObject, resultSet_updateRef, resultSet_updateRef, resultSet_updateRow, resultSet_updateRowId, resultSet_updateRowId, resultSet_updateShort, resultSet_updateShort, resultSet_updateSQLXML, resultSet_updateSQLXML, resultSet_updateString, resultSet_updateString, resultSet_updateTime, resultSet_updateTime, resultSet_updateTimestamp, resultSet_updateTimestamp, resultSet_wasNull, resultSetMetaData_getCatalogName, resultSetMetaData_getColumnClassName, resultSetMetaData_getColumnCount, resultSetMetaData_getColumnDisplaySize, resultSetMetaData_getColumnLabel, resultSetMetaData_getColumnName, resultSetMetaData_getColumnType, resultSetMetaData_getColumnTypeName, resultSetMetaData_getPrecision, resultSetMetaData_getScale, resultSetMetaData_getSchemaName, resultSetMetaData_getTableName, resultSetMetaData_isAutoIncrement, resultSetMetaData_isCaseSensitive, resultSetMetaData_isCurrency, resultSetMetaData_isDefinitelyWritable, resultSetMetaData_isNullable, resultSetMetaData_isReadOnly, resultSetMetaData_isSearchable, resultSetMetaData_isSigned, resultSetMetaData_isWritable, statement_addBatch, statement_cancel, statement_clearBatch, statement_clearWarnings, statement_getConnection, statement_getFetchDirection, statement_getFetchSize, statement_getMaxFieldSize, statement_getMaxRows, statement_getMoreResults, statement_getMoreResults, statement_getQueryTimeout, statement_getResultSetConcurrency, statement_getResultSetHoldability, statement_getResultSetType, statement_getUpdateCount, statement_getWarnings, statement_isClosed, statement_isPoolable, statement_setCursorName, statement_setEscapeProcessing, statement_setFetchDirection, statement_setFetchSize, statement_setMaxFieldSize, statement_setMaxRows, statement_setPoolable, statement_setQueryTimeout, unwrap, unwrap

Methods inherited from class javax.management.NotificationBroadcasterSupport

addNotificationListener, getNotificationInfo, handleNotification, removeNotificationListener, removeNotificationListener, sendNotification

Methods inherited from class java.lang.Object

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

Field Detail

ATTR_NAME_CONNECTION_STAT

public static final String ATTR_NAME_CONNECTION_STAT

See Also:

Constant Field Values

ATTR_TRANSACTION

public static final String ATTR_TRANSACTION

See Also:

Constant Field Values

statementStat

@Deprecated
protected final JdbcStatementStat statementStat

Deprecated.

resultSetStat

@Deprecated
protected final JdbcResultSetStat resultSetStat

Deprecated.

slowSqlMillis

protected long slowSqlMillis

logSlowSql

protected boolean logSlowSql

slowSqlLogLevel

protected String slowSqlLogLevel

Constructor Detail

StatFilter

public StatFilter()

Method Detail

getDbType

public DbType getDbType()

setDbType

public void setDbType(DbType dbType)

setDbType

public void setDbType(String dbType)

getSlowSqlMillis

public long getSlowSqlMillis()

Specified by:

getSlowSqlMillis in interface StatFilterMBean

setSlowSqlMillis

public void setSlowSqlMillis(long slowSqlMillis)

Specified by:

setSlowSqlMillis in interface StatFilterMBean

isLogSlowSql

public boolean isLogSlowSql()

Specified by:

isLogSlowSql in interface StatFilterMBean

setLogSlowSql

public void setLogSlowSql(boolean logSlowSql)

Specified by:

setLogSlowSql in interface StatFilterMBean

isConnectionStackTraceEnable

public boolean isConnectionStackTraceEnable()

setConnectionStackTraceEnable

public void setConnectionStackTraceEnable(boolean connectionStackTraceEnable)

isMergeSql

public boolean isMergeSql()

Specified by:

isMergeSql in interface StatFilterMBean

setMergeSql

public void setMergeSql(boolean mergeSql)

Specified by:

setMergeSql in interface StatFilterMBean

getSlowSqlLogLevel

public String getSlowSqlLogLevel()

setSlowSqlLogLevel

public void setSlowSqlLogLevel(String slowSqlLogLevel)

mergeSql

@Deprecated
public String mergeSql(String sql)

Deprecated.

mergeSql

public String mergeSql(String sql,
                       String dbType)

Specified by:

mergeSql in interface StatFilterMBean

mergeSql

public String mergeSql(String sql,
                       DbType dbType)

init

public void init(DataSourceProxy dataSource)

Specified by:

init in interface Filter

Overrides:

init in class FilterAdapter

configFromProperties

public void configFromProperties(Properties properties)

Specified by:

configFromProperties in interface Filter

Overrides:

configFromProperties in class FilterAdapter

connection_connect

public ConnectionProxy connection_connect(FilterChain chain,
                                          Properties info)
                                   throws SQLException

Specified by:

connection_connect in interface Filter

Overrides:

connection_connect in class FilterEventAdapter

Throws:

SQLException

connection_close

public void connection_close(FilterChain chain,
                             ConnectionProxy connection)
                      throws SQLException

Specified by:

connection_close in interface Filter

Overrides:

connection_close in class FilterAdapter

Throws:

SQLException

connection_commit

public void connection_commit(FilterChain chain,
                              ConnectionProxy connection)
                       throws SQLException

Specified by:

connection_commit in interface Filter

Overrides:

connection_commit in class FilterAdapter

Throws:

SQLException

connection_rollback

public void connection_rollback(FilterChain chain,
                                ConnectionProxy connection)
                         throws SQLException

Specified by:

connection_rollback in interface Filter

Overrides:

connection_rollback in class FilterAdapter

Throws:

SQLException

connection_rollback

public void connection_rollback(FilterChain chain,
                                ConnectionProxy connection,
                                Savepoint savepoint)
                         throws SQLException

Specified by:

connection_rollback in interface Filter

Overrides:

connection_rollback in class FilterAdapter

Throws:

SQLException

statementCreateAfter

public void statementCreateAfter(StatementProxy statement)

Overrides:

statementCreateAfter in class FilterEventAdapter

statementPrepareCallAfter

public void statementPrepareCallAfter(CallableStatementProxy statement)

Overrides:

statementPrepareCallAfter in class FilterEventAdapter

statementPrepareAfter

public void statementPrepareAfter(PreparedStatementProxy statement)

Overrides:

statementPrepareAfter in class FilterEventAdapter

statement_close

public void statement_close(FilterChain chain,
                            StatementProxy statement)
                     throws SQLException

Specified by:

statement_close in interface Filter

Overrides:

statement_close in class FilterAdapter

Throws:

SQLException

statementExecuteUpdateBefore

protected void statementExecuteUpdateBefore(StatementProxy statement,
                                            String sql)

Overrides:

statementExecuteUpdateBefore in class FilterEventAdapter

statementExecuteUpdateAfter

protected void statementExecuteUpdateAfter(StatementProxy statement,
                                           String sql,
                                           int updateCount)

Overrides:

statementExecuteUpdateAfter in class FilterEventAdapter

statementExecuteQueryBefore

protected void statementExecuteQueryBefore(StatementProxy statement,
                                           String sql)

Overrides:

statementExecuteQueryBefore in class FilterEventAdapter

statementExecuteQueryAfter

protected void statementExecuteQueryAfter(StatementProxy statement,
                                          String sql,
                                          ResultSetProxy resultSet)

Overrides:

statementExecuteQueryAfter in class FilterEventAdapter

statementExecuteBefore

protected void statementExecuteBefore(StatementProxy statement,
                                      String sql)

Overrides:

statementExecuteBefore in class FilterEventAdapter

statementExecuteAfter

protected void statementExecuteAfter(StatementProxy statement,
                                     String sql,
                                     boolean firstResult)

Overrides:

statementExecuteAfter in class FilterEventAdapter

statementExecuteBatchBefore

protected void statementExecuteBatchBefore(StatementProxy statement)

Overrides:

statementExecuteBatchBefore in class FilterEventAdapter

statementExecuteBatchAfter

protected void statementExecuteBatchAfter(StatementProxy statement,
                                          int[] result)

Overrides:

statementExecuteBatchAfter in class FilterEventAdapter

handleSlowSql

protected void handleSlowSql(StatementProxy statementProxy)

statement_executeErrorAfter

protected void statement_executeErrorAfter(StatementProxy statement,
                                           String sql,
                                           Throwable error)

Overrides:

statement_executeErrorAfter in class FilterEventAdapter

buildSlowParameters

protected String buildSlowParameters(StatementProxy statement)

resultSetOpenAfter

protected void resultSetOpenAfter(ResultSetProxy resultSet)

Overrides:

resultSetOpenAfter in class FilterEventAdapter

resultSet_close

public void resultSet_close(FilterChain chain,
                            ResultSetProxy resultSet)
                     throws SQLException

Specified by:

resultSet_close in interface Filter

Overrides:

resultSet_close in class FilterAdapter

Throws:

SQLException

getConnectionInfo

public JdbcConnectionStat.Entry getConnectionInfo(ConnectionProxy connection)

createSqlStat

public JdbcSqlStat createSqlStat(StatementProxy statement,
                                 String sql)

getStatFilter

public static StatFilter getStatFilter(DataSourceProxy dataSource)

dataSource_releaseConnection

public void dataSource_releaseConnection(FilterChain chain,
                                         DruidPooledConnection conn)
                                  throws SQLException

Specified by:

dataSource_releaseConnection in interface Filter

Overrides:

dataSource_releaseConnection in class FilterAdapter

Throws:

SQLException

dataSource_getConnection

public DruidPooledConnection dataSource_getConnection(FilterChain chain,
                                                      DruidDataSource dataSource,
                                                      long maxWaitMillis)
                                               throws SQLException

Specified by:

dataSource_getConnection in interface Filter

Overrides:

dataSource_getConnection in class FilterAdapter

Throws:

SQLException

resultSet_getClob

public Clob resultSet_getClob(FilterChain chain,
                              ResultSetProxy resultSet,
                              int columnIndex)
                       throws SQLException

Specified by:

resultSet_getClob in interface Filter

Overrides:

resultSet_getClob in class FilterAdapter

Throws:

SQLException

resultSet_getClob

public Clob resultSet_getClob(FilterChain chain,
                              ResultSetProxy resultSet,
                              String columnLabel)
                       throws SQLException

Specified by:

resultSet_getClob in interface Filter

Overrides:

resultSet_getClob in class FilterAdapter

Throws:

SQLException

callableStatement_getBlob

public Blob callableStatement_getBlob(FilterChain chain,
                                      CallableStatementProxy statement,
                                      int parameterIndex)
                               throws SQLException

Specified by:

callableStatement_getBlob in interface Filter

Overrides:

callableStatement_getBlob in class FilterAdapter

Throws:

SQLException

callableStatement_getBlob

public Blob callableStatement_getBlob(FilterChain chain,
                                      CallableStatementProxy statement,
                                      String parameterName)
                               throws SQLException

Specified by:

callableStatement_getBlob in interface Filter

Overrides:

callableStatement_getBlob in class FilterAdapter

Throws:

SQLException

resultSet_getBlob

public Blob resultSet_getBlob(FilterChain chain,
                              ResultSetProxy result,
                              int columnIndex)
                       throws SQLException

Specified by:

resultSet_getBlob in interface Filter

Overrides:

resultSet_getBlob in class FilterAdapter

Throws:

SQLException

resultSet_getBlob

public Blob resultSet_getBlob(FilterChain chain,
                              ResultSetProxy result,
                              String columnLabel)
                       throws SQLException

Specified by:

resultSet_getBlob in interface Filter

Overrides:

resultSet_getBlob in class FilterAdapter

Throws:

SQLException

callableStatement_getClob

public Clob callableStatement_getClob(FilterChain chain,
                                      CallableStatementProxy statement,
                                      int parameterIndex)
                               throws SQLException

Specified by:

callableStatement_getClob in interface Filter

Overrides:

callableStatement_getClob in class FilterAdapter

Throws:

SQLException

callableStatement_getClob

public Clob callableStatement_getClob(FilterChain chain,
                                      CallableStatementProxy statement,
                                      String parameterName)
                               throws SQLException

Specified by:

callableStatement_getClob in interface Filter

Overrides:

callableStatement_getClob in class FilterAdapter

Throws:

SQLException

resultSet_getObject

public Object resultSet_getObject(FilterChain chain,
                                  ResultSetProxy result,
                                  int columnIndex)
                           throws SQLException

Specified by:

resultSet_getObject in interface Filter

Overrides:

resultSet_getObject in class FilterAdapter

Throws:

SQLException

resultSet_getObject

public <T> T resultSet_getObject(FilterChain chain,
                                 ResultSetProxy result,
                                 int columnIndex,
                                 Class<T> type)
                          throws SQLException

Specified by:

resultSet_getObject in interface Filter

Overrides:

resultSet_getObject in class FilterAdapter

Throws:

SQLException

resultSet_getObject

public Object resultSet_getObject(FilterChain chain,
                                  ResultSetProxy result,
                                  int columnIndex,
                                  Map<String,Class<?>> map)
                           throws SQLException

Specified by:

resultSet_getObject in interface Filter

Overrides:

resultSet_getObject in class FilterAdapter

Throws:

SQLException

resultSet_getObject

public Object resultSet_getObject(FilterChain chain,
                                  ResultSetProxy result,
                                  String columnLabel)
                           throws SQLException

Specified by:

resultSet_getObject in interface Filter

Overrides:

resultSet_getObject in class FilterAdapter

Throws:

SQLException

resultSet_getObject

public <T> T resultSet_getObject(FilterChain chain,
                                 ResultSetProxy result,
                                 String columnLabel,
                                 Class<T> type)
                          throws SQLException

Specified by:

resultSet_getObject in interface Filter

Overrides:

resultSet_getObject in class FilterAdapter

Throws:

SQLException

resultSet_getObject

public Object resultSet_getObject(FilterChain chain,
                                  ResultSetProxy result,
                                  String columnLabel,
                                  Map<String,Class<?>> map)
                           throws SQLException

Specified by:

resultSet_getObject in interface Filter

Overrides:

resultSet_getObject in class FilterAdapter

Throws:

SQLException

callableStatement_getObject

public Object callableStatement_getObject(FilterChain chain,
                                          CallableStatementProxy statement,
                                          int parameterIndex)
                                   throws SQLException

Specified by:

callableStatement_getObject in interface Filter

Overrides:

callableStatement_getObject in class FilterAdapter

Throws:

SQLException

callableStatement_getObject

public Object callableStatement_getObject(FilterChain chain,
                                          CallableStatementProxy statement,
                                          int parameterIndex,
                                          Map<String,Class<?>> map)
                                   throws SQLException

Specified by:

callableStatement_getObject in interface Filter

Overrides:

callableStatement_getObject in class FilterAdapter

Throws:

SQLException

callableStatement_getObject

public Object callableStatement_getObject(FilterChain chain,
                                          CallableStatementProxy statement,
                                          String parameterName)
                                   throws SQLException

Specified by:

callableStatement_getObject in interface Filter

Overrides:

callableStatement_getObject in class FilterAdapter

Throws:

SQLException

callableStatement_getObject

public Object callableStatement_getObject(FilterChain chain,
                                          CallableStatementProxy statement,
                                          String parameterName,
                                          Map<String,Class<?>> map)
                                   throws SQLException

Specified by:

callableStatement_getObject in interface Filter

Overrides:

callableStatement_getObject in class FilterAdapter

Throws:

SQLException

resultSet_getString

public String resultSet_getString(FilterChain chain,
                                  ResultSetProxy result,
                                  int columnIndex)
                           throws SQLException

Specified by:

resultSet_getString in interface Filter

Overrides:

resultSet_getString in class FilterAdapter

Throws:

SQLException

resultSet_getString

public String resultSet_getString(FilterChain chain,
                                  ResultSetProxy result,
                                  String columnLabel)
                           throws SQLException

Specified by:

resultSet_getString in interface Filter

Overrides:

resultSet_getString in class FilterAdapter

Throws:

SQLException

resultSet_getBytes

public byte[] resultSet_getBytes(FilterChain chain,
                                 ResultSetProxy result,
                                 int columnIndex)
                          throws SQLException

Specified by:

resultSet_getBytes in interface Filter

Overrides:

resultSet_getBytes in class FilterAdapter

Throws:

SQLException

resultSet_getBytes

public byte[] resultSet_getBytes(FilterChain chain,
                                 ResultSetProxy result,
                                 String columnLabel)
                          throws SQLException

Specified by:

resultSet_getBytes in interface Filter

Overrides:

resultSet_getBytes in class FilterAdapter

Throws:

SQLException

resultSet_getBinaryStream

public InputStream resultSet_getBinaryStream(FilterChain chain,
                                             ResultSetProxy result,
                                             int columnIndex)
                                      throws SQLException

Specified by:

resultSet_getBinaryStream in interface Filter

Overrides:

resultSet_getBinaryStream in class FilterAdapter

Throws:

SQLException

resultSet_getBinaryStream

public InputStream resultSet_getBinaryStream(FilterChain chain,
                                             ResultSetProxy result,
                                             String columnLabel)
                                      throws SQLException

Specified by:

resultSet_getBinaryStream in interface Filter

Overrides:

resultSet_getBinaryStream in class FilterAdapter

Throws:

SQLException

resultSet_getAsciiStream

public InputStream resultSet_getAsciiStream(FilterChain chain,
                                            ResultSetProxy result,
                                            int columnIndex)
                                     throws SQLException

Specified by:

resultSet_getAsciiStream in interface Filter

Overrides:

resultSet_getAsciiStream in class FilterAdapter

Throws:

SQLException

resultSet_getAsciiStream

public InputStream resultSet_getAsciiStream(FilterChain chain,
                                            ResultSetProxy result,
                                            String columnLabel)
                                     throws SQLException

Specified by:

resultSet_getAsciiStream in interface Filter

Overrides:

resultSet_getAsciiStream in class FilterAdapter

Throws:

SQLException

resultSet_getCharacterStream

public Reader resultSet_getCharacterStream(FilterChain chain,
                                           ResultSetProxy result,
                                           int columnIndex)
                                    throws SQLException

Specified by:

resultSet_getCharacterStream in interface Filter

Overrides:

resultSet_getCharacterStream in class FilterAdapter

Throws:

SQLException

resultSet_getCharacterStream

public Reader resultSet_getCharacterStream(FilterChain chain,
                                           ResultSetProxy result,
                                           String columnLabel)
                                    throws SQLException

Specified by:

resultSet_getCharacterStream in interface Filter

Overrides:

resultSet_getCharacterStream in class FilterAdapter

Throws:

SQLException