(seatunnel-web) branch main updated: [Improve] Enhance MySQL data source configuration and error handling (#299)

[fanjia]

This is an automated email from the ASF dual-hosted git repository.

fanjia pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/seatunnel-web.git


The following commit(s) were added to refs/heads/main by this push:
     new 8e1d49da1 [Improve] Enhance MySQL data source configuration and error 
handling (#299)
8e1d49da1 is described below

commit 8e1d49da1470b0c89c2952644a1dc609a35f8212
Author: Jast <shengh...@apache.org>
AuthorDate: Fri Jul 18 12:00:00 2025 +0800

    [Improve] Enhance MySQL data source configuration and error handling (#299)
---
 .../datasource/plugin/mysql/jdbc/MysqlDataSourceConfig.java        | 7 +++++--
 .../datasource/plugin/mysql/jdbc/MysqlJdbcDataSourceChannel.java   | 2 +-
 2 files changed, 6 insertions(+), 3 deletions(-)

diff --git 
a/seatunnel-datasource/seatunnel-datasource-plugins/datasource-jdbc-mysql/src/main/java/org/apache/seatunnel/datasource/plugin/mysql/jdbc/MysqlDataSourceConfig.java
 
b/seatunnel-datasource/seatunnel-datasource-plugins/datasource-jdbc-mysql/src/main/java/org/apache/seatunnel/datasource/plugin/mysql/jdbc/MysqlDataSourceConfig.java
index 03d6d0cf3..886dbffd3 100644
--- 
a/seatunnel-datasource/seatunnel-datasource-plugins/datasource-jdbc-mysql/src/main/java/org/apache/seatunnel/datasource/plugin/mysql/jdbc/MysqlDataSourceConfig.java
+++ 
b/seatunnel-datasource/seatunnel-datasource-plugins/datasource-jdbc-mysql/src/main/java/org/apache/seatunnel/datasource/plugin/mysql/jdbc/MysqlDataSourceConfig.java
@@ -42,8 +42,11 @@ public class MysqlDataSourceConfig {
 
     public static final OptionRule OPTION_RULE =
             OptionRule.builder()
-                    .required(MysqlOptionRule.URL, MysqlOptionRule.DRIVER)
-                    .optional(MysqlOptionRule.USER, MysqlOptionRule.PASSWORD)
+                    .required(
+                            MysqlOptionRule.URL,
+                            MysqlOptionRule.DRIVER,
+                            MysqlOptionRule.USER,
+                            MysqlOptionRule.PASSWORD)
                     .build();
 
     public static final OptionRule METADATA_RULE =
diff --git 
a/seatunnel-datasource/seatunnel-datasource-plugins/datasource-jdbc-mysql/src/main/java/org/apache/seatunnel/datasource/plugin/mysql/jdbc/MysqlJdbcDataSourceChannel.java
 
b/seatunnel-datasource/seatunnel-datasource-plugins/datasource-jdbc-mysql/src/main/java/org/apache/seatunnel/datasource/plugin/mysql/jdbc/MysqlJdbcDataSourceChannel.java
index 24e863b28..b36a70254 100644
--- 
a/seatunnel-datasource/seatunnel-datasource-plugins/datasource-jdbc-mysql/src/main/java/org/apache/seatunnel/datasource/plugin/mysql/jdbc/MysqlJdbcDataSourceChannel.java
+++ 
b/seatunnel-datasource/seatunnel-datasource-plugins/datasource-jdbc-mysql/src/main/java/org/apache/seatunnel/datasource/plugin/mysql/jdbc/MysqlJdbcDataSourceChannel.java
@@ -116,7 +116,7 @@ public class MysqlJdbcDataSourceChannel implements 
DataSourceChannel {
         try (Connection ignored = getConnection(requestParams)) {
             return true;
         } catch (Exception e) {
-            throw new DataSourcePluginException("check jdbc connectivity 
failed", e);
+            throw new DataSourcePluginException(e.getMessage(), e);
         }
     }