diff --git a/backend/src/main/java/io/dataease/datasource/dto/EsConfigDTO.java b/backend/src/main/java/io/dataease/datasource/dto/EsConfigDTO.java index b879eeb309..7959e9ec68 100644 --- a/backend/src/main/java/io/dataease/datasource/dto/EsConfigDTO.java +++ b/backend/src/main/java/io/dataease/datasource/dto/EsConfigDTO.java @@ -8,8 +8,8 @@ import lombok.Setter; @Setter public class EsConfigDTO { private String url; - private String username; - private String password; + private String esUsername; + private String esPassword; private String version; private String uri; private String dataSourceType = "es"; diff --git a/backend/src/main/java/io/dataease/datasource/provider/EsProvider.java b/backend/src/main/java/io/dataease/datasource/provider/EsProvider.java index eaf4dacb29..02aab04e28 100644 --- a/backend/src/main/java/io/dataease/datasource/provider/EsProvider.java +++ b/backend/src/main/java/io/dataease/datasource/provider/EsProvider.java @@ -50,8 +50,8 @@ public class EsProvider extends DatasourceProvider { try { EsConfigDTO esConfigDTO = new Gson().fromJson(dsr.getDatasource().getConfiguration(), EsConfigDTO.class); HttpClientConfig httpClientConfig = new HttpClientConfig(); - if(StringUtils.isNotEmpty(esConfigDTO.getUsername())){ - String auth = esConfigDTO.getUsername() + ":" + esConfigDTO.getPassword(); + if(StringUtils.isNotEmpty(esConfigDTO.getEsUsername())){ + String auth = esConfigDTO.getEsUsername() + ":" + esConfigDTO.getEsPassword(); byte[] encodedAuth = Base64.encodeBase64(auth.getBytes(StandardCharsets.UTF_8)); httpClientConfig.addHeader(HttpHeaders.AUTHORIZATION, "Basic " + new String(encodedAuth)); } @@ -252,8 +252,8 @@ public class EsProvider extends DatasourceProvider { EsConfigDTO esConfigDTO = new Gson().fromJson(datasourceRequest.getDatasource().getConfiguration(), EsConfigDTO.class); uri = esConfigDTO.getUri()+uri; HttpClientConfig httpClientConfig = new HttpClientConfig(); - if(StringUtils.isNotEmpty(esConfigDTO.getUsername()) && StringUtils.isNotEmpty(esConfigDTO.getPassword())){ - String auth = esConfigDTO.getUsername() + ":" + esConfigDTO.getPassword(); + if(StringUtils.isNotEmpty(esConfigDTO.getEsUsername()) && StringUtils.isNotEmpty(esConfigDTO.getEsPassword())){ + String auth = esConfigDTO.getEsUsername() + ":" + esConfigDTO.getEsPassword(); byte[] encodedAuth = Base64.encodeBase64(auth.getBytes(StandardCharsets.UTF_8)); httpClientConfig.addHeader(HttpHeaders.AUTHORIZATION, "Basic " + new String(encodedAuth)); } @@ -269,8 +269,8 @@ public class EsProvider extends DatasourceProvider { private String exexGetQuery(DatasourceRequest datasourceRequest){ EsConfigDTO esConfigDTO = new Gson().fromJson(datasourceRequest.getDatasource().getConfiguration(), EsConfigDTO.class); HttpClientConfig httpClientConfig = new HttpClientConfig(); - if(StringUtils.isNotEmpty(esConfigDTO.getUsername()) && StringUtils.isNotEmpty(esConfigDTO.getPassword())){ - String auth = esConfigDTO.getUsername() + ":" + esConfigDTO.getPassword(); + if(StringUtils.isNotEmpty(esConfigDTO.getEsUsername()) && StringUtils.isNotEmpty(esConfigDTO.getEsPassword())){ + String auth = esConfigDTO.getEsUsername() + ":" + esConfigDTO.getEsPassword(); byte[] encodedAuth = Base64.encodeBase64(auth.getBytes(StandardCharsets.UTF_8)); httpClientConfig.addHeader(HttpHeaders.AUTHORIZATION, "Basic " + new String(encodedAuth)); } diff --git a/frontend/src/views/system/datasource/form.vue b/frontend/src/views/system/datasource/form.vue index c4275b60ff..f6ec078a84 100644 --- a/frontend/src/views/system/datasource/form.vue +++ b/frontend/src/views/system/datasource/form.vue @@ -39,12 +39,19 @@ {{ $t('datasource.oracle_service_name') }} - + - + + + + + + + + @@ -208,14 +215,6 @@ export default { this.$refs.dsForm.resetFields() }, save() { - if(this.form.type !== 'es' && !this.form.configuration.username){ - this.$message.error(this.$t('datasource.please_input_user_name')) - return - } - if(this.form.type !== 'es' && !this.form.configuration.username){ - this.$message.error(this.$t('datasource.please_input_password')) - return - } if (!this.form.configuration.schema && (this.form.type === 'oracle' || this.form.type === 'sqlServer')) { this.$message.error(this.$t('datasource.please_choose_schema')) return