I'm working with JOOQ 3.4.1 and don't see any direct support for making a
lazy Java 8 Stream from JOOQ's Cursor. Is such a thing planned or am I
missing something already provided? For reference, this is my current
solution which works for me:
public class JooqResultSpliterator<R extends Record> extends
AbstractSpliterator<R>
{
private final Cursor<R> cursor;
public JooqResultSpliterator(ResultQuery<R> q) {
super(Long.MAX_VALUE, NONNULL | ORDERED);
this.cursor = q.fetchSize(50).fetchLazy();
}
@Override public boolean tryAdvance(Consumer<? super R> action) {
final R r = cursor.fetchOne();
if (r == null) return false;
action.accept(r);
return true;
}
@Override public void forEachRemaining(Consumer<? super R> action) {
cursor.fetchInto(action::accept);
}
public static <R extends Record> Stream<R> jooqStream(ResultQuery<R> q) {
final JooqResultSpliterator<R> s = new JooqResultSpliterator<>(q);
return StreamSupport.stream(s, false).onClose(s.cursor::close);
}
}
The nice thing about Streams is that the above can be used without further
ado to parallelize the result set processing. In actual projects I do
provide my own splitting logic, but that's a relatively minor detail.
Marko
--
You received this message because you are subscribed to the Google Groups "jOOQ
User Group" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to [email protected].
For more options, visit https://groups.google.com/d/optout.
