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 <[email protected]>
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);
}