1. 百万级数据查询为什么会把 JVM 撑爆MySQL 与 Oracle 的 JDBC 行为差异先说结论同样一句SELECT * FROM big_table在 MySQL 和 Oracle 上走 JDBC默认行为完全不是一回事。MySQL 默认会把整个结果集一次性拉到客户端内存里Oracle 默认走的是服务端游标分批拉取。这个差异在几万行数据时看不出来一旦上到百万级MySQL 那边大概率直接java.lang.OutOfMemoryError: Java heap space而 Oracle 那边可能只是慢但不会立刻炸。我试过在一张 500 万行的 MySQL 表上跑最朴素的executeQuery()堆内存给了 512MB结果连while(resultSet.next())都没进去就 OOM 了。原因很直接MySQL Connector/J 在默认配置下executeQuery()会阻塞到服务端把所有行都推回来这些行全部堆在客户端内存里。你还没开始处理内存已经满了。Oracle 这边情况不同。Oracle JDBC 驱动默认使用服务端游标客户端每次只拉一批默认大约 10 行起步后续会动态调整所以即使 3000 万行的表只要你不把结果集往 List 里塞单纯遍历计数内存曲线是平的。但 Oracle 也有坑如果你不显式设置setFetchSize()驱动会自己决定每次拉多少抓包能看到前几次每次 10 条后面突然变成大批量返回网络抖动和内存峰值都不可控。所以这篇要解决的核心问题是Java 通过 JDBC 对 MySQL 和 Oracle 做百万级数据查询时怎么配置才能让流式读取真正生效而不是假流式。适合谁看正在做数据迁移、报表导出、离线批处理或者被 OOM 折腾过的后端开发。下面给出两套可直接复制的连接参数和查询代码再用 TaoToken 统一 Key 接入模型辅助生成对比脚本最后用内存占用和耗时日志验证流式是否真的生效。需要提前说明流式读取不等于快。它解决的是内存问题不是速度问题。MySQL 的流式查询在服务端推送模式下如果客户端处理太慢TCP 窗口会打满服务端会等Oracle 的游标拉取模式则是客户端主动要数据节奏由客户端控制。理解这个区别后面的参数配置才不会配错。2. TaoToken 统一 Key 接入用一套凭证管理模型调用与脚本生成在写对比脚本之前先解决一个实际问题MySQL 和 Oracle 两套环境、两套驱动、两套参数手写测试代码容易漏掉关键配置。我的做法是用模型辅助生成骨架代码然后自己改参数。这里用 TaoToken 的统一 Key 来接入好处是一个 Key 走 API 通道不用在多个平台之间切换凭证。TaoToken 的定位是模型 API 聚合通道官网地址是 https://taotoken.net/?utm_sourcetaotoken_aicg_blog_endutm_mediumcsdnutm_campaignrewriteutm_content API 入口是 https://taotoken.net/api 。注意 API 地址不带 UTM 参数直接写https://taotoken.net/api就行。接入分三步拿 Key、配 Base URL、选 Model ID。这三件套缺一不可后面在 Cline 或 Claude Code 里配置时也是同样的逻辑。第一步打开控制台创建 API Key。地址是 https://taotoken.net/console?utm_sourcetaotoken_aicg_blog_endutm_contentconsole_keyutm_campaignrewrite 在 API Keys 页面生成一个 Key复制保存。这个 Key 就是统一凭证后面所有模型调用都用它。第二步确认 Base URL。TaoToken 的 API 根地址是https://taotoken.net/api在 OpenAI 兼容的客户端里Base URL 填这个不要在后面加/v1之外的路径具体看客户端要求。如果是 Claude Code 这类走 Anthropic 协议的用对应的 deep link 入口 https://taotoken.net/doc?utm_sourcetaotoken_aicg_blog_endutm_contentdoc_anthropicutm_campaignrewrite 查看协议配置说明。第三步选 Model ID。在模型对话页面 https://taotoken.net/models?utm_sourcetaotoken_aicg_blog_endutm_contentmodels_chatutm_campaignrewrite 可以看到当前可用的模型列表选一个适合代码生成的。我一般用中等规模的模型生成 JDBC 骨架够用且响应快。配置示例以 OpenAI 兼容的 Python 客户端为例from openai import OpenAI client OpenAI( api_key你的TaoToken Key, base_urlhttps://taotoken.net/api ) resp client.chat.completions.create( model你选的Model ID, messages[ {role: user, content: 生成一段Java JDBC流式查询MySQL的代码要求setFetchSize(Integer.MIN_VALUE)} ] ) print(resp.choices[0].message.content)如果你用的是 Cline 或 Claude Code 这类编码 Agent配置里同样填三件套Base URL 填https://taotoken.net/apiAPI Key 填刚才生成的Model ID 填模型列表里的标识。Cline 的 MCP 配置里如果涉及模型调用也是这套参数。Codex 的auth.json里则是base_url和api_key两个字段对应。这里要提醒一点TaoToken 是模型调用通道不是数据库连接工具。它帮你生成和对比脚本但真正连 MySQL 和 Oracle 的还是 JDBC 驱动。两者不要混在一起理解。拿到 Key 之后让模型生成两段代码一段 MySQL 流式查询一段 Oracle 游标查询。生成结果不要直接用重点检查三个地方MySQL 是否设置了setFetchSize(Integer.MIN_VALUE)或useCursorFetchtrueOracle 是否显式设置了setFetchSize()以及连接是否在 finally 里关闭。这三处是流式生效的关键。3. 可复制的 JDBC 配置MySQL 流式结果集与 Oracle 游标复用参数这一节给出两套完整可复制的配置。先说 MySQL再说 Oracle最后给一个统一的测试主类结构。3.1 MySQL 流式查询配置MySQL 有两种流式方式行为不同别搞混。方式一服务端推送模式。连接串不需要额外参数但Statement必须设置setFetchSize(Integer.MIN_VALUE)。这个值是 MySQL Connector/J 的特殊约定表示逐行流式读取。String url jdbc:mysql://127.0.0.1:3306/kfc?useSSLfalseuseUnicodetruecharacterEncodingutf8; try (Connection conn DriverManager.getConnection(url, root, admin); PreparedStatement ps conn.prepareStatement(SELECT * FROM bigdata)) { ps.setFetchSize(Integer.MIN_VALUE); try (ResultSet rs ps.executeQuery()) { int count 0; while (rs.next()) { count; } System.out.println(count count); } }方式二游标拉取模式。连接串加useCursorFetchtrue然后setFetchSize(n)指定每次拉取条数。这种方式客户端主动拉节奏可控。String url jdbc:mysql://127.0.0.1:3306/kfc?useSSLfalseuseCursorFetchtrue; try (Connection conn DriverManager.getConnection(url, root, admin); PreparedStatement ps conn.prepareStatement(SELECT * FROM bigdata)) { ps.setFetchSize(500); try (ResultSet rs ps.executeQuery()) { int count 0; while (rs.next()) { count; } System.out.println(count count); } }两种方式的区别推送模式下服务端不停发客户端处理慢会导致 TCP Window Full拉取模式下客户端每次要一批服务端把结果写到临时区域供查询首次executeQuery()可能卡顿因为要准备临时数据。3.2 Oracle 游标查询配置Oracle 只有游标拉取一种模式关键是显式设置setFetchSize()。不设置的话驱动会自己调整前几次 10 条后面突然变大内存峰值不可控。String url jdbc:oracle:thin://192.168.88.61:1521/orcl; try (Connection conn DriverManager.getConnection(url, xxx, oracle); PreparedStatement ps conn.prepareStatement(SELECT * FROM test1)) { ps.setFetchSize(1000); try (ResultSet rs ps.executeQuery()) { int count 0; while (rs.next()) { count; } System.out.println(count count); } }Oracle 的setFetchSize建议值1000 到 5000 之间。太小网络往返多太大内存峰值高。实测 1000 在 3000 万行表上内存平稳耗时也可接受。3.3 统一测试主类结构把两段逻辑放在一个类里用参数区分数据库类型方便对比。public class BigQueryTest { public static void main(String[] args) throws Exception { String dbType args[0]; // mysql 或 oracle long start System.currentTimeMillis(); int count 0; if (mysql.equalsIgnoreCase(dbType)) { String url jdbc:mysql://127.0.0.1:3306/kfc?useSSLfalseuseCursorFetchtrue; try (Connection conn DriverManager.getConnection(url, root, admin); PreparedStatement ps conn.prepareStatement(SELECT * FROM bigdata)) { ps.setFetchSize(500); try (ResultSet rs ps.executeQuery()) { while (rs.next()) { count; } } } } else { String url jdbc:oracle:thin://192.168.88.61:1521/orcl; try (Connection conn DriverManager.getConnection(url, xxx, oracle); PreparedStatement ps conn.prepareStatement(SELECT * FROM test1)) { ps.setFetchSize(1000); try (ResultSet rs ps.executeQuery()) { while (rs.next()) { count; } } } } long cost System.currentTimeMillis() - start; System.out.println(db dbType count count cost cost ms); } }依赖方面MySQL 用mysql-connector-java 8.0.23Oracle 用ojdbc8 23.8.0.25.04JDK 1.8 即可。这两个驱动版本在流式行为上比较稳定。配置要点对照表数据库流式方式连接串参数Statement 设置内存表现MySQL服务端推送无特殊参数setFetchSize(Integer.MIN_VALUE)平稳但受 TCP 窗口影响MySQL游标拉取useCursorFetchtruesetFetchSize(n)平稳首次可能卡顿Oracle游标拉取无特殊参数setFetchSize(n)平稳n 建议 1000注意MySQL 的useCursorFetchtrue需要服务端支持MySQL 5.0 以上都支持。如果连接串里同时写了useCursorFetchtrue和setFetchSize(Integer.MIN_VALUE)以游标模式为准Integer.MIN_VALUE会被忽略。4. 验证流式是否真正生效内存占用与耗时日志实测配置写完不代表流式生效。很多人以为设了setFetchSize就是流式结果还是 OOM。这一节给出验证方法。4.1 内存监控在while循环里每处理 10 万行打印一次堆内存使用Runtime rt Runtime.getRuntime(); int count 0; while (rs.next()) { count; if (count % 100000 0) { long used (rt.totalMemory() - rt.freeMemory()) / 1024 / 1024; System.out.println(rows count heapUsedMB used); } }如果流式生效heapUsedMB会在一个区间内波动不会持续上涨。如果没生效这个值会一路涨到 OOM。4.2 耗时日志在executeQuery()前后打时间戳long t1 System.currentTimeMillis(); ResultSet rs ps.executeQuery(); long t2 System.currentTimeMillis(); System.out.println(executeQuery cost (t2 - t1) ms);MySQL 推送模式下executeQuery()几乎立即返回耗时很短。MySQL 游标模式下executeQuery()可能卡顿因为服务端要准备临时数据。Oracle 游标模式下executeQuery()也很快返回数据在next()时逐批拉取。4.3 实测结果在 500 万行 MySQL 表上堆内存 512MB普通查询executeQuery()阻塞约 40 秒后 OOM。推送流式executeQuery()返回小于 100ms遍历耗时约 35 秒堆内存峰值约 180MB。游标流式fetchSize500executeQuery()卡顿约 8 秒遍历耗时约 42 秒堆内存峰值约 120MB。在 3000 万行 Oracle 表上不设 fetchSize遍历耗时约 6 分钟堆内存峰值约 400MB网络包大小不稳定。fetchSize1000遍历耗时约 4 分 30 秒堆内存峰值约 150MB网络包稳定在每次 1000 行。这些数字不是绝对值跟机器和网络有关但趋势一致流式生效后内存平稳耗时可接受。4.4 用 TaoToken 生成对比脚本如果不想手写两套代码可以用 TaoToken 的模型对话生成一个对比脚本模板然后改连接参数。入口是 https://taotoken.net/models?utm_sourcetaotoken_aicg_blog_endutm_contentmodels_compareutm_campaignrewrite 。提示词可以这样写生成一个Java类包含两个方法queryMySQL和queryOracle。 MySQL方法使用useCursorFetchtrue和setFetchSize(500)。 Oracle方法使用setFetchSize(1000)。 两个方法都统计行数、耗时、堆内存峰值。 用try-with-resources关闭连接。生成后重点检查setFetchSize是否在executeQuery()之前调用以及连接串参数是否拼写正确。这两处错了流式就不生效。提示验证流式是否生效最直接的方法是看executeQuery()的返回时间。如果它阻塞很久才返回说明数据在executeQuery()阶段就被拉回来了流式没生效。5. 常见报错排查401、local proxy failed、reading choices、OAuth 与 JDBC 连接问题这一节对照真实报错分两类TaoToken 接入类报错和 JDBC 查询类报错。5.1 TaoToken 接入类报错401 UnauthorizedKey 不对或没带。检查api_key是否填了完整 KeyBase URL 是否是https://taotoken.net/api。如果用的是环境变量确认变量名和代码里读的一致。local proxy failed本地代理配置问题。如果你在客户端里配了代理但代理没启动或端口不对会报这个。检查客户端的代理设置或者临时关掉代理直连。注意这里说的是客户端自身的网络配置不是让你去搞什么网络工具。reading choices 报错通常是响应体解析失败。原因可能是 Model ID 填错或者 Base URL 多了/v1导致路径拼接错误。检查 Model ID 是否在模型列表里存在Base URL 是否只填到https://taotoken.net/api。OAuth 相关报错Claude Code 这类走 Anthropic 协议的客户端如果 OAuth 流程没走完会报认证失败。用 deep link https://taotoken.net/doc?utm_sourcetaotoken_aicg_blog_endutm_contentdoc_oauthutm_campaignrewrite 查看协议配置确认是走 API Key 还是 OAuth。TaoToken 的 API 通道用 Key 即可不需要额外 OAuth。5.2 JDBC 查询类报错MySQL 设了 fetchSize 还是 OOM检查setFetchSize是否在executeQuery()之前调用。如果写在之后无效。另外确认连接串没有useCursorFetchtrue和Integer.MIN_VALUE混用。Oracle 报 ORA-01000 游标超限setFetchSize太大或连接没关。确保用 try-with-resources每个查询独立连接。Oracle 默认游标数有限连接泄漏会累积。MySQL 游标模式 executeQuery 卡顿这是正常现象服务端在准备临时数据。如果卡顿超过 30 秒考虑减小setFetchSize或改用推送模式。TCP Window FullMySQL 推送模式下客户端处理太慢服务端发不出去。解决办法是加快while循环里的处理逻辑或者改用游标模式让客户端控制节奏。ResultSet 关闭后连接未释放确保ResultSet、Statement、Connection都在 try-with-resources 里或者 finally 里按顺序关闭。顺序是 ResultSet - Statement - Connection。排查清单报错可能原因处理401Key 错误或缺失检查 api_key 和 Base URLlocal proxy failed客户端代理配置错误检查代理设置或直连reading choicesModel ID 或路径错误核对 Model ID 和 Base URLOOMfetchSize 未生效确认 setFetchSize 在 executeQuery 前ORA-01000游标泄漏用 try-with-resources 关闭连接TCP Window Full客户端处理慢加快处理或改游标模式注意JDBC 连接串里的参数拼写必须完全正确。useCursorFetch写成useCursorFetchs不会报错但流式不生效这种拼写错误最难查。6. 把流式查询接入日常开发从脚本到 Coding Plan 的落地建议流式查询验证通过后下一步是把它用到实际项目里。这里给几个落地建议。第一把连接参数抽到配置文件里不要硬编码。MySQL 和 Oracle 的连接串、fetchSize 值、驱动类名都放配置切换环境时不用改代码。第二在批处理任务里加内存监控。每处理 N 行打一次堆内存超过阈值告警。这样能在 OOM 之前发现问题。第三MySQL 优先用游标模式useCursorFetchtruesetFetchSize因为节奏可控不会因为客户端处理慢导致 TCP 窗口打满。Oracle 必须显式设setFetchSize建议 1000 起步。第四如果项目里有多套数据库要对比测试可以用 TaoToken 的 Coding Plan 来管理模型调用。入口是 https://taotoken.net/coding-plan?utm_sourcetaotoken_aicg_blog_endutm_contentcoding_planutm_campaignrewrite 。长期做数据迁移或 Agent 类任务的话统一 Key 能省去多平台切换的麻烦。第五验证流式是否生效不要只看代码要看日志。executeQuery()的耗时、堆内存曲线、网络包大小这三个指标能说明一切。最后说一个实际踩过的坑MySQL 的setFetchSize(Integer.MIN_VALUE)在连接池环境下可能失效。因为连接池会复用连接如果上一个查询没把 ResultSet 读完就归还连接下一个查询可能拿到一个状态不对的连接。解决办法是确保每个流式查询都把 ResultSet 读完再关闭或者用独立的连接不用连接池。流式读取的本质是控制数据从服务端到客户端的流动节奏。MySQL 默认是服务端推Oracle 默认是客户端拉。理解这个差异参数就不会配错。验证方法也很简单看executeQuery()返回快不快看堆内存涨不涨。两个都正常流式就生效了。