您现在的位置：程式碼之家 >> 編程語言 > >> Java 程式設計 >> Java 綜合教學

Spring JdbcTemplate 完整指南：五大核心方法、回調體系與最佳實踐

編輯：Java 綜合教學

JdbcTemplate 核心方法分類

類別	方法	用途
執行更新	`update(sql, ...)`	INSERT/UPDATE/DELETE，回傳影響行數
執行更新	`batchUpdate(sqlList)`	批次處理，效能大幅提升
查詢	`query(sql, RowMapper)`	多行映射為對象列表
	`queryForObject(sql, ...)`	單行單值/對象，無結果拋 EmptyResultDataAccessException
	`queryForList(sql, ...)`	直接回傳 List<Map>，無需自定義映射
DDL/通用	`execute(sql)`	CREATE/DROP/任意 SQL，回傳 void
存儲過程/函數	`call(CallableStatementCreator, params)`	IN/OUT/INOUT 參數、ResultSet 回傳

回調體系：JdbcTemplate 的擴展點

1. 語句創建回調

PreparedStatementCreator：createPreparedStatement(Connection) → 自建 PreparedStatement
CallableStatementCreator：同理建立 CallableStatement

2. 參數綁定回調

PreparedStatementSetter：setValues(PreparedStatement) → 手動綁定參數
BatchPreparedStatementSetter：批次版，需實作 setValues(ps, i) + getBatchSize()

3. 通用操作回調（最靈活）

ConnectionCallback：拿到 Connection 隨意操作
StatementCallback / PreparedStatementCallback / CallableStatementCallback

4. 結果集處理回調

介面	方法	特點
`RowMapper<T>`	`mapRow(ResultSet, rowNum)`	逐行映射，JdbcTemplate 自動迭代 `next()`
`RowCallbackHandler`	`processRow(ResultSet)`	逐行處理，無返回值，適合流式處理/寫入檔案
`ResultSetExtractor<T>`	`extractData(ResultSet)`	一次性拿到整個 ResultSet，自行控制迭代，適合複雜聚合

實戰代碼範例

基本查詢 + RowMapper

List<User> users = jdbcTemplate.query(
    "SELECT id, name, email FROM users WHERE status = ?",
    new Object[]{1},
    (rs, rowNum) -> new User(rs.getLong("id"), rs.getString("name"), rs.getString("email"))
);

單值查詢

Integer count = jdbcTemplate.queryForObject(
    "SELECT COUNT(*) FROM users WHERE status = ?", Integer.class, 1);

批次插入

jdbcTemplate.batchUpdate(
    "INSERT INTO users(name, email) VALUES(?, ?)",
    new BatchPreparedStatementSetter() {
        public void setValues(PreparedStatement ps, int i) throws SQLException {
            User u = users.get(i);
            ps.setString(1, u.getName());
            ps.setString(2, u.getEmail());
        }
        public int getBatchSize() { return users.size(); }
    });

存儲過程調用 (MySQL)

Map<String, Object> out = jdbcTemplate.call(
    new CallableStatementCreator() {
        public CallableStatement createCallableStatement(Connection con) throws SQLException {
            CallableStatement cs = con.prepareCall("{call proc_user_stats(?, ?)}");
            cs.setInt(1, userId);
            cs.registerOutParameter(2, Types.INTEGER);
            return cs;
        }
    },
    Arrays.asList(
        new SqlParameter("p_user_id", Types.INTEGER),
        new SqlOutParameter("p_total", Types.INTEGER)
    ));
Integer total = (Integer) out.get("p_total");