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); }