update arg

dbsyncer-biz/src/main/java/org/dbsyncer/biz/checker/impl/tablegroup/TableGroupChecker.java

@@ -107,7 +107,7 @@ public class TableGroupChecker extends AbstractChecker {
         // 默认使用全局的过滤条件
         group.setFilter(CollectionUtils.isEmpty(tableGroup.getFilter()) ? mapping.getFilter() : tableGroup.getFilter());
 
-        Map<String, String> command = manager.getCommand(mapping.getSourceConnectorId(), mapping.getTargetConnectorId(), group);
+        Map<String, String> command = manager.getCommand(mapping, group);
         tableGroup.setCommand(command);
     }
 

dbsyncer-manager/src/main/java/org/dbsyncer/manager/Manager.java

@@ -60,7 +60,7 @@ public interface Manager extends TaskExecutor{
 
     List<TableGroup> getTableGroupAll(String mappingId);
 
-    Map<String, String> getCommand(String sourceConnectorId, String targetConnectorId, TableGroup tableGroup);
+    Map<String, String> getCommand(Mapping mapping, TableGroup tableGroup);
 
     // Meta
     String addMeta(ConfigModel model);

dbsyncer-manager/src/main/java/org/dbsyncer/manager/ManagerFactory.java

@@ -173,8 +173,8 @@ public class ManagerFactory implements Manager, ApplicationContextAware, Applica
     }
 
     @Override
-    public Map<String, String> getCommand(String sourceConnectorId, String targetConnectorId, TableGroup tableGroup) {
-        return parser.getCommand(sourceConnectorId, targetConnectorId, tableGroup);
+    public Map<String, String> getCommand(Mapping mapping, TableGroup tableGroup) {
+        return parser.getCommand(mapping, tableGroup);
     }
 
     @Override

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

@@ -49,12 +49,11 @@ public interface Parser {
     /**
      * 获取映射关系执行命令
      *
-     * @param sourceConnectorId
-     * @param targetConnectorId
+     * @param mapping
      * @param tableGroup
      * @return
      */
-    Map<String, String> getCommand(String sourceConnectorId, String targetConnectorId, TableGroup tableGroup);
+    Map<String, String> getCommand(Mapping mapping, TableGroup tableGroup);
 
     /**
      * 解析连接器配置为Connector

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

@@ -65,7 +65,9 @@ public class ParserFactory implements Parser {
     }
 
     @Override
-    public Map<String, String> getCommand(String sourceConnectorId, String targetConnectorId, TableGroup tableGroup) {
+    public Map<String, String> getCommand(Mapping mapping, TableGroup tableGroup) {
+        final String sourceConnectorId = mapping.getSourceConnectorId();
+        final String targetConnectorId = mapping.getTargetConnectorId();
         List<FieldMapping> fieldMapping = tableGroup.getFieldMapping();
         if (CollectionUtils.isEmpty(fieldMapping)) {
             return null;