[fix](connector) fix no suitable driver found issue when getting fe j…

…dbc connection (#251)
apache · Jan 6, 2025 · 00759cb · 00759cb
1 parent c0b1bc2
commit 00759cb
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/...doris-connector-base/src/main/java/org/apache/doris/spark/client/DorisFrontendClient.java b/...doris-connector-base/src/main/java/org/apache/doris/spark/client/DorisFrontendClient.java
@@ -173,6 +173,11 @@ public <T> T queryFrontends(Function<Connection, T> function) throws Exception {
                 ex = new OptionRequiredException(DorisOptions.DORIS_QUERY_PORT.getName());
                 break;
             }
+            try {
+                Class.forName("com.mysql.cj.jdbc.Driver");
+            } catch (ClassNotFoundException e) {
+                Class.forName("com.mysql.jdbc.Driver");
+            }
             try (Connection conn = DriverManager.getConnection("jdbc:mysql://" + frontEnd.getHost() + ":" + frontEnd.getQueryPort(), username, password)) {
                 return function.apply(conn);
             } catch (SQLException e) {