使用JPA原生查询时如何获取列名并返回键值对格式结果

你的需求是将原生SELECT查询的结果以「列名:列值」的结构返回，原有的multiSelectQuery仅返回纯值列表，且尝试通过query.unwrap(java.sql.ResultSet.class)获取列元数据时抛出Could not unwrap this异常。以下是两种可靠的解决方案：

方案一：使用JPA Tuple接收结果 #

利用JPA的Tuple类型可以直接获取查询结果的列信息，无需手动处理元数据：

import javax.persistence.Tuple;
import javax.persistence.TupleElement;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

public List<Map<String, Object>> multiSelectQuery(String queryStr) {
    try {
        // 创建返回Tuple类型的原生查询
        Query query = em.createNativeQuery(queryStr, Tuple.class);
        List<Tuple> tupleList = query.getResultList();
        
        List<Map<String, Object>> result = new ArrayList<>();
        for (Tuple tuple : tupleList) {
            Map<String, Object> rowMap = new HashMap<>();
            // 遍历每个Tuple元素，获取列名（别名）和对应值
            for (TupleElement<?> element : tuple.getElements()) {
                // 优先使用查询中定义的别名，无别名则用类型名兜底
                String columnName = element.getAlias() != null ? element.getAlias() : element.getJavaType().getSimpleName();
                rowMap.put(columnName, tuple.get(element));
            }
            result.add(rowMap);
        }
        return result;
    } catch (Exception e) {
        e.printStackTrace();
        return List.of(); // 返回空列表替代null，更符合规范
    }
}

方案二：通过JDBC直接执行查询（兼容所有JPA实现） #

部分JPA实现（如Hibernate）不支持将Query直接unwrap为ResultSet，此时可以通过EntityManager获取JDBC连接，手动执行查询并获取元数据：

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

public List<Map<String, Object>> multiSelectQuery(String queryStr) {
    List<Map<String, Object>> result = new ArrayList<>();
    Connection conn = null;
    PreparedStatement stmt = null;
    ResultSet rs = null;
    
    try {
        // 从EntityManager中unwrap出JDBC连接（由JPA管理，不要手动关闭）
        conn = em.unwrap(Connection.class);
        stmt = conn.prepareStatement(queryStr);
        rs = stmt.executeQuery();
        
        ResultSetMetaData metaData = rs.getMetaData();
        int columnCount = metaData.getColumnCount();
        
        // 逐行读取结果，组装列名-值的Map
        while (rs.next()) {
            Map<String, Object> rowMap = new HashMap<>();
            for (int i = 1; i <= columnCount; i++) {
                String columnName = metaData.getColumnName(i);
                rowMap.put(columnName, rs.getObject(i));
            }
            result.add(rowMap);
        }
    } catch (SQLException e) {
        e.printStackTrace();
        return List.of();
    } finally {
        // 手动关闭ResultSet和PreparedStatement
        try { if (rs != null) rs.close(); } catch (SQLException ignored) {}
        try { if (stmt != null) stmt.close(); } catch (SQLException ignored) {}
        // 注意：不要关闭Connection，它由JPA容器管理
    }
    return result;
}

为什么原unwrap方式失败？ #

JPA规范并未强制要求Query支持unwrap为ResultSet，多数ORM框架在执行查询后会立即关闭ResultSet，或内部未保留该对象，因此这种方式不可靠，不推荐使用。

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