File tree Expand file tree Collapse file tree 1 file changed +9
-0
lines changed
model-server/src/main/kotlin/org/modelix/model/server/store Expand file tree Collapse file tree 1 file changed +9
-0
lines changed Original file line number Diff line number Diff line change @@ -17,6 +17,14 @@ package org.modelix.model.server.store
17
17
import org.apache.ignite.cache.store.jdbc.dialect.BasicJdbcDialect
18
18
import org.apache.ignite.internal.util.typedef.F
19
19
20
+ /* *
21
+ * Ignite dialect for PostgreSQL
22
+ *
23
+ * Ignite doesn't have an SQL dialect implementation for PostgreSQL.
24
+ * Implementing and using this one enables bulk updates/inserts (upserts).
25
+ *
26
+ * Originally added in https://github.com/modelix/modelix/commit/eee51caddd9f470307febaa01e2820266ddfc6c9
27
+ */
20
28
class PostgresDialect : BasicJdbcDialect () {
21
29
override fun hasMerge (): Boolean {
22
30
return true
@@ -27,6 +35,7 @@ class PostgresDialect : BasicJdbcDialect() {
27
35
keyCols : Collection <String >,
28
36
uniqCols : Collection <String >,
29
37
): String {
38
+ // Copied over from org.apache.ignite.cache.store.jdbc.dialect.MySQLDialect.mergeQuery
30
39
val cols = F .concat(false , keyCols, uniqCols)
31
40
val updPart = mkString(
32
41
uniqCols,
You can’t perform that action at this time.
0 commit comments