修改access 链接用户名称密码

seatunnel-datasource/seatunnel-datasource-plugins/datasource-jdbc-access/src/main/java/org/apache/seatunnel/datasource/plugin/access/jdbc/AccessDataSourceConfig.java

@@ -49,7 +49,9 @@ public class AccessDataSourceConfig {
                             org.apache.seatunnel.datasource.plugin.access.jdbc.AccessOptionRule
                                     .USER,
                             org.apache.seatunnel.datasource.plugin.access.jdbc.AccessOptionRule
-                                    .PASSWORD)
+                                    .PASSWORD,
+                            AccessOptionRule.MINIO_USER,
+                            AccessOptionRule.MINIO_PASSWORD)
                     .build();
 
     //    public static final OptionRule METADATA_RULE =

seatunnel-datasource/seatunnel-datasource-plugins/datasource-jdbc-access/src/main/java/org/apache/seatunnel/datasource/plugin/access/jdbc/AccessJdbcDataSourceChannel.java

@@ -243,6 +243,8 @@ public class AccessJdbcDataSourceChannel implements DataSourceChannelExt {
         checkNotNull(requestParams.get(AccessOptionRule.URL.key()), "Jdbc url cannot be null");
 
         String url = requestParams.get(AccessOptionRule.URL.key());
+        String user = requestParams.get(AccessOptionRule.USER.key());
+        String pwd = requestParams.get(AccessOptionRule.PASSWORD.key());
 
         String substring = url.substring(url.lastIndexOf("/"), url.length()).replace("/", "");
         if (StringUtils.isBlank(substring)) {
@@ -314,7 +316,7 @@ public class AccessJdbcDataSourceChannel implements DataSourceChannelExt {
         // 加载UCanAccess JDBC驱动
         Class.forName("net.ucanaccess.jdbc.UcanaccessDriver");
         // 建立连接
-        conn = DriverManager.getConnection(connectionString);
+        conn = DriverManager.getConnection(connectionString, user, pwd);
         System.out.println("Connected to the database successfully");
 
         return conn;

seatunnel-datasource/seatunnel-datasource-plugins/datasource-jdbc-access/src/main/java/org/apache/seatunnel/datasource/plugin/access/jdbc/AccessOptionRule.java

@@ -28,7 +28,14 @@ public class AccessOptionRule {
                     .noDefaultValue()
                     .withDescription(
                             "jdbc url, eg:" + " http://localhost:9000/bucket/filename.mdb");
+    public static final Option<String> MINIO_USER =
+            Options.key("minio_user").stringType().noDefaultValue().withDescription("jdbc user");
 
+    public static final Option<String> MINIO_PASSWORD =
+            Options.key("minio_password")
+                    .stringType()
+                    .noDefaultValue()
+                    .withDescription("jdbc password");
     public static final Option<String> USER =
             Options.key("user").stringType().noDefaultValue().withDescription("jdbc user");