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

[jOOQ/jOOQ#9864] Fix Derby ON DUPLICATE KEY / ON CONFLICT

Browse Source
This commit is contained in:
Lukas Eder 2021-11-03 17:35:51 +01:00
parent 167ba3c705
commit 516e87556c
1 changed files with 3 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/impl/InsertQueryImpl.java
View File

@ -100,6 +100,7 @@ import java.util.List;
import java.util.Map;
import java.util.Map.Entry;
import java.util.Set;
import java.util.stream.Collectors;
import org.jooq.Clause;
import org.jooq.Condition;
@ -837,7 +838,7 @@ final class InsertQueryImpl<R extends Record> extends AbstractStoreQuery<R> impl
|| !table().getKeys().isEmpty()) {
Table<?> t = null;
Collection<Field<?>> k = insertMaps.keysFlattened(ctx);
Set<Field<?>> k = insertMaps.keysFlattened(ctx);
Collection<Field<?>> f = null;
if (!NO_SUPPORT_SUBQUERY_IN_MERGE_USING.contains(ctx.dialect())) {
@ -879,7 +880,7 @@ final class InsertQueryImpl<R extends Record> extends AbstractStoreQuery<R> impl
return t != null
? notMatched.whenNotMatchedThenInsert(f).values(t.fields())
: notMatched.whenNotMatchedThenInsert(k).values(insertMaps.lastMap().values());
: notMatched.whenNotMatchedThenInsert(k).values(insertMaps.lastMap().entrySet().stream().filter(e -> k.contains(e.getKey())).map(Entry::getValue).collect(toList()));
}
else
throw new IllegalStateException("The ON DUPLICATE KEY IGNORE/UPDATE clause cannot be emulated when inserting into non-updatable tables : " + table());