使用Snowflake JDBC驱动无法完整获取全部记录，与SQL Server结果集对比存在数据缺失问题

针对你遇到的Snowflake JDBC检索大结果集（超30万条）时丢失记录的问题，结合你的版本（Snowflake 5.33.1、JDBC 3.13.6）和代码实现，我整理了几个排查方向和可行的解决方案：

1. 调整JDBC的Fetch Size配置 #

Snowflake JDBC默认的fetch size通常较小（比如默认1000条），当处理超大结果集时，多次分批拉取数据的过程中可能出现丢包或中断。你可以显式设置更大的fetch size，减少网络交互次数：

// 创建Statement时设置fetch size
Statement snowStmt = snowConnection.createStatement();
snowStmt.setFetchSize(50000); // 根据服务器和本地内存情况调整，比如10000-100000之间
ResultSet SnowflakeSet = snowStmt.executeQuery(snowflakeQuery);

2. 升级Snowflake JDBC驱动版本 #

你当前使用的3.13.6版本比较老旧，旧版本驱动存在不少大结果集处理的已知bug，官方在后续版本中已经修复了类似问题。建议直接升级到最新的稳定版驱动（目前已更新到4.x系列），替换后再测试对比结果。

3. 校验ResultSet遍历逻辑的完整性 #

你的遍历代码看起来没问题，但要确保遍历过程中没有被异常打断，或者遗漏了计数。可以在循环中添加日志监控，追踪计数的变化，同时检查是否有未捕获的SQL警告：

while(SnowflakeSet.next()) {
  for (int columnCount = 1; columnCount <= numberOfColumns1; columnCount++) {
    snowFlakeal.add(SnowflakeSet.getString(columnCount));
  }
  countsnowfalkeVar++;
  // 每1万条记录打印一次，监控计数进度
  if(countsnowfalkeVar % 10000 == 0) {
      System.out.println("已处理Snowflake记录数：" + countsnowfalkeVar);
  }
}
// 检查JDBC是否抛出警告
SQLWarning warning = SnowflakeSet.getStatement().getWarnings();
while(warning != null) {
    System.err.println("JDBC警告：" + warning.getMessage());
    warning = warning.getNextWarning();
}

如果发现计数在某个点突然停止，大概率是遇到了未处理的异常，需要排查列读取时的类型转换问题（比如getString()读取非字符串类型是否有异常）。

4. 验证Snowflake端的查询结果一致性 #

先确认Snowflake本身的查询结果是否完整：在Snowflake Web UI或SnowSQL中执行相同的查询，用COUNT(*)获取总行数，比如：

SELECT COUNT(*) FROM (你的Snowflake查询语句);

如果这个结果和SQL Server的计数一致，但JDBC返回的数量少，那问题肯定出在驱动或代码层面；如果Snowflake端的计数本身就少，那需要排查数据同步或查询逻辑的问题。

5. 调整Snowflake会话参数 #

部分Snowflake会话参数可能影响结果集的返回，比如结果集缓存可能导致读取到旧的不完整数据。可以在建立JDBC连接时禁用结果缓存，确保每次查询都获取实时完整数据：

Properties props = new Properties();
props.put("user", "你的用户名");
props.put("password", "你的密码");
props.put("account", "你的账号");
// 添加会话参数，禁用结果缓存
props.put("sessionParameters", "RESULT_CACHE_MODE=OFF");
Connection snowConn = DriverManager.getConnection("jdbc:snowflake://你的账号.snowflakecomputing.com/", props);

内容的提问来源于stack exchange，提问作者Bhavani kandi