Spring JDBC 核心框架深度解析與實戰

模組架構概覽

Spring JDBC 抽象框架由四個核心包組成，層層遞進：

• org.springframework.jdbc.core：核心功能，含 JdbcTemplate、SQLExceptionTranslator、DAO 基類
• org.springframework.jdbc.datasource：數據源工具類與簡易實現，支援非容器測試
• org.springframework.jdbc.object：將查詢、更新、存儲過程封裝為可重用線程安全對象（RDBMS 操作對象）
• org.springframework.jdbc.support：SQLException 轉換與工具類

所有 JDBC 異常均轉換為 org.springframework.dao 中的未檢查異常，無需強制捕獲，便於按需恢復或向上拋出。

核心類：JdbcTemplate

JdbcTemplate 是最重要的類，負責資源獲取/釋放、Statement 創建/執行、結果集迭代、參數綁定、異常轉換。使用者僅需提供 SQL 與回調接口實現：

• PreparedStatementCreator：創建 PreparedStatement
• CallableStatementCreator：創建 CallableStatement
• RowCallbackHandler：逐行提取結果

可直接實例化或作為 Bean 注入，所有 SQL 執行自動記錄日誌。

數據源體系

DataSourceTransactionManager：單數據源事務管理器，綁定連接到線程，支援隔離級與查詢超時，可替代 JTA 用於單資源場景。

常用操作示例

執行 DDL/DML

JdbcTemplate jt = new JdbcTemplate(dataSource);
jt.execute("create table mytable (id integer, name varchar(100))");

查詢單值

int count = jt.queryForInt("select count(*) from mytable");
String name = (String) jt.queryForObject("select name from mytable", String.class);

查詢列表

List> rows = jt.queryForList("select * from mytable");
// 返回: [{name=Bob, id=1}, {name=Mary, id=2}]

參數化更新

jt.update("update mytable set name = ? where id = ?", new Object[] {name, new Integer(id)});

異常轉換機制

默認使用 SQLErrorCodeSQLExceptionTranslator，基於 sql-error-codes.xml 與數據庫元數據匹配 ErrorCode，精度優於 SQLState。可繼承自定義：

public class MyTranslator extends SQLErrorCodeSQLExceptionTranslator {
    protected DataAccessException customTranslate(String task, String sql, SQLException sqlex) {
        if (sqlex.getErrorCode() == -12345)
            return new DeadlockLoserDataAccessException(task, sqlex);
        return null; // 其餘交給默認處理
    }
}
// 使用
jt.setExceptionTranslator(new MyTranslator());

RDBMS 操作對象化（高層抽象）

MappingSqlQuery - 可重用查詢對象

private class CustomerMappingQuery extends MappingSqlQuery {
    public CustomerMappingQuery(DataSource ds) {
        super(ds, "SELECT id, name FROM customer WHERE id = ?");
        super.declareParameter(new SqlParameter("id", Types.INTEGER));
        compile();
    }
    public Object mapRow(ResultSet rs, int rowNum) throws SQLException {
        Customer c = new Customer();
        c.setId((Integer) rs.getObject("id"));
        c.setName(rs.getString("name"));
        return c;
    }
}
// 執行
List list = new CustomerMappingQuery(ds).execute(new Object[]{id});

SqlUpdate - 參數化更新對象

public class UpdateCreditRating extends SqlUpdate {
    public UpdateCreditRating(DataSource ds) {
        setDataSource(ds);
        setSql("update customer set credit_rating = ? where id = ?");
        declareParameter(new SqlParameter(Types.NUMERIC));
        declareParameter(new SqlParameter(Types.NUMERIC));
        compile();
    }
    public int run(int id, int rating) {
        return update(new Object[]{new Integer(rating), new Integer(id)});
    }
}

StoredProcedure - 存儲過程抽象

public class MyStoredProcedure extends StoredProcedure {
    public static final String SQL = "sysdate";
    public MyStoredProcedure(DataSource ds) {
        setDataSource(ds);
        setFunction(true);
        setSql(SQL);
        declareParameter(new SqlOutParameter("date", Types.DATE));
        compile();
    }
    public Map execute() { return execute(new HashMap()); }
}

SqlFunction - 單行結果函數封裝

public int countRows() {
    SqlFunction sf = new SqlFunction(dataSource, "select count(*) from mytable");
    sf.compile();
    return sf.run();
}