This is an automated email from the ASF dual-hosted git repository.
casion pushed a commit to branch dev-1.3.1-errorcode
in repository https://gitbox.apache.org/repos/asf/incubator-linkis.git
The following commit(s) were added to refs/heads/dev-1.3.1-errorcode by this
push:
new 9a63015a4 [linkis-datasource-client ]module errorcode optimization and
documentation (#3564)
9a63015a4 is described below
commit 9a63015a4ce679cebe3f4bb9501e99e4603c0bd2
Author: 成彬彬 <[email protected]>
AuthorDate: Sun Oct 16 13:34:30 2022 +0800
[linkis-datasource-client ]module errorcode optimization and documentation
(#3564)
---
.../linkis-datasource-client-errorcode.md | 16 ++++
.../DatasourceClientErrorCodeSummary.java | 85 ++++++++++++++++++++++
.../DataSourceClientBuilderException.scala | 4 +-
.../client/impl/LinkisDataSourceRemoteClient.scala | 3 +-
.../request/DataSourceTestConnectAction.scala | 7 +-
.../client/request/DeleteDataSourceAction.scala | 5 +-
.../client/request/ExpireDataSourceAction.scala | 5 +-
.../GetConnectParamsByDataSourceIdAction.scala | 5 +-
.../GetConnectParamsByDataSourceNameAction.scala | 7 +-
.../request/GetDataSourceVersionsAction.scala | 5 +-
.../request/GetInfoByDataSourceIdAction.scala | 7 +-
.../request/GetInfoByDataSourceNameAction.scala | 7 +-
.../GetInfoPublishedByDataSourceNameAction.scala | 7 +-
.../request/GetKeyTypeDatasourceAction.scala | 3 +-
.../client/request/MetadataGetColumnsAction.scala | 11 +--
.../request/MetadataGetDatabasesAction.scala | 7 +-
.../request/MetadataGetPartitionsAction.scala | 9 ++-
.../request/MetadataGetTablePropsAction.scala | 11 +--
.../client/request/MetadataGetTablesAction.scala | 9 ++-
.../request/PublishDataSourceVersionAction.scala | 8 +-
.../client/request/QueryDataSourceAction.scala | 3 +-
.../client/request/QueryDataSourceEnvAction.scala | 3 +-
.../client/request/UpdateDataSourceAction.scala | 5 +-
.../request/UpdateDataSourceParameterAction.scala | 5 +-
24 files changed, 181 insertions(+), 56 deletions(-)
diff --git a/docs/errorcode/linkis-datasource-client-errorcode.md
b/docs/errorcode/linkis-datasource-client-errorcode.md
new file mode 100644
index 000000000..d31b468a6
--- /dev/null
+++ b/docs/errorcode/linkis-datasource-client-errorcode.md
@@ -0,0 +1,16 @@
+## linkis-datasource-client errorcode
+
+| module name(模块名) | error code(错误码) | describe(描述) |enumeration name(枚举)|
Exception Class(类名)|
+| -------- | -------- | ----- |-----|-----|
+|linkis-datasource-client |31000|serverUrl cannot be null.(serverUrl
不能为空.)|SERVERURL_CANNOT_NULL|DatasourceClientErrorCodeSummary|
+|linkis-datasource-client |31000|version is
needed!(版本为空！)|VERSION_NEEDED|DatasourceClientErrorCodeSummary|
+|linkis-datasource-client |31000|version is
needed!(需要版本ID！)"|VERSIONID_NEEDED|DatasourceClientErrorCodeSummary|
+|linkis-datasource-client |31000|dataSourceId is
needed!(需要dataSourceId！)|DATASOURCEID_NEEDED|DatasourceClientErrorCodeSummary|
+|linkis-datasource-client |31000|dataSourceName is
needed!(需要dataSourceName！)|DATASOURCENAME_NEEDED|DatasourceClientErrorCodeSummary|
+|linkis-datasource-client |31000|user is
needed!(用户为空！)|USER_NEEDED|DatasourceClientErrorCodeSummary|
+|linkis-datasource-client |31000|system is
needed!(系统为空！)|SYSTEM_NEEDED|DatasourceClientErrorCodeSummary|
+|linkis-datasource-client |31000|Cannot encode the name of data source:{} for
request(无法对请求的数据源名称进行编码：{})|CANNOT_SOURCE|DatasourceClientErrorCodeSummary|
+|linkis-datasource-client |31000|database is
needed!(数据库为空！)|DATABASE_NEEDED|DatasourceClientErrorCodeSummary|
+|linkis-datasource-client |31000|table is
needed!(表为空！)|TABLE_NEEDED|DatasourceClientErrorCodeSummary|
+
+
diff --git
a/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/java/org/apache/linkis/datasource/client/errorcode/DatasourceClientErrorCodeSummary.java
b/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/java/org/apache/linkis/datasource/client/errorcode/DatasourceClientErrorCodeSummary.java
new file mode 100644
index 000000000..3d690a177
--- /dev/null
+++
b/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/java/org/apache/linkis/datasource/client/errorcode/DatasourceClientErrorCodeSummary.java
@@ -0,0 +1,85 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.linkis.datasource.client.errorcode;
+
+public enum DatasourceClientErrorCodeSummary {
+ CLIENT_ERROR_CODE(31000, "", ""),
+ SERVERURL_CANNOT_NULL(
+ 31000,
+ "serverUrl cannot be null.(serverUrl 不能为空.)",
+ "serverUrl cannot be null.(serverUrl 不能为空.)"),
+ VERSION_NEEDED(31000, "version is needed!(版本为空！)", "version is
needed!(版本为空！)"),
+ VERSIONID_NEEDED(31000, "version is needed!(需要版本ID！)", "version is
needed!(需要版本ID！)"),
+ DATASOURCEID_NEEDED(
+ 31000,
+ "dataSourceId is needed!(需要dataSourceId！)",
+ "dataSourceId is needed!(需要dataSourceId！)"),
+ DATASOURCENAME_NEEDED(
+ 31000,
+ "dataSourceName is needed!(需要dataSourceName！)",
+ "dataSourceName is needed!(需要dataSourceName！)"),
+ USER_NEEDED(31000, "user is needed!(用户为空！)", "user is needed!(用户为空！)"),
+ SYSTEM_NEEDED(31000, "system is needed!(系统为空！)", "system is needed!(系统为空！)"),
+ CANNOT_SOURCE(
+ 31000,
+ "Cannot encode the name of data source:{} for
request(无法对请求的数据源名称进行编码：{})",
+ "Cannot encode the name of data source:{} for
request(无法对请求的数据源名称进行编码：{})"),
+ DATABASE_NEEDED(31000, "database is needed!(数据库为空！)", "database is
needed!(数据库为空！)"),
+ TABLE_NEEDED(31000, "table is needed!(表为空！)", "table is needed!(表为空！)");
+ /** (errorCode)错误码 */
+ private int errorCode;
+ /** (errorDesc)错误描述 */
+ private String errorDesc;
+ /** Possible reasons for the error(错误可能出现的原因) */
+ private String comment;
+
+ DatasourceClientErrorCodeSummary(int errorCode, String errorDesc, String
comment) {
+ this.errorCode = errorCode;
+ this.errorDesc = errorDesc;
+ this.comment = comment;
+ }
+
+ public int getErrorCode() {
+ return errorCode;
+ }
+
+ public void setErrorCode(int errorCode) {
+ this.errorCode = errorCode;
+ }
+
+ public String getErrorDesc() {
+ return errorDesc;
+ }
+
+ public void setErrorDesc(String errorDesc) {
+ this.errorDesc = errorDesc;
+ }
+
+ public String getComment() {
+ return comment;
+ }
+
+ public void setComment(String comment) {
+ this.comment = comment;
+ }
+
+ @Override
+ public String toString() {
+ return "errorCode: " + this.errorCode + ", errorDesc:" + this.errorDesc;
+ }
+}
diff --git
a/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/exception/DataSourceClientBuilderException.scala
b/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/exception/DataSourceClientBuilderException.scala
index 65f0336e6..24f9009f6 100644
---
a/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/exception/DataSourceClientBuilderException.scala
+++
b/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/exception/DataSourceClientBuilderException.scala
@@ -18,8 +18,10 @@
package org.apache.linkis.datasource.client.exception
import org.apache.linkis.common.exception.ErrorException
+import
org.apache.linkis.datasource.client.errorcode.DatasourceClientErrorCodeSummary.CLIENT_ERROR_CODE
-class DataSourceClientBuilderException(errorDesc: String) extends
ErrorException(31000, errorDesc) {
+class DataSourceClientBuilderException(errorDesc: String)
+ extends ErrorException(CLIENT_ERROR_CODE.getErrorCode, errorDesc) {
def this(errorDesc: String, t: Throwable) = {
this(errorDesc)
diff --git
a/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/impl/LinkisDataSourceRemoteClient.scala
b/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/impl/LinkisDataSourceRemoteClient.scala
index bab51b2bc..5e71d7458 100644
---
a/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/impl/LinkisDataSourceRemoteClient.scala
+++
b/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/impl/LinkisDataSourceRemoteClient.scala
@@ -20,6 +20,7 @@ package org.apache.linkis.datasource.client.impl
import org.apache.linkis.common.conf.Configuration
import org.apache.linkis.datasource.client.{AbstractRemoteClient,
DataSourceRemoteClient}
import org.apache.linkis.datasource.client.config.DatasourceClientConfig._
+import
org.apache.linkis.datasource.client.errorcode.DatasourceClientErrorCodeSummary.SERVERURL_CANNOT_NULL
import
org.apache.linkis.datasource.client.exception.DataSourceClientBuilderException
import org.apache.linkis.datasource.client.request._
import org.apache.linkis.datasource.client.response._
@@ -47,7 +48,7 @@ class LinkisDataSourceRemoteClient(clientConfig:
DWSClientConfig, clientName: St
def createClientConfig(): DWSClientConfig = {
val serverUrl = Configuration.getGateWayURL()
if (StringUtils.isEmpty(serverUrl)) {
- throw new DataSourceClientBuilderException("serverUrl cannot be null.")
+ throw new
DataSourceClientBuilderException(SERVERURL_CANNOT_NULL.getErrorDesc)
}
val maxConnection: Int = CONNECTION_MAX_SIZE.getValue
diff --git
a/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/DataSourceTestConnectAction.scala
b/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/DataSourceTestConnectAction.scala
index 3818c5599..6c4050172 100644
---
a/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/DataSourceTestConnectAction.scala
+++
b/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/DataSourceTestConnectAction.scala
@@ -18,6 +18,7 @@
package org.apache.linkis.datasource.client.request
import
org.apache.linkis.datasource.client.config.DatasourceClientConfig.DATA_SOURCE_SERVICE_MODULE
+import
org.apache.linkis.datasource.client.errorcode.DatasourceClientErrorCodeSummary._
import
org.apache.linkis.datasource.client.exception.DataSourceClientBuilderException
import org.apache.linkis.httpclient.dws.DWSHttpClient
import org.apache.linkis.httpclient.request.PutAction
@@ -66,10 +67,10 @@ object DataSourceTestConnectAction {
def build(): DataSourceTestConnectAction = {
if (dataSourceId == null) {
- throw new DataSourceClientBuilderException("dataSourceId is needed!")
+ throw new
DataSourceClientBuilderException(DATASOURCEID_NEEDED.getErrorDesc)
}
- if (version == null) throw new DataSourceClientBuilderException("version
is needed!")
- if (user == null) throw new DataSourceClientBuilderException("user is
needed!")
+ if (version == null) throw new
DataSourceClientBuilderException(VERSION_NEEDED.getErrorDesc)
+ if (user == null) throw new
DataSourceClientBuilderException(USER_NEEDED.getErrorDesc)
val action = new DataSourceTestConnectAction()
action.dataSourceId = dataSourceId
diff --git
a/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/DeleteDataSourceAction.scala
b/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/DeleteDataSourceAction.scala
index d29e98c5a..c405d46e0 100644
---
a/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/DeleteDataSourceAction.scala
+++
b/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/DeleteDataSourceAction.scala
@@ -18,6 +18,7 @@
package org.apache.linkis.datasource.client.request
import
org.apache.linkis.datasource.client.config.DatasourceClientConfig.DATA_SOURCE_SERVICE_MODULE
+import
org.apache.linkis.datasource.client.errorcode.DatasourceClientErrorCodeSummary._
import
org.apache.linkis.datasource.client.exception.DataSourceClientBuilderException
import org.apache.linkis.httpclient.request.DeleteAction
@@ -53,9 +54,9 @@ object DeleteDataSourceAction {
}
def builder(): DeleteDataSourceAction = {
- if (user == null) throw new DataSourceClientBuilderException("user is
needed!")
+ if (user == null) throw new
DataSourceClientBuilderException(USER_NEEDED.getErrorDesc)
if (dataSourceId == null) {
- throw new DataSourceClientBuilderException("dataSourceId is needed!")
+ throw new
DataSourceClientBuilderException(DATASOURCEID_NEEDED.getErrorDesc)
}
val action = new DeleteDataSourceAction
diff --git
a/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/ExpireDataSourceAction.scala
b/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/ExpireDataSourceAction.scala
index 5064a8ca6..bbcf537ac 100644
---
a/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/ExpireDataSourceAction.scala
+++
b/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/ExpireDataSourceAction.scala
@@ -18,6 +18,7 @@
package org.apache.linkis.datasource.client.request
import
org.apache.linkis.datasource.client.config.DatasourceClientConfig.DATA_SOURCE_SERVICE_MODULE
+import
org.apache.linkis.datasource.client.errorcode.DatasourceClientErrorCodeSummary._
import
org.apache.linkis.datasource.client.exception.DataSourceClientBuilderException
import org.apache.linkis.httpclient.request.PutAction
@@ -56,9 +57,9 @@ object ExpireDataSourceAction {
def build(): ExpireDataSourceAction = {
if (dataSourceId == null) {
- throw new DataSourceClientBuilderException("dataSourceId is needed!")
+ throw new
DataSourceClientBuilderException(DATASOURCEID_NEEDED.getErrorDesc)
}
- if (user == null) throw new DataSourceClientBuilderException("user is
needed!")
+ if (user == null) throw new
DataSourceClientBuilderException(USER_NEEDED.getErrorDesc)
val action = new ExpireDataSourceAction()
action.dataSourceId = dataSourceId
diff --git
a/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/GetConnectParamsByDataSourceIdAction.scala
b/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/GetConnectParamsByDataSourceIdAction.scala
index 1d434c12b..452187ac9 100644
---
a/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/GetConnectParamsByDataSourceIdAction.scala
+++
b/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/GetConnectParamsByDataSourceIdAction.scala
@@ -18,6 +18,7 @@
package org.apache.linkis.datasource.client.request
import
org.apache.linkis.datasource.client.config.DatasourceClientConfig.DATA_SOURCE_SERVICE_MODULE
+import
org.apache.linkis.datasource.client.errorcode.DatasourceClientErrorCodeSummary._
import
org.apache.linkis.datasource.client.exception.DataSourceClientBuilderException
import org.apache.linkis.httpclient.request.GetAction
@@ -59,9 +60,9 @@ object GetConnectParamsByDataSourceIdAction {
def build(): GetConnectParamsByDataSourceIdAction = {
if (dataSourceId == null) {
- throw new DataSourceClientBuilderException("dataSourceId is needed!")
+ throw new
DataSourceClientBuilderException(DATASOURCEID_NEEDED.getErrorDesc)
}
- if (user == null) throw new DataSourceClientBuilderException("user is
needed!")
+ if (user == null) throw new
DataSourceClientBuilderException(USER_NEEDED.getErrorDesc)
val getConnectParamsByDataSourceIdAction = new
GetConnectParamsByDataSourceIdAction
getConnectParamsByDataSourceIdAction.dataSourceId = this.dataSourceId
diff --git
a/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/GetConnectParamsByDataSourceNameAction.scala
b/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/GetConnectParamsByDataSourceNameAction.scala
index ea30ed91d..ae75fca76 100644
---
a/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/GetConnectParamsByDataSourceNameAction.scala
+++
b/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/GetConnectParamsByDataSourceNameAction.scala
@@ -18,6 +18,7 @@
package org.apache.linkis.datasource.client.request
import
org.apache.linkis.datasource.client.config.DatasourceClientConfig.DATA_SOURCE_SERVICE_MODULE
+import
org.apache.linkis.datasource.client.errorcode.DatasourceClientErrorCodeSummary._
import
org.apache.linkis.datasource.client.exception.DataSourceClientBuilderException
import org.apache.linkis.httpclient.request.GetAction
@@ -65,10 +66,10 @@ object GetConnectParamsByDataSourceNameAction {
def build(): GetConnectParamsByDataSourceNameAction = {
if (dataSourceName == null) {
- throw new DataSourceClientBuilderException("dataSourceName is needed!")
+ throw new
DataSourceClientBuilderException(DATASOURCENAME_NEEDED.getErrorDesc)
}
- if (system == null) throw new DataSourceClientBuilderException("system
is needed!")
- if (user == null) throw new DataSourceClientBuilderException("user is
needed!")
+ if (system == null) throw new
DataSourceClientBuilderException(SYSTEM_NEEDED.getErrorDesc)
+ if (user == null) throw new
DataSourceClientBuilderException(USER_NEEDED.getErrorDesc)
// Use URIEncoder to encode the datSourceName
var requestDataSourceName = this.dataSourceName
try {
diff --git
a/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/GetDataSourceVersionsAction.scala
b/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/GetDataSourceVersionsAction.scala
index e92ea0730..0ba78bd7a 100644
---
a/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/GetDataSourceVersionsAction.scala
+++
b/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/GetDataSourceVersionsAction.scala
@@ -18,6 +18,7 @@
package org.apache.linkis.datasource.client.request
import
org.apache.linkis.datasource.client.config.DatasourceClientConfig.DATA_SOURCE_SERVICE_MODULE
+import
org.apache.linkis.datasource.client.errorcode.DatasourceClientErrorCodeSummary._
import
org.apache.linkis.datasource.client.exception.DataSourceClientBuilderException
import org.apache.linkis.httpclient.request.GetAction
@@ -53,9 +54,9 @@ object GetDataSourceVersionsAction {
def build(): GetDataSourceVersionsAction = {
if (dataSourceId == null) {
- throw new DataSourceClientBuilderException("dataSourceId is needed!")
+ throw new
DataSourceClientBuilderException(DATASOURCEID_NEEDED.getErrorDesc)
}
- if (user == null) throw new DataSourceClientBuilderException("user is
needed!")
+ if (user == null) throw new
DataSourceClientBuilderException(USER_NEEDED.getErrorDesc)
val action = new GetDataSourceVersionsAction
action.user = user
diff --git
a/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/GetInfoByDataSourceIdAction.scala
b/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/GetInfoByDataSourceIdAction.scala
index deda1ff91..e96d088ca 100644
---
a/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/GetInfoByDataSourceIdAction.scala
+++
b/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/GetInfoByDataSourceIdAction.scala
@@ -18,6 +18,7 @@
package org.apache.linkis.datasource.client.request
import
org.apache.linkis.datasource.client.config.DatasourceClientConfig.DATA_SOURCE_SERVICE_MODULE
+import
org.apache.linkis.datasource.client.errorcode.DatasourceClientErrorCodeSummary._
import
org.apache.linkis.datasource.client.exception.DataSourceClientBuilderException
import org.apache.linkis.httpclient.request.GetAction
@@ -59,10 +60,10 @@ object GetInfoByDataSourceIdAction {
def build(): GetInfoByDataSourceIdAction = {
if (dataSourceId == null) {
- throw new DataSourceClientBuilderException("dataSourceId is needed!")
+ throw new
DataSourceClientBuilderException(DATASOURCEID_NEEDED.getErrorDesc)
}
- if (system == null) throw new DataSourceClientBuilderException("system
is needed!")
- if (user == null) throw new DataSourceClientBuilderException("user is
needed!")
+ if (system == null) throw new
DataSourceClientBuilderException(SYSTEM_NEEDED.getErrorDesc)
+ if (user == null) throw new
DataSourceClientBuilderException(USER_NEEDED.getErrorDesc)
val getInfoByDataSourceIdAction = new GetInfoByDataSourceIdAction
getInfoByDataSourceIdAction.dataSourceId = this.dataSourceId
diff --git
a/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/GetInfoByDataSourceNameAction.scala
b/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/GetInfoByDataSourceNameAction.scala
index 0487ea4c2..5b1b68c02 100644
---
a/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/GetInfoByDataSourceNameAction.scala
+++
b/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/GetInfoByDataSourceNameAction.scala
@@ -18,6 +18,7 @@
package org.apache.linkis.datasource.client.request
import
org.apache.linkis.datasource.client.config.DatasourceClientConfig.DATA_SOURCE_SERVICE_MODULE
+import
org.apache.linkis.datasource.client.errorcode.DatasourceClientErrorCodeSummary._
import
org.apache.linkis.datasource.client.exception.DataSourceClientBuilderException
import org.apache.linkis.httpclient.request.GetAction
@@ -59,10 +60,10 @@ object GetInfoByDataSourceNameAction {
def build(): GetInfoByDataSourceNameAction = {
if (dataSourceName == null) {
- throw new DataSourceClientBuilderException("dataSourceName is needed!")
+ throw new
DataSourceClientBuilderException(DATASOURCENAME_NEEDED.getErrorDesc)
}
- if (system == null) throw new DataSourceClientBuilderException("system
is needed!")
- if (user == null) throw new DataSourceClientBuilderException("user is
needed!")
+ if (system == null) throw new
DataSourceClientBuilderException(SYSTEM_NEEDED.getErrorDesc)
+ if (user == null) throw new
DataSourceClientBuilderException(USER_NEEDED.getErrorDesc)
val getInfoByDataSourceNameAction = new GetInfoByDataSourceNameAction
getInfoByDataSourceNameAction.dataSourceName = this.dataSourceName
diff --git
a/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/GetInfoPublishedByDataSourceNameAction.scala
b/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/GetInfoPublishedByDataSourceNameAction.scala
index 23eb39876..b450d763f 100644
---
a/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/GetInfoPublishedByDataSourceNameAction.scala
+++
b/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/GetInfoPublishedByDataSourceNameAction.scala
@@ -18,6 +18,7 @@
package org.apache.linkis.datasource.client.request
import
org.apache.linkis.datasource.client.config.DatasourceClientConfig.DATA_SOURCE_SERVICE_MODULE
+import
org.apache.linkis.datasource.client.errorcode.DatasourceClientErrorCodeSummary._
import
org.apache.linkis.datasource.client.exception.DataSourceClientBuilderException
import org.apache.linkis.httpclient.request.GetAction
@@ -59,10 +60,10 @@ object GetInfoPublishedByDataSourceNameAction {
def build(): GetInfoPublishedByDataSourceNameAction = {
if (dataSourceName == null) {
- throw new DataSourceClientBuilderException("dataSourceName is needed!")
+ throw new
DataSourceClientBuilderException(DATASOURCENAME_NEEDED.getErrorDesc)
}
- if (system == null) throw new DataSourceClientBuilderException("system
is needed!")
- if (user == null) throw new DataSourceClientBuilderException("user is
needed!")
+ if (system == null) throw new
DataSourceClientBuilderException(SYSTEM_NEEDED.getErrorDesc)
+ if (user == null) throw new
DataSourceClientBuilderException(USER_NEEDED.getErrorDesc)
val getPublishedInfoByDataSourceNameAction = new
GetInfoPublishedByDataSourceNameAction
getPublishedInfoByDataSourceNameAction.dataSourceName =
this.dataSourceName
diff --git
a/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/GetKeyTypeDatasourceAction.scala
b/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/GetKeyTypeDatasourceAction.scala
index 0af5efc5c..bb972d98e 100644
---
a/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/GetKeyTypeDatasourceAction.scala
+++
b/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/GetKeyTypeDatasourceAction.scala
@@ -18,6 +18,7 @@
package org.apache.linkis.datasource.client.request
import
org.apache.linkis.datasource.client.config.DatasourceClientConfig.DATA_SOURCE_SERVICE_MODULE
+import
org.apache.linkis.datasource.client.errorcode.DatasourceClientErrorCodeSummary._
import
org.apache.linkis.datasource.client.exception.DataSourceClientBuilderException
import org.apache.linkis.httpclient.request.GetAction
@@ -52,7 +53,7 @@ object GetKeyTypeDatasourceAction {
}
def build(): GetKeyTypeDatasourceAction = {
- if (user == null) throw new DataSourceClientBuilderException("user is
needed!")
+ if (user == null) throw new
DataSourceClientBuilderException(USER_NEEDED.getErrorDesc)
val getKeyTypeDatasourceAction = new GetKeyTypeDatasourceAction
getKeyTypeDatasourceAction.dataSourceTypeId = this.dataSourceTypeId
diff --git
a/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/MetadataGetColumnsAction.scala
b/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/MetadataGetColumnsAction.scala
index f09d939c4..7729747af 100644
---
a/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/MetadataGetColumnsAction.scala
+++
b/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/MetadataGetColumnsAction.scala
@@ -18,6 +18,7 @@
package org.apache.linkis.datasource.client.request
import
org.apache.linkis.datasource.client.config.DatasourceClientConfig.METADATA_SERVICE_MODULE
+import
org.apache.linkis.datasource.client.errorcode.DatasourceClientErrorCodeSummary._
import
org.apache.linkis.datasource.client.exception.DataSourceClientBuilderException
import org.apache.linkis.httpclient.request.GetAction
@@ -74,12 +75,12 @@ object MetadataGetColumnsAction {
def build(): MetadataGetColumnsAction = {
if (dataSourceName == null) {
- throw new DataSourceClientBuilderException("dataSourceName is needed!")
+ throw new
DataSourceClientBuilderException(DATASOURCENAME_NEEDED.getErrorDesc)
}
- if (database == null) throw new
DataSourceClientBuilderException("database is needed!")
- if (table == null) throw new DataSourceClientBuilderException("table is
needed!")
- if (system == null) throw new DataSourceClientBuilderException("system
is needed!")
- if (user == null) throw new DataSourceClientBuilderException("user is
needed!")
+ if (database == null) throw new
DataSourceClientBuilderException(DATABASE_NEEDED.getErrorDesc)
+ if (table == null) throw new
DataSourceClientBuilderException(TABLE_NEEDED.getErrorDesc)
+ if (system == null) throw new
DataSourceClientBuilderException(SYSTEM_NEEDED.getErrorDesc)
+ if (user == null) throw new
DataSourceClientBuilderException(USER_NEEDED.getErrorDesc)
val metadataGetColumnsAction = new MetadataGetColumnsAction
metadataGetColumnsAction.dataSourceName = this.dataSourceName
diff --git
a/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/MetadataGetDatabasesAction.scala
b/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/MetadataGetDatabasesAction.scala
index ae9cd6953..3287dafba 100644
---
a/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/MetadataGetDatabasesAction.scala
+++
b/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/MetadataGetDatabasesAction.scala
@@ -18,6 +18,7 @@
package org.apache.linkis.datasource.client.request
import
org.apache.linkis.datasource.client.config.DatasourceClientConfig.METADATA_SERVICE_MODULE
+import
org.apache.linkis.datasource.client.errorcode.DatasourceClientErrorCodeSummary._
import
org.apache.linkis.datasource.client.exception.DataSourceClientBuilderException
import org.apache.linkis.httpclient.request.GetAction
@@ -59,10 +60,10 @@ object MetadataGetDatabasesAction {
def build(): MetadataGetDatabasesAction = {
if (dataSourceName == null) {
- throw new DataSourceClientBuilderException("dataSourceName is needed!")
+ throw new
DataSourceClientBuilderException(DATASOURCENAME_NEEDED.getErrorDesc)
}
- if (system == null) throw new DataSourceClientBuilderException("system
is needed!")
- if (user == null) throw new DataSourceClientBuilderException("user is
needed!")
+ if (system == null) throw new
DataSourceClientBuilderException(SYSTEM_NEEDED.getErrorDesc)
+ if (user == null) throw new
DataSourceClientBuilderException(USER_NEEDED.getErrorDesc)
val metadataGetDatabasesAction = new MetadataGetDatabasesAction
metadataGetDatabasesAction.dataSourceName = this.dataSourceName
diff --git
a/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/MetadataGetPartitionsAction.scala
b/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/MetadataGetPartitionsAction.scala
index 6d4c02d03..f17552c6c 100644
---
a/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/MetadataGetPartitionsAction.scala
+++
b/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/MetadataGetPartitionsAction.scala
@@ -18,6 +18,7 @@
package org.apache.linkis.datasource.client.request
import
org.apache.linkis.datasource.client.config.DatasourceClientConfig.METADATA_SERVICE_MODULE
+import
org.apache.linkis.datasource.client.errorcode.DatasourceClientErrorCodeSummary._
import
org.apache.linkis.datasource.client.exception.DataSourceClientBuilderException
import org.apache.linkis.httpclient.request.GetAction
@@ -80,11 +81,11 @@ object MetadataGetPartitionsAction {
def build(): MetadataGetPartitionsAction = {
if (dataSourceName == null) {
- throw new DataSourceClientBuilderException("dataSourceName is needed!")
+ throw new
DataSourceClientBuilderException(DATASOURCENAME_NEEDED.getErrorDesc)
}
- if (database == null) throw new
DataSourceClientBuilderException("database is needed!")
- if (table == null) throw new DataSourceClientBuilderException("table is
needed!")
- if (system == null) throw new DataSourceClientBuilderException("system
is needed!")
+ if (database == null) throw new
DataSourceClientBuilderException(DATABASE_NEEDED.getErrorDesc)
+ if (table == null) throw new
DataSourceClientBuilderException(TABLE_NEEDED.getErrorDesc)
+ if (system == null) throw new
DataSourceClientBuilderException(SYSTEM_NEEDED.getErrorDesc)
val metadataGetPartitionsAction = new MetadataGetPartitionsAction
metadataGetPartitionsAction.dataSourceName = this.dataSourceName
diff --git
a/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/MetadataGetTablePropsAction.scala
b/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/MetadataGetTablePropsAction.scala
index aaeb8d39f..fd41d70da 100644
---
a/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/MetadataGetTablePropsAction.scala
+++
b/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/MetadataGetTablePropsAction.scala
@@ -18,6 +18,7 @@
package org.apache.linkis.datasource.client.request
import
org.apache.linkis.datasource.client.config.DatasourceClientConfig.METADATA_SERVICE_MODULE
+import
org.apache.linkis.datasource.client.errorcode.DatasourceClientErrorCodeSummary._
import
org.apache.linkis.datasource.client.exception.DataSourceClientBuilderException
import org.apache.linkis.httpclient.request.GetAction
@@ -74,12 +75,12 @@ object MetadataGetTablePropsAction {
def build(): MetadataGetTablePropsAction = {
if (dataSourceName == null) {
- throw new DataSourceClientBuilderException("dataSourceName is needed!")
+ throw new
DataSourceClientBuilderException(DATASOURCENAME_NEEDED.getErrorDesc)
}
- if (database == null) throw new
DataSourceClientBuilderException("database is needed!")
- if (table == null) throw new DataSourceClientBuilderException("table is
needed!")
- if (system == null) throw new DataSourceClientBuilderException("system
is needed!")
- if (user == null) throw new DataSourceClientBuilderException("user is
needed!")
+ if (database == null) throw new
DataSourceClientBuilderException(DATABASE_NEEDED.getErrorDesc)
+ if (table == null) throw new
DataSourceClientBuilderException(TABLE_NEEDED.getErrorDesc)
+ if (system == null) throw new
DataSourceClientBuilderException(SYSTEM_NEEDED.getErrorDesc)
+ if (user == null) throw new
DataSourceClientBuilderException(USER_NEEDED.getErrorDesc)
val metadataGetTablePropsAction = new MetadataGetTablePropsAction
metadataGetTablePropsAction.dataSourceName = this.dataSourceName
diff --git
a/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/MetadataGetTablesAction.scala
b/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/MetadataGetTablesAction.scala
index e3b705180..5c28ea028 100644
---
a/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/MetadataGetTablesAction.scala
+++
b/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/MetadataGetTablesAction.scala
@@ -18,6 +18,7 @@
package org.apache.linkis.datasource.client.request
import
org.apache.linkis.datasource.client.config.DatasourceClientConfig.METADATA_SERVICE_MODULE
+import
org.apache.linkis.datasource.client.errorcode.DatasourceClientErrorCodeSummary._
import
org.apache.linkis.datasource.client.exception.DataSourceClientBuilderException
import org.apache.linkis.httpclient.request.GetAction
@@ -65,11 +66,11 @@ object MetadataGetTablesAction {
def build(): MetadataGetTablesAction = {
if (dataSourceName == null) {
- throw new DataSourceClientBuilderException("dataSourceName is needed!")
+ throw new
DataSourceClientBuilderException(DATASOURCENAME_NEEDED.getErrorDesc)
}
- if (database == null) throw new
DataSourceClientBuilderException("database is needed!")
- if (system == null) throw new DataSourceClientBuilderException("system
is needed!")
- if (user == null) throw new DataSourceClientBuilderException("user is
needed!")
+ if (database == null) throw new
DataSourceClientBuilderException(DATABASE_NEEDED.getErrorDesc)
+ if (system == null) throw new
DataSourceClientBuilderException(SYSTEM_NEEDED.getErrorDesc)
+ if (user == null) throw new
DataSourceClientBuilderException(USER_NEEDED.getErrorDesc)
val metadataGetTablesAction = new MetadataGetTablesAction
metadataGetTablesAction.dataSourceName = this.dataSourceName
diff --git
a/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/PublishDataSourceVersionAction.scala
b/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/PublishDataSourceVersionAction.scala
index 60f2d307b..bc3c6051b 100644
---
a/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/PublishDataSourceVersionAction.scala
+++
b/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/PublishDataSourceVersionAction.scala
@@ -18,6 +18,7 @@
package org.apache.linkis.datasource.client.request
import
org.apache.linkis.datasource.client.config.DatasourceClientConfig.DATA_SOURCE_SERVICE_MODULE
+import
org.apache.linkis.datasource.client.errorcode.DatasourceClientErrorCodeSummary._
import
org.apache.linkis.datasource.client.exception.DataSourceClientBuilderException
import org.apache.linkis.httpclient.dws.DWSHttpClient
import org.apache.linkis.httpclient.request.POSTAction
@@ -65,10 +66,11 @@ object PublishDataSourceVersionAction {
def build(): PublishDataSourceVersionAction = {
if (dataSourceId == null) {
- throw new DataSourceClientBuilderException("dataSourceId is needed!")
+ throw new
DataSourceClientBuilderException(DATASOURCEID_NEEDED.getErrorDesc)
}
- if (versionId == null) throw new
DataSourceClientBuilderException("versionId is needed!")
- if (user == null) throw new DataSourceClientBuilderException("user is
needed!")
+ if (versionId == null)
+ throw new
DataSourceClientBuilderException(VERSIONID_NEEDED.getErrorDesc)
+ if (user == null) throw new
DataSourceClientBuilderException(USER_NEEDED.getErrorDesc)
val action = new PublishDataSourceVersionAction()
action.dataSourceId = dataSourceId
diff --git
a/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/QueryDataSourceAction.scala
b/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/QueryDataSourceAction.scala
index a83d90851..17170f092 100644
---
a/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/QueryDataSourceAction.scala
+++
b/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/QueryDataSourceAction.scala
@@ -18,6 +18,7 @@
package org.apache.linkis.datasource.client.request
import
org.apache.linkis.datasource.client.config.DatasourceClientConfig.DATA_SOURCE_SERVICE_MODULE
+import
org.apache.linkis.datasource.client.errorcode.DatasourceClientErrorCodeSummary._
import
org.apache.linkis.datasource.client.exception.DataSourceClientBuilderException
import org.apache.linkis.httpclient.request.GetAction
@@ -79,7 +80,7 @@ object QueryDataSourceAction {
}
def build(): QueryDataSourceAction = {
- if (user == null) throw new DataSourceClientBuilderException("user is
needed!")
+ if (user == null) throw new
DataSourceClientBuilderException(USER_NEEDED.getErrorDesc)
val queryDataSourceAction = new QueryDataSourceAction
if (system != null) {
diff --git
a/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/QueryDataSourceEnvAction.scala
b/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/QueryDataSourceEnvAction.scala
index 30ab5c28e..f24203177 100644
---
a/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/QueryDataSourceEnvAction.scala
+++
b/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/QueryDataSourceEnvAction.scala
@@ -18,6 +18,7 @@
package org.apache.linkis.datasource.client.request
import
org.apache.linkis.datasource.client.config.DatasourceClientConfig.DATA_SOURCE_SERVICE_MODULE
+import
org.apache.linkis.datasource.client.errorcode.DatasourceClientErrorCodeSummary._
import
org.apache.linkis.datasource.client.exception.DataSourceClientBuilderException
import org.apache.linkis.httpclient.request.GetAction
@@ -67,7 +68,7 @@ object QueryDataSourceEnvAction {
}
def build(): QueryDataSourceEnvAction = {
- if (user == null) throw new DataSourceClientBuilderException("user is
needed!")
+ if (user == null) throw new
DataSourceClientBuilderException(USER_NEEDED.getErrorDesc)
val queryDataSourceEnvAction = new QueryDataSourceEnvAction
diff --git
a/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/UpdateDataSourceAction.scala
b/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/UpdateDataSourceAction.scala
index 9d673d1ef..0891fcc05 100644
---
a/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/UpdateDataSourceAction.scala
+++
b/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/UpdateDataSourceAction.scala
@@ -18,6 +18,7 @@
package org.apache.linkis.datasource.client.request
import
org.apache.linkis.datasource.client.config.DatasourceClientConfig.DATA_SOURCE_SERVICE_MODULE
+import
org.apache.linkis.datasource.client.errorcode.DatasourceClientErrorCodeSummary._
import
org.apache.linkis.datasource.client.exception.DataSourceClientBuilderException
import org.apache.linkis.httpclient.dws.DWSHttpClient
import org.apache.linkis.httpclient.request.PutAction
@@ -73,9 +74,9 @@ object UpdateDataSourceAction {
def build(): UpdateDataSourceAction = {
if (dataSourceId == null) {
- throw new DataSourceClientBuilderException("dataSourceId is needed!")
+ throw new
DataSourceClientBuilderException(DATASOURCEID_NEEDED.getErrorDesc)
}
- if (user == null) throw new DataSourceClientBuilderException("user is
needed!")
+ if (user == null) throw new
DataSourceClientBuilderException(USER_NEEDED.getErrorDesc)
val action = new UpdateDataSourceAction()
action.dataSourceId = dataSourceId
diff --git
a/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/UpdateDataSourceParameterAction.scala
b/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/UpdateDataSourceParameterAction.scala
index 78cc61c60..4786acfc1 100644
---
a/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/UpdateDataSourceParameterAction.scala
+++
b/linkis-public-enhancements/linkis-datasource/linkis-datasource-client/src/main/scala/org/apache/linkis/datasource/client/request/UpdateDataSourceParameterAction.scala
@@ -18,6 +18,7 @@
package org.apache.linkis.datasource.client.request
import
org.apache.linkis.datasource.client.config.DatasourceClientConfig.DATA_SOURCE_SERVICE_MODULE
+import
org.apache.linkis.datasource.client.errorcode.DatasourceClientErrorCodeSummary._
import
org.apache.linkis.datasource.client.exception.DataSourceClientBuilderException
import org.apache.linkis.httpclient.dws.DWSHttpClient
import org.apache.linkis.httpclient.request.POSTAction
@@ -73,9 +74,9 @@ object UpdateDataSourceParameterAction {
def build(): UpdateDataSourceParameterAction = {
if (dataSourceId == null) {
- throw new DataSourceClientBuilderException("dataSourceId is needed!")
+ throw new
DataSourceClientBuilderException(DATASOURCEID_NEEDED.getErrorDesc)
}
- if (user == null) throw new DataSourceClientBuilderException("user is
needed!")
+ if (user == null) throw new
DataSourceClientBuilderException(USER_NEEDED.getErrorDesc)
val action = new UpdateDataSourceParameterAction()
action.dataSourceId = dataSourceId
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
