从EclipseLink迁移到Hibernate：如何识别原生查询结果列类型

实现方案 #

Hibernate中没有直接对应EclipseLink DatabaseField的API，但可以通过**标准JDBC的ResultSetMetaData**实现等价逻辑，以下是两种可行方案：

方案1：直接使用JDBC原生API（最贴合原逻辑） #

绕开Hibernate封装，直接操作JDBC连接与结果集元数据，和原EclipseLink代码逻辑对齐：

String table = /* 你的表变量 */;
String where = /* 你的查询条件 */;
String sentencia = "SELECT * FROM " + table + where;

Map<String, String> definiciones = new HashMap<>();

// 从Hibernate Session中获取JDBC连接
Session session = entityManager.unwrap(Session.class);
session.doWork(connection -> {
    try (PreparedStatement stmt = connection.prepareStatement(sentencia);
         ResultSet rs = stmt.executeQuery()) {

        ResultSetMetaData metaData = rs.getMetaData();
        int columnCount = metaData.getColumnCount();

        // 遍历列元数据，生成类型映射
        for (int i = 1; i <= columnCount; i++) {
            String nombreCol = metaData.getColumnName(i);
            int jdbcType = metaData.getColumnType(i);
            String type = define(jdbcType);
            definiciones.put(nombreCol, type);
        }
    } catch (SQLException e) {
        _log.error("获取列元数据失败", e);
    }
});

适配后的define方法（参数改为JDBC类型码）：

public String define(int jdbcType) {
    _log.debug("JDBC Type: " + JDBCType.valueOf(jdbcType));
    JDBCType type = JDBCType.valueOf(jdbcType);
    
    if (type == JDBCType.TIMESTAMP || type == JDBCType.TIME ||
        type == JDBCType.TIME_WITH_TIMEZONE || type == JDBCType.TIMESTAMP_WITH_TIMEZONE ||
        type == JDBCType.DATE) {
        return "F";
    } else if (type == JDBCType.NUMERIC || type == JDBCType.DECIMAL ||
               type == JDBCType.BIGINT || type == JDBCType.TINYINT ||
               type == JDBCType.SMALLINT || type == JDBCType.DOUBLE ||
               type == JDBCType.FLOAT) {
        return "N";
    } else if (type == JDBCType.VARCHAR || type == JDBCType.NVARCHAR ||
               type == JDBCType.CHAR || type == JDBCType.LONGVARCHAR) {
        return "S"; // 对应需求中"字符串类"标识，原代码返回"C"可按需调整
    } else {
        _log.error("未识别的列类型: " + jdbcType);
        return "?"; // 可自定义默认标识
    }
}

方案2：基于Hibernate NativeQuery封装 #

如果希望保留Hibernate的查询封装，可以通过NativeQuery的结果集消费者获取元数据：

String table = /* 你的表变量 */;
String where = /* 你的查询条件 */;
String sentencia = "SELECT * FROM " + table + where;

Map<String, String> definiciones = new HashMap<>();

Session session = entityManager.unwrap(Session.class);
NativeQuery<Object[]> nativeQuery = session.createNativeQuery(sentencia);

// 注册结果集处理器获取元数据
nativeQuery.unwrap(org.hibernate.query.NativeQuery.class)
           .setResultSetConsumer(resultSet -> {
               try {
                   ResultSetMetaData metaData = resultSet.getMetaData();
                   int columnCount = metaData.getColumnCount();
                   
                   for (int i = 1; i <= columnCount; i++) {
                       String nombreCol = metaData.getColumnName(i);
                       int jdbcType = metaData.getColumnType(i);
                       String type = define(jdbcType);
                       definiciones.put(nombreCol, type);
                   }
               } catch (SQLException e) {
                   _log.error("处理结果集元数据失败", e);
               }
           });

// 触发查询执行
nativeQuery.list();

关键说明 #

• 两种方案均依赖标准JDBC的ResultSetMetaData，兼容性强，不受ORM框架版本限制
• 注意原代码中字符串类型返回C，需求中对应标识为S，已在代码中统一，可根据实际需求调整
• 异常处理逻辑可结合业务场景优化，比如加入自定义告警或日志

内容的提问来源于stack exchange，提问作者ALEJANDRO HERNANDEZ