(seatunnel) branch dev updated: [Fix][Connector-V2] Fix oceanbase mysql jdbc sink create statement error (#9267)

[lidongdai]

This is an automated email from the ASF dual-hosted git repository.

lidongdai pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new 79f8125ea6 [Fix][Connector-V2] Fix oceanbase mysql jdbc sink create 
statement error (#9267)
79f8125ea6 is described below

commit 79f8125ea618b102a691b37572994a89b89d0ab4
Author: Jia Fan <fanjiaemi...@qq.com>
AuthorDate: Sat May 10 12:01:17 2025 +0800

    [Fix][Connector-V2] Fix oceanbase mysql jdbc sink create statement error 
(#9267)
---
 .../seatunnel/jdbc/internal/dialect/oceanbase/OceanBaseMysqlDialect.java | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/oceanbase/OceanBaseMysqlDialect.java
 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/oceanbase/OceanBaseMysqlDialect.java
index 0f9fe3ee40..c89bde6427 100644
--- 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/oceanbase/OceanBaseMysqlDialect.java
+++ 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/oceanbase/OceanBaseMysqlDialect.java
@@ -137,6 +137,7 @@ public class OceanBaseMysqlDialect implements JdbcDialect {
     public Map<String, String> defaultParameter() {
         HashMap<String, String> map = new HashMap<>();
         map.put("rewriteBatchedStatements", "true");
+        map.put("allowMultiQueries", "true");
         return map;
     }