From 18099108f2052c42d9168fe123d3aaeac22cc19a Mon Sep 17 00:00:00 2001 From: zhouhongfa Date: Sat, 3 Aug 2019 10:59:43 +0800 Subject: [PATCH] =?UTF-8?q?update:=20=E5=A2=9E=E5=8A=A0=20where=20?= =?UTF-8?q?=E5=8F=82=E6=95=B0=E6=8E=A5=E6=94=B6=EF=BC=9B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/main/java/com/wugui/dataxweb/dto/DataxJsonDto.java | 1 + .../wugui/dataxweb/service/impl/DataxJsonServiceImpl.java | 6 ++++++ 2 files changed, 7 insertions(+) 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 index d8ac92e..9fa355f 100644 --- 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 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 index 432cf3e..0763afd 100644 --- 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()); //