Spring Batch 5.1.0启动时BATCH_JOB_INSTANCE表SQL并发错误求助

ORA-08177是Oracle数据库在序列化事务隔离级别下，并发修改同一数据导致的访问冲突。针对Spring Batch插入BATCH_JOB_INSTANCE表时的这个问题，可通过以下方式处理：

• 调整JobRepository的事务隔离级别
  Spring Batch默认创建JobInstance时使用SERIALIZABLE隔离级别，这在Oracle高并发场景下极易触发序列化冲突。将隔离级别改为READ_COMMITTED或REPEATABLE_READ，降低冲突概率：

  @Bean
  public JobRepository jobRepository(DataSource dataSource, PlatformTransactionManager transactionManager) throws Exception {
      JobRepositoryFactoryBean factory = new JobRepositoryFactoryBean();
      factory.setDataSource(dataSource);
      factory.setTransactionManager(transactionManager);
      // 替换默认的ISOLATION_SERIALIZABLE
      factory.setIsolationLevelForCreate("ISOLATION_READ_COMMITTED");
      factory.setTablePrefix("BATCH_");
      return factory.getObject();
  }
  

• 确保JobInstance的唯一性标识（JobKey）不重复
  JobInstance的插入逻辑是先查询是否存在相同JOB_NAME和JOB_KEY的记录，不存在才插入。如果两个进程启动的是同一Job且使用相同JobParameters，会生成相同JobKey，引发竞争。需为每次Job启动生成唯一的JobParameters，比如添加时间戳参数：

  JobParameters jobParameters = new JobParametersBuilder()
          .addString("jobName", "yourJobName")
          .addLong("timestamp", System.currentTimeMillis()) // 确保每次启动参数唯一
          .toJobParameters();
  jobLauncher.run(yourJob, jobParameters);
  

• 添加并发重试机制
  ORA-08177属于临时并发冲突，通过重试可解决。使用Spring Retry为JobLauncher添加重试逻辑：

  @Bean
  public JobLauncher jobLauncher(JobRepository jobRepository) {
      SimpleJobLauncher launcher = new SimpleJobLauncher();
      launcher.setJobRepository(jobRepository);
      
      RetryTemplate retryTemplate = new RetryTemplate();
      SimpleRetryPolicy retryPolicy = new SimpleRetryPolicy();
      retryPolicy.setMaxAttempts(3); // 最多重试3次
      // 指定需要重试的异常类型
      Map<Class<? extends Throwable>, Boolean> retryableExceptions = new HashMap<>();
      retryableExceptions.put(UncategorizedSQLException.class, true);
      retryPolicy.setRetryableExceptions(retryableExceptions);
      
      retryTemplate.setRetryPolicy(retryPolicy);
      launcher.setRetryTemplate(retryTemplate);
      
      return launcher;
  }
  

• 优化Oracle序列配置
  如果JOB_INSTANCE_ID使用Oracle序列生成，增大序列的缓存大小（比如执行ALTER SEQUENCE BATCH_JOB_SEQ CACHE 100;），减少并发下序列获取的冲突。

内容的提问来源于stack exchange，提问作者ALAN PAINTER