AI专业者开发社区 1 号成员
  •  0 回帖  •  2 浏览  •  4 个月前
 

JavaWeb之数据库连接池

 

 

时间：2016-12-2 23:56

 

——DBCP 连接池
连接池参数（所有连接池参数都有默认值）：
    初始大小
    最小空闲连接数
    增量
    最大空闲连接数
    最大连接数
    最长等待时间
四大连接参数：
    连接池也是使用四大连接参数来完成创建连接对象的。
实现的接口：
    连接池必须实现：javax.sql.DataSource 接口。
连接池返回的 Connection 对象，它的 close() 方法并不是关闭连接，而是把连接归还给连接池，使用的是装饰设计模式。
dbcp.properties 配置：
#基本配置
driverClassName=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/mydb
username=root
password=root
#初始化池大小，即一开始池中连接对象的数量
#默认值为 0
initialSize=0
#最大连接数，如果设置 maxActive=50 时，表示池中最多可以有 50 个连接，包含使用和未使用的连接
#默认为 8，如果设置为非正数，表示无限大
maxActive=8
#最大空闲连接数
#默认为 8，如果设置为非正数，表示无限大
maxIdle=8
#最小空闲连接数
#默认值为 0
minIdle=0
#最大等待时间
#当设置 maxWait=5000 时，表示等待 5 秒，超时会抛出异常
#默认值为 -1，表示无期限等待，超时不会抛异常
maxWait=-1
#连接属性
#就是之前放在 url 之后的参数，现在可以使用 connectionPreperties 来指定
#userServerPrepStmts=true，表示 MySQL 开启预编译功能。
#cachePrepStmts=true，表示 MySQL 开启缓存 PrepareStatement 功能。
#prepStmtCacheSize=50，表示缓存 PreparedStatement 的上限。
#prepStmtCacheSqlLimit=300，当 SQL 模板长度大于 200 时，就不再缓存它。
#连接的默认提交方式
#默认值为 true，表示自动提交事务
defaultAutoCommit=true
#连接是否为只读连接
#Connection 有一对方法，setReadOnly(boolean) 和 isReadOnly()
#如果是只读连接，那么只能用这个连接来做查询
#指定连接为只读是为了优化，这个优化与并发事务相关
defaultReadOnly=false
#指定事务的事务隔离级别
#可选值：NONE, READ_UNCOMMITTED, READ_COMMITTED, REPEATABLE_READ, SERIALIZABLE
#如果没有指定，那么由驱动中的 Connection 类自己来决定。
defaultTransactionIsolation=REPEATABLE_READ

import java.sql.Connection;
import java.sql.SQLException;
 
import org.apache.commons.dbcp.BasicDataSource;
import org.junit.Test;
 
/**
 * DBCP 连接池
 * 
 * @author 31067
 * 
 */
public class Demo01 {
    @Test
    public void fun1() throws Exception {
        /*
         * 1、创建连接池对象 2、配置四大参数 3、配置连接池 4、得到连接池对象
         */
        BasicDataSource dataSource = new BasicDataSource();
        dataSource.setDriverClassName("com.mysql.jdbc.Driver");
        dataSource.setUrl("jdbc:mysql://localhost:3306/mydb3");
        dataSource.setUsername("root");
        dataSource.setPassword("Admin123");
        // 最大活动连接数
        dataSource.setMaxActive(20);
        // 最小空闲连接
        dataSource.setMinIdle(3);
        // 最大不活动时间
        dataSource.setMaxWait(1000);
 
        Connection conn = dataSource.getConnection();
        System.out.println(conn.getClass().getName());
 
        /**
         * 连接池内部使用四大参数创建了连接对象，即 MySQL 驱动提供的 Connection
         * 连接池使用 MySQL 的连接对象进行了装饰，只对 close() 方法进行了增强。
         * 原 close()调用之后会关闭连接，装饰之后的 close() 方法会把当前连接归还给连接池
         */
        conn.close();
    }
}
——装饰设计模式
对象增强的手段：
    1）继承
        *   被增强的对象是固定的
        *   增强的内容也是固定的

    2）装饰设计模式
        *   被增强的对象是可以切换的
        *   增强的内容时固定的

    3）动态代理
        *   被增强的对象可以切换
        *   增强的内容也可以切换
是你还有你，一切拜托你。
是你：继承或实现要装饰类的接口
还有你：内部使用构造方法保存要修饰类的对象
一切拜托你：
class MyConnection implements Connection {    // 是你
    // 还有你
    private  Connection conn;    // 底层对象，也是被增强对象
    // 通过构造器传递底层对象
    public MyConnection(Connection conn){    // 使用父类接口接受参数，保证能够接收任意参数
        this.conn = conn;
    }
    // 一切拜托你，表示使用底层对象来调用全部方法
    public Statement createStatement() {
        return conn.createStatement();
    }
    // 被装饰（增强）方法
    public void close() {
        将当前连接归还给连接池，而不是关闭。
    }
}
——C3P0 连接池
C3P0 是开源免费的连接池。
import java.sql.Connection;
 
