資料庫連線池——C3P0&Druid

(一) 資料庫連線池

每一個事物都有其存在的意義，在初學jdbc的時候，我們建立資料庫連線物件後，會對其進行釋放，但是資料庫連線的建立和關閉是非常消耗資源的，而且頻繁的操作會使得效能變得低下，資料庫連線池可以幫我們解決這樣的問題

(1) 概念

資料庫連線池負責分配、管理和釋放資料庫連線，它允許應用程式重複使用一個現有的資料庫連線，而不是再重新建立一個；釋放空閒時間超過最大空閒時間的資料庫連線來避免因為沒有釋放資料庫連線而引起的資料庫連線遺漏。這項技術能明顯提高對資料庫操作的效能。

簡單理解：就是一個存放資料庫連線的容器，當用戶需要訪問資料庫的時候，容器提供連線物件給使用者用，之後使用者將連線物件歸還給容器

(2) 使用

A：實現 javax.sql 包下的 DataSource 介面

• 方法：獲取連線：getConnection()
• 方法：歸還連線：Connection.close()

注意：在連線池中使用connection.close()方法，不代表關閉連線，代表歸還連線

B：我們可以使用一些開源的資料庫廠商提供的實現

• C3P0
• Druid (來自阿里巴巴)

(3) C3P0

A：首先匯入三個jar包 c3p0-0.9.5.2.jar 、mchange-commons-java-0.2.12.jar、資料庫驅動jar包

B：修改配置檔案

C：建立資料庫連線池物件——ComboPooledDataSource()

D：獲取連線——getConnection()

package cn.ideal.datasource.c3p0;

import com.mchange.v2.c3p0.ComboPooledDataSource;

import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.SQLException;

public class C3P0Demo {

    private static DataSource comboPooledDataSource = null;

    static{
        //不指定則使用預設XML配置
        //資料庫連線池物件 ComboPooledDataSource
        comboPooledDataSource = new ComboPooledDataSource();
    }

    public static Connection getConnection() throws SQLException {
        //獲取連線
        return comboPooledDataSource.getConnection();
    }

    public static void main(String[] args) throws SQLException {
        System.out.println(getConnection());
    }
}

//測試輸出日誌及內容
 

(4) Druid

package cn.ideal.datasource.druid;

import com.alibaba.druid.pool.DruidDataSourceFactory;

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

public class DruidDemo {
    public static void main(String[] args) throws Exception {
        //載入配置檔案
        Properties pro = new Properties();
        InputStream is = DruidDemo.class.getClassLoader().getResourceAsStream("druid.properties");
        pro.load(is);

        //獲取連線池物件
        DataSource ds = DruidDataSourceFactory.createDataSource(pro);

        //獲取連線
        Connection connection =ds.getConnection();

        System.out.println(connection);
    }
}

試著用Druid寫一個工具類

package cn.ideal.datasource.utils;

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;

public class JDBCUtils {

    private static DataSource ds = null;

    static {
        //載入配置檔案
        Properties properties = new Properties();
        try {
            properties.load(JDBCUtils.class.getClassLoader().getResourceAsStream("druid.properties"));
            ds = DruidDataSourceFactory.createDataSource(properties);
        } catch (IOException e) {
            e.printStackTrace();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    /**
     * 獲取連線
     */
    public static Connection getConnection() throws SQLException {
        return ds.getConnection();
    }

    /**
     * 釋放資源
     */

    public static void close(Statement statement, Connection connection) {
        close(null, statement, connection);
    }

    public static void close(ResultSet resultSet, Statement statement, Connection connection) {
        if (resultSet != null) {
            try {
                resultSet.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }

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

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

工具類測試

package cn.ideal.datasource.test;

import cn.ideal.datasource.utils.JDBCUtils;

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

public class JDBCUtilsTest {
    public static void main(String[] args) {
        Connection connection = null;
        PreparedStatement preparedStatement = null;
        try {
            //獲取連線
            connection = JDBCUtils.getConnection();
            //定義sql
            String sql = "INSERT INTO account VALUES(NULL,?,?)";
            //獲取preparedStatement物件
            preparedStatement = connection.prepareStatement(sql);
            //給?賦值
            preparedStatement.setString(1, "lisi");
            preparedStatement.setString(2, "2000");
            //執行sql
            int count = preparedStatement.executeUpdate();
            System.out.println(count);
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            JDBCUtils.close(preparedStatement,connection);
        }
    }
}

結尾：

如果內容中有什麼不足，或者錯誤的地方，歡迎大家給我留言提出意見, 蟹蟹大家 ！^_^

如果能幫到你的話，那就來關注我吧！（系列文章均會在公眾號第一時間更新）

在這裡的我們素不相識，卻都在為了自己的夢而努力 ❤

一個堅持推送原創Java技術的公眾號：理想二旬不止

相關推薦