Skip to content

Commit dbdbdf0

Browse files
authored
[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
1 parent 57e5627 commit dbdbdf0

File tree

3 files changed

+7
-3
lines changed
  • docs/en/connector-v2
  • seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/mysql

3 files changed

+7
-3
lines changed

docs/en/connector-v2/sink/Mysql.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@
44
55
## Support Mysql Version
66

7-
- 5.5/5.6/5.7/8.0
7+
- 5.5/5.6/5.7/8.0/8.4
88

99
## Support Those Engines
1010

docs/en/connector-v2/source/Mysql.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@ Read external data source data through JDBC.
88

99
## Support Mysql Version
1010

11-
- 5.5/5.6/5.7/8.0
11+
- 5.5/5.6/5.7/8.0/8.4
1212

1313
## Support Those Engines
1414

seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/mysql/MySqlVersion.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,8 @@ public enum MySqlVersion {
2121
V_5_5,
2222
V_5_6,
2323
V_5_7,
24-
V_8;
24+
V_8,
25+
V_8_4;
2526

2627
public static MySqlVersion parse(String version) {
2728
if (version != null) {
@@ -37,6 +38,9 @@ public static MySqlVersion parse(String version) {
3738
if (version.startsWith("8.0")) {
3839
return V_8;
3940
}
41+
if (version.startsWith("8.4")) {
42+
return V_8_4;
43+
}
4044
}
4145
throw new UnsupportedOperationException("Unsupported MySQL version: " + version);
4246
}

0 commit comments

Comments
 (0)