Spring Data Hibernate 6父对象数据丢失状态未更新问题求助

问题梳理 #

业务流程 #

应用接收数据后将父实体以UPLOADED状态存入Postgres；独立Worker定时提取该状态数据，完成数据补充（enrichment）后将状态改为READY，再进行评级：评级正常设为ACCEPTED/REJECTED，数据缺失则保持READY；最终状态触发后续操作。

核心代码片段 #

final var uploadedData = repository.findByStatus(ParentEntity.UPLOADED, PageRequest.of(0, 50, Sort.by("createdAt", "id").ascending())); 

uploadedData
            .forEach(parentEntity -> {
                ...
                var processedParentEntity = parentEntity;
                try {
                    processedParentEntity = transaction.execute(status -> {
                        analyze(parentEntity, retries.getOrDefault(parentEntity.getId(), 0) < maxTries);
                        return receiptRepository.findFirstById(parentEntity.getId()).get();
                    });
                 
                } catch (final TemporaryProblem temporaryProblem) {
                  ...
                } catch (final Exception exception) {
                 ...
                }
            });
        logger.info("finished parentEntity analysis");

异常现象 #

• 偶发父实体状态停留在UPLOADED，但关联子实体持久化正常，无异常无回滚；
• 99%场景正常，出现时连续影响多个实体，数小时后自动停止；
• 疑似与Spring Boot 3升级相关，本地环境无法复现，部署在AWS Fargate + RDS Postgres。

排查方向与验证步骤 #

1. Spring Boot 3事务逻辑变更检查 #

• 核对Spring 6（Spring Boot 3依赖）中TransactionTemplate的执行规则：回调内的异常处理是否影响事务提交/回滚。默认情况下，TransactionTemplate在回调抛出RuntimeException时自动回滚，但若异常被内部捕获且未重新抛出，事务会提交；
• 确认analyze()方法是否在当前事务上下文内执行：若analyze()内部调用了不带事务注解的方法，且该方法修改实体后未通过Repository持久化，可能导致状态变更未被纳入事务。

2. 数据库并发与隔离级别问题 #

• 检查Postgres事务隔离级别（默认READ COMMITTED）：多Worker实例同时运行时，可能出现不可重复读——Worker A读取UPLOADED数据后，Worker B也读取同批数据；A提交修改后，B的事务仍持有旧快照，导致修改无效；
• 查看RDS慢查询日志与事务日志：确认是否存在事务长时间未提交（如analyze()调用外部接口超时），导致事务超时后未触发异常，最终状态未同步；
• 建议给查询添加悲观锁：修改findByStatus为SELECT ... FROM parent_entity WHERE status = 'UPLOADED' FOR UPDATE SKIP LOCKED，避免多实例重复读取同一条数据。

3. 实体持久化逻辑验证 #

• 检查analyze()方法内的状态修改方式：若直接修改传入的parentEntity（detached状态，来自外部查询），未调用repository.save(parentEntity)，事务提交时Hibernate不会自动同步该修改；
• 核对receiptRepository.findFirstById(...)的意义：若analyze()未正确持久化修改，该查询返回的仍是旧数据，但日志打印的可能是内存中修改后的对象，导致日志与数据库不一致。

4. 异常处理的事务影响 #

• 检查TemporaryProblem和Exception的捕获逻辑：若analyze()抛出RuntimeException被外层Exception捕获且未重新抛出，TransactionTemplate会认为执行成功并提交事务，但此时状态可能未被正确修改；
• 开启Spring事务DEBUG日志（logging.level.org.springframework.transaction=DEBUG），查看事务最终是提交还是回滚，确认异常是否导致事务异常终止。

5. Hibernate 6（Spring Boot 3默认）的脏检查变化 #

• 核对Hibernate 6的脏检查机制：对枚举类型的状态字段，是否存在修改未被检测到的情况。确保ParentEntity的状态字段正确标注@Enumerated(EnumType.STRING)；
• 检查实体的字段访问策略：若使用字段访问（@Access(AccessType.FIELD)），确认状态字段的修改是否被Hibernate跟踪。

6. 乐观锁机制补充 #

• 给ParentEntity添加version字段（@Version注解），更新时自动校验版本号，防止并发修改导致的状态覆盖问题。

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