This is an automated email from the ASF dual-hosted git repository.
RocMarshal pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-jdbc.git
The following commit(s) were added to refs/heads/main by this push:
new 444707be [hotfix][JDBC] Fix db2 Db2Dialect error. (#199)
444707be is described below
commit 444707bece0095ff2c145d77b1196df0a36c21c7
Author: Yuepeng Pan <[email protected]>
AuthorDate: Tue Jun 23 00:08:32 2026 +0800
[hotfix][JDBC] Fix db2 Db2Dialect error. (#199)
Co-authored-by: andyphone <[email protected]>
---
.../apache/flink/connector/jdbc/db2/database/dialect/Db2Dialect.java | 2 +-
.../connector/jdbc/db2/database/dialect/Db2PreparedStatementTest.java | 3 ++-
2 files changed, 3 insertions(+), 2 deletions(-)
diff --git
a/flink-connector-jdbc-db2/src/main/java/org/apache/flink/connector/jdbc/db2/database/dialect/Db2Dialect.java
b/flink-connector-jdbc-db2/src/main/java/org/apache/flink/connector/jdbc/db2/database/dialect/Db2Dialect.java
index 68ba6b1b..2081376f 100644
---
a/flink-connector-jdbc-db2/src/main/java/org/apache/flink/connector/jdbc/db2/database/dialect/Db2Dialect.java
+++
b/flink-connector-jdbc-db2/src/main/java/org/apache/flink/connector/jdbc/db2/database/dialect/Db2Dialect.java
@@ -111,7 +111,7 @@ public class Db2Dialect extends AbstractDialect {
+ " WHEN MATCHED THEN"
+ " UPDATE SET %s"
+ " WHEN NOT MATCHED THEN"
- + " INSERT (%s) VALUES (%s);",
+ + " INSERT (%s) VALUES (%s)",
quoteIdentifier(tableName),
valuesBinding,
columnBinding,
diff --git
a/flink-connector-jdbc-db2/src/test/java/org/apache/flink/connector/jdbc/db2/database/dialect/Db2PreparedStatementTest.java
b/flink-connector-jdbc-db2/src/test/java/org/apache/flink/connector/jdbc/db2/database/dialect/Db2PreparedStatementTest.java
index 821ffe63..a14b7886 100644
---
a/flink-connector-jdbc-db2/src/test/java/org/apache/flink/connector/jdbc/db2/database/dialect/Db2PreparedStatementTest.java
+++
b/flink-connector-jdbc-db2/src/test/java/org/apache/flink/connector/jdbc/db2/database/dialect/Db2PreparedStatementTest.java
@@ -74,7 +74,8 @@ class Db2PreparedStatementTest {
String upsertStmt = dialect.getUpsertStatement(tableName, fieldNames,
keyFields).get();
assertThat(upsertStmt)
.isEqualTo(
- "MERGE INTO tbl AS TARGET USING TABLE (VALUES ( :id,
:name, :email, :ts, :field1, :field_2, :__field_3__ )) AS SOURCE ( id, name,
email, ts, field1, field_2, __field_3__ ) ON (TARGET.id= SOURCE.id AND
TARGET.__field_3__= SOURCE.__field_3__) WHEN MATCHED THEN UPDATE SET
TARGET.name= SOURCE.name, TARGET.email= SOURCE.email, TARGET.ts= SOURCE.ts,
TARGET.field1= SOURCE.field1, TARGET.field_2= SOURCE.field_2 WHEN NOT MATCHED
THEN INSERT (id, name, email, ts, field1, fi [...]
+ "MERGE INTO tbl AS TARGET USING TABLE (VALUES ( :id,
:name, :email, :ts, :field1, :field_2, :__field_3__ )) AS SOURCE ( id, name,
email, ts, field1, field_2, __field_3__ ) ON (TARGET.id= SOURCE.id AND
TARGET.__field_3__= SOURCE.__field_3__) WHEN MATCHED THEN UPDATE SET
TARGET.name= SOURCE.name, TARGET.email= SOURCE.email, TARGET.ts= SOURCE.ts,
TARGET.field1= SOURCE.field1, TARGET.field_2= SOURCE.field_2 WHEN NOT MATCHED
THEN INSERT (id, name, email, ts, field1, fi [...]
+ .doesNotEndWith(";");
}
@Test
