@Override
    public String getExtParams(StreamSourceEntity sourceEntity) {
        SqlSourceDTO sqlSourceDTO = SqlSourceDTO.getFromJson(sourceEntity.getExtParams());
        if (Objects.nonNull(sqlSourceDTO) && StringUtils.isNotBlank(sourceEntity.getDataNodeName())) {
            SqlDataNodeInfo dataNodeInfo =
                    (SqlDataNodeInfo) dataNodeService.getByKeyWithoutTenant(sourceEntity.getDataNodeName(),
                            DataNodeType.SQL);
            sqlSourceDTO.setJdbcUrl(dataNodeInfo.getUrl());
            sqlSourceDTO.setUsername(dataNodeInfo.getUsername());
            sqlSourceDTO.setJdbcPassword(dataNodeInfo.getToken());
            return JsonUtils.toJsonString(sqlSourceDTO);
        }
        return sourceEntity.getExtParams();
    }
Sql source operator, such as get or set Sql source info.
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/sql/SqlSourceOperator.java