如何用JPARepository校验外键关联后删除过期的实体A记录

解决方案 #

首先先确认映射偏差：你当前贴出的A实体@OneToOne配置是将外键b_id存储在A表，和你描述的「B存在指向A的外键」场景不符，你可以先核对实际表结构的外键存储位置，以下方案按照「B表存在指向A主键的外键列、B实体无A的引用属性」的需求场景给出。

这个需求涉及跨表关联判断，无法通过Spring Data JPA的方法名派生查询直接实现，需要自定义查询语句，有两种常用实现方式：

方式1：单条JPQL/原生SQL直接删除（性能最优） #

直接在A对应的Repository接口中添加带自定义查询的删除方法，注意添加@Modifying和事务注解：

import org.springframework.data.jpa.repository.Modifying;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;
import org.springframework.transaction.annotation.Transactional;

// 你的A Repository接口定义
public interface ARepository extends JpaRepository<A, Long> {
    // 如果B实体中定义了对应外键的属性（比如名为aId），用JPQL实现
    @Modifying
    @Transactional
    @Query("DELETE FROM A a WHERE a.userId = :userId AND a.expiryDate < :expiryDate AND NOT EXISTS (SELECT 1 FROM B b WHERE b.aId = a.id)")
    void deleteExpiredUnlinkedA(@Param("userId") Long userId, @Param("expiryDate") Date expiryDate);

    // 如果B实体没有定义对应外键的属性，直接用原生SQL操作表字段，注意替换实际的表名、列名
    @Modifying
    @Transactional
    @Query(value = "DELETE FROM a_table WHERE user_id = :userId AND expiry_date < :expiryDate AND NOT EXISTS (SELECT 1 FROM b_table WHERE b_table.a_id = a_table.id)", nativeQuery = true)
    void deleteExpiredUnlinkedANative(@Param("userId") Long userId, @Param("expiryDate") Date expiryDate);
}

方式2：先筛选再删除（适合小数据量场景） #

如果你不想写自定义SQL，也可以分两步操作：

• 先定义B的Repository方法，判断指定A的id是否被B关联：

  boolean existsByAId(Long aId);
  

• 业务层先查询出所有符合userId、已过期的A列表，过滤掉被B关联的条目后批量删除：

  @Transactional
  public void deleteExpiredA(Long userId, Date expiryDate) {
      List<A> expiredAList = aRepository.findByUserIdAndExpiryDateBefore(userId, expiryDate);
      List<A> toDeleteList = expiredAList.stream()
              .filter(a -> !bRepository.existsByAId(a.getId()))
              .collect(Collectors.toList());
      aRepository.deleteAll(toDeleteList);
  }
  

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