如何在@PreRemove注解方法中更新实体后再执行删除操作

根因分析 #

JPA规范中@PreRemove回调触发时，当前实体已经被持久化上下文标记为待删除状态，你在回调中手动调用persistAndFlush()的操作会被JPA实现直接忽略，不会生成对应的UPDATE SQL语句，因此变更无法持久化到数据库。手动触发flush还可能导致当前持久化上下文状态混乱。

可行方案 #

方案1：业务层显式控制操作顺序（推荐） #

直接在删除实体的业务逻辑中先执行更新、再执行删除，逻辑透明可控，不会出现持久化上下文状态冲突问题，示例代码如下：

// 业务层删除逻辑
public void deleteTargetEntity(BaseEntity entity) {
    CurrentUser currentUser = CDI.current().select(CurrentUser.class).get();
    if (currentUser != null) {
        entity.deletedBy = currentUser.userId;
        entity.persistAndFlush();
    }
    // 完成更新后再执行删除
    entity.remove();
}

方案2：调整EntityListener逻辑，移除手动持久化操作 #

大部分JPA实现（如Hibernate）默认会在执行DELETE SQL前，先处理待删除实体的字段变更，生成并执行UPDATE语句，你仅需要在@PreRemove回调中修改字段属性即可，不需要手动调用持久化相关方法，调整后代码如下：

@PreRemove
void onRemove(Object entity) {
    CurrentUser currentUser = CDI.current().select(CurrentUser.class).get();
    if (currentUser != null && entity instanceof BaseEntity) {
        BaseEntity baseEntity = (BaseEntity) entity;
        baseEntity.deletedBy = currentUser.userId;
        // 移除persistAndFlush调用，依赖JPA默认的SQL执行顺序
    }
}

如果执行后仍然未生成UPDATE语句，可配置JPA实现参数，以Hibernate为例，将hibernate.order_updates、hibernate.order_inserts均设置为true，即可保证更新操作在删除操作前执行。

方案3：独立事务执行更新（备选） #

如果业务要求必须通过EntityListener完成逻辑，可开启独立的新事务执行更新操作，和当前删除事务隔离，避免状态冲突，示例代码如下：

@PreRemove
void onRemove(Object entity) {
    CurrentUser currentUser = CDI.current().select(CurrentUser.class).get();
    if (currentUser == null || !(entity instanceof BaseEntity)) {
        return;
    }
    UserTransaction tx = CDI.current().select(UserTransaction.class).get();
    EntityManager independentEm = CDI.current().select(EntityManager.class).get();
    try {
        tx.begin();
        BaseEntity baseEntity = (BaseEntity) independentEm.merge(entity);
        baseEntity.deletedBy = currentUser.userId;
        independentEm.flush();
        tx.commit();
    } catch (Exception e) {
        try {
            tx.rollback();
        } catch (Exception rollbackEx) {
            // 自定义回滚异常处理逻辑
        }
    }
}

该方案需要额外处理事务边界，性能略低，仅作为备选方案使用。

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