数据库连接池(DBCP C3P0)
2016-08-15 16:10
302 查看
一:DBCP(commons-dbcp-1.4)
//纯Java方式设置参数,使用dbcp池
@Test
public void testDbcp() throws Exception{
BasicDataSource pool = new BasicDataSource();//连接池
pool.setUsername("root");
pool.setPassword("");
pool.setDriverClassName("com.mysql.jdbc.Driver");
pool.setUrl("jdbc:mysql://127.0.0.1:3306/mysql?useUnicode=true&characterEncoding=utf-8");
System.out.println(pool.getMaxActive());//最多能有多少个Connection
System.out.println(pool.getInitialSize());//初始化时有几个Connection
System.out.println( pool.getMaxIdle() ); //最大空闲时间。如果一个用户获取一个连接,不用,多长时间会被强行收回
System.out.println( pool.getMaxWait() ); //等待多长时间,超过该时间就算超时,抛出异常
System.out.println("-----------------");
pool.setMaxActive(10);//可以我们自己设置池的相关参数,如最大连接数
//从它的池中获取连接
for(int i=0;i<20;i++){
Connection con = pool.getConnection();
System.out.println(con.hashCode());
if(i%2==0){
con.close();
}
}
}
注意事项:BasicDataSource.getConnection拿到的con对象,一旦.close之后,该对象关闭,无法继续操作数据库,下次获取的知识hash值一样的其他连接。
处理事务:
public class DbcpUtil {
private static DataSource pool;
private static ThreadLocal<Connection> t = new ThreadLocal<Connection>();
static{
try {
// 读取配置文件
Properties p = new Properties();
p.load(DbcpUtil.class.getResourceAsStream("dbcp.properties"));// 配置文件和当前类的class放在一起
pool = BasicDataSourceFactory.createDataSource(p);
} catch (Exception e) {
e.printStackTrace();
}
}
//返回DataSource--池
public static DataSource getDataSource(){
return pool;
}
public static Connection getConn() throws Exception{
//从本地线程管理对象t中拿
Connection con = t.get();
if(con==null||con.isColose()){
con = pool.getConnection();
//放到t中
t.set(con);
}
return con;
}
}
二:C3P0(c3p0-0.9.1.2)
@Test//纯Java方法使用c3p0
public void C3p0Demo() throws Exception{
ComboPooledDataSource pool = new ComboPooledDataSource();
pool.setUser("root");
pool.setPassword("");
pool.setJdbcUrl("jdbc:mysql://127.0.0.1:3306/mysql?useUnicode=true&characterEncoding=utf-8");
pool.setDriverClass("com.mysql.jdbc.Driver");
//System.out.println(pool);
//可以在此调用pool.setters()方法对pool进行定制
pool.setAcquireIncrement(5);
// pool.setMaxPoolSize(20);
//跟dbcp不同之处,连接关闭之后,内存会被释放,下次取时会重新开(内存地址不共用)
for(int i=0;i<20;i++){
Connection con = pool.getConnection();
System.out.println(i+":"+ con);
if(i%2==0){
con.close();
}
}
}
配置文件:c3p0-config.xml:
<c3p0-config>
<!-- 默认配置,如果没有指定则使用这个配置 -->
<default-config>
<property name="driverClass">com.mysql.jdbc.Driver</property>
<property name="jdbcUrl">
<![CDATA[jdbc:mysql://127.0.0.1:3306/mysql?useUnicode=true&characterEncoding=UTF-8]]>
</property>
<property name="user">root</property>
<property name="password"></property>
<!-- 初始化池大小 -->
<property name="initialPoolSize">2</property>
<!-- 最大空闲时间 -->
<property name="maxIdleTime">30</property>
<!-- 最多有多少个连接 -->
<property name="maxPoolSize">10</property>
<!-- 最少几个连接 -->
<property name="minPoolSize">2</property>
<!-- 每次最多可以执行多少个批处理语句 -->
<property name="maxStatements">50</property>
</default-config>
<!-- 命名的配置 -->
<named-config name="hncu">
<property name="driverClass">com.mysql.jdbc.Driver</property>
<property name="jdbcUrl">jdbc:mysql://127.0.0.1:3306/mysql</property>
<property name="user">root</property>
<property name="password"></property>
<property name="acquireIncrement">5</property><!-- 如果池中数据连接不够时一次增长多少个 -->
<property name="initialPoolSize">100</property>
<property name="minPoolSize">50</property>
<property name="maxPoolSize">1000</property>
<property name="maxStatements">0</property>
<property name="maxStatementsPerConnection">5</property> <!-- he's important, but there's only one of him -->
</named-config>
</c3p0-config>
//纯Java方式设置参数,使用dbcp池
@Test
public void testDbcp() throws Exception{
BasicDataSource pool = new BasicDataSource();//连接池
pool.setUsername("root");
pool.setPassword("");
pool.setDriverClassName("com.mysql.jdbc.Driver");
pool.setUrl("jdbc:mysql://127.0.0.1:3306/mysql?useUnicode=true&characterEncoding=utf-8");
System.out.println(pool.getMaxActive());//最多能有多少个Connection
System.out.println(pool.getInitialSize());//初始化时有几个Connection
System.out.println( pool.getMaxIdle() ); //最大空闲时间。如果一个用户获取一个连接,不用,多长时间会被强行收回
System.out.println( pool.getMaxWait() ); //等待多长时间,超过该时间就算超时,抛出异常
System.out.println("-----------------");
pool.setMaxActive(10);//可以我们自己设置池的相关参数,如最大连接数
//从它的池中获取连接
for(int i=0;i<20;i++){
Connection con = pool.getConnection();
System.out.println(con.hashCode());
if(i%2==0){
con.close();
}
}
}
//通过配置文件方式设置参数,使用dbcp池 @Test public void testPropertyFile() throws Exception{ Properties p = new Properties(); p.load(DbcpPoolDemo.class.getResourceAsStream("dbcp.properties"));//配置文件和当前类的class放在一起 //p.load(DbcpPoolDemo.class.getClassLoader().getResourceAsStream("dbcp.properties"));//配置文件要放在src(bin)的根目录---classpath的根 DataSource pool = BasicDataSourceFactory.createDataSource(p); //从它的池中获取连接 for(int i=0;i<10;i++){ Connection con = pool.getConnection(); System.out.println(con.hashCode()); if(i%2==0){ con.close(); } } }
注意事项:BasicDataSource.getConnection拿到的con对象,一旦.close之后,该对象关闭,无法继续操作数据库,下次获取的知识hash值一样的其他连接。
处理事务:
public class DbcpUtil {
private static DataSource pool;
private static ThreadLocal<Connection> t = new ThreadLocal<Connection>();
static{
try {
// 读取配置文件
Properties p = new Properties();
p.load(DbcpUtil.class.getResourceAsStream("dbcp.properties"));// 配置文件和当前类的class放在一起
pool = BasicDataSourceFactory.createDataSource(p);
} catch (Exception e) {
e.printStackTrace();
}
}
//返回DataSource--池
public static DataSource getDataSource(){
return pool;
}
public static Connection getConn() throws Exception{
//从本地线程管理对象t中拿
Connection con = t.get();
if(con==null||con.isColose()){
con = pool.getConnection();
//放到t中
t.set(con);
}
return con;
}
}
二:C3P0(c3p0-0.9.1.2)
@Test//纯Java方法使用c3p0
public void C3p0Demo() throws Exception{
ComboPooledDataSource pool = new ComboPooledDataSource();
pool.setUser("root");
pool.setPassword("");
pool.setJdbcUrl("jdbc:mysql://127.0.0.1:3306/mysql?useUnicode=true&characterEncoding=utf-8");
pool.setDriverClass("com.mysql.jdbc.Driver");
//System.out.println(pool);
//可以在此调用pool.setters()方法对pool进行定制
pool.setAcquireIncrement(5);
// pool.setMaxPoolSize(20);
//跟dbcp不同之处,连接关闭之后,内存会被释放,下次取时会重新开(内存地址不共用)
for(int i=0;i<20;i++){
Connection con = pool.getConnection();
System.out.println(i+":"+ con);
if(i%2==0){
con.close();
}
}
}
@Test//演示采用配置文件的方式使用c3p0 public void C3p0PropertyDemo() throws Exception{ //ComboPooledDataSource pool = new ComboPooledDataSource();//空参,自动到classpath目录下面加载“c3p0-config.xml”配置文件---配置文件的存储位置和名称必须是这样,且使用“默认配置” ComboPooledDataSource pool = new ComboPooledDataSource("hncu");//加载“c3p0-config.xml”文件中定义的“hncu”这个配置元素 for(int i=0;i<200;i++){ Connection con = pool.getConnection(); System.out.println(i+":"+ con); // if(i%2==0){ // con.close(); // } } }
配置文件:c3p0-config.xml:
<c3p0-config>
<!-- 默认配置,如果没有指定则使用这个配置 -->
<default-config>
<property name="driverClass">com.mysql.jdbc.Driver</property>
<property name="jdbcUrl">
<![CDATA[jdbc:mysql://127.0.0.1:3306/mysql?useUnicode=true&characterEncoding=UTF-8]]>
</property>
<property name="user">root</property>
<property name="password"></property>
<!-- 初始化池大小 -->
<property name="initialPoolSize">2</property>
<!-- 最大空闲时间 -->
<property name="maxIdleTime">30</property>
<!-- 最多有多少个连接 -->
<property name="maxPoolSize">10</property>
<!-- 最少几个连接 -->
<property name="minPoolSize">2</property>
<!-- 每次最多可以执行多少个批处理语句 -->
<property name="maxStatements">50</property>
</default-config>
<!-- 命名的配置 -->
<named-config name="hncu">
<property name="driverClass">com.mysql.jdbc.Driver</property>
<property name="jdbcUrl">jdbc:mysql://127.0.0.1:3306/mysql</property>
<property name="user">root</property>
<property name="password"></property>
<property name="acquireIncrement">5</property><!-- 如果池中数据连接不够时一次增长多少个 -->
<property name="initialPoolSize">100</property>
<property name="minPoolSize">50</property>
<property name="maxPoolSize">1000</property>
<property name="maxStatements">0</property>
<property name="maxStatementsPerConnection">5</property> <!-- he's important, but there's only one of him -->
</named-config>
</c3p0-config>
相关文章推荐
- MySQL中的integer 数据类型
- MySQL存储过程
- mysql中int、bigint、smallint 和 tinyint的区别与长度
- mysql load data 导出、导入 csv
- source命令执行SQL脚本文件
- MySQL创建用户及权限控制
- MySQL管理数据表
- linux下mysql添加用户
- mysql procedure
- mysql触发器
- MySQL 备份和恢复策略
- mac下安装mysql(转载)
- mysql 修改编码 Linux/Mac/Unix/通用(杜绝修改后无法启动的情况!)
- MySQL数据的导出、导入(mysql内部命令:mysqldump、mysql)
- mysql数据行转列
- Linux下修改MySQL编码的方法
- MySQL Server 日志
- MySQL 安全事宜