处理Hibernate中动态数据库列：原生查询的策略

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

public class DynamicColumnService {

    private EntityManager entityManager; // 假设EntityManager已被注入或获取

    public DynamicColumnService(EntityManager entityManager) {
        this.entityManager = entityManager;
    }

    /**
     * 使用原生SQL查询获取指定表的所有列数据。
     *
     * @param tableName 要查询的表名。
     * @return 包含每行数据的列表，每行数据是一个Object数组。
     */
    public List<Object[]> fetchAllColumnsNative(String tableName) {
        // 构建原生SQL查询语句
        String sql = "SELECT * FROM " + tableName;

        // 创建原生查询
        Query query = entityManager.createNativeQuery(sql);

        // 执行查询并获取结果
        // 对于SELECT * 查询，通常返回List<Object[]>，
        // 其中每个Object[]代表一行数据，数组中的元素按列的顺序排列。
        List<Object[]> results = query.getResultList();

        // 打印结果示例（仅用于演示）
        System.out.println("Fetched data for table: " + tableName);
        for (Object[] row : results) {
            System.out.println(Arrays.toString(row));
        }

        return results;
    }
}

import javax.persistence.EntityManager;
import javax.persistence.Query;
import java.sql.Connection;
import java.sql.DatabaseMetaData;
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;
import org.hibernate.Session; // 获取JDBC Connection可能需要Hibernate Session

public class DynamicColumnProcessor {

    private EntityManager entityManager;

    public DynamicColumnProcessor(EntityManager entityManager) {
        this.entityManager = entityManager;
    }

    /**
     * 使用原生SQL查询获取指定表的所有列数据，并尝试将结果转换为Map。
     * 注意：此方法需要获取JDBC Connection以获取ResultSetMetaData，
     * 这在纯JPA环境中可能需要解包EntityManager到Hibernate Session。
     *
     * @param tableName 要查询的表名。
     * @return 包含每行数据的列表，每行数据是一个Map<String, Object>。
     * @throws SQLException 如果数据库操作失败。
     */
    public List<Map<String, Object>> fetchDynamicColumnsAsMap(String tableName) throws SQLException {
        List<Map<String, Object>> resultList = new ArrayList<>();
        Connection connection = null;

        try {
            // 从EntityManager获取底层的JDBC Connection
            // 这通常需要解包到Hibernate Session
            Session session = entityManager.unwrap(Session.class);
            connection = session.doReturningWork(conn -> conn); // 获取Connection

            String sql = "SELECT * FROM " + tableName;
            java.sql.Statement statement = connection.createStatement();
            ResultSet resultSet = statement.executeQuery(sql);
            ResultSetMetaData metaData = resultSet.getMetaData();
            int columnCount = metaData.getColumnCount();
            List<String> columnNames = new ArrayList<>();

            // 获取列名
            for (int i = 1; i <= columnCount; i++) {
                columnNames.add(metaData.getColumnLabel(i)); // 使用getColumnLabel获取别名或列名
            }

            // 处理结果集
            while (resultSet.next()) {
                Map<String, Object> rowMap = new HashMap<>();
                for (int i = 0; i < columnCount; i++) {
                    rowMap.put(columnNames.get(i), resultSet.getObject(i + 1));
                }
                resultList.add(rowMap);
            }

            resultSet.close();
            statement.close();

        } finally {
            // Connection由Hibernate管理，通常不需要手动关闭
            // 但如果手动获取，则需要关闭
        }
        return resultList;
    }
}