p6spy mysql8_P6Spy监控SQL语句及性能测试

http://p6spy.github.io/p6spy/2.0/configandusage.html

P6Spy下载：http://sourceforge.net/projects/p6spy/files/

P6Spy介绍：http://www.open-open.com/lib/view/open1429863625385.html

配置sqlP6Spy配置信息说明：http://blog.csdn.net/z69183787/article/details/43453581

P6Spy和sping配合显示真正的SQL：http://blog.csdn.net/rznice/article/details/7044614

P6Spy源码分析,理解跟踪SQL的工作原理：http://blog.csdn.net/sunyujia/article/details/2207027

测试实例：

package p6spy;

import java.beans.PropertyVetoException;

import java.io.IOException;

import java.io.InputStream;

import java.sql.Connection;

import java.sql.PreparedStatement;

import java.sql.ResultSet;

import java.util.Properties;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import com.mchange.v2.c3p0.ComboPooledDataSource;

import com.p6spy.engine.spy.P6DataSource;

public class testP6Spy {

private static Logger log = LoggerFactory.getLogger(testP6Spy.class);

private static P6DataSource p6DSource =null;

private static ComboPooledDataSource cpDSource =null;

private static void initP6SpyDataSource(){

Properties props = new Properties();

InputStream in = Thread.currentThread().getContextClassLoader().getResourceAsStream("c3p0.properties");

try {

props.load(in);

} catch (IOException e) {

e.printStackTrace();

}

finally{

try {

in.close();

} catch (IOException e) {

e.printStackTrace();

}

cpDSource = new ComboPooledDataSource();

try {

cpDSource.setDriverClass(props.getProperty("driver"));

log.info("=============driver:"+props.getProperty("driver"));

cpDSource.setJdbcUrl(props.getProperty("url"));

log.info("=============url:"+props.getProperty("url"));

cpDSource.setUser(props.getProperty("user"));

log.info("=============user:"+props.getProperty("user"));

cpDSource.setPassword(props.getProperty("password"));

log.info("=============password:"+props.getProperty("password"));

cpDSource.setInitialPoolSize(5);

cpDSource.setMinPoolSize(30);

cpDSource.setMinPoolSize(5);

/*c3p0全局的PreparedStatements缓存的大小。

如果maxStatements与maxStatementsPerConnection均为0，则缓存不生效，

只要有一个不为0，则语句的缓存就能生效。如果默认值: 0*/

cpDSource.setMaxStatements(100);

//最大空闲时间，60秒内未使用则连接被丢弃。若为0则永不丢弃。默认值: 0

cpDSource.setIdleConnectionTestPeriod(60);

/*如果为false，则获取连接失败将会引起所有等待连接池来获取连接的线程抛出异常，

但是数据源仍有效保留，并在下次调用getConnection()的时候继续尝试获取连接。

如果设为true，那么在尝试获取连接失败后该数据源将申明已断开并永久关闭。默认: false*/

cpDSource.setBreakAfterAcquireFailure(false);

//定义在从数据库获取新连接失败后重复尝试的次数。默认值: 30 ；小于等于0表示无限次

cpDSource.setAcquireRetryAttempts(30);

cpDSource.setTestConnectionOnCheckout(false);

} catch (PropertyVetoException e) {

e.printStackTrace();

}

p6DSource = new P6DataSource(cpDSource);

log.info("========Init p6DSource end=============");

}

public static void main(String[] args){

initP6SpyDataSource();

testP6SpyBaseMysql();

}

public static void testP6SpyBaseMysql()

{

Connection con = null;// 创建一个数据库连接

PreparedStatement pre = null;// 创建预编译语句对象，一般都是用这个而不用Statement

ResultSet result = null;// 创建一个结果集对象

try

{

con = p6DSource.getConnection();

String iSql = "INSERT INTO user(name,age)VALUES(?,?)";

PreparedStatement ps =con.prepareStatement(iSql);

ps.setString(1, "jack");

ps.setInt(2, 23);

ps.execute();

ps.setString(1, "mark");

ps.setInt(2, 67);

ps.execute();

String uSql = "UPDATE user SET name = ?,age=? WHERE id=?";

ps = con.prepareStatement(uSql);

ps.setString(1, "donald");

ps.setInt(2, 28);

ps.setInt(3, 11);

ps.executeUpdate();

}

catch (Exception e)

{

log.error("============ERROR:"+e.getMessage());

e.printStackTrace();

}

finally

{

try

{

if (result != null)

result.close();

if (pre != null)

pre.close();

if (con != null)

con.close();

}

catch (Exception e)

{

e.printStackTrace();

}

测试结果：

八月 23, 2016 6:42:43 下午 com.mchange.v2.log.slf4j.Slf4jMLog$Slf4jMLogger$InfoLogger log

信息: MLog clients using slf4j logging.

八月 23, 2016 6:42:44 下午 com.mchange.v2.log.slf4j.Slf4jMLog$Slf4jMLogger$InfoLogger log

信息: Initializing c3p0-0.9.5.2 [built 08-December-2015 22:06:04 -0800; debug? true; trace: 10]