From f7bf0f14f3ac1090d8d05426217ac05fa7e19e5c Mon Sep 17 00:00:00 2001
From: lukaseder <lukas.eder@gmail.com>
Date: Fri, 10 Feb 2017 16:02:23 +0100
Subject: [PATCH] [#5361] Add ResultQuery.fetchStreamInto()

---
 jOOQ/src/main/java/org/jooq/ResultQuery.java  | 41 ++++++++++++++++++-
 .../org/jooq/impl/AbstractResultQuery.java    | 10 +++++
 .../main/java/org/jooq/impl/SelectImpl.java   | 10 +++++
 3 files changed, 60 insertions(+), 1 deletion(-)

diff --git a/jOOQ/src/main/java/org/jooq/ResultQuery.java b/jOOQ/src/main/java/org/jooq/ResultQuery.java
index 51ddf395fb..8a162a77ca 100644
--- a/jOOQ/src/main/java/org/jooq/ResultQuery.java
+++ b/jOOQ/src/main/java/org/jooq/ResultQuery.java
@@ -153,6 +153,45 @@ public interface ResultQuery<R extends Record> extends Query, Iterable<R> {
      */
     Stream<R> fetchStream() throws DataAccessException;
 
+    /**
+     * Stream this query, mapping records into a custom type.
+     * <p>
+     * This is the same as calling
+     * <code>fetchStream().map(r -> r.into(type))</code>. See
+     * {@link Record#into(Class)} for more details
+     *
+     * @param <E> The generic entity type.
+     * @param type The entity type.
+     * @see Record#into(Class)
+     * @see Result#into(Class)
+     * @see DefaultRecordMapper
+     * @return The results.
+     * @throws DataAccessException if something went wrong executing the query
+     * @throws MappingException wrapping any reflection or data type conversion
+     *             exception that might have occurred while mapping records
+     */
+    <E> Stream<E> fetchStreamInto(Class<? extends E> type) throws DataAccessException, MappingException;
+
+    /**
+     * Stream this query, mapping records into a custom record.
+     * <p>
+     * This is the same as calling
+     * <code>fetchStream().map(r -> r.into(table))</code>. See
+     * {@link Record#into(Table)} for more details
+     * <p>
+     * The result and its contained records are attached to the original
+     * {@link Configuration} by default. Use {@link Settings#isAttachRecords()}
+     * to override this behaviour.
+     *
+     * @param <Z> The generic table record type.
+     * @param table The table type.
+     * @return The results. This will never be <code>null</code>.
+     * @see Record#into(Table)
+     * @see Result#into(Table)
+     * @throws DataAccessException if something went wrong executing the query
+     */
+    <Z extends Record> Stream<Z> fetchStreamInto(Table<Z> table) throws DataAccessException;
+
     /**
      * Stream this query.
      * <p>
@@ -3023,11 +3062,11 @@ public interface ResultQuery<R extends Record> extends Query, Iterable<R> {
      * @param type The entity type.
      * @see Record#into(Class)
      * @see Result#into(Class)
+     * @see DefaultRecordMapper
      * @return The results. This will never be <code>null</code>.
      * @throws DataAccessException if something went wrong executing the query
      * @throws MappingException wrapping any reflection or data type conversion
      *             exception that might have occurred while mapping records
-     * @see DefaultRecordMapper
      */
     <E> List<E> fetchInto(Class<? extends E> type) throws DataAccessException, MappingException;
 
diff --git a/jOOQ/src/main/java/org/jooq/impl/AbstractResultQuery.java b/jOOQ/src/main/java/org/jooq/impl/AbstractResultQuery.java
index 707dbd8cc8..a822857b63 100644
--- a/jOOQ/src/main/java/org/jooq/impl/AbstractResultQuery.java
+++ b/jOOQ/src/main/java/org/jooq/impl/AbstractResultQuery.java
@@ -336,6 +336,16 @@ abstract class AbstractResultQuery<R extends Record> extends AbstractQuery imple
         return fetchLazy().stream();
     }
 
+    @Override
+    public final <E> Stream<E> fetchStreamInto(Class<? extends E> type) {
+        return fetchStream().map(r -> r.into(type));
+    }
+
+    @Override
+    public final <Z extends Record> Stream<Z> fetchStreamInto(Table<Z> table) {
+        return fetchStream().map(r -> r.into(table));
+    }
+
     @Override
     public final Stream<R> stream() {
         return fetchLazy().stream();
diff --git a/jOOQ/src/main/java/org/jooq/impl/SelectImpl.java b/jOOQ/src/main/java/org/jooq/impl/SelectImpl.java
index 1ebc322ca8..e105127c38 100644
--- a/jOOQ/src/main/java/org/jooq/impl/SelectImpl.java
+++ b/jOOQ/src/main/java/org/jooq/impl/SelectImpl.java
@@ -2718,6 +2718,16 @@ final class SelectImpl<R extends Record, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10
         return getDelegate().fetchStream();
     }
 
+    @Override
+    public final <E> Stream<E> fetchStreamInto(Class<? extends E> type) {
+        return getDelegate().fetchStreamInto(type);
+    }
+
+    @Override
+    public <Z extends Record> Stream<Z> fetchStreamInto(Table<Z> table) {
+        return getDelegate().fetchStreamInto(table);
+    }
+
     @Override
     public final Stream<R> stream() {
         return getDelegate().stream();