java学习笔记之数据库连接池（DBCP和C3P0）

数据库连接池（DBCP和C3P0）

一.数据库连接池的概念

　　数据库连接池可以理解为是存放多个数据库连接的集合。

　　作用；解决建立数据库连接耗费很多资源和时间问题，提高性能

　　Java为数据库连接池提供了公共的接口：javax.sql.DataSource，各个厂商需要让自己的连接池实现这个接口。这样应用程序可以方便的切换不同厂商的连接池！

　　连接池图解：
　

 二..DBCP连接池：

　　1.简单介绍：

　　　　dbcp是apache组织的开源的连接池

　　2.使用步骤：

　　　　①添加jar包 commons-dbcp-1.4.jar  commons-pool-1.5.6.jar

　　　　②,编写配置文件（四大信息）

　　　　　　配置文件名以   .properties结尾

　　　　　　最好放在src目录下

　　　　　　配置文件信息如下：

driverClassName=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/day05db
username=root
password=root

　　　　③编写连接池工具类

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;
/*
 * javax.sql.DataSource接口
 *    DBCP连接池实现类：
 *      BasicDataSource
 *      BasicDataSourceFactory
 * 
 * 连接池的创建步骤 ：
 *  1：创建一个空的连接池
 *     BasicDataSource dataSource = new  BasicDataSource();
 *  2:给这个连接池设置四大信息--->连接池会自动的向池子中存放连接 (默认一般是10个)
 *    dataSource.setDriverClassName("com.mysql.jdbc.Driver");
 *    dataSource.setUrl("jdbc:mysql://localhost:3306/day04db");
 *    dataSource.setUserName("root");
 *    dataSource.setPassword("123");
 *    
 *  3:封装一个方法，对外提供一个连接池中连接 
 *     getConntion();
 */
public class MyDBCPUtils {
    private static DataSource dataSource=null;
    //创建一个空的连接池
    static{
        Properties properties=new Properties();
        try {
            
            properties.load(MyDBCPUtils.class.getClassLoader().getResourceAsStream("dbcp.properties"));
            /*MyDBCPUtils.class.getClassLoader().getResourceAsStream("dbcp.properties")
             * 方法会自动的去bin目录中找配置文件夹
             */
            /*
             * 该方法会做两件事情：
             *  1：自动从Properties集合中获取四大信息
             *  2: 创建一个有连接的连接池
             */
            dataSource=BasicDataSourceFactory.createDataSource(properties);
        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        
    }
    /**
     * 创建一个静态方法 ，可以让外界获取连接对象
     * @return  Connection 
     * @throws Exception
     */
    public static Connection  getConnection() throws Exception{
        return dataSource.getConnection();
    }
    /**
     * 
     * @param rs 结果集对象，没有写null
     * @param stat  sql执行平台对象
     * @param conn  数据库连接对象
     */
    public static void closeAll(ResultSet rs,Statement stat,Connection conn){
        
        if(rs!=null){
            try {
                rs.close();
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
        if(stat!=null){
            try {
                stat.close();
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
        
        //这里这个close不是关流释放资源，而是重写方法，将连接放回连接池
        if(conn!=null){
            try {
                conn.close();
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
    }

}

　　④使用编写的工具类（简单demo）

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;

public class Test01 {
    public static void main(String[] args)throws  Exception{
        //获得连接
        Connection conn = MyDBCPUtils.getConnection();
        
        //获得sql语句的执行平台
        PreparedStatement stat = conn.prepareStatement("select * from student");
        //获得结果集
        ResultSet result = stat.executeQuery();
        //处理结果集
        
        while(result.next()){
            System.out.println(result.getInt("stu_id"));
        }
        //释放资源
        MyDBCPUtils.closeAll(result, stat, conn);
        
    }

}

三.C3P0连接池

　　1.简单介绍

　　　　C3P0开源免费的连接池！目前使用它的开源项目有：Spring、Hibernate等。使用第三方工具需要导入jar包，c3p0使用时还需要添加配置文件 c3p0-config.xml

　　2使用步骤：

　　　　①：导入jar包

　　　　②：编写配置文件

　　　　　　　　文件类型：xml

　　　　　　　　文件名必须是 c3p0-config.xml，放在src中

　　　　　　　　简单的文件demo：

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

<!--
            dataSource.setDriverClass("com.mysql.jdbc.Driver");
            dataSource.setJdbcUrl("jdbc:mysql://localhost:3306/day05db");
            dataSource.setUser("root");
            dataSource.setPassword("123");

      1：获取name属性：driverClass
      2：进行字符串拼接:setDriverClass
      3: 反射setDriverClass()
      4: 调用setDriverClass()给变量赋值：com.mysql.jdbc.Driver
 -->
<c3p0-config> 
    <default-config>
         <property name="driverClass">com.mysql.jdbc.Driver</property>
         <property name="jdbcUrl">jdbc:mysql://localhost:3306/day05db</property>
         <property name="user">root</property>
         <property name="password">123</property>
    </default-config>
</c3p0-config>

　　③编写连接池使用工具类

　　

/*
 * javax.sql.DataSource接口
 *    实现类：ComboPooledDataSource
 *    
 * 创建连接池：
 *   1：创建一个空的连接池
 *      ComboPooledDataSource dataSource = new ComboPooledDataSource();
 *   2: 设置四大信息--->连接池会自动的存放连接
 *     dataSource.setXxx("");
 *     dataSource.setXxx("");
 *     dataSource.setXxx("");
 *     dataSource.setXxx("");
 */

public class MyC3P0Utils {
    /*
     * 1：该对象在创建的时候会自动的检测是否有c3p0-config.xml
     * 2: 如果没有c3p0-config.xml
     *    你需要手动的设置四大信息
     * 3: 如果有c3p0-config.xml
     *    1：该对象在创建的时候会自动的解析xml文件
     *    2：获取四大信息
     *    3: 创建连接池，并向连接池中存放连接池
     */
    private static DataSource dataSource = new ComboPooledDataSource();

    //封装一个方法，让别人能够获取连接池中的连接
    public static Connection getConnetion()throws Exception{
        
        return dataSource.getConnection();
    }
    
    public static void closeAll(ResultSet rs, Statement stat, Connection conn) {
        if (rs != null) {
            try {
                rs.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        if (stat != null) {
            try {
                stat.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        if (conn != null) {
            try {
                conn.close();// 连接池已经重写类该方法，该方法是将连接重新放回到连接池
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

　　④使用工具类

import java.sql.Connection;
import java.sql.PreparedStatement;

public class TestDemo01 {
    public static void main(String[] args) throws Exception {
        //1:获取连接
         Connection conn = MyC3P0Utils.getConnetion();
        //2:执行sql
        PreparedStatement stat = conn.prepareStatement("delete from category where cid = ?");
        stat.setObject(1, 2);
        int rows = stat.executeUpdate();
        
        //3:处理结果
        if(rows > 0){
            System.out.println("删除成功");
        }else{
            System.out.println("删除失败");
        }
        
        //4: 释放资源
        MyC3P0Utils.closeAll(null, stat, conn);
    }
}