DBCP建立数据连接池

缺乏、安全感 2022-06-09 00:49 259阅读 0赞

数据库连接池负责分配,管理和释放数据库连接,它允许应用程序重复使用一个现有的数据库连接,而不是重新建立一个

*   *   *  导入jar包
         *  新建dbcpconfigproperties文件
         *  建立工具类代码

--------------------

### 导入jar包 ###

DBCPjar包：  
[http://download.csdn.net/download/zhengyikuangge/9946326][http_download.csdn.net_download_zhengyikuangge_9946326]  
数据库连接jar包（mysql）：  
[http://download.csdn.net/download/zhengyikuangge/9406895][http_download.csdn.net_download_zhengyikuangge_9406895]

--------------------

### 新建dbcpconfig.properties文件 ###

在项目上右键新建一个File，然后命名为： dbcpconfig.properties。  
代码如下：

#连接设置
    driverClassName=com.mysql.jdbc.Driver
    url=jdbc:mysql://localhost:3306/testdb
    username=root
    password=123456
    
    #
    initialSize=10
    
    #最大连接数量
    maxActive=50
    
    #最大空闲连接
    maxIdle=20
    
    #最小空闲连接
    minIdle=5
    
    #超时等待时间以毫秒为单位
    maxWait=60000
    
    connectionProperties=useUnicode=true;characterEncoding=UTF8
    
    #指定由连接池所创建的连接的自动提交（auto-commit）状态。
    defaultAutoCommit=true
    
    #driver default 指定由连接池所创建的连接的只读（read-only）状态。
    defaultReadOnly=false
    
    #driver default 指定由连接池所创建的连接的事务级别
    defaultTransactionIsolation=REPEATABLE_READ

--------------------

### 建立工具类代码 ###

package com.wt.utils;
    
    import java.io.InputStream;
    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 JdbcUtils {
        
    
        private static DataSource ds = null;
        // 在静态代码块中创建数据库连接池
        static {
            try {
                // 加载配置文件
                InputStream in = JdbcUtils_DBCP.class.getClassLoader()
                        .getResourceAsStream("dbcpconfig.properties");
                Properties prop = new Properties();
                prop.load(in);
                // 创建数据源
                ds = BasicDataSourceFactory.createDataSource(prop);
            } catch (Exception e) {
                throw new ExceptionInInitializerError(e);
            }
        }
    
        /*
         * 从数据源中获取数据库连接
         */
        public static Connection getConnection() throws SQLException {
            return  ds.getConnection();
        }
    
        /*
         * 释放资源
         */
        public static void release(Connection conn, Statement st, ResultSet rs) {
            if (rs != null) {
                try {
                    rs.close();
                } catch (Exception e) {
                    e.printStackTrace();
                }
                if (st != null) {
                    try {
                        st.close();
                    } catch (Exception e) {
                        e.printStackTrace();
                    }
                    if (conn != null) {
                        try {
                            conn.close();
                        } catch (SQLException e) {
                            e.printStackTrace();
                        }
                    }
                }
            }
        }
    }

需要connection的时候直接调用getConnection()方法，用完之后调用release方法。

[http_download.csdn.net_download_zhengyikuangge_9946326]: http://download.csdn.net/download/zhengyikuangge/9946326
[http_download.csdn.net_download_zhengyikuangge_9406895]: http://download.csdn.net/download/zhengyikuangge/9406895