rename

dbsyncer-biz/src/main/java/org/dbsyncer/biz/checker/impl/connector/ElasticSearchConfigChecker.java → dbsyncer-biz/src/main/java/org/dbsyncer/biz/checker/impl/connector/ElasticsearchConfigChecker.java

@@ -13,7 +13,7 @@ import java.util.Map;
  * @date 2021/8/25 23:30
  */
 @Component
-public class ElasticSearchConfigChecker implements ConnectorConfigChecker<ESConfig> {
+public class ElasticsearchConfigChecker implements ConnectorConfigChecker<ESConfig> {
 
     @Override
     public void modify(ESConfig connectorConfig, Map<String, String> params) {

dbsyncer-connector/src/main/java/org/dbsyncer/connector/enums/ConnectorEnum.java

@@ -34,6 +34,10 @@ public enum ConnectorEnum {
      * SqlServer 连接器
      */
     SQL_SERVER("SqlServer", new SqlServerConnector(), DatabaseConfig.class),
+    /**
+     * Elasticsearch 连接器
+     */
+    ELASTIC_SEARCH("Elasticsearch", new ESConnector(), ESConfig.class),
     /**
      * DqlMysql 连接器
      */
@@ -45,11 +49,7 @@ public enum ConnectorEnum {
     /**
      * DqlSqlServer 连接器
      */
-    DQL_SQL_SERVER("DqlSqlServer", new DQLSqlServerConnector(), DatabaseConfig.class),
-    /**
-     * ElasticSearch 连接器
-     */
-    ELASTIC_SEARCH("ElasticSearch", new ESConnector(), ESConfig.class);
+    DQL_SQL_SERVER("DqlSqlServer", new DQLSqlServerConnector(), DatabaseConfig.class);
 
     // 连接器名称
     private String type;

dbsyncer-parser/src/main/java/org/dbsyncer/parser/ParserFactory.java

@@ -31,6 +31,7 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.context.ApplicationContext;
 import org.springframework.stereotype.Component;
 import org.springframework.util.Assert;
@@ -64,6 +65,7 @@ public class ParserFactory implements Parser {
     private FlushService flushService;
 
     @Autowired
+    @Qualifier("taskExecutor")
     private Executor taskExecutor;
 
     @Autowired