自定义的数据库连接不会因错误而回滚春季批处理：块

如何解决自定义的数据库连接不会因错误而回滚春季批处理：块

在我的第一个Spring Batch块作业（我是初学者）中，
我写了db实用程序类，供在块步骤中使用，
因为我需要覆盖由application.properties设置的默认连接属性。

但是，这会导致错误时发生回滚问题（从不回滚）。
有什么建议可以改善这些逻辑？

DBUtility类

// Construct
public DBUtility() {
  ... some business logic to get connection attributes dynamically.
}

@Bean
@BatchDataSource
@Primary
public DriverManagerDataSource getConnection() {
  DriverManagerDataSource dataSource = new DriverManagerDataSource();
    dataSource.setDriverClassName(driverNameGottenAbove);
    dataSource.setUrl(urlGottenAbove);
    dataSource.setUsername(userNameGottenAbove);
    dataSource.setPassword(passwordGottenAbove);

  return dataSource;
}

@Bean
public DataSourceTransactionManager transactionManager(){
  DataSourceTransactionManager dtm = new DataSourceTransationManager(getConnection());
  dtm.setRollbackOnCommitFailure(true);
  return dtm;
}

@Bean
public JdbcTemplate jdbcTemplate(){
  return new JdbcTemplate(getConnection());
}

BatchConfiguration类（块）

@SpringBootApplication
@EnableBatchProcessing
@Transactional
public class BatchConfiguration extends DefaultBatchConfigurer {
  ...
  private DBUtility dbUtil;
  private DriverManagerDataSource ds;
  private PlatformTransactionManager ptm;

  // Construct
  public BatchConfiguration(){
    dbUtil = new DBUtility();
    ds = dbUtil.getConnection();
    ptm = dbUtil.transactionManager();
  }

  // Override
  @Override
  public JobRepository createJobRepository() throws Exception {
    JobRepositoryFactoryBean factory = new JobRepositoryFactoryBean();
      factory.setDataSource(ds);
      factory.setTransactionManager(ptm);
    JobRepository repo = factory.getObject();
    return repo;
  }

  @Bean
  public Job BatchJob() {
    return jobBuilderFactory.get("BatchJob")
      .incrementer(new RunIdIncrementer())
      .listener(jobListener())
      .flow(step1())
      .end().build();
  }

  @Bean
  public step step1() {
    DefaultTransactionAttribute att = new DefaultTransactionAttribute();
      att.setPropagationBehavior(Propagation.REQUIRED.value());

    return stepBuilderFactory.get("step1")
      .transactionManager(ptm)
      .listener(stepListener())
      .<Entity,Entity>chunk(COMMIT_INTERVAL)
      .reader(reader())
      .processor(processore())
      .writer(writer())
      .readerIsTransactionalQueue()
      .transactionAttribute(att)
      .build();
  }

  ...

}

感谢您查看这篇文章。