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

liugddx 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 dbdbdf015b [Improve][connector-v2-jdbc-mysql] Add support for MySQL 
8.4 (#7151)
dbdbdf015b is described below

commit dbdbdf015bceb90767787be465399c00b7baa167
Author: ChunFuWu <319355...@qq.com>
AuthorDate: Wed Jul 10 20:28:51 2024 +0800

    [Improve][connector-v2-jdbc-mysql] Add support for MySQL 8.4 (#7151)
    
    * [Improve][connector-v2-jdbc-mysql] Add support for MySQL 8.4
    
    * [Improve][connector-v2-jdbc-mysql] Add support for MySQL 8.4
---
 docs/en/connector-v2/sink/Mysql.md                                  | 2 +-
 docs/en/connector-v2/source/Mysql.md                                | 2 +-
 .../seatunnel/jdbc/internal/dialect/mysql/MySqlVersion.java         | 6 +++++-
 3 files changed, 7 insertions(+), 3 deletions(-)

diff --git a/docs/en/connector-v2/sink/Mysql.md 
b/docs/en/connector-v2/sink/Mysql.md
index b6c3fd4a9b..5ac881f69f 100644
--- a/docs/en/connector-v2/sink/Mysql.md
+++ b/docs/en/connector-v2/sink/Mysql.md
@@ -4,7 +4,7 @@
 
 ## Support Mysql Version
 
-- 5.5/5.6/5.7/8.0
+- 5.5/5.6/5.7/8.0/8.4
 
 ## Support Those Engines
 
diff --git a/docs/en/connector-v2/source/Mysql.md 
b/docs/en/connector-v2/source/Mysql.md
index a02469d66a..b97ec324ea 100644
--- a/docs/en/connector-v2/source/Mysql.md
+++ b/docs/en/connector-v2/source/Mysql.md
@@ -8,7 +8,7 @@ Read external data source data through JDBC.
 
 ## Support Mysql Version
 
-- 5.5/5.6/5.7/8.0
+- 5.5/5.6/5.7/8.0/8.4
 
 ## Support Those Engines
 
diff --git 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/mysql/MySqlVersion.java
 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/mysql/MySqlVersion.java
index 6ffbf77356..97a37c0621 100644
--- 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/mysql/MySqlVersion.java
+++ 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/mysql/MySqlVersion.java
@@ -21,7 +21,8 @@ public enum MySqlVersion {
     V_5_5,
     V_5_6,
     V_5_7,
-    V_8;
+    V_8,
+    V_8_4;
 
     public static MySqlVersion parse(String version) {
         if (version != null) {
@@ -37,6 +38,9 @@ public enum MySqlVersion {
             if (version.startsWith("8.0")) {
                 return V_8;
             }
+            if (version.startsWith("8.4")) {
+                return V_8_4;
+            }
         }
         throw new UnsupportedOperationException("Unsupported MySQL version: " 
+ version);
     }

Reply via email to