JPA多对多关联新增用户时重复创建Profile实体问题

你的问题核心是未对Profile的枚举值设置唯一约束，且业务逻辑中直接使用新建的ProfileEntity对象关联用户，JPA会将这些对象判定为新实体插入数据库，哪怕枚举值相同也会生成新ID。再加上级联配置不当，最终导致重复的Profile记录。

以下是具体解决方案：

1. 给ProfileEntity添加唯一约束 #

在ProfileEntity的profile字段上添加唯一约束，确保同一个Profiles枚举值只能对应一条数据库记录：

@Data
@Entity
@AllArgsConstructor
@NoArgsConstructor
@Table(name = "t_profile")
public class ProfileEntity {
    @Id
    @GeneratedValue(strategy = GenerationType.AUTO)
    @Column(name = "profile_id")
    private Long Id;
    @Column(nullable = false, unique = true) // 新增唯一约束
    @Enumerated(EnumType.STRING)
    private Profiles profile;
    @ManyToMany(fetch = FetchType.LAZY, mappedBy = "profiles") // 移除不必要的级联配置
    private Set<UserEntity> users = new HashSet<>(); // 变量名修正为users更符合语义
}

同时需要给t_profile表的profile字段添加唯一索引（可通过数据库迁移工具如Flyway/Liquibase生成脚本，或手动执行SQL），从数据库层面杜绝重复数据。

2. 调整UserEntity的级联配置 #

移除Hibernate专属的@Cascade注解，仅保留JPA标准的必要级联类型，避免不必要的实体创建操作：

@Data
@Entity
@AllArgsConstructor
@NoArgsConstructor
@Table(name = "t_user")
public class UserEntity {
    @Id
    @GeneratedValue(strategy = GenerationType.AUTO)
    @Column(name = "user_id")
    private Long Id;
    @Column(nullable = false)
    private String username;
    @Column(nullable = false, length = 14)
    private String siret;
    @ManyToMany(fetch = FetchType.LAZY, cascade = {CascadeType.MERGE}) // 仅保留MERGE级联
    @JoinTable(name = "t_user_profile", joinColumns = {@JoinColumn(name = "user_id")},
            inverseJoinColumns = {@JoinColumn(name = "profile_id")})
    private Set<ProfileEntity> profiles = new HashSet<>();

    @OneToOne(fetch = FetchType.LAZY,cascade = CascadeType.ALL)
    @JoinColumn(name = "ressource_id")
    private RessourceEntity ressource;
}

3. 业务层实现"查询优先，不存在则创建"的逻辑 #

在分配Profile的业务代码中，先根据枚举值查询数据库，存在则直接使用，不存在才新建并保存：

@Service
public class UserService {
    @Autowired
    private UserRepository userRepository;
    @Autowired
    private ProfileRepository profileRepository;

    public void assignProfileToUser(Long userId, Profiles profileEnum) {
        // 1. 获取目标用户
        UserEntity user = userRepository.findById(userId)
                .orElseThrow(() -> new RuntimeException("用户不存在"));
        
        // 2. 查询或创建Profile
        ProfileEntity profile = profileRepository.findByProfile(profileEnum)
                .orElseGet(() -> {
                    ProfileEntity newProfile = new ProfileEntity();
                    newProfile.setProfile(profileEnum);
                    return profileRepository.save(newProfile);
                });
        
        // 3. 关联用户与Profile并保存
        user.getProfiles().add(profile);
        userRepository.save(user);
    }
}

配套的ProfileRepository需要提供根据枚举值查询的方法：

public interface ProfileRepository extends JpaRepository<ProfileEntity, Long> {
    Optional<ProfileEntity> findByProfile(Profiles profile);
}

关键说明 #

绝对不要直接新建ProfileEntity对象就加到User的profiles集合中——即使枚举值相同，JPA也会将其视为新实体插入。必须通过查询确认存在性后，再关联到用户。

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