数据库连接池-DBCP

发布于:2023-01-13 ⋅ 阅读:(245) ⋅ 点赞:(0)

目录

一、简介 

二、常用参数说明

三、编码测试 

一、简介 

DBCP (DatabaseConnection Pool)是Apache放下的一个依赖Jakarta commons-pool对象池机制的数据库连接池,Tomcat的数据源使用的就是DBCP。

使用DBCP会用到commons-dbcp.jarcommons-pool.jar两个包。

DBCP的工作原理是,程序首先会初始化相应的数据库连接池,以供程序访问,当某个操作需要访问数据库时,程序会首先在连接池中取得空闲连接,如没有空闲连接在创建,用完之后归还连接池,这样达到了连接的重利用,不用频繁的创建连接和销毁,从而优化程序。

二、常用参数说明

  • initialSize=10:初始化连接,连接池启动时创建的初始化连接数量(默认为0)
  • maxActive=50:最大活动连接,在连接池中可同时连接的最大的连接数(默认为8)
  • minIdle=10:最小空闲连接,连接池中最小的空闲的连接数,低于这个数量就会创建新的连接(默认为0,该参数越接近maxIdle性能越好,因为连接的创建和销毁都是需要消耗资源的,但是也不能太大)
  • maxIdle=20:最大空闲连接数,超过的空闲连接将会被释放,如果设置为负数表示不限制(默认是8个,maxIdle不能设置太小,因为在高负载的情况下,连接的打开时间比关闭时间快,会导致连接池中Idle的个数上升超过maxIdle,因而造成频繁的连接创建和销毁)
  • maxWait=60000:从连接池取连接的最大等待时间,单位是毫秒(ms),当没有可用连接时,超过该时间限制后就会抛出异常,如果设置为-1表示无限等待(默认为无限等待)

三、编码测试 

1)导入jar包

commons-pool2-2.11.1-bin.zip-Java文档类资源-CSDN下载

commons-dbcp2-2.9.0-bin.zip-Java文档类资源-CSDN下载

2)准备配置文件

#连接设置
driverClassName=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/jdbcstudy?useUnicode=true&characterEncoding=utf8&useSSL=true
username=xxxx
password=xxxx

#初始化连接数
initialSize=10

#最大活动连接数
maxActive=50

#最大空闲数
maxIdle=20

#最小空闲数
minIdle=5

#最长等待时间(以毫秒为单位)
maxWait=60000

#JDBC驱动建立连接时附带的连接属性属性的格式必须为这样:[属性名=property;]
#注意:“user” 与 “password” 两个属性会被明确地传递,因此这里不需要包含他们。
connectionProperties=useUnicode=true;characterEncoding=UTF8

#指定由连接池所创建的连接的自动提交(auto-commit)状态。
defaultAutoCommit=true

defaultReadOnly=

#driver default 指定由连接池所创建的连接的事务级别(TransactionIsolation)。
#可用值为下列之一:(详情可见javadoc。)NONE,READ_UNCOMMITTED, READ_COMMITTED, REPEATABLE_READ, SERIALIZABLE
defaultTransactionIsolation=READ_UNCOMMITTED

3)改写工具类

import com.jdbc.study04.JdbcUtils;
import org.apache.commons.dbcp2.BasicDataSource;
import org.apache.commons.dbcp2.BasicDataSourceFactory;

import java.io.InputStream;
import java.sql.*;
import java.util.Properties;

public class JdbcUtils_DBCP {
    private  static  BasicDataSource dataSource=null;

    static {
        try{
            InputStream in = JdbcUtils.class.getClassLoader().getResourceAsStream("dbcpconfig.properties");
            Properties properties = new Properties();
            properties.load(in);

            //创建数据源 (工厂模式)
            dataSource = BasicDataSourceFactory.createDataSource(properties);

        }catch (Exception e){
            e.printStackTrace();
        }
    }

    //获取连接 数据源中自带连接
    public static Connection getConnection() throws SQLException {
        return dataSource.getConnection();
    }

    public static void release(Connection conn,Statement st,ResultSet rs){
        if(rs!=null){
            try {
                rs.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        if(st!=null){
            try {
                st.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        if(conn!=null){
            try {
                conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

4)运行测试

import java.sql.*;

public class TestDBCP {
    public static void main(String[] args) {
        Connection conn=null;
        PreparedStatement st=null;
        try {
            conn= JdbcUtils_DBCP.getConnection();
            String sql="insert into users(`id`,`NAME`,`PASSWORD`,`email`,`birthday`) value (?,?,?,?,?)";
            st=conn.prepareStatement(sql);

            //手动给参数赋值
            st.setInt(1,4);//id复制
            st.setString(2,"ming");
            st.setString(3,"123456");
            st.setString(4,"ming@qq.com");
            //sql.Date    数据库
            //util.Date   Java           new Date().getTime()获得时间戳
            st.setDate(5,new java.sql.Date(new java.util.Date().getTime()));

            int i = st.executeUpdate();

            if(i>0){
                System.out.println("插入成功");
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            JdbcUtils_DBCP.release(conn,st,null);
        }
    }
}

可能出现的问题:

原因:DBCP2之后的版本需要 logging 包

下载loggingjar包,再导入lib目录下

百度网盘 请输入提取码

提取码:qymn

问题解决:


网站公告

今日签到

点亮在社区的每一天
去签到