自定義連接池，C3P0，DBUtils使用

連接池

在開發(fā)中獲得連接和釋放資源，是非常消耗資源的兩個過程。
為了解決此類性能問題，通常情況下會采用連接池技術(shù)，來共享連接Connection。

通過連接池來獲取Connection，當使用完Connection后，調(diào)用Close()不會真的關(guān)閉Connection，而是把Connection歸還池，從而可以重復使用Connection，不需要自己多次重復創(chuàng)建。

常見連接池：DBCP、C3P0，使用最多的C3P0。

連接池實現(xiàn)

Java為數(shù)據(jù)庫連接池提供了公共的接口，javax.sql.DataSource，各個廠商需要讓自己的連接池實現(xiàn)這個接口。

自定義連接池
1.創(chuàng)建連接池實現(xiàn)數(shù)據(jù)源，并實現(xiàn)接口DataSource

public class ConnTest implements DataSource {

    //1.創(chuàng)建容器，用于存儲Connection,因為移除和添加操作多，選擇LinkedList
    private static LinkedList<Connection> pool = new LinkedList<>();

    static {
        //2.創(chuàng)建連接放入容器，用于存儲Connection，連接數(shù)目自定義
        for (int i = 0; i < 5; i++) {
            pool.add(JdbcUtil.getConn());
        }
    }

    /**
     * 重寫獲取連接的方法
     */
    @Override
    public Connection getConnection() throws SQLException {
        Connection conn = null;
        if (pool.size() == 0) {
            for (int i = 0; i < 5; i++) {
                conn = JdbcUtil.getConn();
                pool.add(conn);
            }
        }

        //為了保證當前連接只能提供給一個線程使用，所以我們需要將連接從連接池中移除，
        //remove的返回值是移除的對象
        conn = pool.remove(0);
        return conn;
    }

    /**
     * 將連接歸還連接池
     * 當用戶使用完連接，釋放資源時，不執(zhí)行close()方法，而是將連接添加到連接池中
     */
    public void backConnection(Connection conn) {
        pool.add(conn);
    }

    省略其他接口方法...
}

調(diào)用
public class StudentDaoTest {

    private ConnTest mConnTest = new ConnTest();
    private Connection conn = null;

    @Test
    public void testSave() {
        try {
            conn = mConnTest.getConnection();
            if(conn==null){
                System.out.println("Null");
                return;
            }
            
            String sql = "insert into t_student(name,age)values(?,?)";
            PreparedStatement ps = conn.prepareStatement(sql);
            ps.setString(1, "連接池測試插入");
            ps.setInt(2, 18);
            ps.executeUpdate();
            ps.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }finally{
            mConnTest.backConnection(conn); 
        }
    }
}

上述實現(xiàn)存在的問題
因為是通過自定義backConnection(Connection conn)歸還Connection，
所以當調(diào)用close()時，還是會關(guān)閉掉Connection。

解決辦法
重寫Connection，用裝飾者模式增強close()方法。

public class MyConnection implements Connection {

    private Connection conn;
    private LinkedList<Connection> pool;

    public MyConnection(Connection conn, LinkedList<Connection> pool) {
        this.conn = conn;
        this.pool = pool;
    }

    @Override
    public void close() throws SQLException {
        pool.add(conn);
    }
    
    
    /**
     * 需要重寫預編譯注入，不然會報Null
     */
    @Override
    public PreparedStatement prepareStatement(String sql) throws SQLException {
        return conn.prepareStatement(sql);
    }

   省略其他接口方法...
}

修改ConnTest

public class ConnTest implements DataSource {

    //1.創(chuàng)建容器，用于存儲Connection，因為移除和添加操作多，選擇LinkedList
    private static LinkedList<Connection> pool = new LinkedList<>();

    static {
        //2.創(chuàng)建連接放入容器，用于存儲Connection，連接數(shù)目自定義
        for (int i = 0; i < 5; i++) {
            MyConnection conn = new MyConnection(JdbcUtil.getConn(), pool); 
            pool.add(conn);
        }
    }

    /**
     * 重寫獲取連接的方法
     */
    @Override
    public Connection getConnection() throws SQLException {
        Connection conn = null;
        if (pool.size() == 0) {
            for (int i = 0; i < 5; i++) {
                conn = new MyConnection(JdbcUtil.getConn(), pool);
                pool.add(conn);
            }
        }

        //為了保證當前連接只能提供給一個線程使用，所以我們需要將連接從連接池中移除，
        //remove的返回值是移除的對象
        conn = pool.remove(0);
        return conn;
    }
}

