Java 中怎么在 JDBC 中使用流式查询处理百万级数据-java教程-PHP中文网

java中jdbc流式查询处理百万级数据的核心是边取边处理、不缓存全量结果；需设fetchsize=integer.min_value、关自动提交、用游标分页、严格管理资源生命周期，并搭配流式文件写入与异步化导出。

java 中怎么在 jdbc 中使用流式查询处理百万级数据

Java 中用 JDBC 流式查询处理百万级数据，核心是避免一次性把全部结果加载进内存，而是边取边处理。关键不在“查得多”，而在“不存全量”。

启用流式结果集（MySQL 为例）

MySQL 的 JDBC 驱动默认会将整个结果集缓存在客户端内存中。必须显式配置 Statement 或 PreparedStatement 才能启用流式读取：

设置 fetchSize = Integer.MIN_VALUE（MySQL 特定语义，表示流式）
关闭自动提交（connection.setAutoCommit(false)），防止驱动内部做额外缓冲
确保使用 executeQuery() 而非批量操作

示例代码片段：

Connection conn = dataSource.getConnection();
Statement stmt = conn.createStatement();
// 关键：触发流式读取
stmt.setFetchSize(Integer.MIN_VALUE);
ResultSet rs = stmt.executeQuery("SELECT id, name, amount FROM orders WHERE status = 'done'");
while (rs.next()) {
  // 每次只从网络/数据库拉一行，不缓存整表
  long id = rs.getLong("id");
  String name = rs.getString("name");
  // → 直接写入文件、发消息、聚合统计等
}