JDBC 连接池

连接池基本概念

容器创建后，创建一个连接池，初始化一些连接对象，使用时调用其中的连接对象，用完归还给连接池。这样能加快数据库连接速度。

1.DataSource 表示连接池对象

它是 javax.sql 包下的一个类

这个类是一个接口类

一般不由我们自己实现，而是数据库厂商实现连接池

2.连接池的基本使用方法

获取连接

getConnection();

归还连接

Connection.clonse();

C3P0连接池技术

1.导入 jar 包，（点击这里下载）（需要导入2个 jar 包）

（c3p0-0.9.5.2-sources.jar ，mchange-commons-java-0.2.12.jar ）

(注意：数据库连接池，仍需要导入驱动 jar 包）

2.定义配置文件，这里有一些强制的规定

• 名称：c3p0.properties 或者 c3p0-config.xml
• 路径：放在 src 下即可，会自动读取

<c3p0-config>
  <!-- 使用默认的配置读取连接池对象 -->
  <default-config>
  	<!--  连接参数 -->
    <property name="driverClass">com.mysql.jdbc.Driver</property>
    <property name="jdbcUrl">jdbc:mysql://localhost:3306/day25</property>
    <property name="user">root</property>
    <property name="password">root</property>
    
    <!-- 连接池参数，初始化数量，最大数量，连接失败超时时间 -->
    <property name="initialPoolSize">5</property>
    <property name="maxPoolSize">10</property>
    <property name="checkoutTimeout">3000</property>
  </default-config>

  <named-config name="otherc3p0"> 
    <!--  连接参数 -->
    <property name="driverClass">com.mysql.jdbc.Driver</property>
    <property name="jdbcUrl">jdbc:mysql://localhost:3306/day25</property>
    <property name="user">root</property>
    <property name="password">root</property>
    
    <!-- 连接池参数 -->
    <property name="initialPoolSize">5</property>
    <property name="maxPoolSize">8</property>
    <property name="checkoutTimeout">1000</property>
  </named-config>
</c3p0-config>

3.创建核心对象，数据库连接池对象 ComboPooledDataSource

DataSource ds = new ComboPooledDataSource();

(如果需要指定名称的数据库连接池对象，那么指定连接池配置的 name 属性）

DataSource ds = new ComboPooledDataSource("otherc3p0");

4.获取连接：getConnection();

Connection conn = ds.getConnection();

Druid 连接池

1.导入 jar 包，点击这里下载（同时不要忘记导入 驱动 jar 包）

maven导入如下坐标

    <dependency>
      <groupId>com.alibaba</groupId>
      <artifactId>druid</artifactId>
      <version>1.1.6</version>
    </dependency>

2.定义配置文件

• 必须是 properties 类型的文件
• 名称任意，可以放置在任意地方（假设为 druid.properties)

driverClassName=com.mysql.jdbc.Driver
url=jdbc:mysql://127.0.0.1:3306/db3
username=root
password=root
initialSize=5
maxActive=10
maxWait=3000

3.加载配置文件（假设当前类名为 DruidDemo）

Properties pro = new Properties();
InputStream is = DruidDemo.class.getClassLoader().getResourceAsStream("druid.properties");
pro.load(is);

4.获取数据库连接池对象，通过工厂类 DruidDataSourceFactory 获取

DataSource ds = DruidDataSourceFactory.createDataSource(pro);

5.获取连接池对象，getConnection();

Connection conn = ds.getConnection();

Druid连接池工具类

1.定义配置文件，和上面一样的操作（这里假设为 druid.properties）

2.定义一个类 JDBCUtils

import com.alibaba.druid.pool.DruidDataSourceFactory;

import javax.sql.DataSource;
import java.io.IOException;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;

/**
 * Druid连接池的工具类
 */
public class JDBCUtils {

    //定义成员变量 DataSource
    private static DataSource ds ;

    static{
        try {
            //1.加载配置文件
            Properties pro = new Properties();
            pro.load(JDBCUtils.class.getClassLoader().getResourceAsStream("druid.properties"));
            //2.获取DataSource
            ds = DruidDataSourceFactory.createDataSource(pro);
        } catch (IOException e) {
            e.printStackTrace();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    /**
     * 获取连接池方法
     */

    public static DataSource getDataSource(){
        return  ds;
    }
    
    /**
     * 获取连接方法
     */
    public static Connection getConnection() throws SQLException {
        return ds.getConnection();
    }

    //归还连接（2参数）
    public static void close(Statement stmt,Connection conn){
    	
       close(null,stmt,conn);
    }


    //归还连接（3参数）
    public static void close(ResultSet rs , Statement stmt, Connection conn){

        if(rs != null){
            try {
                rs.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }

        if(stmt != null){
            try {
                stmt.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }

        if(conn != null){
            try {
                conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}