From d4b4fee7004ead010fda7ed283183f1d2c27ef85 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=99=AF=E6=96=87=E5=87=AF?= Date: Wed, 18 Mar 2020 13:50:53 +0800 Subject: [PATCH] =?UTF-8?q?=E5=88=A0=E9=99=A4json=20column=E4=B8=AD?= =?UTF-8?q?=E6=8B=BC=E6=8E=A5=E7=9A=84``=E7=AC=A6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../admin/service/impl/DataxJsonServiceImpl.java | 14 -------------- 1 file changed, 14 deletions(-) diff --git a/datax-admin/src/main/java/com/wugui/datax/admin/service/impl/DataxJsonServiceImpl.java b/datax-admin/src/main/java/com/wugui/datax/admin/service/impl/DataxJsonServiceImpl.java index 7fd699b0..aad8c759 100644 --- a/datax-admin/src/main/java/com/wugui/datax/admin/service/impl/DataxJsonServiceImpl.java +++ b/datax-admin/src/main/java/com/wugui/datax/admin/service/impl/DataxJsonServiceImpl.java @@ -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 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 writerColumns = dataxJsonDto.getWriterColumns().stream() - .map(column -> "`" + column + "`") - .collect(Collectors.toList()); - dataxJsonDto.setWriterColumns(writerColumns); - } dataxJsonHelper.initWriter(dataxJsonDto,writerDatasource); return JSON.toJSONString(dataxJsonHelper.buildJob()); }