Java中调用存储过程并封装为POJO，核心是用CallableStatement执行{call ...}语法、注册OUT参数或处理ResultSet，再逐字段映射到自定义POJO；需注意资源关闭、类型安全映射及数据库兼容性。
Java中在Callable中调用存储过程并封装为自定义POJO，核心是使用java.sql.CallableStatement执行带OUT参数或结果集的存储过程，再手动映射字段到POJO。注意：Callable本身是接口（常用于ExecutorService提交异步任务），真正执行数据库调用的是CallableStatement——这里应理解为“在实现Callable的任务中，用CallableStatement调用存储过程”。
1. 准备自定义POJO
先定义一个干净的Java Bean，字段名建议与存储过程返回的列名或OUT参数名保持一致（便于映射）：
public class UserSummary {
private Long id;
private String name;
private Integer orderCount;
private BigDecimal totalAmount;
// 构造、getter、setter 省略
}
2. 在Callable中使用CallableStatement调用存储过程
关键点：获取Connection、构建{call ...}语法、注册OUT参数或处理ResultSet、关闭资源。推荐使用try-with-resources确保释放。
- 若存储过程返回结果集（最常见），用
executeQuery()+ResultSet逐行映射 - 若只有OUT参数（如单个统计值），用
executeUpdate()+getXXX()获取 - 务必显式设置参数类型（
registerOutParameter）和IN参数值（setXXX）
public class CallUserSummaryProc implements Callable<List<UserSummary>> {
private final DataSource dataSource;
private final Long userId;
public CallUserSummaryProc(DataSource dataSource, Long userId) {
this.dataSource = dataSource;
this.userId = userId;
}
@Override
public List<UserSummary> call() throws Exception {
String sql = "{call get_user_summary_by_id(?)}"; // Oracle/MySQL通用写法
List<UserSummary> results = new ArrayList<>();
try (Connection conn = dataSource.getConnection();
CallableStatement cs = conn.prepareCall(sql)) {
cs.setLong(1, userId); // IN参数：用户ID
try (ResultSet rs = cs.executeQuery()) {
while (rs.next()) {
UserSummary pojo = new UserSummary();
pojo.setId(rs.getLong("id"));
pojo.setName(rs.getString("name"));
pojo.setOrderCount(rs.getInt("order_count"));
pojo.setTotalAmount(rs.getBigDecimal("total_amount"));
results.add(pojo);
}
}
}
return results;
}
}
3. 提交并获取结果
将该Callable提交给线程池，异步执行并获得POJO列表：
立即学习“Java免费学习笔记（深入）”；
ExecutorService executor = Executors.newFixedThreadPool(4);
Callable<List<UserSummary>> task = new CallUserSummaryProc(dataSource, 1001L);
try {
List<UserSummary> summaries = executor.submit(task).get(); // 阻塞等待
summaries.forEach(System.out::println);
} catch (ExecutionException e) {
throw new RuntimeException("存储过程调用失败", e.getCause());
}
4. 注意事项与优化建议
-
数据库兼容性：Oracle用
{call proc_name(?, ?)}；SQL Server支持exec proc_name ?，但统一用JDBC标准{call ...}更稳妥 -
异常处理：SQL异常（如ORA-XXXX）会包装为
SQLException，需在call()中捕获并转为业务异常 -
大结果集：避免一次性加载全部数据，可改用流式处理（JDBC 4.2+ 的
rs.unwrap(ResultSet.class)配合游标，或分页调用存储过程） -
连接泄漏风险：务必用try-with-resources，不要依赖
finalize或外部连接池自动回收 -
类型映射安全：用
rs.getObject("col", Type.class)替代rs.getXxx("col")可减少空指针（如rs.getObject("name", String.class)）
