Spring WebFlux用Mono合并一对多父子实体时父更新子不更新问题

你当前的update方法实现如下：

public void update(AdmWeightageDefinitionDBO t) {
    sessionFactory.withTransaction((session, tx) ->  session.merge(t)).subscribeAsCompletionStage();
}

问题诱因排查 #

• 关联注解配置缺失：父实体AdmWeightageDefinitionDBO中对应子实体集合的@OneToMany注解未配置级联更新属性，默认情况下merge操作仅作用于父实体本身，不会同步处理关联子实体。需显式指定cascade = CascadeType.MERGE或cascade = CascadeType.ALL才能触发子实体的级联更新；如果需要同步删除子集合中被移除的元素，还需配置orphanRemoval = true。
• 子实体状态异常：待更新的子实体未携带合法主键值，会被Hibernate识别为瞬时状态对象，默认不会触发更新操作；若子实体外键字段未关联父实体主键，也会导致关联关系断裂无法同步更新。
• 异常被静默吞噬：当前实现直接调用subscribeAsCompletionStage()未配置异常捕获逻辑，子实体更新过程中抛出的约束冲突、字段不合法等异常会被静默丢弃，从外部只能观测到父实体更新成功的结果。

修复步骤 #

1. 修正父实体关联注解配置，示例如下：

@OneToMany(mappedBy = "parentField", cascade = {CascadeType.MERGE, CascadeType.PERSIST}, orphanRemoval = true)
private List<子实体类名> childList;

2. 优化update方法实现，避免异常丢失，建议将返回值改为Mono交给上层订阅，符合响应式编程规范：

public Mono<Void> update(AdmWeightageDefinitionDBO t) {
    return sessionFactory.withTransaction((session, tx) -> session.merge(t))
            .then()
            .doOnError(e -> log.error("实体更新失败: ", e));
}

如果必须在方法内部完成订阅，补全异常处理逻辑即可：

public void update(AdmWeightageDefinitionDBO t) {
    sessionFactory.withTransaction((session, tx) -> session.merge(t))
            .doOnError(e -> log.error("实体更新失败: ", e))
            .subscribe();
}

3. 入参校验：更新前确认所有待修改子实体携带合法主键，新增子实体的外键字段已正确关联父实体主键。

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