import org.junit.Test;
 
import com.mchange.v2.c3p0.ComboPooledDataSource;
 
/**
 * 演示 C3P0
 * 手动配置参数
 * @author 31067
 * 
 */
public class Demo01 {
    @Test
    public void fun1() throws Exception {
        // 创建连接池对象
        ComboPooledDataSource dataSource = new ComboPooledDataSource();
 
        // 对连接池进行四大参数配置
        dataSource.setDriverClass("com.mysql.jdbc.Driver");
        dataSource.setJdbcUrl("jdbc:mysql://localhost:3306/mydb3");
        dataSource.setUser("root");
        dataSource.setPassword("Admin123");
 
        // 配置连接池参数
        dataSource.setAcquireIncrement(5); // 增量
        dataSource.setInitialPoolSize(20); // 初始化连接
        dataSource.setMinPoolSize(2); // 最小连接数
        dataSource.setMaxPoolSize(50); // 最大连接数
 
        Connection conn = dataSource.getConnection();
        System.out.println(conn);
        conn.close();
    }
}


输出结果：com.mchange.v2.c3p0.impl.NewProxyConnection@6adca536
可以看到实现的是 c3p3 接口，并且创建了一个新的动态代理，而非装饰类。
——使用 C3P0 配置文件创建连接池

 
配置文件要求：
    1、文件名称：必须是 c3p0-config.xml
    2、文件位置：必须在 src 目录下。
c3p0 也可以指定配置文件，而且配置文件可以是 properties，也可以是 XML 文件，当然，XML 更高级一些。但是 c3p0 的配置文件名必须为 c3p0-config.xml，并且必须放在类路径下。
配置文件信息：
<?xml version="1.0" encoding="UTF-8"?>
 
<c3p0-config>
    <!-- 默认配置 -->
    <default-config>
        <!-- 连接四大参数配置 -->
        <property name="jdbcUrl">jdbc:mysql://localhost:3306/mydb3</property>
        <property name="driverClass">com.mysql.jdbc.Driver</property>
        <property name="user">root</property>
        <property name="password">Admin123</property>
        <!-- 连接池参数配置 -->
        <property name="acquireIncrement">3</property>
        <property name="initialPoolSize">10</property>
        <prpperty name="minPoolSize">2</prpperty>
        <property name="maxPoolSize">10</property>
    </default-config>
 
    <!-- 指定名称的配置参数 -->
    <name-config name="oracle-config">
        <!-- 连接四大参数配置 -->
        <property name="jdbcUrl">jdbc:mysql://localhost:3306/mydb1</property>
        <property name="driverClass">com.mysql.jdbc.Driver</property>
        <property name="user">root</property>
        <property name="password">Admin123</property>
        <!-- 连接池参数配置 -->
        <property name="acquireIncrement">3</property>
        <property name="initialPoolSize">10</property>
        <prpperty name="minPoolSize">2</prpperty>
        <property name="maxPoolSize">10</property>
    </name-config>
</c3p0-config>
程序代码：
import java.sql.Connection;
import java.sql.SQLException;
 
import org.junit.Test;
 
import com.mchange.v2.c3p0.ComboPooledDataSource;
 
/**
 * 演示 C3P0 手动配置参数
 * 
 * @author 31067
 * 
 */
public class Demo01 {
    @Test
    public void fun1() throws Exception {
        // 创建连接池对象
        ComboPooledDataSource dataSource = new ComboPooledDataSource();
 
        // 对连接池进行四大参数配置
        dataSource.setDriverClass("com.mysql.jdbc.Driver");
        dataSource.setJdbcUrl("jdbc:mysql://localhost:3306/mydb3");
        dataSource.setUser("root");
        dataSource.setPassword("Admin123");
 
        // 配置连接池参数
        dataSource.setAcquireIncrement(5); // 增量
        dataSource.setInitialPoolSize(20); // 初始化连接
        dataSource.setMinPoolSize(2); // 最小连接数
        dataSource.setMaxPoolSize(50); // 最大连接数
 
        Connection conn = dataSource.getConnection();
        System.out.println(conn);
        conn.close();
    }
 
    /**
     * 使用配置文件的默认配置
     * 
     * @throws Exception
     */
    @Test
    public void fun2() throws Exception {
        /*
         * 在创建连接池对象时，这个对象就会自动加载配置文件，不需要手动指定（无参构造方法）
         */
        ComboPooledDataSource dataSource = new ComboPooledDataSource();
        Connection conn = dataSource.getConnection();
        System.out.println(conn);
        conn.close();
    }
 
    /**
     * 使用命名配置信息 <name-config name="oracle-config">
     * 
     * @throws Exception
     */
    @Test
    public void fun3() throws Exception {
        /*
         * 构造器的参数指定了命名配置元素的名称，用来加载指定的配置信息
         */
        ComboPooledDataSource dataSource = new ComboPooledDataSource("oracle-config");
        Connection conn = dataSource.getConnection();
        System.out.println(conn);
        conn.close();
    }
}
——使用 C3P0 创建 JDBCUtils
import java.sql.Connection;
import java.sql.SQLException;
 
