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

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

public class NativeQueryResultTypeHandler {

    private EntityManager em; // 假设em已通过依赖注入或工厂方法获取

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

    /**
     * 执行原生SQL查询并动态处理结果类型
     * @param sqlQuery 待执行的原生SQL语句
     */
    public void processDynamicNativeQuery(String sqlQuery) {
        // 执行原生查询，返回List<Object[]>
        List<Object[]> results = em.createNativeQuery(sqlQuery).getResultList();

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

        System.out.println("开始处理原生查询结果...");
        for (Object[] row : results) {
            System.out.print("行数据: [");
            for (int i = 0; i < row.length; i++) {
                Object columnValue = row[i];

                // 检查是否为null
                if (columnValue == null) {
                    System.out.print("列" + i + ": null (未知类型)");
                } else if (columnValue instanceof String) {
                    String value = (String) columnValue;
                    System.out.print("列" + i + ": 字符串 [" + value + "]");
                    // 可以在此处执行针对String类型的业务逻辑
                } else if (columnValue instanceof Number) {
                    // Number是所有数值类型的父类（Integer, Long, Double, BigDecimal等）
                    Number value = (Number) columnValue;
                    if (value instanceof Long) {
                        Long longValue = (Long) value;
                        System.out.print("列" + i + ": 长整型 [" + longValue + "]");
                    } else if (value instanceof Integer) {
                        Integer intValue = (Integer) value;
                        System.out.print("列" + i + ": 整型 [" + intValue + "]");
                    } else if (value instanceof Double) {
                        Double doubleValue = (Double) value;
                        System.out.print("列" + i + ": 双精度浮点型 [" + doubleValue + "]");
                    } else if (value instanceof BigDecimal) {
                        BigDecimal bigDecimalValue = (BigDecimal) value;
                        System.out.print("列" + i + ": BigDecimal [" + bigDecimalValue + "]");
                    } else {
                        System.out.print("列" + i + ": 其他数值型 [" + value + ", 类型: " + value.getClass().getName() + "]");
                    }
                    // 可以在此处执行针对Number类型的业务逻辑，例如统一转换为Long或BigDecimal
                    // Long longVal = value.longValue();
                } else if (columnValue instanceof Date) {
                    Date value = (Date) columnValue;
                    System.out.print("列" + i + ": 日期/时间 [" + value + "]");
                    // 可以在此处执行针对Date类型的业务逻辑
                } else if (columnValue instanceof Boolean) {
                    Boolean value = (Boolean) columnValue;
                    System.out.print("列" + i + ": 布尔型 [" + value + "]");
                    // 可以在此处执行针对Boolean类型的业务逻辑
                } else {
                    // 处理其他未知类型
                    System.out.print("列" + i + ": 未知类型 [" + columnValue + ", 类型: " + columnValue.getClass().getName() + "]");
                }

                if (i < row.length - 1) {
                    System.out.print(", ");
                }
            }
            System.out.println("]");
        }
        System.out.println("原生查询结果处理完成。");
    }

    // 示例用法（需要配置Hibernate和数据库连接）
    public static void main(String[] args) {
        // 实际应用中，em需要通过JPA或Spring等方式获取
        // 例如：EntityManagerFactory emf = Persistence.createEntityManagerFactory("your-persistence-unit");
        // EntityManager em = emf.createEntityManager();
        // NativeQueryResultTypeHandler handler = new NativeQueryResultTypeHandler(em);

        // 假设em已初始化
        // handler.processDynamicNativeQuery("SELECT id, name, age, salary, create_date FROM users WHERE status = 1");
        // handler.processDynamicNativeQuery("SELECT count(*) FROM products");

        // em.close();
        // emf.close();
    }
}

// ... (同上导入和类结构)

    /**
     * 执行原生SQL查询并动态处理单列结果类型
     * @param sqlQuery 待执行的原生SQL语句
     */
    public void processSingleColumnNativeQuery(String sqlQuery) {
        // 执行原生查询，返回List<Object>
        List<Object> results = em.createNativeQuery(sqlQuery).getResultList();

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

        System.out.println("开始处理单列原生查询结果...");
        for (Object columnValue : results) {
            // 检查是否为null
            if (columnValue == null) {
                System.out.println("结果: null (未知类型)");
            } else if (columnValue instanceof String) {
                String value = (String) columnValue;
                System.out.println("结果: 字符串 [" + value + "]");
            } else if (columnValue instanceof Number) {
                Number value = (Number) columnValue;
                System.out.println("结果: 数值型 [" + value + ", 类型: " + value.getClass().getName() + "]");
            } else if (columnValue instanceof Date) {
                Date value = (Date) columnValue;
                System.out.println("结果: 日期/时间 [" + value + "]");
            } else {
                System.out.println("结果: 未知类型 [" + columnValue + ", 类型: " + columnValue.getClass().getName() + "]");
            }
        }
        System.out.println("单列原生查询结果处理完成。");
    }