修改access 链接用户名称密码

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

@@ -34,6 +34,7 @@ import java.net.HttpURLConnection;
 import java.net.URL;
 import java.sql.*;
 import java.util.*;
+import java.util.concurrent.ConcurrentHashMap;
 import java.util.function.Function;
 import java.util.stream.Collectors;
 
@@ -42,6 +43,8 @@ import static com.google.common.base.Preconditions.checkNotNull;
 public class AccessJdbcDataSourceChannel implements DataSourceChannelExt {
     List<String> typeList = Arrays.asList("varchar", "char", "json");
 
+    private ConcurrentHashMap<String, Connection> concurrentHashMap = new ConcurrentHashMap<>(1);
+
     public static class Holder {
         private static final AccessJdbcDataSourceChannel INSTANCE =
                 new AccessJdbcDataSourceChannel();
@@ -250,6 +253,12 @@ public class AccessJdbcDataSourceChannel implements DataSourceChannelExt {
         if (StringUtils.isBlank(substring)) {
             throw new RuntimeException("没找到文件名称！");
         }
+
+        Connection connection = concurrentHashMap.get(url);
+        if (connection != null) {
+            return connection;
+        }
+
         String[] split = substring.split("\\.");
         String prefix = split[0];
         String suffix = "";
@@ -319,6 +328,8 @@ public class AccessJdbcDataSourceChannel implements DataSourceChannelExt {
         conn = DriverManager.getConnection(connectionString, user, pwd);
         System.out.println("Connected to the database successfully");
 
+        concurrentHashMap.put(url, conn);
+
         return conn;
     }