JDBC数据源连接池(1)---DBCP

何为数据源呢？也就是数据的来源。我在前面的一篇文章《JDBC原生数据库连接》中，采用了mysql数据库，数据来源于mysql，那么mysql就是一种数据源。在实际工作中，除了mysql，往往还会有Oracle，sql server等数据库。

在与数据源连接方面，我在《JDBC原生数据库连接》中未采用连接池的方式，而是在需要使用数据源的时候开始建立连接，等到我们使用完之后，就会把个连接close(回收释放销毁），等到我们又需要连接数据库时再建立连接，不断循环重复。由于数据库连接是比较耗时的操作，所以这种方式会造成效率下降。为此，我们引入数据源连接池的概念。在实际工作中，我们通常都是通过数据源连接池进行数据库连接的。

连接池采用了连接管理复用的机制，我们可以在数据源连接池中初始化连接数量，最小空闲数量，最大空闲数量，最大连接数量，资源回收等。数据源连接池通常有DBCP连接池，C3P0连接池，Tomcat自带的连接池机制，当然，我们也可以自己动手写一个数据源连接池工具。

我们先来看DBCP连接池。这是Apache公司推出的一种数据源连接池，全称为Database Connection Pool。我们接下来仍使用《JDBC原生数据库连接》中的前端页面与数据库，看如何使用DBCP连接池。

首先，在Web项目的WebContent--->WEB-INF--->lib文件夹中添加分别以commons-dbcp和commons-pool起始的DBCP的两个jar包。

其次，在Java Resources--->src中添加dbcpconfig.properties属性配置文件，里面的内容为：

#连接设置

driverClassName=com.mysql.jdbc.Driver

url=jdbc:mysql://localhost:3306/itszt2

username=root

password=2017

#<!-- 初始化连接 -->

initialSize=10

#最大连接数量

maxActive=50

#<!-- 最大空闲连接 -->

maxIdle=20

#<!-- 最小空闲连接 -->

minIdle=5

#<!-- 超时等待时间以毫秒为单位 6000毫秒/1000等于60秒 -->

maxWait=60000

#JDBC驱动建立连接时附带的连接属性属性的格式必须为这样：[属性名=property;]

#注意："user" 与 "password" 两个属性会被明确地传递，因此这里不需要包含他们。

connectionProperties=useUnicode=true&characterEncoding=utf8

#指定由连接池所创建的连接的自动提交（auto-commit）状态。

defaultAutoCommit=true

#driver default 指定由连接池所创建的连接的事务级别（TransactionIsolation）。

#可用值为下列之一：（详情可见javadoc。）NONE,READ_UNCOMMITTED, READ_COMMITTED, REPEATABLE_READ, SERIALIZABLE

defaultTransactionIsolation=REPEATABLE_READ

　　再次，编写数据源连接池工具类。

import org.apache.commons.dbcp.BasicDataSourceFactory;

import javax.sql.DataSource;

import java.io.IOException;

import java.io.InputStream;

import java.sql.*;

import java.util.Properties;

/**

 * DBCP数据源连接池

 *

 */

public abstract class Util_2_JDBC_DBCP {

    private static DataSource dataSource=null;

    //注册mysql驱动

    static {

    //也可以采用ResourceBundle来解析与读取属性文件里的配置信息;我们在此采用Properties类加载属性文件

　　//如果是读取的文件带有“properties”后缀名，它会从工程根目录下找;如果是到classes下则去掉后缀就可以了

//        ResourceBundle bundle = ResourceBundle.getBundle("dbcpconfig");

        Properties properties=new Properties();

        InputStream resourceAsStream = Util_2_JDBC_DBCP.class.getClassLoader().getResourceAsStream("dbcpconfig.properties");

        try {

            properties.load(resourceAsStream);

        } catch (IOException e) {

            throw new RuntimeException("读取属性文件失败!");

        }

        try {

            dataSource = BasicDataSourceFactory.createDataSource(properties);

        } catch (Exception e) {

            throw new RuntimeException("数据源连接池失败!");

        }

    }

    /**

     * 打开与数据库的连接

     * @return 一个连接对象

     */

    public static Connection openConnection(){

        try {

            return dataSource.getConnection();

        } catch (SQLException e) {

            e.printStackTrace();

        }

        return null;

    }

    //释放资源

    public static void release(Connection connection, Statement statement, ResultSet resultSet){

        if(connection!=null){

            try {

                connection.close();

            } catch (SQLException e) {

                e.printStackTrace();

            }

        }

        if (statement != null) {

            try {

                statement.close();

            } catch (SQLException e) {

                e.printStackTrace();

            }

        }

        if (resultSet != null) {

            try {

                resultSet.close();

            } catch (SQLException e) {

                e.printStackTrace();

            }

        }

    }

}

　　最后，我们在com.itszt.demo文件夹中的LoginServlet.java的Servlet文件中，将产生Connection对象的方式修改为DBCP连接池方式即可。

巴特西

JDBC数据源连接池(1)---DBCP

最新文章

热门文章