Hibernate原生SQL查询结果数据类型判别与处理

理解Hibernate原生查询结果的数据类型映射

在使用hibernate的entitymanager.createnativequery()方法执行原生sql查询时，hibernate会将数据库返回的原始数据类型映射为相应的java对象类型。例如，数据库中的varchar类型通常会映射为java的string，int或bigint会映射为integer或long，date或timestamp则会映射为java.util.date或java.sql.timestamp。需要注意的是，hibernate不会直接返回java.sql.jdbctype枚举，而是返回其对应的java对象。

createNativeQuery()的getResultList()方法根据查询的列数返回不同类型的列表：

• 单列查询：如果SQL查询只选择一个列（例如 SELECT column_name FROM table），getResultList()通常返回 List
• 多列查询：如果SQL查询选择多个列（例如 SELECT col1, col2 FROM table），getResultList()通常返回 List

通过instanceof判别运行时数据类型

由于原生查询的动态性，我们可能无法预先知道每个列的具体Java类型。在这种情况下，Java的instanceof运算符是判别运行时数据类型的有效工具。通过检查结果集中每个元素的类型，我们可以安全地进行类型转换和后续处理。

以下是处理原生SQL查询结果并判别数据类型的示例代码：

LongShot

LongShot 是一款 AI 写作助手，可帮助您生成针对搜索引擎优化的内容博客。

下载

import jakarta.persistence.EntityManager;
import jakarta.persistence.Query;
import java.math.BigDecimal; // 可能返回的数字类型
import java.util.Date;
import java.util.List;

public class NativeQueryResultProcessor {

    private final EntityManager em;

    public NativeQueryResultProcessor(EntityManager em) {
        this.em = em;
    }

    /**
     * 执行原生SQL查询并处理结果的数据类型。
     *
     * @param sqlQuery 要执行的原生SQL语句。
     */
    public void processNativeQueryResult(String sqlQuery) {
        // 创建原生查询
        Query query = em.createNativeQuery(sqlQuery);

        // 执行查询并获取结果列表
        List results = query.getResultList();

        if (results == null || results.isEmpty()) {
            System.out.println("查询结果为空。");
            return;
        }

        // 假设我们处理的是多列查询，返回 List
        // 如果是单列查询，results.get(0) 将直接是 Object 类型
        if (results.get(0) instanceof Object[]) {
            System.out.println("处理多列查询结果 (List):");
            for (Object row : results) {
                Object[] columns = (Object[]) row;
                System.out.print("行数据: [");
                for (int i = 0; i < columns.length; i++) {
                    Object columnValue = columns[i];
                    String typeName = "未知类型";
                    String valueString = "null";

                    if (columnValue != null) {
                        if (columnValue instanceof String) {
                            typeName = "String";
                            valueString = (String) columnValue;
                        } else if (columnValue instanceof Integer) {
                            typeName = "Integer";
                            valueString = String.valueOf((Integer) columnValue);
                        } else if (columnValue instanceof Long) {
                            typeName = "Long";
                            valueString = String.valueOf((Long) columnValue);
                        } else if (columnValue instanceof Double) {
                            typeName = "Double";
                            valueString = String.valueOf((Double) columnValue);
                        } else if (columnValue instanceof Float) {
                            typeName = "Float";
                            valueString = String.valueOf((Float) columnValue);
                        } else if (columnValue instanceof BigDecimal) {
                            typeName = "BigDecimal"; // 数据库DECIMAL/NUMERIC可能映射为BigDecimal
                            valueString = ((BigDecimal) columnValue).toPlainString();
                        } else if (columnValue instanceof Date) {
                            typeName = "Date"; // java.util.Date 或其子类 java.sql.Timestamp
                            valueString = ((Date) columnValue).toString();
                        } else if (columnValue instanceof Boolean) {
                            typeName = "Boolean";
                            valueString = String.valueOf((Boolean) columnValue);
                        }
                        // 可以根据需要添加更多类型判断
                        else {
                            typeName = columnValue.getClass().getName();
                            valueString = columnValue.toString();
                        }
                    }
                    System.out.print(String.format("列%d: %s (类型: %s)", i + 1, valueString, typeName));
                    if (i < columns.length - 1) {
                        System.out.print(", ");
                    }
                }
                System.out.println("]");
            }
        } else {
            // 处理单列查询，返回 List