Spring Boot中如何实现跨双库分批读写并隔离SQL事务？

你的场景核心是让SQL数据库的事务隔离级别仅作用于SQL操作，同时MongoDB的持久化操作完全脱离SQL事务约束，还要支持大数据量下的分批次报表生成。下面是具体的实现思路和代码示例：

1. 拆分事务边界：SQL读取与Mongo写入完全解耦 #

不要把整个分批次处理的方法标注@Transactional，而是把SQL数据读取的逻辑封装到单独的、带有@Transactional(isolation = Isolation.REPEATABLE_READ)的分页方法中，Mongo的持久化逻辑则完全独立于这个事务。

具体做法： #

• 改造你已有的OriginDataService，新增分页/分批读取方法，确保每次分页读取都在符合隔离级别的SQL事务中执行。
• 在ReportGenerationService的分批次处理方法中，循环调用分页读取接口，每次拿到一批数据后生成部分报表，直接调用MongoService.persist()写入MongoDB——这一步不需要事务，因为Mongo的单文档写入本身是原子性的，且不需要和SQL事务绑定。

示例代码片段：

@Service
public class ReportGenerationService {
    @Autowired
    private OriginDataService originDataService;
    @Autowired
    private MongoService mongoService;

    public void generateAndPersistBatchReport() {
        int batchSize = 1000; // 根据内存承载能力调整批次大小
        int currentPage = 1;
        boolean hasMoreData = true;

        while (hasMoreData) {
            // 每次分页读取都在REPEATABLE_READ的SQL事务中执行，保证数据快照一致性
            List<Lease> batchLeaseData = originDataService.getLeaseDataByPage(currentPage, batchSize);
            
            if (batchLeaseData.isEmpty()) {
                hasMoreData = false;
                break;
            }

            // 基于当前批次数据生成部分报表
            PartialLeaseReport partialReport = generatePartialReport(batchLeaseData);
            
            // 直接持久化到MongoDB，不受SQL事务影响
            mongoService.persistPartialReport(partialReport);
            
            currentPage++;
        }

        // 可选：合并所有PartialReport生成最终完整报表
        mergeAndPersistFinalReport();
    }

    private PartialLeaseReport generatePartialReport(List<Lease> batchData) {
        // 实现批次数据的统计逻辑，比如计算该批次的租赁时长、金额等
        return new PartialLeaseReport();
    }

    private void mergeAndPersistFinalReport() {
        // 从MongoDB读取所有PartialReport，合并为最终报表后再存储
        List<PartialLeaseReport> allPartials = mongoService.getAllPartialReports();
        FinalLeaseReport finalReport = mergePartialsToFinal(allPartials);
        mongoService.persistFinalReport(finalReport);
    }
}

@Service
public class OriginDataService {
    @Autowired
    private LeaseRepository leaseRepository;

    // 分页读取方法，标注REPEATABLE_READ隔离级别
    @Transactional(isolation = Isolation.REPEATABLE_READ)
    public List<Lease> getLeaseDataByPage(int pageNum, int pageSize) {
        Pageable pageable = PageRequest.of(pageNum - 1, pageSize);
        return leaseRepository.findAll(pageable).getContent();
    }
}

2. 保证SQL数据的一致性：利用REPEATABLE_READ的快照特性 #

因为每次分页读取都在独立的REPEATABLE_READ事务中，所以在整个分批次处理过程中，SQL数据库的租赁数据会保持一个一致的快照——其他事务对数据的修改不会影响当前报表生成的数据源，彻底避免了不可重复读和脏读问题。

3. 避免事务蔓延的关键细节 #

• 绝对不要在ReportGenerationService的分批次方法上标注@Transactional，否则Spring会尝试创建跨SQL和Mongo的全局事务（若配置了JTA），导致Mongo操作也被纳入事务，违背你的需求。
• 确保MongoService的persist()方法上没有标注@Transactional，或者明确指定只使用Mongo事务管理器（但这里完全不需要，我们要让Mongo操作脱离SQL事务的约束）。

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