Java操作數據庫——使用連接池連接數據庫

摘要：本文主要學習了如何使用JDBC連接池連接數據庫。

傳統方式和連接池方式

傳統方式的步驟

使用傳統方式在Java中使用JDBC連接數據庫，完成一次數據庫的操作，一般有以下幾個步驟：

加載驅動。

建立連接。

執行SQL語句。

釋放連接。

傳統方式的弊端

每一次對數據庫的操作都要建立一次連接，並且會將得到的Connection對象加載到內存中，導致消耗了大量的內存和時間。如果短時間有很多需要進行建立連接的操作，會導致占用很多系統資源，甚至會導致服務器崩潰。

同建立連接相對應，每次使用都需要手動釋放連接，如果忘記釋放連接或者程序出現異常未能成功釋放，會導致內存泄露。

此外，傳統方式並不能控制連接的數量，如果連接的人數過多，會導致無限制的創建連接對象，導致內存開銷過大，服務器崩潰。

連接池的步驟

創建連接池並配置連接屬性。

使用連接池獲取連接。

連接池的優勢

每次需要連接數據庫時，不需要建立連接，而是通過連接池獲取，由連接池提供連接。

在使用完連接后，不需要手動釋放連接，而是交由連接池釋放連接。

可以通過連接池控制連接的數量，在連接池里的連接可多次重復使用，避免了無限制創建連接的問題。

使用連接池

使用C3P0連接池

C3P0是一個開放源代碼的JDBC連接池，它在lib目錄中與Hibernate一起發布，包括實現了數據源和JNDI綁定，支持JDBC3規范和JDBC2的標准擴展。目前使用它的開源項目有Hibernate，Spring等。

導入jar包：

c3p0-0.9.5.2.jar

在當前項目的代碼根目錄 src 下新建名為 c3p0-config.xml 的配置文件，注意文件名稱不可改變，內容如下：

<c3p0-config>
    <!-- 連接名稱 -->
    <named-config name="mysql">
        <!-- 接數據庫的驅動類名 -->
        <property name="driverClass">com.mysql.jdbc.Driver</property>
        <!-- 連接屬性 -->
        <property name="jdbcUrl">jdbc:mysql://192.168.35.128:3306/demo</property>
        <property name="user">root</property>
        <property name="password">123456</property>
        <!-- 當連接池用完時等待獲取新連接的時間，超時后將拋出SQLException，單位毫秒，如設為0則無限期等待。默認為0。 -->
        <property name="checkoutTimeout">5000</property>
        <!-- 當連接用盡后，一次獲取的連接個數 -->
        <property name="acquireIncrement">2</property>
        <!-- 初始連接數 -->
        <property name="initialPoolSize">1</property>
        <!-- 最小連接數 -->
        <property name="minPoolSize">3</property>
        <!-- 最大連接數 -->
        <property name="maxPoolSize">5</property>
    </named-config>
</c3p0-config>

程序代碼：

public class TestDataPool {
    // 根據配置文件里的名稱創建連接池
    public static ComboPooledDataSource cpds = new ComboPooledDataSource("mysql");
    
    /**
     * 主程序
     */
    public static void main(String[] args) {
        // 模擬多次對數據庫的查詢操作
        for (int i = 0; i < 6; i++) {
            new Thread(new Runnable() {
                @Override
                public void run() {
                    select();
                }
            }, "線程" + i).start();
        }
    }
    
