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()); }