Snowflake存储过程在Web UI可正常返回结果，但通过JDBC调用时提示无结果集的问题排查与解决咨询

我来帮你排查这个问题——你遇到的情况确实和Snowflake存储过程通过JDBC返回结果集的机制有关，咱们从几个关键方向入手分析解决：

一、先确认Python存储过程的返回值结构是否符合要求 #

Snowflake的Python存储过程返回TABLE类型时，Web UI会自动适配解析，但JDBC对返回结果的结构要求更严格。你的存储过程定义了返回三列的表，必须确保Python handler函数返回的结果是结构化的、与定义的表 schema 完全匹配的数据：

正确的Python Handler示例 #

如果你的main函数没有用Snowpark构造DataFrame，或者返回的不是符合列顺序的结构化数据，JDBC可能无法识别结果集。比如应该这样返回：

def main(session):
    # 你的业务逻辑处理（调用processor.py、analyzer.py等）
    # 构造与RETURNS TABLE完全匹配的结果
    result_rows = [
        (True, False, "检测完成，未触发限制"),
        (False, True, "已超出阈值限制")
    ]
    # 使用Snowpark Session构造对应schema的DataFrame返回
    return session.create_dataframe(
        result_rows,
        schema=["FLAG_A", "LIMIT_EXCEEDED", "MESSAGE"]
    )

如果你的handler返回的是普通列表、字典或者非结构化的JSON，JDBC无法映射成表结果集，就会出现“无结果集”的错误。

二、调整JDBC会话参数与调用逻辑 #

你的Java代码里已经设置了JDBC_QUERY_RESULT_FORMAT='JSON'，但还可以补充几个关键参数，同时优化调用逻辑：

1. 升级Snowflake JDBC驱动版本 #

旧版本的JDBC驱动可能对Python存储过程返回TABLE的支持不完善，建议升级到最新稳定版本（比如3.14.x及以上）。如果用Maven，依赖配置如下：

<dependency>
    <groupId>net.snowflake</groupId>
    <artifactId>snowflake-jdbc</artifactId>
    <version>3.14.4</version>
</dependency>

2. 补充关键会话参数 #

在创建Statement后，添加几个参数确保结果集能正确返回：

try (Statement stmt = conn.createStatement()) {
    stmt.execute("ALTER SESSION SET JDBC_QUERY_RESULT_FORMAT='JSON'");
    stmt.execute("ALTER SESSION SET USE_CACHED_RESULT = FALSE"); // 禁用缓存，避免旧结果干扰
    stmt.execute("ALTER SESSION SET CLIENT_SESSION_KEEP_ALIVE = TRUE"); // 保持会话活跃
}

3. 优化ResultSet的处理逻辑 #

可以在读取结果前先检查结果集的元数据，确认是否有返回列，帮助排查问题：

try (PreparedStatement pstmt = conn.prepareStatement("SELECT * FROM TABLE(MY_DB.MY_SCHEMA.MY_PROCEDURE());")) {
    ResultSet rs = pstmt.executeQuery();
    ResultSetMetaData metaData = rs.getMetaData();
    int columnCount = metaData.getColumnCount();
    System.out.println("返回列数：" + columnCount); // 打印列数，确认结果集是否存在
    
    while (rs.next()) {
        ResultDTO dto = new ResultDTO();
        dto.setFlagA(rs.getBoolean("FLAG_A"));
        dto.setLimitExceeded(rs.getBoolean("LIMIT_EXCEEDED"));
        dto.setMessage(rs.getString("MESSAGE"));
        results.add(dto);
    }
}

如果打印的列数为0，说明存储过程确实没有返回符合要求的结果集，需要回到Python代码排查；如果列数正常但没有数据，可能是业务逻辑返回了空结果（但你说Web UI有结果，所以大概率是结构问题）。

三、权限与执行上下文检查 #

1. 确保JDBC连接的用户拥有调用该存储过程的权限，以及存储过程EXECUTE AS OWNER设置下，OWNER用户拥有访问业务逻辑中涉及的所有对象（比如@MY_DB.SCHEMA.UTILS里的文件、查询的表等）的权限。
2. 检查存储过程是否在执行过程中抛出了隐性异常——Web UI会显示异常信息，但JDBC可能只返回“无结果集”的错误。可以在Python代码中添加日志或者异常捕获，比如：

import logging
logger = logging.getLogger("snowflake")
logger.setLevel(logging.INFO)

def main(session):
    try:
        # 你的业务逻辑
        ...
    except Exception as e:
        logger.error(f"存储过程执行异常：{str(e)}")
        raise e # 抛出异常，便于在JDBC中捕获

四、尝试Alternative调用方式 #

如果上述调整后还是有问题，可以尝试用CALL语句结合RESULT_SCAN来获取结果：

try (PreparedStatement pstmt = conn.prepareStatement("CALL MY_DB.MY_SCHEMA.MY_PROCEDURE();")) {
    boolean hasResult = pstmt.execute();
    if (hasResult) {
        ResultSet rs = pstmt.getResultSet();
        // 处理结果集逻辑
    }
}

不过这种方式只适用于存储过程通过CALL返回结果的场景，如果你定义的是RETURNS TABLE，还是推荐用SELECT * FROM TABLE(...)的方式。

按照以上步骤排查和调整，应该能解决JDBC调用时无结果集的问题。

内容来源于stack exchange