修改調(diào)用
public class StudentDaoTest {

    private ConnTest mConnTest = new ConnTest();
    private Connection conn = null;

    @Test
    public void testSave() {
        try {
            conn = mConnTest.getConnection();
            if (conn == null) {
                System.out.println("Null");
                return;
            }

            String sql = "insert into t_student(name,age)values(?,?)";
            PreparedStatement ps = conn.prepareStatement(sql);
            ps.setString(1, "連接池測試插入");
            ps.setInt(2, 18);
            ps.executeUpdate();
            ps.close();
            conn.close(); //現(xiàn)在調(diào)用關(guān)閉，不會真正關(guān)閉連接
            
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

C3P0連接池框架

C3P0下載地址

C3P0可以通過代碼配置，也可以通過配置文件配置，一般開發(fā)用配置文件配置，將配置文件放到src/resource目錄下。

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

  <default-config>
    <property name="driverClass">com.mysql.jdbc.Driver</property>
    <property name="jdbcUrl">jdbc:mysql://localhost:3306/jdbcdemo</property>
    <property name="user">root</property>
    <property name="password">root</property>
    <property name="initialPoolSize">5</property>
    <property name="maxPoolSize">20</property>
  </default-config>
  
  <named-config name="oracle"> 
    <property name="driverClass">com.mysql.jdbc.Driver</property>
    <property name="jdbcUrl">jdbc:mysql://localhost:3306/jdbcdemo</property>
    <property name="user">root</property>
    <property name="password">root</property>
  </named-config>
  

</c3p0-config>

C3P0工具類

public class C3P0Util {

    private static ComboPooledDataSource dataSource = new ComboPooledDataSource();

    //  使用自定義XML參數(shù)
    //  ComboPooledDataSource dataSource = new ComboPooledDataSource("oracle");

    public static ComboPooledDataSource getDataSource() {
        return dataSource;
    }

    public static Connection getConn() {
        try {
            return dataSource.getConnection();
        } catch (SQLException e) {
            throw new RuntimeException(e);
        }
    }
}

調(diào)用
public class StudentDaoTest {

    @Test
    public void testSave() {
        try {   

            Connection conn = C3P0Util.getConn();
            String sql = "insert into t_student(name,age)values(?,?)";
            PreparedStatement ps = conn.prepareStatement(sql);
            ps.setString(1, "連接池測試插入C3");
            ps.setInt(2, 18);
            ps.executeUpdate();
            ps.close();
            conn.close(); 
            
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}
DBUtils使用

DBUtils是Apache出品一個用于數(shù)據(jù)庫操作的框架，它對JDBC進行了簡單的封裝，學習成本極低，并且使用dbutils能極大簡化jdbc編碼的工作量，同時也不會影響程序的性能。
Apache的DBUtils框架學習

最后編輯于 ：
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成，瀏覽時請結(jié)合常識與多方信息審慎甄別。
平臺聲明：文章內(nèi)容（如有圖片或視頻亦包括在內(nèi)）由作者上傳并發(fā)布，文章內(nèi)容僅代表作者本人觀點，簡書系信息發(fā)布平臺，僅提供信息存儲服務。

相關(guān)閱讀更多精彩內(nèi)容

  • 本文包括傳統(tǒng)JDBC的缺點連接池原理自定義連接池開源數(shù)據(jù)庫連接池DBCP連接池C3P0連接池Tomcat內(nèi)置連接池...
    廖少少閱讀 16,938評論 0贊 37
  • JDBC概述 在Java中，數(shù)據(jù)庫存取技術(shù)可分為如下幾類：JDBC直接訪問數(shù)據(jù)庫、JDO技術(shù)、第三方O/R工具，如...
    usopp閱讀 3,639評論 3贊 75
  • Spring Cloud為開發(fā)人員提供了快速構(gòu)建分布式系統(tǒng)中一些常見模式的工具（例如配置管理，服務發(fā)現(xiàn)，斷路器，智...
    卡卡羅2017閱讀 136,535評論 19贊 139
  • 去政府辦事，被一皂角小吏惡心壞了，無奈其手握權(quán)柄，只能心里默默問候其祖宗十八代。昨晚睡覺前，突發(fā)奇想，除了問候祖宗...
    樹先生1988閱讀 325評論 0贊 0

友情鏈接更多精彩內(nèi)容