Spring Data JPA多对多关联投影查询返回重复对象问题

这个问题我之前也碰到过！本质原因是多对多关联的JOIN查询会产生笛卡尔积——当一个用户拥有多个权限时，数据库会返回多条用户记录（每个权限对应一条），而Spring Data的Projection默认不会帮你自动合并这些重复的用户对象，就出现了你看到的同一个用户多次返回、每次只带一个权限的情况。

下面给你几个实用的解决方案，按推荐程度排序：

方案1：在查询中添加DISTINCT关键字（最推荐） #

直接在Repository的方法上通过@Query注解指定带DISTINCT的JPQL，让数据库层面就返回唯一的用户记录，Spring Data会自动把关联的所有权限合并到用户的权限列表中：

@Repository
public interface UserRepository extends JpaRepository<User, Long> {
    User findByUsername(String username);
    
    @Query("SELECT DISTINCT u FROM User u JOIN u.authorities a WHERE u.nodeId = :nodeId")
    List<UserWithUuid> findAllByNodeId(Long nodeId);

    interface UserWithUuid {
        String getFirstname();
        String getLastname();
        String getEmail();
        List<Authority> getAuthorities();
        UUID getApiKey();
    }
}

方案2：用方法名自动生成DISTINCT查询 #

如果你不想写JPQL，也可以直接在方法名里加上Distinct，Spring Data会自动帮你生成带DISTINCT的查询语句：

@Repository
public interface UserRepository extends JpaRepository<User, Long> {
    User findByUsername(String username);
    
    List<UserWithUuid> findDistinctAllByNodeId(Long nodeId);

    interface UserWithUuid {
        String getFirstname();
        String getLastname();
        String getEmail();
        List<Authority> getAuthorities();
        UUID getApiKey();
    }
}

方案3：内存层面手动合并（不推荐，仅作备选） #

如果因为某些原因无法修改查询语句，也可以在查询后用Java Stream在内存中去重并合并权限。不过这种方法效率较低，尤其是数据量大的时候，因为数据库已经返回了重复数据，还要在内存处理：

首先你需要定义一个DTO类来接收合并后的结果（因为Projection接口无法直接修改权限列表）：

public class UserWithUuidDto {
    private String firstname;
    private String lastname;
    private String email;
    private List<Authority> authorities;
    private UUID apiKey;

    // 构造函数、getter
    public UserWithUuidDto(String firstname, String lastname, String email, List<Authority> authorities, UUID apiKey) {
        this.firstname = firstname;
        this.lastname = lastname;
        this.email = email;
        this.authorities = authorities;
        this.apiKey = apiKey;
    }

    // getter方法省略
}

然后在业务代码中处理：

List<UserWithUuid> rawUsers = userRepository.findAllByNodeId(nodeId);
List<UserWithUuidDto> distinctUsers = rawUsers.stream()
    // 按唯一标识（比如apiKey）分组
    .collect(Collectors.groupingBy(UserWithUuid::getApiKey))
    .values()
    .stream()
    .map(userGroup -> {
        UserWithUuid firstUser = userGroup.get(0);
        // 合并该用户的所有权限并去重
        List<Authority> mergedAuthorities = userGroup.stream()
            .flatMap(u -> u.getAuthorities().stream())
            .distinct()
            .collect(Collectors.toList());
        // 返回合并后的DTO
        return new UserWithUuidDto(
            firstUser.getFirstname(),
            firstUser.getLastname(),
            firstUser.getEmail(),
            mergedAuthorities,
            firstUser.getApiKey()
        );
    })
    .collect(Collectors.toList());

总结 #

优先用前两种方案，在数据库层面解决重复问题，既高效又简洁。第三种方案只适合临时应急或者特殊场景。

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