commit

src/main/java/com/jz/dmp/cmdexectool/scheduler/common/task/sync/SyncParameters.java

@@ -91,7 +91,7 @@ public class SyncParameters extends AbstractParameters {
         sink = "";
         transform = "";
         this.script = script;
-
+        //Map<String, Object> scriptObj = (Map<String, Object>) JSONObject.parse(script);
         JSONObject scriptObj = JSONObject.parseObject(script);
         Map<String, Object> scripts = (Map<String, Object>) scriptObj.get("scripts");
         Map<String, Object> sourceObj = (Map<String, Object>) scripts.get("reader"); //来源数据
@@ -245,7 +245,7 @@ public class SyncParameters extends AbstractParameters {
         targetBaseDataSource.setJdbcUrlDirect(targetDatasource.getJdbcUrl());
         targetBaseDataSource.setUser(targetDatasource.getUserName());
         String password = EncryptionUtils.decode(targetDatasource.getPassword(), publicKey);
-        MyDbType myDbType = MyDbType.obtainByIdStr(targetDatasource.getId().toString());
+        MyDbType myDbType = MyDbType.obtainByIdStr(targetDatasource.getDatasourceType().toString());
         targetBaseDataSource.setPassword(password);
         targetBaseDataSource.setMyDbType(myDbType);