com.ds.common.database

类 ProfiledConnection

java.lang.Object

com.ds.common.database.ConnectionAdapter

com.ds.common.database.ProfiledConnection

所有已实现的接口:

AutoCloseable, Connection, Wrapper

public class ProfiledConnection
extends ConnectionAdapter

Title: 常用代码打包

Description: Wraps a Connection object and collects statistics about the database queries that are performed.

Statistics of the profiled Connections can be obtained from the static methods of this class. Instances of this class are the actual wrappers that perform profiling.

Copyright: Copyright (c) 2006

Company: www.justdos.net

版本:

1.0

作者:

wenzhang li

字段概要

字段

限定符和类型	字段和说明
static int	DELETE Constant for DELETE database queries.
static int	INSERT Constant for INSERT database queries.
static int	SELECT Constant for SELECT database queries.
static int	UPDATE Constant for UPDATE database queries.

从类继承的字段 com.ds.common.database.ConnectionAdapter

connection

从接口继承的字段 java.sql.Connection

TRANSACTION_NONE, TRANSACTION_READ_COMMITTED, TRANSACTION_READ_UNCOMMITTED, TRANSACTION_REPEATABLE_READ, TRANSACTION_SERIALIZABLE

构造器概要

构造器

构造器和说明
ProfiledConnection(Connection connection) Creates a new ProfiledConnection that wraps the specified connection.

方法概要

限定符和类型	方法和说明
static void	addQuery(int type, String sql, long time)
void	close()
Statement	createStatement()
Statement	createStatement(int resultSetType, int resultSetConcurrency)
static double	getAverageQueryTime(int type) Returns the average amount of time spent executing the specified type of query.
static double	getQueriesPerSecond(int type) Returns the average number of queries of a certain type that have been performed per second since profiling started.
static long	getQueryCount(int type) Returns the total number database queries of a particular type performed.
static ProfiledConnectionEntry[]	getSortedQueries(int type, boolean sortByTime) Returns an array of sorted queries (as ProfiledConnectionEntry objects) by type
static long	getTotalQueryTime(int type) Returns the total amount of time in milliseconds spent doing a particular type of query.
PreparedStatement	prepareStatement(String sql)
PreparedStatement	prepareStatement(String sql, int resultSetType, int resultSetConcurrency)
static void	resetStatistics() Reset all statistics.
static void	start() Start profiling.
static void	stop() Stop profiling.

从类继承的方法 com.ds.common.database.ConnectionAdapter

abort, clearWarnings, commit, createArrayOf, createBlob, createClob, createNClob, createSQLXML, createStatement, createStruct, getAutoCommit, getCatalog, getClientInfo, getClientInfo, getHoldability, getMetaData, getNetworkTimeout, getSchema, getTransactionIsolation, getTypeMap, getWarnings, isClosed, isReadOnly, isValid, isWrapperFor, nativeSQL, prepareCall, prepareCall, prepareCall, prepareStatement, prepareStatement, prepareStatement, prepareStatement, releaseSavepoint, rollback, rollback, setAutoCommit, setCatalog, setClientInfo, setClientInfo, setHoldability, setNetworkTimeout, setReadOnly, setSavepoint, setSavepoint, setSchema, setTransactionIsolation, setTypeMap, toString, unwrap

从类继承的方法 java.lang.Object

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

字段详细资料

SELECT

public static final int SELECT

Constant for SELECT database queries.

另请参阅:

常量字段值

UPDATE

public static final int UPDATE

Constant for UPDATE database queries.

另请参阅:

常量字段值

INSERT

public static final int INSERT

Constant for INSERT database queries.

另请参阅:

常量字段值

DELETE

public static final int DELETE

Constant for DELETE database queries.

另请参阅:

常量字段值

构造器详细资料

ProfiledConnection

public ProfiledConnection(Connection connection)
                   throws SQLException

Creates a new ProfiledConnection that wraps the specified connection.

参数:

connection - the Connection to wrap and collect stats for.

抛出:

SQLException

方法详细资料

start

public static void start()

Start profiling.

stop

public static void stop()

Stop profiling.

getQueryCount

public static long getQueryCount(int type)

Returns the total number database queries of a particular type performed. Valid types are ProfiledConnection.SELECT, ProfiledConnection.UPDATE, ProfiledConnection.INSERT, and ProfiledConnection.DELETE.

参数:

type - the type of query to get the count for.

返回:

the number queries of type type performed.

addQuery

public static void addQuery(int type,
                            String sql,
                            long time)

参数:

sql - the insert sql string.

time - the length of time the query took in milliseconds

getQueriesPerSecond

public static double getQueriesPerSecond(int type)

Returns the average number of queries of a certain type that have been performed per second since profiling started. If profiling has been stopped, that moment in time is used for the calculation. Otherwise, the current moment in time is used.

参数:

type - the type of database query to check.

返回:

the average number of queries of a certain typed performed per second.

getAverageQueryTime

public static double getAverageQueryTime(int type)

Returns the average amount of time spent executing the specified type of query.

参数:

type - the type of query.

返回:

a double representing the average time spent executing the type of query.

getTotalQueryTime

public static long getTotalQueryTime(int type)

Returns the total amount of time in milliseconds spent doing a particular type of query. Note that this isn't necessarily representative of actual real time since db queries often occur in parallel.

参数:

type - the type of query to check.

返回:

the number of milliseconds spent executing the specified type of query.

getSortedQueries

public static ProfiledConnectionEntry[] getSortedQueries(int type,
                                                         boolean sortByTime)

Returns an array of sorted queries (as ProfiledConnectionEntry objects) by type

参数:

type - the type of query to check

sortByTime - sort the resulting list by Time if true, otherwise sort by count if false (default)

返回:

an array of ProfiledConnectionEntry objects

resetStatistics

public static void resetStatistics()

Reset all statistics.

close

public void close()
           throws SQLException

指定者:

close 在接口中 AutoCloseable

指定者:

close 在接口中 Connection

覆盖:

close 在类中 ConnectionAdapter

抛出:

SQLException

createStatement

public Statement createStatement()
                          throws SQLException

指定者:

createStatement 在接口中 Connection

覆盖:

createStatement 在类中 ConnectionAdapter

抛出:

SQLException

prepareStatement

public PreparedStatement prepareStatement(String sql)
                                   throws SQLException

指定者:

prepareStatement 在接口中 Connection

覆盖:

prepareStatement 在类中 ConnectionAdapter

抛出:

SQLException

createStatement

public Statement createStatement(int resultSetType,
                                 int resultSetConcurrency)
                          throws SQLException

指定者:

createStatement 在接口中 Connection

覆盖:

createStatement 在类中 ConnectionAdapter

抛出:

SQLException

prepareStatement

public PreparedStatement prepareStatement(String sql,
                                          int resultSetType,
                                          int resultSetConcurrency)
                                   throws SQLException

指定者:

prepareStatement 在接口中 Connection

覆盖:

prepareStatement 在类中 ConnectionAdapter

抛出:

SQLException