MySQL -> 数据库连接池

• 编写连接池，实现一个接口——DataSource
• 开源数据源实现（拿来即用）
  • DBCP
  • C3P0
  • Druid : 阿里巴巴
• 使用里这些数据库连接池之后，我们在项目开发中就不需要编写连接数据库的代码了

1. DBCP

• 需要用到的jar包

  • commons-dbcp-1.4 ：连接池的实现
  • commons-pool-1.6 ：连接池实现的依赖库

• dbcpconfig.properties

#连接设置
driverClassName = com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/jdbcStudy?useUnicode=true&CharacterEncoding=utf8&useSSL=true
username = root
password = 123456

#<!-- 初始化连接 -->
initialSize = 10

#最大连接数量
maxActive = 50

#<!-- 最大空闲连接 -->
maxIdle = 20

#<!-- 最小空闲连接 -->
minIdle = 5

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

connectionProperties = useUnicode=true;CharacterEncoding=utf8

defaultAutoCommit = true

defaultReadOnly=

defaultTransactionIsolation = READ_UNCOMMITTED

• JdbcUtils_JDBC.java

import org.apache.commons.dbcp.BasicDataSourceFactory;

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

public class JdbcUtils_DBCP {
    private static DataSource dataSource = null;

    static {
        try{
            InputStream in = JdbcUtils_DBCP.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(conn!=null){
            try {
                conn.close();
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            }
        }
        if(st!=null){
            try {
                st.close();
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            }
        }
        if(rs!=null){
            try {
                rs.close();
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            }
        }
    }
}

• TestDBCP.java

import com.anobabe.lesson05.utils.JdbcUtils_DBCP;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.Date;

public class TestDBCP {
    public static void main(String[] args) {
        Connection conn = null;
        PreparedStatement pst = null;


        try {
            conn = JdbcUtils_DBCP.getConnection();
            // 与Statement的区别：使用？占位符代表参数
            String sql = "INSERT INTO users(`id`,`name`,`password`,`email`,`birthday`) VALUES (?,?,?,?,?)";
            pst = conn.prepareStatement(sql);
            pst.setInt(1,5);
            pst.setString(2,"Jay");
            pst.setString(3,"111111");
            pst.setString(4,"jay@sina.com");
            //注意点：java.sql.Date  -- 数据库
            //      java.util.Date -- Java  new Date().getTime()获得时间戳
            pst.setDate(5,new java.sql.Date(new Date().getTime()));

            //执行：预编译执行不用穿参数
            int i = pst.executeUpdate();
            if(i>0){
                System.out.println("插入成功！");
            }
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        }finally {
            JdbcUtils_DBCP.release(conn,pst,null);
        }
    }
}

2. C3P0

• 需要用到的jar包

  • c3p0-0.9.5.5.jar
  • mchange-commons-java-0.2.19.jar

• c3p0配置文件：c3p0-config.xml

<?xml version="1.0" encoding="UTF-8" ?>

<c3p0-config>
    <default-config>

        <property name="user">root</property> //数据库用户名
        <property name="password">123456</property> //数据库密码
        <property name="jdbcUrl">jdbc:mysql://localhost:3306/sys</property>//jdbc数据库连接地址
        <property name="driverClass">com.mysql.jdbc.Driver</property>//加载相应数据库驱动


        <property name="checkoutTimeout">30000</property>//当连接池用完时客户端调用getConnection()后等待获取新连接的时间，超时后将抛出SQLException,如设为0则无限期等待。单位毫秒。
        <property name="idleConnectionTestPeriod">30</property>//每个几秒检查所有连接池中的空闲连接
        <property name="initialPoolSize">10</property>//连接池初始化时创建的连接数
        <property name="maxIdleTime">30</property>//连接的最大空闲时间，如果超过这个时间，某个数据库连接还没有被使用，则会断开掉这个连接如果为0，则永远不会断开连接
        <property name="maxPoolSize">20</property>连接池中拥有的最大连接数，如果获得新连接时会使连接总数超过这个值则不会再获取新连接，而是等待其他连接释放，所以这个值有可能会设计地很大
        <property name="minPoolSize">5</property>连接池保持的最小连接数，后面的maxIdleTimeExcessConnections跟这个配合使用来减轻连接池的负载
        <property name="acquireIncrement">5</property>//连接池在无空闲连接可用时一次性创建的新数据库连接数
        <property name="maxIdleTimeExcessConnection">25</property>//单位秒，为了减轻连接池的负载，当连接池经过数据访问高峰创建了很多连接，但是后面连接池不需要维护这么多连接，必须小于maxIdleTime.配置不为0，则将连接池的数量保持到minPoolSize

    </default-config>

    <named-config name="MySQL">
        <property name="driverClass">com.mysql.jdbc.Driver</property>
        <property name="jdbcUrl">jdbc:mysql://localhost:3306/jdbcStudy?useUnicode=true&amp;characterEncoding=utf8&amp;useSSL=true</property>
        <property name="user">root</property>
        <property name="password">123456</property>

        <property name="acquireIncrement">5</property>
        <property name="initialPoolSize">10</property>//连接池初始化时创建的连接数
        <property name="maxPoolSize">20</property>连接池中拥有的最大连接数，如果获得新连接时会使连接总数超过这个值则不会再获取新连接，而是等待其他连接释放，所以这个值有可能会设计地很大
        <property name="minPoolSize">5</property>连接池保持的最小连接数，后面的maxIdleTimeExcessConnections跟这个配合使用来减轻连接池的负载
    </named-config>

</c3p0-config>

• new ComboPooledDataSource();
• new ComboPooledDataSource(“MySQL”);

结论：无论使用什么数据源，本质还是一样的，均是使用DataSource接口，方法不变。