Java封装PreparedStatement通用增删改操作的核心是提取SQL模板与参数绑定逻辑，统一executeUpdate方法处理INSERT/UPDATE/DELETE，通过try-with-resources安全释放资源，并动态适配参数类型设参。
Java 中封装 PreparedStatement 的通用增删改操作，核心是提取 SQL 模板与参数绑定逻辑，避免重复写 Connection、PreparedStatement、资源关闭等样板代码。关键在于：SQL 语句结构化（如字段名、占位符统一）、参数动态传入、异常安全释放资源、支持主键返回（尤其是插入）。
统一执行模板：封装 executeUpdate 方法
所有 INSERT/UPDATE/DELETE 都调用 PreparedStatement.executeUpdate()，可抽象为一个共用方法：
- 接收 SQL 字符串（含 ? 占位符）和 Object[] 参数数组
- 自动获取 Connection（建议通过 DataSource 或工具类获取）
- 预编译、设参、执行、返回影响行数
- 使用 try-with-resources 确保 PreparedStatement 和 Connection（若本地创建）及时关闭
public int executeUpdate(String sql, Object... params) throws SQLException {
try (Connection conn = dataSource.getConnection();
PreparedStatement ps = conn.prepareStatement(sql)) {
setParameters(ps, params);
return ps.executeUpdate();
}
}
注意：Connection 若由外部传入（如事务中复用），则不应在方法内关闭，需调整资源管理策略。
参数批量绑定：setParameters 辅助方法
PreparedStatement 对不同类型的参数需调用不同 setXxx() 方法。通用封装可用反射或类型判断做适配：
立即学习“Java免费学习笔记（深入）”；
- 遍历 Object[]，对 null 值调用
ps.setNull(i, Types.VARCHAR)（需根据实际列类型调整 SQLType） - 对 String、Integer、Long、Date、LocalDateTime 等常见类型分别调用
setString、setLong、setTimestamp等 - 推荐使用 Apache Commons DbUtils 的
BasicRowProcessor.toBean()思路，但此处只需设参，无需引入依赖
private void setParameters(PreparedStatement ps, Object... params) throws SQLException {
for (int i = 0; i < params.length; i++) {
if (params[i] == null) {
ps.setNull(i + 1, Types.VARCHAR); // 可按需扩展映射
} else if (params[i] instanceof String) {
ps.setString(i + 1, (String) params[i]);
} else if (params[i] instanceof Integer) {
ps.setInt(i + 1, (Integer) params[i]);
} else if (params[i] instanceof Timestamp) {
ps.setTimestamp(i + 1, (Timestamp) params[i]);
} else if (params[i] instanceof LocalDateTime) {
ps.setTimestamp(i + 1, Timestamp.valueOf((LocalDateTime) params[i]));
}
// 其他类型依此类推...
}
}
插入后获取主键：支持 RETURN_GENERATED_KEYS
MySQL、PostgreSQL 等支持自增主键，需显式声明并读取生成的键值：
- 调用
conn.prepareStatement(sql, Statement.RETURN_GENERATED_KEYS) - 执行
executeUpdate()后，用getGeneratedKeys()获取 ResultSet - 通常只取第一列（主键），封装成通用方法返回 Long 或 Integer
public Long insertAndReturnKey(String sql, Object... params) throws SQLException {
try (Connection conn = dataSource.getConnection();
PreparedStatement ps = conn.prepareStatement(sql, Statement.RETURN_GENERATED_KEYS)) {
setParameters(ps, params);
int affected = ps.executeUpdate();
if (affected == 0) throw new SQLException("No rows inserted");
try (ResultSet rs = ps.getGeneratedKeys()) {
if (rs.next()) {
return rs.getLong(1);
}
}
}
return null;
}
增删改接口抽象：按操作语义分层
不建议把 insert/update/delete 全塞进一个方法，应按语义提供清晰 API：
-
int insert(String sql, Object... params)—— 返回影响行数（通常为 1） -
Long insertWithKey(String sql, Object... params)—— 返回新主键（适用于单主键表） -
int update(String sql, Object... params)—— 支持 WHERE 条件的更新 -
int delete(String sql, Object... params)—— 同上，带条件删除
提示：SQL 字符串建议来自配置或静态常量，避免拼接；WHERE 条件必须带参数化，杜绝字符串拼接导致 SQL 注入。
