Skip to content

Commit 8e1d49d

Browse files
[Improve] Enhance MySQL data source configuration and error handling (#299)
1 parent 72bb3f2 commit 8e1d49d

File tree

2 files changed

+6
-3
lines changed

2 files changed

+6
-3
lines changed

seatunnel-datasource/seatunnel-datasource-plugins/datasource-jdbc-mysql/src/main/java/org/apache/seatunnel/datasource/plugin/mysql/jdbc/MysqlDataSourceConfig.java

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -42,8 +42,11 @@ public class MysqlDataSourceConfig {
4242

4343
public static final OptionRule OPTION_RULE =
4444
OptionRule.builder()
45-
.required(MysqlOptionRule.URL, MysqlOptionRule.DRIVER)
46-
.optional(MysqlOptionRule.USER, MysqlOptionRule.PASSWORD)
45+
.required(
46+
MysqlOptionRule.URL,
47+
MysqlOptionRule.DRIVER,
48+
MysqlOptionRule.USER,
49+
MysqlOptionRule.PASSWORD)
4750
.build();
4851

4952
public static final OptionRule METADATA_RULE =

seatunnel-datasource/seatunnel-datasource-plugins/datasource-jdbc-mysql/src/main/java/org/apache/seatunnel/datasource/plugin/mysql/jdbc/MysqlJdbcDataSourceChannel.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -116,7 +116,7 @@ public boolean checkDataSourceConnectivity(
116116
try (Connection ignored = getConnection(requestParams)) {
117117
return true;
118118
} catch (Exception e) {
119-
throw new DataSourcePluginException("check jdbc connectivity failed", e);
119+
throw new DataSourcePluginException(e.getMessage(), e);
120120
}
121121
}
122122

0 commit comments

Comments
 (0)