Spring Boot自定义关联表实现用户评分：重复更新而非新增问题排查

问题场景 #

基于Spring Boot + AWS RDS构建评分系统，为避免使用@ManyToMany注解，自定义ProductsRatedByUserEntity作为用户与商品的关联表，用于记录用户对商品的星级评分。当前出现异常：首个用户评分商品时可正常创建关联记录，但其他用户评分同一商品时，系统会更新已有记录而非新增行，不符合「一人一行」的预期。

核心原因 #

这类问题几乎都是因为ProductsRatedByUserEntity未正确配置复合主键，导致JPA无法识别「用户ID+商品ID」作为唯一标识，将后续请求判定为对已有实体的更新操作。

解决方案 #

1. 创建复合主键类 #

定义实现Serializable的复合主键类，包含用户ID和商品ID两个字段，并重写equals和hashCode方法（JPA依赖这两个方法判断实体唯一性）：

import jakarta.persistence.Embeddable;
import java.io.Serializable;
import java.util.Objects;

@Embeddable
public class UserProductRatingId implements Serializable {
    private Long userId;
    private Long productId;

    // 无参、全参构造
    public UserProductRatingId() {}
    public UserProductRatingId(Long userId, Long productId) {
        this.userId = userId;
        this.productId = productId;
    }

    // 必须重写equals和hashCode
    @Override
    public boolean equals(Object o) {
        if (this == o) return true;
        if (o == null || getClass() != o.getClass()) return false;
        UserProductRatingId that = (UserProductRatingId) o;
        return Objects.equals(userId, that.userId) && Objects.equals(productId, that.productId);
    }

    @Override
    public int hashCode() {
        return Objects.hash(userId, productId);
    }

    // Getter、Setter方法
}

2. 修改关联表实体类 #

在ProductsRatedByUserEntity中使用@EmbeddedId引入复合主键，通过@MapsId将关联实体的ID映射到复合主键的对应字段：

import jakarta.persistence.*;

@Entity
@Table(name = "products_rated_by_user")
public class ProductsRatedByUserEntity {
    @EmbeddedId
    private UserProductRatingId id;

    @ManyToOne
    @MapsId("userId") // 映射复合主键中的userId字段
    @JoinColumn(name = "user_id")
    private UserEntity user;

    @ManyToOne
    @MapsId("productId") // 映射复合主键中的productId字段
    @JoinColumn(name = "product_id")
    private ProductEntity product;

    private Integer rating; // 星级评分值

    // 构造方法
    public ProductsRatedByUserEntity() {}

    public ProductsRatedByUserEntity(UserEntity user, ProductEntity product, Integer rating) {
        this.id = new UserProductRatingId(user.getId(), product.getId());
        this.user = user;
        this.product = product;
        this.rating = rating;
    }

    // Getter、Setter方法
}

3. 调整Service层逻辑 #

在保存评分前，先根据用户ID和商品ID查询是否已有记录，区分「更新」和「新增」操作：

@Service
public class RatingService {
    @Autowired
    private ProductsRatedByUserRepository ratingRepository;

    public ProductsRatedByUserEntity saveOrUpdateRating(Long userId, Long productId, Integer rating) {
        // 查询是否已有该用户对该商品的评分
        Optional<ProductsRatedByUserEntity> existingRating = ratingRepository.findById(new UserProductRatingId(userId, productId));
        
        if (existingRating.isPresent()) {
            // 已有记录，更新评分值
            ProductsRatedByUserEntity ratingEntity = existingRating.get();
            ratingEntity.setRating(rating);
            return ratingRepository.save(ratingEntity);
        } else {
            // 无记录，创建新的关联实体
            UserEntity user = new UserEntity(); // 实际业务中应从UserRepository查询已有用户
            user.setId(userId);
            ProductEntity product = new ProductEntity(); // 实际业务中应从ProductRepository查询已有商品
            product.setId(productId);
            
            ProductsRatedByUserEntity newRating = new ProductsRatedByUserEntity(user, product, rating);
            return ratingRepository.save(newRating);
        }
    }
}

4. 更新Repository接口 #

确保Repository继承JpaRepository时，泛型参数使用定义好的复合主键：

import org.springframework.data.jpa.repository.JpaRepository;

public interface ProductsRatedByUserRepository extends JpaRepository<ProductsRatedByUserEntity, UserProductRatingId> {
}

关键注意事项 #

• 复合主键类必须实现Serializable，且正确重写equals和hashCode，这是JPA识别实体唯一性的核心。
• 使用@MapsId可避免在关联表中重复存储用户ID和商品ID，保证数据一致性。
• Service层的前置查询逻辑既符合「一人一行」的业务规则，也能避免不必要的数据库操作。

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