github/jooq
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

[#6145] Add Queries.block()

Browse Source
This commit is contained in:
lukaseder 2018-01-18 16:44:47 +01:00
parent 464b8c9548
commit c638df856b
2 changed files with 13 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
jOOQ/src/main/java/org/jooq/Queries.java
View File

@ -58,6 +58,11 @@ public interface Queries extends QueryPart, Attachable, Iterable<Query> {
*/
Query[] queries();
/**
* The wrapped collection of queries as a {@link Block}.
*/
Block block();
/**
* The wrapped collection of queries.

10
jOOQ/src/main/java/org/jooq/impl/QueriesImpl.java
View File

@ -43,6 +43,7 @@ import java.util.Collection;
import java.util.Iterator;
import java.util.stream.Stream;
import org.jooq.Block;
import org.jooq.Clause;
import org.jooq.Configuration;
import org.jooq.Context;
@ -80,6 +81,11 @@ final class QueriesImpl extends AbstractQueryPart implements Queries {
return queries.toArray(EMPTY_QUERY);
}
@Override
public final Block block() {
return configuration.dsl().begin(queries);
}
@SuppressWarnings({ "unchecked", "rawtypes" })
@Override
public final Iterator<Query> iterator() {
@ -106,7 +112,7 @@ final class QueriesImpl extends AbstractQueryPart implements Queries {
@Override
public final Results fetchMany() {
ResultsImpl results = new ResultsImpl(configuration());
DSLContext ctx = DSL.using(configuration());
DSLContext ctx = configuration().dsl();
for (Query query : this)
if (query instanceof ResultQuery)
@ -119,7 +125,7 @@ final class QueriesImpl extends AbstractQueryPart implements Queries {
@Override
public final int[] executeBatch() {
return DSL.using(configuration()).batch(this).execute();
return configuration().dsl().batch(this).execute();
}
// ------------------------------------------------------------------------