update: 增加 where 参数接收；

Kyofin · Aug 3, 2019 · 1809910 · 1809910
1 parent 04c5828
commit 1809910
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 0 deletions.
diff --git a/datax-web/src/main/java/com/wugui/dataxweb/dto/DataxJsonDto.java b/datax-web/src/main/java/com/wugui/dataxweb/dto/DataxJsonDto.java
@@ -30,5 +30,6 @@ public class DataxJsonDto implements Serializable {
 
     private List<String> writerColumns;
 
+    private String whereParams;
 
 }
diff --git a/datax-web/src/main/java/com/wugui/dataxweb/service/impl/DataxJsonServiceImpl.java b/datax-web/src/main/java/com/wugui/dataxweb/service/impl/DataxJsonServiceImpl.java
@@ -1,5 +1,6 @@
 package com.wugui.dataxweb.service.impl;
 
+import cn.hutool.core.util.StrUtil;
 import com.alibaba.fastjson.JSON;
 import com.wugui.dataxweb.dto.DataxJsonDto;
 import com.wugui.dataxweb.entity.JobJdbcDatasource;
@@ -33,6 +34,11 @@ public String buildJobJson(DataxJsonDto dataxJsonDto) {
         // reader
         JobJdbcDatasource readerDatasource = jobJdbcDatasourceService.getById(dataxJsonDto.getReaderDatasourceId());
 
+        //where
+        if (StrUtil.isNotBlank(dataxJsonDto.getWhereParams())) {
+            dataxJsonHelper.addWhereParams(dataxJsonDto.getWhereParams());
+        }
+
         // reader plugin init
         dataxJsonHelper.initReader(readerDatasource, dataxJsonDto.getReaderTables(), dataxJsonDto.getReaderColumns());
         //
Original file line number	Diff line number	Diff line change
Expand Up		@@ -30,5 +30,6 @@ public class DataxJsonDto implements Serializable {

		private List<String> writerColumns;

		private String whereParams;

		}