修复已知问题

core/src/main/java/com/tbyf/cdcengine2/core/JdbcConnInfo.java

@@ -56,4 +56,16 @@ public class JdbcConnInfo {
     public void setPassword(String password) {
         this.password = password;
     }
+
+    @Override
+    public String toString() {
+        return "JdbcConnInfo{" +
+                "host='" + host + '\'' +
+                ", port=" + port +
+                ", dbname='" + dbname + '\'' +
+                ", url='" + url + '\'' +
+                ", user='" + user + '\'' +
+                ", password='******'" +
+                '}';
+    }
 }

mysql-cdc/src/main/java/com/tbyf/cdcengine2/mysql/MySqlUtils.java

 package com.tbyf.cdcengine2.mysql;
 
+import com.tbyf.cdcengine2.core.JdbcConnInfo;
+
+import java.net.MalformedURLException;
+import java.net.URL;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
+
 public class MySqlUtils {
 
     public static void loadDriver() {
@@ -13,4 +20,26 @@ public class MySqlUtils {
     public static String buildUrl(String host, int port, String database) {
         return "jdbc:mysql://" + host + ":" + port + "/" + database + "?serverTimezone=Asia/Shanghai";
     }
+
+
+    private static final Pattern urlPattern = Pattern.compile("jdbc:mysql://([a-zA-Z0-9.]+):(\\d+)/([a-zA-Z]+)\\?*.*");
+
+    public static JdbcConnInfo parseConnInfoFromUrl(String url) {
+        Matcher matcher = urlPattern.matcher(url);
+        if (matcher.find()) {
+            String host = matcher.group(1);
+            int port = Integer.parseInt(matcher.group(2));
+            String dbname = matcher.group(3);
+
+            JdbcConnInfo connInfo = new JdbcConnInfo();
+            connInfo.setUrl(url);
+            connInfo.setHost(host);
+            connInfo.setPort(port);
+            connInfo.setDbname(dbname);
+            return connInfo;
+        } else {
+            throw new IllegalArgumentException(url);
+        }
+    }
+
 }

sqlserver-cdc/src/main/java/com/tbyf/cdcengine2/sqlserver/SqlServerUtils.java

 package com.tbyf.cdcengine2.sqlserver;
 
+import com.tbyf.cdcengine2.core.JdbcConnInfo;
+
 import java.sql.Connection;
 import java.sql.DriverManager;
 import java.sql.SQLException;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
 
 public class SqlServerUtils {
 
@@ -28,4 +32,24 @@ public class SqlServerUtils {
             throw new IllegalStateException("获取数据库连接失败", e);
         }
     }
+
+    private static final Pattern urlPattern = Pattern.compile("jdbc:sqlserver://([a-zA-Z0-9.]+):(\\d+);databaseName=([a-zA-Z]*)");
+
+    public static JdbcConnInfo parseConnInfoFromUrl(String url) {
+        Matcher matcher = urlPattern.matcher(url);
+        if (matcher.find()) {
+            String host = matcher.group(1);
+            int port = Integer.parseInt(matcher.group(2));
+            String dbname = matcher.group(3);
+            JdbcConnInfo connInfo = new JdbcConnInfo();
+            connInfo.setUrl(url);
+            connInfo.setHost(host);
+            connInfo.setPort(port);
+            connInfo.setDbname(dbname);
+            return connInfo;
+        } else {
+            throw new IllegalArgumentException(url);
+        }
+    }
+
 }