数据库连接池常用数据源之DBCP

逃离我推掉我的手 2022-06-08 06:45 209阅读 0赞

### 1.添jar包 ###

![这里写图片描述][SouthEast]  
这三个

### 2.配置文件 ###

名字：dbcpconfig.properties  
代码：

#连接设置
    driverClassName=com.mysql.jdbc.Driver
    #
    url=jdbc:mysql://localhost:3306/day_14
    username=root
    password=123456
    
    #
    initialSize=10
    
    #最大连接数量
    maxActive=50
    
    #
    maxIdle=20
    
    #
    minIdle=5
    
    #
    maxWait=60000
    
    
    #JDBC驱动建立连接时附带的连接属性属性的格式必须为这样：[属性名=property;] 
    #注意："user" 与 "password" 两个属性会被明确地传递，因此这里不需要包含他们。
    connectionProperties=useUnicode=true;characterEncoding=utf8
    
    #指定由连接池所创建的连接的自动提交（auto-commit）状态。
    defaultAutoCommit=true
    
    #driver default 指定由连接池所创建的连接的只读（read-only）状态。
    #如果没有设置该值，则“setReadOnly”方法将不被调用。（某些驱动并不支持只读模式，如：Informix）
    defaultReadOnly=
    
    #driver default 指定由连接池所创建的连接的事务级别（TransactionIsolation）。
    #可用值为下列之一：（详情可见javadoc。）NONE,READ_UNCOMMITTED, READ_COMMITTED, REPEATABLE_READ, SERIALIZABLE四个隔离级别
    defaultTransactionIsolation=REPEATABLE_READ

### 3.添加DBCP工具类 ###

package com.qf.util;
    
    import java.sql.Connection;
    import java.sql.ResultSet;
    import java.sql.SQLException;
    import java.sql.Statement;
    import java.util.Properties;
    
    import javax.sql.DataSource;
    
    import org.apache.commons.dbcp.BasicDataSourceFactory;
    
    public class DBCPUtil { 
        private  static DataSource ds=null;
    
        //处理配置文件
        static{
            Properties prop=new Properties();
            try {
                prop.load(DBCPUtil.class.getClassLoader().getResourceAsStream("dbcpconfig.properties"));
                ds=BasicDataSourceFactory.createDataSource(prop);
            } catch (Exception e) {
                e.printStackTrace();
            }
    
        }
        //得到连接 pool
        public static Connection getConnection(){
            try {
                return ds.getConnection();
            } catch (SQLException e) {
                e.printStackTrace();
                throw new RuntimeException("服务器繁忙！！");
            }
        }
        //释放资源
        public static void release(ResultSet rs,Statement stmt,Connection conn){
            if(rs!=null){
                try {
                    rs.close();
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
                rs=null;
            }
            if(stmt!=null){
                try {
                    stmt.close();
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
                stmt=null;
            }
            if(conn!=null){
                try {
                    conn.close();//运行的时候检查调用自己重写的 close() 连接还回取
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
                conn=null;
            }
        }
    }

### 4.DBCP测试类 ###

package com.qf.dbcp.test;
    
    import java.sql.Connection;
    import java.sql.PreparedStatement;
    import java.sql.SQLException;
    
    import org.junit.Test;
    
    import com.qf.util.DBCPUtil;
    
    public class DBCPTestCURD { 
        @Test
       public void testInsert(){
            Connection conn =null;
             PreparedStatement ps=null;
           try {
                 conn= DBCPUtil.getConnection();//从连接池中获取连接
                 ps = conn.prepareStatement("insert into account values (null,'eee',1000)");
                 int i = ps.executeUpdate();
            } catch (SQLException e) {
    
                e.printStackTrace();
    
            }finally{
                DBCPUtil.release(null, ps, conn);
            }
       }
    }

[SouthEast]: /images/20220608/e65afa8894884d90b2e490de26330524.png