feat(sink): use mysql dialect for jdbc url start with mariadb (#19523)

risingwavelabs · Nov 26, 2024 · 5d6aaf4 · 5d6aaf4
1 parent 759ea19
commit 5d6aaf4
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...connector-node/risingwave-sink-jdbc/src/main/java/com/risingwave/connector/JdbcUtils.java b/...connector-node/risingwave-sink-jdbc/src/main/java/com/risingwave/connector/JdbcUtils.java
@@ -29,7 +29,7 @@ public abstract class JdbcUtils {
     static final int SOCKET_TIMEOUT = 300;
 
     public static Optional<JdbcDialectFactory> getDialectFactory(String jdbcUrl) {
-        if (jdbcUrl.startsWith("jdbc:mysql")) {
+        if (jdbcUrl.startsWith("jdbc:mysql") || jdbcUrl.startsWith("jdbc:mariadb")) {
             return Optional.of(new MySqlDialectFactory());
         } else if (jdbcUrl.startsWith("jdbc:postgresql")) {
             return Optional.of(new PostgresDialectFactory());