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

[jOOQ/jOOQ#12864] OSS Edition H2 INSERT .. RETURNING no longer works if

Browse Source 
columns are qualified with a schema
This commit is contained in:
Lukas Eder 2022-01-14 13:22:52 +01:00
parent 8b49c63267
commit ac65a07db2
2 changed files with 14 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
jOOQ-examples/jOOQ-r2dbc-example/src/test/java/org/jooq/example/r2dbc/test/R2dbcTest.java
View File

@ -2,8 +2,12 @@ package org.jooq.example.r2dbc.test;
import static org.jooq.example.r2dbc.db.Tables.AUTHOR;
import static org.jooq.example.r2dbc.db.Tables.BOOK;
import static org.junit.Assert.assertEquals;
import java.util.List;
import org.jooq.DSLContext;
import org.jooq.Record3;
import org.jooq.RowCountQuery;
import org.jooq.Source;
import org.jooq.impl.DSL;
@ -42,6 +46,7 @@ public class R2dbcTest {
@Test
public void test() {
Record3<String, String, String> r =
Flux.from(ctx
.insertInto(AUTHOR)
.columns(AUTHOR.FIRST_NAME, AUTHOR.LAST_NAME)
@ -54,7 +59,10 @@ public class R2dbcTest {
.thenMany(ctx
.select(BOOK.author().FIRST_NAME, BOOK.author().LAST_NAME, BOOK.TITLE)
.from(BOOK))
.doOnNext(System.out::println)
.subscribe();
.blockFirst();
assertEquals("John", r.value1());
assertEquals("Doe", r.value2());
assertEquals("Fancy Book", r.value3());
}
}

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

@ -2178,8 +2178,8 @@ final class SelectQueryImpl<R extends Record> extends AbstractResultQuery<R> imp
if (TRUE.equals(context.data(BooleanDataKey.DATA_RENDERING_DATA_CHANGE_DELTA_TABLE)))
context.qualify(false);
context.declareFields(true);
@ -2195,10 +2195,8 @@ final class SelectQueryImpl<R extends Record> extends AbstractResultQuery<R> imp
else
context.visit(getSelectResolveUnsupportedAsterisks(context.configuration()));
if (TRUE.equals(context.data(BooleanDataKey.DATA_RENDERING_DATA_CHANGE_DELTA_TABLE)))
context.qualify(qualify);
context.declareFields(false)
.end(SELECT_SELECT);