JOOQ DSL执行原生SQL查询无法获取数据的问题排查

一、JOOQ DSL执行原生SQL返回UPDATE_COUNT=0的原因及修复 #

你遇到的这个问题大概率是调用了错误的JOOQ执行方法：

• 如果使用DSLContext.execute(String sql)，该方法返回的是受影响的行数（UPDATE_COUNT），仅适用于DML语句（INSERT/UPDATE/DELETE），执行SELECT语句时自然会返回0（因为没有行被修改）。
• 要获取SELECT语句的结果集，应该使用DSLContext.fetch(String sql)（返回JOOQ的Result对象），或者DSLContext.fetchResultSet(String sql)（直接返回JDBC标准的ResultSet）。

示例代码：

// 错误用法：返回UPDATE_COUNT
int updateCount = dsl.execute("SELECT TABLE_CAT, TABLE_SCHEM, TABLE_NAME FROM information_schema.tables");

// 正确用法：获取结果集
Result<Record> result = dsl.fetch("SELECT NULL AS TABLE_CAT, table_schema AS TABLE_SCHEM, table_name AS TABLE_NAME FROM information_schema.tables WHERE table_schema = ?", "your_db");
// 或者直接获取JDBC ResultSet
ResultSet rs = dsl.fetchResultSet("SELECT NULL AS TABLE_CAT, table_schema AS TABLE_SCHEM, table_name AS TABLE_NAME FROM information_schema.tables WHERE table_schema = ?", "your_db");

注意：MySQL的information_schema.tables中没有TABLE_CAT字段（JDBC标准中该字段对应目录，MySQL不支持），所以需要用NULL AS TABLE_CAT来填充，否则会出现Unknown column label : TABLE_CAT的异常——这正是Hikari抛出错误的核心原因。

二、自定义Metadata类getTables方法的实现方案 #

Hibernate启动时调用的是JDBC标准Connection.getMetaData()返回的DatabaseMetaData对象的getTables方法，而非JOOQ的Meta接口。因此你需要：

1. 实现自定义DatabaseMetaData
   继承java.sql.DatabaseMetaData的基础实现，重点重写getTables方法：

public class CustomMySqlDatabaseMetaData extends DatabaseMetaDataWrapper {
    private final Connection connection;
    private final String databaseName;

    public CustomMySqlDatabaseMetaData(Connection connection, String databaseName) {
        super(connection.getMetaData());
        this.connection = connection;
        this.databaseName = databaseName;
    }

    @Override
    public ResultSet getTables(String catalog, String schemaPattern, String tableNamePattern, String[] types) throws SQLException {
        // 构造符合JDBC标准的查询SQL，必须包含所有要求的列
        String sql = "SELECT " +
            "NULL AS TABLE_CAT, " +
            "table_schema AS TABLE_SCHEM, " +
            "table_name AS TABLE_NAME, " +
            "table_type AS TABLE_TYPE, " +
            "NULL AS REMARKS, " +
            "NULL AS TYPE_CAT, " +
            "NULL AS TYPE_SCHEM, " +
            "NULL AS TYPE_NAME, " +
            "NULL AS SELF_REFERENCING_COL_NAME, " +
            "NULL AS REF_GENERATION " +
            "FROM information_schema.tables " +
            "WHERE table_schema LIKE ? " +
            "AND table_name LIKE ?";

        // 处理通配符，将JDBC的%/_转义为MySQL的通配符
        String schema = schemaPattern == null ? "%" : schemaPattern.replace("_", "\\_").replace("%", "\\%");
        String tableName = tableNamePattern == null ? "%" : tableNamePattern.replace("_", "\\_").replace("%", "\\%");

        try (PreparedStatement stmt = connection.prepareStatement(sql)) {
            stmt.setString(1, schema);
            stmt.setString(2, tableName);
            return stmt.executeQuery();
        }
    }
}

2. 在自定义Connection中返回自定义Metadata
   重写自定义Connection的getMetaData()方法，返回上面实现的CustomMySqlDatabaseMetaData：

public class CustomMySqlConnection extends ConnectionWrapper {
    private final String databaseName;
    private CustomMySqlDatabaseMetaData metaData;

    public CustomMySqlConnection(Connection delegate, String databaseName) {
        super(delegate);
        this.databaseName = databaseName;
    }

    @Override
    public DatabaseMetaData getMetaData() throws SQLException {
        if (metaData == null) {
            metaData = new CustomMySqlDatabaseMetaData(getDelegate(), databaseName);
        }
        return metaData;
    }
}

3. 确保JOOQ使用正确的连接与方言
   初始化JOOQ的DSLContext时，传入自定义的Connection和MySQL方言，确保JOOQ能正确解析元数据：

DSLContext dsl = DSL.using(customMySqlConnection, SQLDialect.MYSQL);

关键注意事项 #

• 必须严格遵循JDBC标准的DatabaseMetaData.getTables方法返回的ResultSet列定义，包括列名和顺序，Hibernate等ORM框架依赖这些标准列进行元数据校验。
• MySQL的information_schema中的字段名与JDBC标准不完全一致，需要通过别名映射（比如table_schema → TABLE_SCHEM，table_name → TABLE_NAME）。
• 避免在元数据查询中使用JOOQ的DSL API生成SQL，直接使用原生JDBC执行更可靠，因为JOOQ的元数据API是基于JDBC Metadata封装的，而你需要自定义底层实现。

内容的提问来源于stack exchange，提问作者Cristian López González