fix

dbsyncer-connector/dbsyncer-connector-elasticsearch/src/main/java/org/dbsyncer/connector/elasticsearch/ElasticsearchConnector.java

@@ -146,12 +146,13 @@ public final class ElasticsearchConnector extends AbstractConnector implements C
 
     @Override
     public String getConnectorInstanceCacheKey(ESConfig config) {
-        return String.format("%s-%s-%s-%s", config.getConnectorType(), config.getUrl(), config.getIndex(), config.getUsername());
+        return String.format("%s-%s-%s", config.getConnectorType(), config.getUrl(), config.getUsername());
     }
 
     @Override
     public List<Table> getTable(ESConnectorInstance connectorInstance) {
         try {
+            // TODO 获取所有索引和type
             ESConfig config = connectorInstance.getConfig();
             GetIndexRequest request = new GetIndexRequest(config.getIndex());
             GetIndexResponse indexResponse = connectorInstance.getConnection().indices().get(request, RequestOptions.DEFAULT);

dbsyncer-sdk/src/main/java/org/dbsyncer/sdk/model/SqlTable.java

@@ -1,3 +1,6 @@
+/**
+ * DBSyncer Copyright 2020-2024 All Rights Reserved.
+ */
 package org.dbsyncer.sdk.model;
 
 public class SqlTable {
@@ -8,15 +11,6 @@ public class SqlTable {
 
     private String table;
 
-    public SqlTable() {
-    }
-
-    public SqlTable(String sqlName, String sql, String table) {
-        this.sqlName = sqlName;
-        this.sql = sql;
-        this.table = table;
-    }
-
     public String getSqlName() {
         return sqlName;
     }