修改http 赋值bug

seatunnel-datasource/seatunnel-datasource-plugins/datasource-http/src/main/java/org/apache/seatunnel/datasource/plugin/http/HttpAConfiguration.java

@@ -31,10 +31,10 @@ public class HttpAConfiguration {
         }
 
         HttpConfiguration httpAConfiguration = new HttpConfiguration();
-        httpAConfiguration.setUrl(HttpOptionRule.URL.key());
-        httpAConfiguration.setMethod(HttpOptionRule.METHOD.key());
-        httpAConfiguration.setToken(HttpOptionRule.TOKEN.key());
-        httpAConfiguration.setRequest_params(HttpOptionRule.REQUEST_PARAMS.key());
+        httpAConfiguration.setUrl(ftpOption.get(HttpOptionRule.URL.key()));
+        httpAConfiguration.setMethod(ftpOption.get(HttpOptionRule.METHOD.key()));
+        httpAConfiguration.setToken(ftpOption.get(HttpOptionRule.TOKEN.key()));
+        httpAConfiguration.setRequest_params(ftpOption.get(HttpOptionRule.REQUEST_PARAMS.key()));
 
         return httpAConfiguration;
     }

seatunnel-datasource/seatunnel-datasource-plugins/datasource-http/src/main/java/org/apache/seatunnel/datasource/plugin/http/HttpDataSourceFactory.java

@@ -45,7 +45,7 @@ public class HttpDataSourceFactory implements DataSourceFactory {
                         .type(DatasourcePluginTypeEnum.FILE.getCode())
                         .version("1.0.0")
                         .supportVirtualTables(false)
-                        .icon("FtpFile")
+                        .icon("Http")
                         .build();
 
         return Sets.newHashSet(ftpDatasourcePluginInfo);

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

@@ -241,7 +241,7 @@ public class AccessJdbcDataSourceChannel implements DataSourceChannelExt {
         // checkNotNull(requestParams.get(org.apache.seatunnel.datasource.plugin.access.jdbc.AccessOptionRule.DRIVER.key()));
         checkNotNull(requestParams.get(AccessOptionRule.URL.key()), "Jdbc url cannot be null");
 
-        String url = AccessOptionRule.URL.key();
+        String url = requestParams.get(AccessOptionRule.URL.key());
 
         String substring = url.substring(url.lastIndexOf("/"), url.length()).replace("/", "");
         if (StringUtils.isBlank(substring)) {
@@ -303,6 +303,7 @@ public class AccessJdbcDataSourceChannel implements DataSourceChannelExt {
         }
 
         String database = path + "/" + file.getName();
+        database = database.replace("\\", "/");
         // JDBC连接字符串
         // 在application.properties或application.yml文件中配置数据库连接信息。你需要指定驱动类名为net.ucanaccess.jdbc.UcanaccessDriver，并提供Access数据库的URL。例如，URL可以是jdbc:ucanaccess://D:/Access2003/database/db_test.mdb;openExclusive=false;ignoreCase=true。[1]
 
@@ -312,7 +313,7 @@ public class AccessJdbcDataSourceChannel implements DataSourceChannelExt {
         // 加载UCanAccess JDBC驱动
         Class.forName("net.ucanaccess.jdbc.UcanaccessDriver");
         // 建立连接
-        conn = DriverManager.getConnection(url);
+        conn = DriverManager.getConnection(connectionString);
         System.out.println("Connected to the database successfully");
 
         return conn;