您现在的位置：程式碼之家 >> 編程語言 > >> Java 程式設計 >> Java 相關知識

JDBC 數據庫連接優化實戰：連接池、PreparedStatement 與事務管理

編輯：Java 相關知識

核心優化原則

數據庫連接是昂貴資源，優化核心在於復用連接、減少網絡交互、保證數據一致性。

一、連接池：消除創建開銷

問題

每次請求創建連接：DriverManager.getConnection() 涉及網絡握手、認證、資源分配，極其耗時。

解決方案：連接池模式


// 初始化池 (啟動時一次)
DataSource ds = new ComboPooledDataSource(); // 或 BasicDataSource
ds.setJdbcUrl("jdbc:mysql://localhost:3306/db");
ds.setUser("root");
ds.setPassword("pass");
ds.setMinPoolSize(5);
ds.setMaxPoolSize(20);

// 業務代碼中獲取/歸還
Connection conn = null;
try {
    conn = ds.getConnection(); // 從池獲取，極快
    // 業務邏輯
} finally {
    if (conn != null) conn.close(); // 歸還池中，非真正關閉
}

關鍵配置參數

參數	建議值	說明
minPoolSize	5-10	啟動預熱，避免冷啟動延遲
maxPoolSize	20-50	根據 CPU 核數與並發調整
maxWait	3000-5000ms	獲取連接超時，防止無限等待
idleConnectionTestPeriod	300s	定期檢測閒置連接有效性
preferredTestQuery	SELECT 1	輕量級驗證查詢
maxStatements	100-500	PreparedStatement 緩存大小

二、PreparedStatement：預編譯與參數化

優勢

SQL 預編譯：數據庫解析、優化、生成執行計劃僅一次
防止 SQL 注入：參數與代碼分離
批量處理：addBatch() + executeBatch() 減少網絡往返
類型安全：setInt()、setString() 自動轉義

正確使用模式


// 1. 獲取預編譯語句
PreparedStatement ps = conn.prepareStatement(
    "SELECT * FROM users WHERE username = ? AND status = ?"
);

// 2. 綁定參數 (索引從 1 開始)
ps.setString(1, "zhangsan");
ps.setInt(2, 1);

// 3. 執行查詢
ResultSet rs = ps.executeQuery();
while (rs.next()) {
    // 處理結果
}

// 4. 關閉語句 (釋放游標、緩存)
ps.close(); // 重要！防止游標洩漏

// 批量插入示例
conn.setAutoCommit(false);
PreparedStatement batchPs = conn.prepareStatement(
    "INSERT INTO logs (level, message, created_at) VALUES (?, ?, ?)"
);
for (LogEntry log : logs) {
    batchPs.setString(1, log.getLevel());
    batchPs.setString(2, log.getMessage());
    batchPs.setTimestamp(3, new Timestamp(log.getTime()));
    batchPs.addBatch();
}
int[] results = batchPs.executeBatch(); // 一次網絡往返
conn.commit();
batchPs.close();

三、事務管理：ACID 保障

隔離級別選擇

隔離級別	臟讀	不可重複讀	幻讀	適用場景
READ_COMMITTED (默認)	防止	允許	允許	大多數業務，性能較好
REPEATABLE_READ	防止	防止	允許	需要一致性讀取的報表查詢
SERIALIZABLE	防止	防止	防止	極高一致性要求，性能最差

標準事務模板


Connection conn = null;
try {
    conn = ds.getConnection();
    conn.setAutoCommit(false);                    // 關閉自動提交
    conn.setTransactionIsolation(Connection.TRANSACTION_READ_COMMITTED);
    
    // 業務操作 1
    updateAccountBalance(conn, fromAccount, -amount);
    // 業務操作 2
    updateAccountBalance(conn, toAccount, +amount);
    // 記錄流水
    insertTransactionLog(conn, fromAccount, toAccount, amount);
    
    conn.commit();                                // 提交事務
} catch (Exception e) {
    if (conn != null) {
        try { conn.rollback(); } catch (SQLException se) { log.error(se); }
    }
    throw new BusinessException("轉賬失敗", e);
} finally {
    if (conn != null) {
        try { 
            conn.setAutoCommit(true);             // 還原自動提交 (歸還池前)
            conn.close();                         // 歸還連接池
        } catch (SQLException e) { log.error(e); }
    }
}