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

删除json column中拼接的``符

Browse Source
This commit is contained in:
景文凯 2020-03-18 13:50:53 +08:00
parent 53123ec162
commit d4b4fee700
1 changed files with 0 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
datax-admin/src/main/java/com/wugui/datax/admin/service/impl/DataxJsonServiceImpl.java
View File

@ -24,8 +24,6 @@ import java.util.stream.Collectors;
@Service
public class DataxJsonServiceImpl implements DataxJsonService {
private static final String[] sqlDataSource = new String[]{"mysql", "oracle", "postgresql", "sqlserver"};
@Autowired
private IJobJdbcDatasourceService jobJdbcDatasourceService;
@ -34,21 +32,9 @@ public class DataxJsonServiceImpl implements DataxJsonService {
DataxJsonHelper dataxJsonHelper = new DataxJsonHelper();
// reader
JobJdbcDatasource readerDatasource = jobJdbcDatasourceService.getById(dataxJsonDto.getReaderDatasourceId());
if (Arrays.stream(sqlDataSource).anyMatch(db -> db.equals(readerDatasource.getDatasource()))) {
List<String> readerColumns = dataxJsonDto.getReaderColumns().stream()
.map(column -> "`" + column + "`")
.collect(Collectors.toList());
dataxJsonDto.setReaderColumns(readerColumns);
}
// reader plugin init
dataxJsonHelper.initReader(dataxJsonDto,readerDatasource);
JobJdbcDatasource writerDatasource = jobJdbcDatasourceService.getById(dataxJsonDto.getWriterDatasourceId());
if (Arrays.stream(sqlDataSource).anyMatch(db -> db.equals(writerDatasource.getDatasource()))) {
List<String> writerColumns = dataxJsonDto.getWriterColumns().stream()
.map(column -> "`" + column + "`")
.collect(Collectors.toList());
dataxJsonDto.setWriterColumns(writerColumns);
}
dataxJsonHelper.initWriter(dataxJsonDto,writerDatasource);
return JSON.toJSONString(dataxJsonHelper.buildJob());
}