    /**
     * 查詢程序
     */
    public static void select() {
        Connection conn = null;
        PreparedStatement pstmt = null;
        ResultSet rs = null;
        // 獲取連接並執行SQL
        try {
            conn = cpds.getConnection();
            pstmt = conn.prepareStatement("select * from student where id = 906");
            rs = pstmt.executeQuery();
            while (rs.next()) {
                System.out.println(Thread.currentThread().getName() + "\t" + rs.getString(1) + "\t" + rs.getString(2) + "\t" + rs.getString("address"));
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            // 釋放資源
            try {
                rs.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
            try {
                pstmt.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
            try {
                conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

使用DBCP連接池

DBCP是Apache上的一個Java連接池項目，是一個依賴Jakarta項目commons-pool對象池機制的數據庫連接池。DBCP可以直接的在應用程序中使用，Tomcat的數據源使用的就是DBCP。

導入jar包：

commons-dbcp-1.4.jar2 commons-pool-1.5.5.jar

在當前項目的代碼根目錄 src 下新建名為 dbcp.properties 的配置文件，文件名需要同代碼中引用的文件名一致，內容如下：

# 接數據庫的驅動類名
driverClassName=com.mysql.jdbc.Driver
# 連接屬性
url=jdbc:mysql://192.168.35.128:3306/demo
username=root
password=123456
# 初始化連接數
initialSize=10
# 最大連接數
maxActive=15

程序代碼：

public class TestDBCP {
    // 根據配置文件里的名稱創建連接池
    private static DataSource source = null;
    static {
        Properties pros = new Properties();
        InputStream is = TestDBCP.class.getClassLoader().getResourceAsStream("dbcp.properties");
        try {
            pros.load(is);
            source = BasicDataSourceFactory.createDataSource(pros);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    /**
     * 主程序
     */
    public static void main(String[] args) {
        // 模擬多次對數據庫的查詢操作
        for (int i = 0; i < 6; i++) {
            new Thread(new Runnable() {
                @Override
                public void run() {
                    select();
                }
            }, "線程" + i).start();
        }
    }

    /**
     * 查詢程序
     */
    public static void select() {
        Connection conn = null;
        PreparedStatement pstmt = null;
        ResultSet rs = null;
        // 獲取連接並執行SQL
        try {
            conn = source.getConnection();
            pstmt = conn.prepareStatement("select * from student where id = 906");
            rs = pstmt.executeQuery();
            while (rs.next()) {
                System.out.println(Thread.currentThread().getName() + "\t" + rs.getString(1) + "\t" + rs.getString(2) + "\t" + rs.getString("address"));
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            // 釋放資源
            try {
                rs.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
            try {
                pstmt.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
            try {
                conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

使用Druid連接池

Druid是阿里巴巴出品的數據源，而且是淘寶和支付寶專用數據庫連接池，但它不僅僅是一個數據庫連接池，它還包含一個ProxyDriver，一系列內置的JDBC組件庫，一個SQL Parser。

導入jar包：

druid-1.0.9.jar

在當前項目的代碼根目錄 src 下新建名為 druid.properties 的配置文件，文件名需要同代碼中引用的文件名一致，內容如下：

# 接數據庫的驅動類名
driverClassName=com.mysql.jdbc.Driver
# 連接屬性
url=jdbc:mysql://192.168.35.128:3306/demo
username=root
password=123456
# 最大連接數
maxActive=15
# 最長等待時間
maxWait=3000
# 配置初始化連接數
initialSize=1
# 配置最大活動連接數
maxActive=10

程序代碼：

public class TestDruid {
    // 根據配置文件里的名稱創建連接池
    private static DataSource source = null;
    static {
        Properties pros = new Properties();
        InputStream is = TestDruid.class.getClassLoader().getResourceAsStream("druid.properties");
        try {
            pros.load(is);
            source = DruidDataSourceFactory.createDataSource(pros);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    /**
     * 主程序
     */
    public static void main(String[] args) {
        // 模擬多次對數據庫的查詢操作
        for (int i = 0; i < 6; i++) {
            new Thread(new Runnable() {
                @Override
                public void run() {
                    select();
                }
            }, "線程" + i).start();
        }
    }

    /**
     * 查詢程序
     */
    public static void select() {
        Connection conn = null;
        PreparedStatement pstmt = null;
        ResultSet rs = null;
        // 獲取連接並執行SQL
        try {
            conn = source.getConnection();
            pstmt = conn.prepareStatement("select * from student where id = 906");
            rs = pstmt.executeQuery();
            while (rs.next()) {
                System.out.println(Thread.currentThread().getName() + "\t" + rs.getString(1) + "\t" + rs.getString(2) + "\t" + rs.getString("address"));
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            // 釋放資源
            try {
                rs.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
            try {
                pstmt.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
            try {
                conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}