Mysql 流结果集和 jOOQ fetchLazy

Question

通常当我想使用 Mysql 查询大型结果集时，我会写这个（取自this answer）：

stmt = conn.createStatement(java.sql.ResultSet.TYPE_FORWARD_ONLY, java.sql.ResultSet.CONCUR_READ_ONLY);
stmt.setFetchSize(Integer.MIN_VALUE);

现在我正在使用jOOQ 2.0.5，但我无法获得相同的结果。

我尝试调用fetchLazy，但没有成功，它将整个结果集加载到内存中：

Cursor<Record> result = query.fetchLazy(Integer.MIN_VALUE);

作为一种解决方法，我可以使用query.getSQL() 获取sql 查询并创建一个合适的Statement 来执行它。

还有其他方法可以使用 jOOQ 获得流式结果集吗？

Answer 1

根据 JDBC 规范，Integer.MIN_VALUE 不是 Statement.setFetchSize() 方法的有效参数：

当此语句生成的 ResultSet 对象需要更多行时，向 JDBC 驱动程序提示应从数据库中获取的行数。如果指定的值为零，则忽略提示。默认值为零。

参数：

rows要获取的行数

投掷： SQLException - 如果发生数据库访问错误，则在关闭的 Statement 上调用此方法或不满足条件 rows >= 0。

对于负提取大小，实现可能会抛出 SQLException。因此，jOOQ 不接受小于 0 的参数。您应该尝试使用 1 的提取大小。同时，jOOQ 的下一个版本可能会打破 JDBC 标准，支持documented MySQL feature ：

https://github.com/jOOQ/jOOQ/issues/1263（在 jOOQ 2.2.0 中实现）