基於Druid數據庫連接池的DBUtil工具類

工具類 DruidUtil.java

package com.zzuli.util;

import com.alibaba.druid.pool.DruidDataSourceFactory;

import javax.sql.DataSource;
import java.io.IOException;
import java.sql.*;
import java.util.Properties;

/**
 * Created by hejjon on 2019/6/19 23:10.
 * <p>
 * 基於Druid數據庫連接池的工具類
 */
public class DruidUtil {
    // 私有成員 DataSource
    private static DataSource ds;

    static {
        try {
            // 加載配置文件
            Properties pro = new Properties();
            pro.load(DruidUtil.class.getClassLoader().getResourceAsStream("druid.properties"));
            // 獲取DataSource對象
            ds = DruidDataSourceFactory.createDataSource(pro);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

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


    /**
     * 獲取數據庫連接池對象
     * @return
     */
    public static DataSource getDataSource() {
        return ds;
    }

    /**
     * 釋放數據庫資源
     * @param rs
     * @param sta
     * @param conn
     */
    public static void close(ResultSet rs, Statement sta, Connection conn) {
        if (null != rs) {
            try {
                rs.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }

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

        if (null != conn) {
            try {
                conn.close();       // 歸還數據庫連接對象
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }


    /**
     * 釋放數據庫連接資源
     * @param sta
     * @param conn
     */
    public static void close(Statement sta, Connection conn) {
        close(null, sta, conn);
    }

}

配置文件druid.properties

driverClassName=com.mysql.jdbc.Driver
url=jdbc:mysql://127.0.0.1:3306/zzuli
username=root
password=123123
# 初始化連接數量
initialSize=5
# 最大連接數量
maxActive=10
# 最大等待時間
maxWait=3000

測試類DruidDemo2.java

package com.zzuli.testDruid;

import com.zzuli.util.DruidUtil;

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

/**
 * Created by hejjon on 2019/6/19 23:25.
 * <p>
 * 測試工具類DruidUtil
 */
public class DruidDemo2 {

    public static void main(String[] args) {
        Connection conn = null;
        PreparedStatement pre = null;

        // 定義sql語句
        String sql = "insert into t_salary values (null,?,?)";
        try {
            // 獲取連接
            conn = DruidUtil.getConnection();
            // 創建PreparedStatement對象
            pre = conn.prepareStatement(sql);
            // 設置?的值
            pre.setString(1, "王五");
            pre.setInt(2, 4000);

            // 執行sql
            int count = pre.executeUpdate();

            if (count >= 1) {
                System.out.println("記錄添加成功");
            }
            
        } catch (SQLException e) {
            e.printStackTrace();
        }

    }

}

數據庫查詢結果