queryLazily() overload without fetchSize

Author: fluentfuture

mug-guava/src/.DS_Store

@@ -728,6 +728,34 @@ public <T> List<T> query(
     }
   }
 
+  /**
+   * Executes the encapsulated SQL as a query against {@code connection},
+   * and then fetches the results lazily in a stream.
+   *
+   * <p>The returned {@code Stream} includes results transformed by {@code rowMapper}.
+   * The caller must close it using try-with-resources idiom, which will close the associated
+   * {@link Statement} and {@link ResultSet}.
+   *
+   * <p>For example: <pre>{@code
+   * SafeSql sql = SafeSql.of("SELECT name FROM Users WHERE name LIKE '%{name}%'", name);
+   * try (Stream<String> names = sql.queryLazily(connection, row -> row.getLong("id"))) {
+   *   return names.findFirst();
+   * }
+   * }</pre>
+   *
+   * <p>Internally it delegates to {@link PreparedStatement#executeQuery} or {@link
+   * Statement#executeQuery} if this sql contains no JDBC binding parameters.
+   *
+   * @throws UncheckedSqlException wraps {@link SQLException} if failed
+   * @since 8.4
+   */
+  @MustBeClosed
+  @SuppressWarnings("MustBeClosedChecker")
+  public <T> Stream<T> queryLazily(
+      Connection connection, SqlFunction<? super ResultSet, ? extends T> rowMapper) {
+    return queryLazily(connection, 0, rowMapper);
+  }
+
   /**
    * Executes the encapsulated SQL as a query against {@code connection}, sets {@code fetchSize}
    * using {@link Statement#setFetchSize}, and then fetches the results lazily in a stream.

mug-guava/src/main/java/com/google/mu/safesql/SafeSql.java

@@ -334,7 +334,7 @@ private List<?> queryColumn(SafeSql sql, String column) throws Exception {
   }
 
   private List<?> queryColumnStream(SafeSql sql, String column) throws Exception {
-    try (Stream<?> stream = sql.queryLazily(connection(), 1, resultSet -> resultSet.getObject(column))) {
+    try (Stream<?> stream = sql.queryLazily(connection(), resultSet -> resultSet.getObject(column))) {
       return stream.collect(Collectors.toList());
     }
   }