精准获取Hibernate原生查询结果的列数据类型

import javax.persistence.EntityManager;
import javax.persistence.Query;
import java.math.BigDecimal; // For potential numeric types
import java.util.Date;       // For date/time types
import java.util.List;

public class NativeQueryResultTypeHandler {

    private EntityManager em; // 假设EntityManager已通过依赖注入或其他方式获取

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

    /**
     * 处理动态原生SQL查询的结果，并识别各列的Java数据类型。
     *
     * @param sqlQuery 要执行的原生SQL查询语句
     */
    public void processDynamicNativeQuery(String sqlQuery) {
        Query query = em.createNativeQuery(sqlQuery);
        List<Object[]> results = query.getResultList(); // 假设查询返回多列

        if (results == null || results.isEmpty()) {
            System.out.println("查询 '" + sqlQuery + "' 未返回任何结果。");
            return;
        }

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

                if (columnValue == null) {
                    System.out.print("null (类型: N/A)");
                } else if (columnValue instanceof String) {
                    String value = (String) columnValue;
                    System.out.print("'" + value + "' (类型: String)");
                    // 在这里可以执行针对String类型的操作
                } else if (columnValue instanceof Number) {
                    // Number是所有数值类型的父类 (Integer, Long, Double, BigDecimal等)
                    Number value = (Number) columnValue;
                    System.out.print(value + " (类型: Number - 具体类: " + value.getClass().getSimpleName() + ")");
                    // 可以进一步细化为具体的数值类型，例如：
                    // if (value instanceof Long) { Long longVal = (Long) value; /* ... */ }
                    // else if (value instanceof Integer) { Integer intVal = (Integer) value; /* ... */ }
                    // else if (value instanceof BigDecimal) { BigDecimal decimalVal = (BigDecimal) value; /* ... */ }
                } else if (columnValue instanceof Date) {
                    // 数据库的日期时间类型通常映射到 java.util.Date 或其子类 (如 java.sql.Timestamp)
                    Date value = (Date) columnValue;
                    System.out.print(value + " (类型: Date)");
                    // 在这里可以执行针对Date类型的操作
                } else if (columnValue instanceof Boolean) {
                    Boolean value = (Boolean) columnValue;
                    System.out.print(value + " (类型: Boolean)");
                    // 在这里可以执行针对Boolean类型的操作
                } else {
                    // 处理其他未知或不常见的类型
                    System.out.print(columnValue + " (类型: 未知 - " + columnValue.getClass().getName() + ")");
                }

                if (i < row.length - 1) {
                    System.out.print(", ");
                }
            }
            System.out.println("]");
        }

        // ---------------------------------------------------------------------
        // 针对单列查询结果的特殊处理 (List<Object>)
        // 如果确定查询只返回一列，可以直接转换为 List<Object>
        // 例如: String singleColumnSql = "SELECT user_name FROM users WHERE id = 1";
        // List<Object> singleColumnResults = em.createNativeQuery(singleColumnSql).getResultList();
        // if (singleColumnResults != null && !singleColumnResults.isEmpty()) {
        //     Object firstValue = singleColumnResults.get(0);
        //     if (firstValue instanceof String) {
        //         String name = (String) firstValue;
        //         System.out.println("单列查询结果 (用户姓名): " + name);
        //     }
        //     // 其他类型检查...
        // }
    }

    // 假设在实际应用中，EntityManager会被注入或通过其他方式获取
    public static void main(String[] args) {
        // 实际使用时，需要配置JPA环境并获取EntityManager实例
        // 例如，在Spring Boot应用中，EntityManager会被自动注入
        // EntityManagerFactory emf = Persistence.createEntityManagerFactory("yourPersistenceUnitName");
        // EntityManager entityManager = emf.createEntityManager();
        // NativeQueryResultTypeHandler handler = new NativeQueryResultTypeHandler(entityManager);

        // 模拟调用 (需要一个真实的EntityManager实例才能运行)
        // handler.processDynamicNativeQuery("SELECT id, name, age, registration_date, is_active FROM users");
        // handler.processDynamicNativeQuery("SELECT product_name, price, stock_quantity FROM products WHERE category = 'Electronics'");

        System.out.println("请替换为实际的EntityManager实例以运行示例。");
    }
}