能否使用多个native query将结果集映射至同一Java对象？

当然可行！这种场景在实际开发里其实挺常见的——尤其是当数据分散在不同查询结果里，没法用单条SQL一次性拉取的时候。下面我给你两种常见的实现思路，结合代码示例来解释：

一、手动使用EntityManager执行多个Native Query #

这是最灵活的方式，适合需要精细控制查询过程的场景：

1. 定义结果承载对象
   首先你需要一个POJO来存放最终的结果，比如：

public class ResultHolder {
    private String userName;
    private Integer orderCount;

    // 构造方法、getter、setter根据需求添加
    public ResultHolder() {}
    public ResultHolder(String userName, Integer orderCount) {
        this.userName = userName;
        this.orderCount = orderCount;
    }

    // getter和setter省略
}

2. 编写并执行Native Query
   通过EntityManager依次执行两个查询，把结果填充到ResultHolder中：

import jakarta.persistence.EntityManager;
import jakarta.persistence.NoResultException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

@Service
@Transactional(readOnly = true) // 加只读事务保证数据一致性
public class ResultService {

    @Autowired
    private EntityManager entityManager;

    public ResultHolder getResultForUser(Long userId) {
        ResultHolder result = new ResultHolder();

        // 第一个查询：获取用户名
        String userNameSql = "SELECT user_name FROM users WHERE user_id = ?1";
        try {
            String userName = (String) entityManager.createNativeQuery(userNameSql)
                    .setParameter(1, userId)
                    .getSingleResult();
            result.setUserName(userName);
        } catch (NoResultException e) {
            // 处理用户不存在的情况，比如设置默认值或者抛出业务异常
            result.setUserName("未知用户");
        }

        // 第二个查询：获取该用户的订单数量
        String orderCountSql = "SELECT COUNT(*) FROM orders WHERE user_id = ?1";
        Integer orderCount = ((Number) entityManager.createNativeQuery(orderCountSql)
                .setParameter(1, userId)
                .getSingleResult()).intValue();
        result.setOrderCount(orderCount);

        return result;
    }
}

二、用Spring Data JPA的自定义Repository方法 #

如果你的项目用了Spring Data JPA，可以把查询逻辑封装到Repository接口里，代码会更简洁：

1. 定义Repository接口
   分别为两个查询创建对应的Repository方法：

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

public interface UserRepository extends JpaRepository<UserEntity, Long> {
    @Query(value = "SELECT user_name FROM users WHERE user_id = ?1", nativeQuery = true)
    String findUserNameById(Long userId);
}

public interface OrderRepository extends JpaRepository<OrderEntity, Long> {
    @Query(value = "SELECT COUNT(*) FROM orders WHERE user_id = ?1", nativeQuery = true)
    Integer countOrdersByUserId(Long userId);
}

2. 在服务层调用并组装结果

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

@Service
@Transactional(readOnly = true)
public class ResultService {

    @Autowired
    private UserRepository userRepository;
    @Autowired
    private OrderRepository orderRepository;

    public ResultHolder getResult(Long userId) {
        String userName = userRepository.findUserNameById(userId);
        // 同样可以处理用户不存在的情况，比如用Optional包装
        // String userName = userRepository.findUserNameById(userId).orElse("未知用户");
        Integer orderCount = orderRepository.countOrdersByUserId(userId);
        return new ResultHolder(userName, orderCount);
    }
}

一些注意事项 #

• 事务一致性：如果两次查询需要保证数据状态一致，记得加上@Transactional注解，避免在查询间隙数据被修改；
• 异常处理：getSingleResult()如果没有匹配结果会抛出NoResultException，如果有多个结果会抛出NonUniqueResultException，记得根据业务场景处理这些异常；
• 性能考量：如果这种多查询场景很频繁，也可以考虑合并成一条SQL（比如用子查询或者JOIN），但如果数据逻辑确实分散，多查询的方式完全没问题。

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