AE86 1 年之前
父节点
当前提交
aac5c7a67d

+ 1 - 2
dbsyncer-connector/dbsyncer-connector-mysql/src/main/java/org/dbsyncer/connector/mysql/cdc/MySQLListener.java

@@ -134,9 +134,8 @@ public class MySQLListener extends AbstractDatabaseListener {
 
     private List<Host> readNodes(String url) {
         Matcher matcher = compile("(//)(?!(/)).+?(/)").matcher(url);
-        while (matcher.find()) {
+        if (matcher.find()) {
             url = matcher.group(0);
-            break;
         }
         url = StringUtil.replace(url, "/", "");
 

+ 1 - 2
dbsyncer-sdk/src/main/java/org/dbsyncer/sdk/util/DatabaseUtil.java

@@ -38,9 +38,8 @@ public abstract class DatabaseUtil {
 
     public static String getDatabaseName(String url) {
         Matcher matcher = compile("(//)(?!(\\?)).+?(\\?)").matcher(url);
-        while (matcher.find()) {
+        if (matcher.find()) {
             url = matcher.group(0);
-            break;
         }
         int s = url.lastIndexOf("/");
         int e = url.lastIndexOf("?");

+ 1 - 2
dbsyncer-storage/src/main/test/LuceneFactoryTest.java → dbsyncer-storage/src/test/LuceneFactoryTest.java

@@ -261,8 +261,7 @@ public class LuceneFactoryTest {
         System.out.println("新增后:");
         maps = query(new MatchAllDocsQuery());
         maps.forEach(m -> {
-            m.get("content");
-            System.out.println(m);
+            logger.info(String.valueOf(m.get("content")));
         });
         check();