import javax.sql.DataSource;
 
import com.mchange.v2.c3p0.ComboPooledDataSource;
 
public class JDBCUtils2 {
    // 使用的是配置文件的默认配置，即必须给出 c3p0-config.xml 配置文件
    private static ComboPooledDataSource dataSource = new ComboPooledDataSource();
 
    /*
     * 使用连接池返回一个连接对象
     */
    public static Connection getConnection() throws SQLException{
        return dataSource.getConnection();
    }
 
    /*
     * 返回连接池对象
     */
    public static DataSource getDataSource(){
        return dataSource;
    }
}
 

——Tomcat 配置连接池

 
1、Tomcat 配置 JNDI 资源
    JNDI（Java Naming and Directory Interface），Java 命名和目录接口。

    JNDI 的作用就是：在服务器上配置资源，然后通过统一的方式来获取配置的资源。
    这里要配置的资源当然是连接池了，这样项目中就可以通过统一的方式来获取连接池对象了。
2、下面的配置是 Tomcat 文档提供的：

<Context .>
    ...
    <Resource name="bean/MyBeanFactory" auth="Container"
        type="com.mycompany.MyBean" factory="org.apache.naming.factory.BeanFactory"
        bar="23" />
</Context>
配置 JNDI 资源需要到 <Context> 元素中配置 <Resource> 子元素：
    *   name：指定资源的名称，这个名称可以随便给，在获取资源时需要这个名称。
    *   factory：用来创建资源的工厂，这个值基本是固定的。
    *   type：资源的类型，我们要给出的类型当然是我们连接池的类型了。
        用于生成该类的对象，例如“com.mchange.v2.c3p0.ComboPooledDataSource”。
    *   bar：表示资源的属性，如果资源存在名为 bar 的属性，那么就配置 bar 的信息。对于 DBCP 连接池而言，需要配置的不是 bar，因为它没有 bar 这个属性，而是应该去配置 url、username 等属性。

<?xml version="1.0" encoding="UTF-8"?>
 
<Context>
    <!-- 
        name：指定资源的名称
        factory：指定资源由谁创建
        type：指定资源的类型
        其他相关内容都是资源的参数
     -->
    <Resource name="myc3p0"
        factory="org.apache.naming.factory.BeanFactory"
        type="com.mchange.v2.c3p0.ComboPooledDataSource"
        jdbcUrl="jdbc:mysql://localhost:3306/mydb3"
        driverClass="com.mysql.jdbc.Driver"
        user="root"
        password="Admin123"
        acquireIncrement="5"
        initialPoolSize="10"
        ......
    />
</Context>


3、获取资源
    配置资源的目的当然是为了获取资源，只要一启动 Tomcat，那么就可以在项目中任何类中通过 JNDI 获取资源的方式来获取资源了。
    与上面 Tomcat 文档提供的配置信息对应的获取资源代码如下：
    Context cxt= new InitialContext();
    Context envCxt = (Context)cxt.lookup("java:comp/env");
    MyBean bean = (MyBean)envCxt.lookup("bean/MyBeanFactory");
    Connection conn = bean.getConnection();
    writer.print("foo = " + bean.getFoo() + ", bar = " + bean.getBar());
    获取资源：
        *   Context：javax.naming.Context
        *   InitialContext：javax.naming.InitalContext
        *   lookup(String)：获取资源的方法，其中“java:comp/env”是资源的入口（这是固定的名称），获取的对象是一个 Context，这说明需要在获取到的 Context 上进一步进行获取。“bean/MyBeanFactory”对应 <Resource> 中配置的 name 的值，通过该 name 值获取到的就是资源对象了。

import java.io.IOException;
import java.sql.Connection;
 
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.sql.DataSource;
 
/**
 * 获取 JNDI 资源（数据库连接对象）
 * 
 * @author 31067
 * 
 */
public class AServlet extends HttpServlet {
 
    public void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        request.setCharacterEncoding("utf-8");
        response.setContentType("text/html;charset=utf-8");
 
 
        try {
            // 1、创建 JNDI 的上下文对象 
            Context cxt = new InitialContext();
            // 2、查询出入口
            // Context envContext = (Context) cxt.lookup("java:comp/env");
            // 3、再进行第二次查询，找到要查找的资源
            // 使用的名称与 <Resource> 元素的 name 属性对应
            // DataSource dataSource = (DataSource)
            // envContext.lookup("jdbc/dataSource");
 
            // 合并代码
            DataSource dataSource = (DataSource) cxt.lookup("java:comp/env/jdbc/dataSource");
 
            // 4、得到连接
            Connection conn = dataSource.getConnection();
            System.out.println(conn);
            conn.close();
        } catch (Exception e) {
            throw new RuntimeException();
        }
    }
}