class DataSourceParam implements ProcessAddTaskParam, InitializingBean {

    @Override
    public JsonNode addImportSpecialParam(JsonNode taskNode) {
        ObjectNode sqlParameters = (ObjectNode) taskNode.path(PARAMS);
        List<DataSource> dataSources = dataSourceMapper.queryDataSourceByName(sqlParameters.path("datasourceName").asText());
        if (!dataSources.isEmpty()) {
            DataSource dataSource = dataSources.get(0);
            sqlParameters.put("datasource", dataSource.getId());
        }
        ((ObjectNode)taskNode).set(PARAMS, sqlParameters);
        return taskNode;
    }

}