Spring Batch Writer遇ORA-00060死锁问题求助

一、ORA-00060死锁原因 #

1. 非原子的查询-插入操作：Writer中先调用findBy查询Table-A、再执行插入的逻辑是两步独立操作，并发场景下多个线程会同时查询到同一记录不存在，随后同时触发插入请求，导致Oracle为这些操作分配行锁时出现循环等待，触发死锁。
2. 自定义事务与框架事务冲突：在ItemWriter方法上添加@Transactional注解会干扰Spring Batch的事务管理机制。Spring Batch的Chunk处理默认会为每个chunk创建独立事务，自定义事务会导致嵌套事务或事务边界混乱，延长锁持有时间，加剧死锁概率。
3. 多线程Step的无分片并发：如果Step配置为多线程执行且未对数据做分片处理，多个线程会同时处理可能重叠的数据，增加对Table-A同一行的锁竞争概率。

二、后续错误序列（ORA-02396、乐观锁失败）原因 #

1. 连接超时：死锁导致事务等待时间过长（15分钟），超过了Hikari连接池的maxLifeTime设置（2分钟），连接被池回收后，事务仍尝试使用失效连接，触发Oracle的ORA-02396（连接空闲超时）和ORA-01012（未登录）错误。
2. Job元数据乐观锁失败：事务超时后，Spring Batch尝试更新Step执行上下文时，由于之前的死锁处理导致Step执行版本号已被修改，触发OptimisticLockingFailureException，使Job进入未知状态。

三、解决方案 #

1. 用原子操作替代查询-插入逻辑 #

使用Oracle的MERGE语句将查询和插入合并为一个原子操作，避免并发下的锁竞争。示例如下：

MERGE INTO Table_A t
USING (SELECT :id AS id, :name AS name FROM dual) s
ON (t.id = s.id)
WHEN NOT MATCHED THEN
  INSERT (id, name) VALUES (s.id, s.name);

在Spring中可通过EntityManager执行原生SQL，或自定义JpaRepository方法实现：

public interface TableARepository extends JpaRepository<TableA, Long> {
    @Modifying
    @Query(value = "MERGE INTO Table_A t USING (SELECT :id AS id, :name AS name FROM dual) s ON (t.id = s.id) WHEN NOT MATCHED THEN INSERT (id, name) VALUES (s.id, s.name)", nativeQuery = true)
    void mergeTableA(@Param("id") Long id, @Param("name") String name);
}

2. 移除Writer方法上的@Transactional注解 #

Spring Batch的ChunkOrientedTasklet会自动为每个chunk管理事务，自定义事务会导致事务边界混乱，直接移除该注解即可。

3. 优化多线程Step的分片策略 #

如果使用多线程Step，需对输入数据按主键范围、哈希值等规则分片，确保每个线程处理互不重叠的数据，减少对Table-A同一行的锁竞争。示例配置：

@Bean
public Step readDataStep(StepBuilderFactory stepBuilderFactory, ItemReader<YourItem> reader, ItemWriter<YourItem> writer) {
    return stepBuilderFactory.get("readDataStep")
            .<YourItem, YourItem>chunk(100)
            .reader(reader)
            .writer(writer)
            .taskExecutor(taskExecutor())
            .partitioner("readDataStep", partitioner())
            .build();
}

@Bean
public Partitioner partitioner() {
    return new RangePartitioner(); // 自定义按主键范围分片的Partitioner
}

@Bean
public TaskExecutor taskExecutor() {
    SimpleAsyncTaskExecutor executor = new SimpleAsyncTaskExecutor();
    executor.setConcurrencyLimit(5); // 根据数据库性能调整并发数
    return executor;
}

4. 对齐连接池与Oracle的空闲超时配置 #

先查询Oracle用户配置文件的IDLE_TIME参数：

SELECT profile, resource_name, limit FROM dba_profiles WHERE resource_name = 'IDLE_TIME';

确保Hikari连接池的maxLifeTime小于等于Oracle的IDLE_TIME，例如Oracle IDLE_TIME为10分钟，则设置：

spring.datasource.hikari.maxLifeTime=540000 # 9分钟，单位毫秒
spring.datasource.hikari.idleTimeout=300000 # 5分钟，小于maxLifeTime

5. 处理Job未知状态 #

如果Job已进入不可重启状态，需手动清理Spring Batch元数据表：

DELETE FROM BATCH_STEP_EXECUTION_CONTEXT WHERE STEP_EXECUTION_ID = {你的STEP_EXECUTION_ID};
DELETE FROM BATCH_STEP_EXECUTION WHERE STEP_EXECUTION_ID = {你的STEP_EXECUTION_ID};
DELETE FROM BATCH_JOB_EXECUTION_CONTEXT WHERE JOB_EXECUTION_ID = {你的JOB_EXECUTION_ID};
DELETE FROM BATCH_JOB_EXECUTION_PARAMS WHERE JOB_EXECUTION_ID = {你的JOB_EXECUTION_ID};
DELETE FROM BATCH_JOB_EXECUTION WHERE JOB_EXECUTION_ID = {你的JOB_EXECUTION_ID};

清理后可重新启动Job，同时确保已解决死锁和超时问题，避免再次出现该情况。

内容的提问来源于stack exchange，提问作者Mohit Darmwal