CodeCow/datax-web
1
0
Fork 0
mirror of https://github.com/WeiYe-Jing/datax-web.git synced 2026-07-03 21:08:58 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

add: writer 增加 preSql 属性构建

Browse Source
This commit is contained in:
zhouhongfa 2019-08-05 15:44:06 +08:00
parent ebf9caff51
commit be109eceec
5 changed files with 17 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
datax-web/src/main/java/com/wugui/dataxweb/dto/DataxJsonDto.java
View File

@ -34,4 +34,5 @@ public class DataxJsonDto implements Serializable {
private String querySql;
private String preSql;
}

1
datax-web/src/main/java/com/wugui/dataxweb/service/impl/DataxJsonServiceImpl.java
View File

@ -50,6 +50,7 @@ public class DataxJsonServiceImpl implements DataxJsonService {
} else {
JobJdbcDatasource writerDatasource = jobJdbcDatasourceService.getById(dataxJsonDto.getWriterDatasourceId());
dataxJsonHelper.initWriter(writerDatasource, dataxJsonDto.getWriterTables(), dataxJsonDto.getWriterColumns());
dataxJsonHelper.setPreSql(dataxJsonDto.getPreSql());
}
return JSON.toJSONString(dataxJsonHelper.buildJob());

7
datax-web/src/main/java/com/wugui/tool/datax/DataxJsonHelper.java
View File

@ -63,6 +63,8 @@ public class DataxJsonHelper implements DataxJsonInterface {
private String querySql;
private String preSql;
private BaseDataxPlugin readerPlugin;
private BaseDataxPlugin writerPlugin;
@ -156,6 +158,7 @@ public class DataxJsonHelper implements DataxJsonInterface {
dataxPluginPojo.setJdbcDatasource(writerDatasource);
dataxPluginPojo.setTables(writerTables);
dataxPluginPojo.setColumns(writerColumns);
dataxPluginPojo.setPreSql(preSql);
return writerPlugin.build(dataxPluginPojo);
}
@ -171,4 +174,8 @@ public class DataxJsonHelper implements DataxJsonInterface {
public void setQuerySql(String querySql) {
this.querySql = querySql;
}
public void setPreSql(String preSql) {
this.preSql = preSql;
}
}

3
datax-web/src/main/java/com/wugui/tool/datax/writer/BaseWriterPlugin.java
View File

@ -31,6 +31,9 @@ public abstract class BaseWriterPlugin extends BaseDataxPlugin {
parameterObj.put("column", dataxPluginPojo.getColumns());
// preSql
parameterObj.put("preSql", ImmutableList.of(dataxPluginPojo.getPreSql()));
Map<String, Object> connectionObj = Maps.newLinkedHashMap();
connectionObj.put("table", dataxPluginPojo.getTables());

5
datax-web/src/main/java/com/wugui/tool/pojo/DataxPluginPojo.java
View File

@ -35,4 +35,9 @@ public class DataxPluginPojo {
* querySql 属性，如果指定了，则优先于columns参数
*/
private String querySql;
/**
* preSql 属性
*/
private String preSql;
}