JPA实体设计咨询：用户-商铺收藏、评价与评分场景优化

先看你的收藏实体设计和实现，存在几个可以优化的点，同时针对「用户查看所有商铺并获取自身收藏状态」这个场景，我们可以给出更高效的方案，最后聊聊评价与评分的设计思路。

一、当前收藏实体设计的问题与优化 #

1. 实体映射的错误与修正 #

你的FavouriteEntity里存在几个明显的问题，先帮你修正：

• 字段accessory_id对应的是StoreEntity，字段名改成store_id更贴合语义；
• 构造函数里的this.storeEntity = accessoryEntity;是笔误，应该替换为storeEntity；
• @JoinColumn的nullable应该设为false——一条收藏记录必须关联一个用户和一个商铺，不能为null；
• StoreEntity中的@OneToMany没有指定mappedBy，这会导致JPA自动生成额外的中间表，正确做法是关联到FavouriteEntity中的对应字段；
• 别忘了给实体加主键！JPA要求实体必须有主键字段。

优化后的FavouriteEntity：

@Entity
@Table(name = "favourite")
public class FavouriteEntity {
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Long id;

    @ManyToOne(optional = false)
    @JoinColumn(name = "user_id", nullable = false)
    private UserEntity userEntity;

    @Type(type="true_false")
    private boolean value;

    @ManyToOne(optional = false)
    @JoinColumn(name = "store_id", nullable = false)
    private StoreEntity storeEntity;

    // JPA必须要有无参构造函数
    public FavouriteEntity() {}

    // 修正构造函数笔误
    public FavouriteEntity(UserEntity user, boolean value, StoreEntity storeEntity) {
        this.value = value;
        this.storeEntity = storeEntity;
        this.userEntity = user;
    }

    // getter和setter省略
}

优化后的StoreEntity关联部分：

@Entity
@Table(name = "store")
public class StoreEntity {
    // 其他字段省略...

    @OneToMany(mappedBy = "storeEntity", cascade = CascadeType.ALL, orphanRemoval = true)
    private List<FavouriteEntity> favouriteEntities = new ArrayList<>();

    // 推荐添加关联维护方法，避免外部直接操作集合
    public void addFavourite(FavouriteEntity favourite) {
        favouriteEntities.add(favourite);
        favourite.setStoreEntity(this);
    }

    // getter和setter省略
}

2. 收藏实现方法的优化 #

原方法里的findOne已经过时，建议用findById处理Optional；另外，直接保存商铺实体不是最优选择，我们只需要保存收藏实体即可：

public void makeStoreFavorite(long storeId, boolean val, long userId) {
    StoreEntity storeEntity = storeRepository.findById(storeId)
            .orElseThrow(() -> new RuntimeException("商铺不存在"));
    UserEntity userEntity = userRepository.findById(userId)
            .orElseThrow(() -> new RuntimeException("用户不存在"));

    // 自定义查询方法，根据用户ID和商铺ID查询收藏记录
    Optional<FavouriteEntity> fEntityOpt = favouriteRepository.findByUserEntityIdAndStoreEntityId(userId, storeId);
    
    FavouriteEntity fEntity;
    if (fEntityOpt.isEmpty()) {
        fEntity = new FavouriteEntity(userEntity, val, storeEntity);
        storeEntity.addFavourite(fEntity);
    } else {
        fEntity = fEntityOpt.get();
        fEntity.setValue(val);
    }

    // 直接保存收藏实体，级联配置会同步到商铺
    favouriteRepository.save(fEntity);
}

同时在FavouriteRepository中定义查询方法：

public interface FavouriteRepository extends JpaRepository<FavouriteEntity, Long> {
    Optional<FavouriteEntity> findByUserEntityIdAndStoreEntityId(Long userId, Long storeId);
}

二、用户查看所有商铺并获取自身收藏状态的最优方案 #

你提到的遍历收藏列表或逐个查询都是N+1查询，性能很差。最优方案是通过一次JPQL查询，左外连接当前用户的收藏记录，把商铺和收藏状态一起返回。

1. 定义DTO封装结果 #

创建一个DTO来存储商铺信息和当前用户的收藏状态：

public class StoreWithFavoriteStatusDTO {
    private Long storeId;
    private String storeName; // 商铺其他字段按需添加
    private boolean isFavorited;

    // 用于JPQL查询的投影构造函数
    public StoreWithFavoriteStatusDTO(Long storeId, String storeName, Boolean isFavorited) {
        this.storeId = storeId;
        this.storeName = storeName;
        // 处理无收藏记录的情况：默认设为false
        this.isFavorited = Boolean.TRUE.equals(isFavorited);
    }

    // getter和setter省略
}

2. 编写JPQL查询 #

在StoreRepository中添加查询方法：

public interface StoreRepository extends JpaRepository<StoreEntity, Long> {
    @Query("SELECT new com.yourpackage.dto.StoreWithFavoriteStatusDTO(" +
            "s.id, s.name, f.value) " +
            "FROM StoreEntity s " +
            "LEFT JOIN s.favouriteEntities f ON f.userEntity.id = :userId")
    List<StoreWithFavoriteStatusDTO> findAllWithFavoriteStatus(Long userId);
}

调用storeRepository.findAllWithFavoriteStatus(currentUserId)就能一次性获取所有商铺及当前用户的收藏状态，彻底避免N+1问题。

三、评价与评分功能的设计与实现 #

1. 实体设计 #

ReviewEntity需要关联用户和商铺，同时包含评分和评价内容：

@Entity
@Table(name = "review")
public class ReviewEntity {
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Long id;

    @ManyToOne(optional = false)
    @JoinColumn(name = "user_id", nullable = false)
    private UserEntity userEntity;

    @ManyToOne(optional = false)
    @JoinColumn(name = "store_id", nullable = false)
    private StoreEntity storeEntity;

    @Column(nullable = false)
    private Integer score; // 评分范围建议1-5分

    @Column(length = 1000)
    private String content;

    @Column(nullable = false)
    private LocalDateTime createTime;

    // 无参构造函数、带参构造函数、getter和setter省略
}

在StoreEntity中添加评价关联：

@Entity
@Table(name = "store")
public class StoreEntity {
    // 其他字段省略...

    @OneToMany(mappedBy = "storeEntity", cascade = CascadeType.ALL, orphanRemoval = true)
    private List<ReviewEntity> reviews = new ArrayList<>();

    // 关联维护方法
    public void addReview(ReviewEntity review) {
        reviews.add(review);
        review.setStoreEntity(this);
    }

    // getter和setter省略
}

2. 获取商铺平均评分 #

如果需要实时获取平均评分，可以在StoreRepository中定义查询方法：

public interface StoreRepository extends JpaRepository<StoreEntity, Long> {
    // 其他方法省略...

    @Query("SELECT AVG(r.score) FROM ReviewEntity r WHERE r.storeEntity.id = :storeId")
    Optional<Double> getAverageScore(Long storeId);
}

或者用Hibernate的@Formula注解，把平均评分作为商铺实体的一个字段：

@Entity
@Table(name = "store")
public class StoreEntity {
    // 其他字段省略...

    @Formula("(SELECT AVG(r.score) FROM review r WHERE r.store_id = id)")
    private Double averageScore;

    // getter省略
}

这样查询商铺时会自动计算平均评分，无需额外查询。

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