Java批量数据库操作需隔离单条异常：为每条数据封装独立try-catch方法，记录日志并写入error_detail表或Kafka；优先使用Spring Batch的skip机制；区分局部失败（可跳过）与全局失败（须中断）；失败时保留traceId、batchId等上下文信息。
Java 中批量数据库操作要让单条数据异常不中断整体批次，关键不是“堵住异常”，而是“隔离异常”——把每条数据的执行边界划清楚，失败只影响自己，不波及其他。
按数据粒度封装 try-catch
不要用一个大 try 包整个 for 循环或 batchUpdate 调用。而是为每条数据的处理逻辑单独加一层保护：
- 把单条记录的校验、转换、入库抽成独立方法（如 processOneRecord(data)）
- 该方法内部用 try-catch 捕获所有可预期异常（如 ParseException、ConstraintViolationException）
- catch 块中只做轻量动作：记录 warn 日志、写入 error_detail 表、放入 Kafka 失败队列，然后 return 或 continue
- 避免在 catch 里 throw 新异常，也别 re-throw 原异常，否则会跳出当前循环体
善用 Spring Batch 的 skip 机制
如果项目已集成 Spring Batch，优先用它的原生跳过能力，比手写 try-catch 更健壮：
Alibabacloud Sdk Client Initialization For Java
下载
在 Java 中初始化和管理阿里云 SDK客户端。包括单例模式、线程安全、endpoint 与 region 配置、VPC 终端节点、同步与异步等。
- 配置 skip-limit="10"，表示允许最多 10 条失败记录继续执行
- 声明 skippable-exception-classes，例如 SQLException、DataIntegrityViolationException
- 配合自定义 SkipPolicy，可实现更细粒度控制（如仅跳过特定 SQLState 或错误码）
- 失败项会被自动移出当前 chunk，不影响事务提交，后续数据照常处理
区分局部失败与全局失败
不是所有异常都适合跳过。要从业务语义判断失败是否具备传染性：
立即学习“Java免费学习笔记（深入）”；
- 局部失败：某条订单手机号为空、时间格式非法、主键冲突（可用 INSERT IGNORE 规避）→ 可记录后跳过
- 全局失败：数据库连接池耗尽、JDBC 驱动加载失败、目标表被删、事务管理器不可用 → 应立即中断并告警，防止持续写入脏数据
- 建议用不同异常类型标识，比如自定义 SkippableDataException 和 FatalBatchException
失败时保留可追溯上下文
不中断只是第一步，更重要的是知道“谁错了、在哪错、为什么错”：
- 每条失败记录附带唯一 traceId、批次号（batchId）、步骤名（stepName）、原始数据摘要（如前 50 字符，脱敏后）
- 用 MDC 注入日志上下文，确保 warn 日志能关联到具体批次和线程
- 统一写入结构化 error_detail 表，字段包括：id、batch_id、record_id、error_class、error_message、stack_summary、created_time
- 对 Web 接口，HTTP 状态码仍返回 200，失败详情放在响应体中，避免语义混淆
