Spring 如何在forEach循环中实现每500条记录批量提交事务

这个需求完全可行，首先需要先理清原代码的两个核心问题：

• 原代码中@Transactional标注在private方法上，且是同类内部直接方法调用，Spring默认的AOP代理根本不会拦截触发事务增强逻辑，当前出现的“每条插入完成就提交”，本质是因为事务压根没生效，数据库连接走了默认的自动提交模式
• 原本的事务注解打在单条处理方法上，就算不考虑代理的问题，粒度也太细，没法实现按500条的批量提交逻辑

核心调整思路是把事务粒度从单条记录调整为按批次控制，根据实际场景可以选择以下两种常用实现方式：

方案1：基于声明式事务的批次控制 #

首先移除原sendData方法上的@Transactional注解，将其改回普通的单条数据处理方法：

private void sendData(Data myData){
  // 原有的数据修改、插入逻辑保持不变
}

调整外层的sendList方法，按每500条为一个批次切分数据，把批次处理的逻辑抽到独立的事务方法中。注意因为Spring自调用不会触发代理，需要在当前类注入自身的代理对象，确保事务注解真正生效：

// 注入当前类的代理对象，解决自调用不触发事务增强的问题
@Autowired
private SendService self;

private void sendList(List<Data> myData) {
  int batchSize = 500;
  int total = myData.size();
  // 按固定步长切分批次
  for (int start = 0; start < total; start += batchSize) {
    int end = Math.min(start + batchSize, total);
    List<Data> batch = myData.subList(start, end);
    // 调用代理对象的事务方法
    self.processBatch(batch);
  }
}

// 由代理调用的公共方法，事务注解才会真正生效
@Transactional(rollbackFor = Exception.class)
public void processBatch(List<Data> batch) {
  for (Data data : batch) {
    sendData(data);
  }
}

这种方式下，每一个批次的处理逻辑执行完成后，事务就会自动提交，如果批次内出现异常，会自动回滚当前批次的所有操作，不会影响之前已经提交的批次。

方案2：基于TransactionTemplate的编程式事务控制 #

如果不想处理自调用的代理问题，可以直接用Spring提供的TransactionTemplate做细粒度的事务控制，这种方式不需要依赖AOP代理，事务触发时机完全由代码控制：

@Autowired
private TransactionTemplate transactionTemplate;

private void sendList(List<Data> myData) {
  int batchSize = 500;
  for (int start = 0; start < myData.size(); start += batchSize) {
    int end = Math.min(start + batchSize, myData.size());
    List<Data> currentBatch = myData.subList(start, end);
    // 每个批次对应一个独立事务，代码执行完成后自动提交
    transactionTemplate.executeWithoutResult(status -> {
      for (Data data : currentBatch) {
        sendData(data);
      }
    });
  }
}

• 不要把整个全量列表的处理放到一个大事务里，否则会导致事务持续时间过长、数据库undo日志占用过大、连接池耗尽等问题，完全违背批量提交的设计初衷
• 批次大小不是固定值，500条是通用经验值，实际可以根据单条数据的插入耗时调整，单条处理逻辑越复杂，批次大小可以适当缩小
• 如果业务需要跳过单条脏数据，要注意异常捕获的位置，避免因为单条数据的问题导致整个事务被意外标记回滚

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