Hibernate Native Query结果集列数据类型获取指南

import javax.persistence.EntityManager;
import javax.persistence.Query;
import java.util.Date;
import java.util.List;

public class NativeQueryTypeDetection {

    // 假设 em 是一个已注入或创建的 EntityManager 实例
    private EntityManager em; 

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

    public void processNativeQueryResult(String sqlQuery) {
        // 执行原生查询
        List<Object[]> results = em.createNativeQuery(sqlQuery).getResultList();

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

        // 遍历每一行数据
        for (Object[] row : results) {
            System.out.println("--- 新行数据 ---");
            // 遍历行中的每一个列值
            for (int i = 0; i < row.length; i++) {
                Object columnValue = row[i];

                if (columnValue == null) {
                    System.out.println("列 " + i + ": null 值");
                    continue;
                }

                // 使用 instanceof 判断其Java类型
                if (columnValue instanceof String) {
                    String value = (String) columnValue;
                    System.out.println("列 " + i + ": 字符串类型 (String) - 值: " + value);
                    // 进行字符串相关的处理...
                } else if (columnValue instanceof Number) {
                    // Number是所有数值类型的父类 (Integer, Long, Double, BigDecimal等)
                    Number value = (Number) columnValue;
                    System.out.println("列 " + i + ": 数值类型 (Number) - 值: " + value);
                    // 可以进一步细分，例如：
                    if (columnValue instanceof Integer) {
                        Integer intValue = (Integer) columnValue;
                        System.out.println("  -> 具体为 Integer");
                    } else if (columnValue instanceof Long) {
                        Long longValue = (Long) columnValue;
                        System.out.println("  -> 具体为 Long");
                    } else if (columnValue instanceof Double) {
                        Double doubleValue = (Double) columnValue;
                        System.out.println("  -> 具体为 Double");
                    }
                    // 进行数值相关的处理...
                } else if (columnValue instanceof Date) {
                    Date value = (Date) columnValue;
                    System.out.println("列 " + i + ": 日期类型 (java.util.Date) - 值: " + value);
                    // 进行日期相关的处理...
                } else if (columnValue instanceof Boolean) {
                    Boolean value = (Boolean) columnValue;
                    System.out.println("列 " + i + ": 布尔类型 (Boolean) - 值: " + value);
                    // 进行布尔相关的处理...
                } else {
                    // 处理其他未知类型
                    System.out.println("列 " + i + ": 未知类型 - Class: " + columnValue.getClass().getName() + " - 值: " + columnValue);
                }
            }
        }
    }

    // 示例用法
    public static void main(String[] args) {
        // 实际应用中，em 会通过依赖注入等方式获取
        // 这里仅为示例，创建一个模拟的EntityManager
        EntityManager mockEm = createMockEntityManager(); 
        NativeQueryTypeDetection detector = new NativeQueryTypeDetection(mockEm);

        // 假设有一个查询，返回字符串、整数和日期
        String query1 = "SELECT name, age, birth_date FROM users";
        detector.processNativeQueryResult(query1);

        // 假设有一个查询，返回单个列
        String query2 = "SELECT description FROM products";
        detector.processNativeQueryResult(query2);
    }

    // 模拟 EntityManager，实际应用中会是真实的JPA EntityManager
    private static EntityManager createMockEntityManager() {
        // 实际应用中会使用JPA的EntityManagerFactory创建
        return new MockEntityManager();
    }
}

// 模拟的EntityManager和Query实现，用于演示getResultList()行为
class MockEntityManager implements EntityManager {
    // ... 其他方法省略 ...
    @Override
    public Query createNativeQuery(String sqlString) {
        return new MockQuery(sqlString);
    }
}

class MockQuery implements Query {
    private String sqlString;

    public MockQuery(String sqlString) {
        this.sqlString = sqlString;
    }

    @Override
    public List getResultList() {
        // 根据模拟的SQL返回不同的结果
        if (sqlString.contains("users")) {
            return List.of(
                new Object[]{"Alice", 30, new Date()},
                new Object[]{"Bob", 25, new Date(System.currentTimeMillis() - 86400000L)}
            );
        } else if (sqlString.contains("products")) {
            // 模拟单列查询返回 List<Object>
            return List.of("Laptop Description", "Mouse Description");
        }
        return List.of();
    }
    // ... 其他方法省略 ...
}