Updated on 2026-09-18 GMT+08:00

Updating Data Connection Information

Function

This API is used to update information about a data connection.

Calling Method

For details, see Calling APIs.

Authorization Information

Each account has all the permissions required to call all APIs, but IAM users must be assigned the required permissions.

  • If you are using role/policy-based authorization, see Permissions Policies and Supported Actions for details on the required permissions.
  • If you are using identity policy-based authorization, no identity policy-based permission required for calling this API.

URI

PUT /v1/{project_id}/data-connections/{data_connection_id}

Table 1 Path Parameters

Parameter

Mandatory

Type

Description

data_connection_id

Yes

String

Data connection ID, which can be obtained from the data connection list.

project_id

Yes

String

Project ID. For details about how to obtain it, see Project ID and Account ID

Request Parameters

Table 2 Request header parameters

Parameter

Mandatory

Type

Description

X-Auth-Token

Yes

String

User token. This parameter is mandatory when token authentication is used. You can obtain it from the value of X-Subject-Token in the response message header returned by the "Obtaining a User Token" API of the IAM service.

workspace

Yes

String

Workspace ID. For details about how to obtain it, see Instance ID and Workspace ID.

Table 3 Request body parameters

Parameter

Mandatory

Type

Description

data_source_vos

Yes

Array of ApigDataSourceVo objects

Data source structure

mode

No

Integer

Workspace mode. The options are 0 (simple mode) and 1 (enterprise mode). The default value is 0.

Table 4 ApigDataSourceVo

Parameter

Mandatory

Type

Description

dw_name

Yes

String

Data connection type, which is customized during connection creation and obtained from Querying the Data Connection List during connection editting.

dw_type

Yes

String

Data connection type, for example, DWS, DLI, Hive, RDS, or SparkSQL. You can view all data connection types on the console and obtain data connections from Data Connections.

dw_config

Yes

Object

Configuration items for the data connection. They vary depending on the connection type. You are advised to debug them on the console.

agent_name

No

String

CDM cluster name. For details about how to obtain it, see Listing Clusters. In most scenarios, you need to specify the cluster to use. You can confirm whether this parameter is mandatory on the console.

agent_id

No

String

CDM cluster ID. For details about how to obtain it, see Listing Clusters. In most scenarios, you need to specify the cluster to use. You can confirm whether this parameter is mandatory on the console.

support_service

No

String

Applicable components that are allowed to use this data connection. You are advised to select the required components on the console and perform debugging to obtain the corresponding parameter values. By default, all applicable components supported by the connection configuration are selected.

description

No

String

Data connection description.

dw_category

No

String

Data connection label.

env_type

No

Integer

Environment type. This parameter does not need to be set for simple-mode workspaces. For enterprise-mode workspaces, data connections are distinguished by environment.

Options:

  • 1: Development environment.

  • 2: Production environment.

create_user

No

String

Data connection creator

create_time

No

Number

Data connection creation time, which is a timestamp

dw_id

No

String

Data connection ID, which can be obtained from ListDataconnections.xml.

qualified_name

No

String

Qualified data connection name

Response Parameters

Status code: 200

The data connection information is updated.

Status code: 400

Table 5 Response body parameters

Parameter

Type

Description

error_msg

String

Returned error information.

error_code

String

Returned error code.

Status code: 500

Table 6 Response body parameters

Parameter

Type

Description

error_msg

String

Returned error information.

error_code

String

Returned error code.

Example Requests

  • Update an MRS HBase data connection.

    /v1/0833a5737480d53b2f25c010dc1a7b88/data-connections/d06e52a4eb884b5c942b22d98b5947f8
    
    {
      "mode" : 0,
      "data_source_vos" : [ {
        "dw_config" : {
          "clusterId" : "353ff458-a560-413e-9b84-33f930cb8057",
          "clusterName" : "mrs_3x_autotest_do_not_del",
          "dbUserName" : "xxxxxx",
          "dbPassword" : "xxxxxx",
          "kmsId" : "a721616c-9a12-47b1-a805-3cfcd3e63cd7",
          "kmsName" : "KMS-1111",
          "mrsConnectionType" : "agent"
        },
        "dw_type" : "HBASE",
        "dw_name" : "test_hbase_01",
        "agent_id" : "91f81a12-75c5-43ce-aab8-7149ecef3b17",
        "agent_name" : "cdm-4autotest-nodelete",
        "create_user" : "",
        "create_time" : 1606879861750,
        "qualified_name" : "hive@192.168.0.4-dayu_cdc_w00591497.62099355b894428e8916573ae635f1f9-workspace-e96e2cddce4340acb61591f8f570059d",
        "description" : "Sample parameters.",
        "dw_category" : "test"
      } ]
    }
  • Update an RDS for MySQL data connection.

    /v1/0833a5737480d53b2f25c010dc1a7b88/data-connections/d06e52a4eb884b5c942b22d98b5947f8
    
    {
      "mode" : 0,
      "data_source_vos" : [ {
        "dw_config" : {
          "dbDriverName" : "com.mysql.jdbc.Driver",
          "configStorageType" : "USER_OBS",
          "driverPath" : "obs://obsbucket/driver/mysql-connector-java-5.1.44.jar",
          "ip" : "192.168.1.174",
          "port" : "3306",
          "dbUserName" : "********",
          "dbPassword" : "********",
          "kmsId" : "2d921482-bece-4183-b332-11ce324510e8",
          "kmsName" : "evs/default",
          "kmsSpec" : "AES_256",
          "cdmPropertyEnable" : false,
          "metadata.enableRealtimeSync" : false,
          "metadata.enableAutoCollection" : false
        },
        "dw_type" : "RDS",
        "dw_name" : "rds_mysql_connection",
        "agent_id" : "fbc429c3-3952-4b99-af17-d043b7216000",
        "agent_name" : "cdm-y60071169",
        "support_service" : 12,
        "create_user" : "",
        "create_time" : 1777777666666
      } ],
      "visible" : 1
    }

Example Responses

Status code: 200

The data connection information is updated.

{
  "is_success" : true,
  "message" : null
}

Status code: 400

Bad request.

{
  "error_code" : "DAYU.4402",
  "error_msg" : "The operation failed, detail msg {0}."
}

Status code: 500

Internal server error.

{
  "error_code" : "DAYU.3531",
  "error_msg" : "Internal server error: {0}"
}

SDK Sample Code

The SDK sample code is as follows.

  • Update an MRS HBase data connection.

     1
     2
     3
     4
     5
     6
     7
     8
     9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    28
    29
    30
    31
    32
    33
    34
    35
    36
    37
    38
    39
    40
    41
    42
    43
    44
    45
    46
    47
    48
    49
    50
    51
    52
    53
    54
    55
    56
    57
    58
    59
    60
    61
    62
    63
    64
    65
    package com.huaweicloud.sdk.test;
    
    import com.huaweicloud.sdk.core.auth.ICredential;
    import com.huaweicloud.sdk.core.auth.BasicCredentials;
    import com.huaweicloud.sdk.core.exception.ConnectionException;
    import com.huaweicloud.sdk.core.exception.RequestTimeoutException;
    import com.huaweicloud.sdk.core.exception.ServiceResponseException;
    import com.huaweicloud.sdk.dataartsstudio.v1.region.DataArtsStudioRegion;
    import com.huaweicloud.sdk.dataartsstudio.v1.*;
    import com.huaweicloud.sdk.dataartsstudio.v1.model.*;
    
    import java.util.List;
    import java.util.ArrayList;
    
    public class UpdateDataconnectionSolution {
    
        public static void main(String[] args) {
            // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great security risks. It is recommended that the AK and SK be stored in ciphertext in configuration files or environment variables and decrypted during use to ensure security.
            // In this example, AK and SK are stored in environment variables for authentication. Before running this example, set environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment
            String ak = System.getenv("CLOUD_SDK_AK");
            String sk = System.getenv("CLOUD_SDK_SK");
            String projectId = "{project_id}";
    
            ICredential auth = new BasicCredentials()
                    .withProjectId(projectId)
                    .withAk(ak)
                    .withSk(sk);
    
            DataArtsStudioClient client = DataArtsStudioClient.newBuilder()
                    .withCredential(auth)
                    .withRegion(DataArtsStudioRegion.valueOf("<YOUR REGION>"))
                    .build();
            UpdateDataconnectionRequest request = new UpdateDataconnectionRequest();
            request.withDataConnectionId("{data_connection_id}");
            ApigDataSourcesVo body = new ApigDataSourcesVo();
            List<ApigDataSourceVo> listbodyDataSourceVos = new ArrayList<>();
            listbodyDataSourceVos.add(
                new ApigDataSourceVo()
                    .withDwName("test_hbase_01")
                    .withDwType("HBASE")
                    .withDwConfig("{\"mrsConnectionType\":\"agent\",\"clusterName\":\"mrs_3x_autotest_do_not_del\",\"kmsName\":\"KMS-1111\",\"clusterId\":\"353ff458-a560-413e-9b84-33f930cb8057\",\"kmsId\":\"a721616c-9a12-47b1-a805-3cfcd3e63cd7\",\"dbUserName\":\"xxxxxx\",\"dbPassword\":\"xxxxxx\"}")
                    .withAgentId("91f81a12-75c5-43ce-aab8-7149ecef3b17")
                    .withAgentName("cdm-4autotest-nodelete")
                    .withDwCategory("test")
                    .withDescription("Sample parameters.")
            );
            body.withDataSourceVos(listbodyDataSourceVos);
            body.withMode(0);
            request.withBody(body);
            try {
                UpdateDataconnectionResponse response = client.updateDataconnection(request);
                System.out.println(response.toString());
            } catch (ConnectionException e) {
                e.printStackTrace();
            } catch (RequestTimeoutException e) {
                e.printStackTrace();
            } catch (ServiceResponseException e) {
                e.printStackTrace();
                System.out.println(e.getHttpStatusCode());
                System.out.println(e.getRequestId());
                System.out.println(e.getErrorCode());
                System.out.println(e.getErrorMsg());
            }
        }
    }
    
  • Update an RDS for MySQL data connection.

     1
     2
     3
     4
     5
     6
     7
     8
     9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    28
    29
    30
    31
    32
    33
    34
    35
    36
    37
    38
    39
    40
    41
    42
    43
    44
    45
    46
    47
    48
    49
    50
    51
    52
    53
    54
    55
    56
    57
    58
    59
    60
    61
    62
    63
    64
    package com.huaweicloud.sdk.test;
    
    import com.huaweicloud.sdk.core.auth.ICredential;
    import com.huaweicloud.sdk.core.auth.BasicCredentials;
    import com.huaweicloud.sdk.core.exception.ConnectionException;
    import com.huaweicloud.sdk.core.exception.RequestTimeoutException;
    import com.huaweicloud.sdk.core.exception.ServiceResponseException;
    import com.huaweicloud.sdk.dataartsstudio.v1.region.DataArtsStudioRegion;
    import com.huaweicloud.sdk.dataartsstudio.v1.*;
    import com.huaweicloud.sdk.dataartsstudio.v1.model.*;
    
    import java.util.List;
    import java.util.ArrayList;
    
    public class UpdateDataconnectionSolution {
    
        public static void main(String[] args) {
            // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great security risks. It is recommended that the AK and SK be stored in ciphertext in configuration files or environment variables and decrypted during use to ensure security.
            // In this example, AK and SK are stored in environment variables for authentication. Before running this example, set environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment
            String ak = System.getenv("CLOUD_SDK_AK");
            String sk = System.getenv("CLOUD_SDK_SK");
            String projectId = "{project_id}";
    
            ICredential auth = new BasicCredentials()
                    .withProjectId(projectId)
                    .withAk(ak)
                    .withSk(sk);
    
            DataArtsStudioClient client = DataArtsStudioClient.newBuilder()
                    .withCredential(auth)
                    .withRegion(DataArtsStudioRegion.valueOf("<YOUR REGION>"))
                    .build();
            UpdateDataconnectionRequest request = new UpdateDataconnectionRequest();
            request.withDataConnectionId("{data_connection_id}");
            ApigDataSourcesVo body = new ApigDataSourcesVo();
            List<ApigDataSourceVo> listbodyDataSourceVos = new ArrayList<>();
            listbodyDataSourceVos.add(
                new ApigDataSourceVo()
                    .withDwName("rds_mysql_connection")
                    .withDwType("RDS")
                    .withDwConfig("{\"driverPath\":\"obs://obsbucket/driver/mysql-connector-java-5.1.44.jar\",\"ip\":\"192.168.1.174\",\"kmsName\":\"evs/default\",\"dbUserName\":\"********\",\"metadata.enableAutoCollection\":false,\"configStorageType\":\"USER_OBS\",\"metadata.enableRealtimeSync\":false,\"port\":\"3306\",\"cdmPropertyEnable\":false,\"kmsSpec\":\"AES_256\",\"kmsId\":\"2d921482-bece-4183-b332-11ce324510e8\",\"dbDriverName\":\"com.mysql.jdbc.Driver\",\"dbPassword\":\"********\"}")
                    .withAgentId("fbc429c3-3952-4b99-af17-d043b7216000")
                    .withAgentName("cdm-y60071169")
            );
            body.withDataSourceVos(listbodyDataSourceVos);
            body.withVisible(1);
            body.withMode(0);
            request.withBody(body);
            try {
                UpdateDataconnectionResponse response = client.updateDataconnection(request);
                System.out.println(response.toString());
            } catch (ConnectionException e) {
                e.printStackTrace();
            } catch (RequestTimeoutException e) {
                e.printStackTrace();
            } catch (ServiceResponseException e) {
                e.printStackTrace();
                System.out.println(e.getHttpStatusCode());
                System.out.println(e.getRequestId());
                System.out.println(e.getErrorCode());
                System.out.println(e.getErrorMsg());
            }
        }
    }
    
  • Update an MRS HBase data connection.

     1
     2
     3
     4
     5
     6
     7
     8
     9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    28
    29
    30
    31
    32
    33
    34
    35
    36
    37
    38
    39
    40
    41
    42
    43
    44
    45
    46
    47
    # coding: utf-8
    
    import os
    from huaweicloudsdkcore.auth.credentials import BasicCredentials
    from huaweicloudsdkdataartsstudio.v1.region.dataartsstudio_region import DataArtsStudioRegion
    from huaweicloudsdkcore.exceptions import exceptions
    from huaweicloudsdkdataartsstudio.v1 import *
    
    if __name__ == "__main__":
        # The AK and SK used for authentication are hard-coded or stored in plaintext, which has great security risks. It is recommended that the AK and SK be stored in ciphertext in configuration files or environment variables and decrypted during use to ensure security.
        # In this example, AK and SK are stored in environment variables for authentication. Before running this example, set environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment
        ak = os.environ["CLOUD_SDK_AK"]
        sk = os.environ["CLOUD_SDK_SK"]
        projectId = "{project_id}"
    
        credentials = BasicCredentials(ak, sk, projectId)
    
        client = DataArtsStudioClient.new_builder() \
            .with_credentials(credentials) \
            .with_region(DataArtsStudioRegion.value_of("<YOUR REGION>")) \
            .build()
    
        try:
            request = UpdateDataconnectionRequest()
            request.data_connection_id = "{data_connection_id}"
            listDataSourceVosbody = [
                ApigDataSourceVo(
                    dw_name="test_hbase_01",
                    dw_type="HBASE",
                    dw_config="{\"mrsConnectionType\":\"agent\",\"clusterName\":\"mrs_3x_autotest_do_not_del\",\"kmsName\":\"KMS-1111\",\"clusterId\":\"353ff458-a560-413e-9b84-33f930cb8057\",\"kmsId\":\"a721616c-9a12-47b1-a805-3cfcd3e63cd7\",\"dbUserName\":\"xxxxxx\",\"dbPassword\":\"xxxxxx\"}",
                    agent_id="91f81a12-75c5-43ce-aab8-7149ecef3b17",
                    agent_name="cdm-4autotest-nodelete",
                    dw_category="test",
                    description="Sample parameters."
                )
            ]
            request.body = ApigDataSourcesVo(
                data_source_vos=listDataSourceVosbody,
                mode=0
            )
            response = client.update_dataconnection(request)
            print(response)
        except exceptions.ClientRequestException as e:
            print(e.status_code)
            print(e.request_id)
            print(e.error_code)
            print(e.error_msg)
    
  • Update an RDS for MySQL data connection.

     1
     2
     3
     4
     5
     6
     7
     8
     9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    28
    29
    30
    31
    32
    33
    34
    35
    36
    37
    38
    39
    40
    41
    42
    43
    44
    45
    46
    # coding: utf-8
    
    import os
    from huaweicloudsdkcore.auth.credentials import BasicCredentials
    from huaweicloudsdkdataartsstudio.v1.region.dataartsstudio_region import DataArtsStudioRegion
    from huaweicloudsdkcore.exceptions import exceptions
    from huaweicloudsdkdataartsstudio.v1 import *
    
    if __name__ == "__main__":
        # The AK and SK used for authentication are hard-coded or stored in plaintext, which has great security risks. It is recommended that the AK and SK be stored in ciphertext in configuration files or environment variables and decrypted during use to ensure security.
        # In this example, AK and SK are stored in environment variables for authentication. Before running this example, set environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment
        ak = os.environ["CLOUD_SDK_AK"]
        sk = os.environ["CLOUD_SDK_SK"]
        projectId = "{project_id}"
    
        credentials = BasicCredentials(ak, sk, projectId)
    
        client = DataArtsStudioClient.new_builder() \
            .with_credentials(credentials) \
            .with_region(DataArtsStudioRegion.value_of("<YOUR REGION>")) \
            .build()
    
        try:
            request = UpdateDataconnectionRequest()
            request.data_connection_id = "{data_connection_id}"
            listDataSourceVosbody = [
                ApigDataSourceVo(
                    dw_name="rds_mysql_connection",
                    dw_type="RDS",
                    dw_config="{\"driverPath\":\"obs://obsbucket/driver/mysql-connector-java-5.1.44.jar\",\"ip\":\"192.168.1.174\",\"kmsName\":\"evs/default\",\"dbUserName\":\"********\",\"metadata.enableAutoCollection\":false,\"configStorageType\":\"USER_OBS\",\"metadata.enableRealtimeSync\":false,\"port\":\"3306\",\"cdmPropertyEnable\":false,\"kmsSpec\":\"AES_256\",\"kmsId\":\"2d921482-bece-4183-b332-11ce324510e8\",\"dbDriverName\":\"com.mysql.jdbc.Driver\",\"dbPassword\":\"********\"}",
                    agent_id="fbc429c3-3952-4b99-af17-d043b7216000",
                    agent_name="cdm-y60071169"
                )
            ]
            request.body = ApigDataSourcesVo(
                data_source_vos=listDataSourceVosbody,
                visible=1,
                mode=0
            )
            response = client.update_dataconnection(request)
            print(response)
        except exceptions.ClientRequestException as e:
            print(e.status_code)
            print(e.request_id)
            print(e.error_code)
            print(e.error_msg)
    
  • Update an MRS HBase data connection.

     1
     2
     3
     4
     5
     6
     7
     8
     9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    28
    29
    30
    31
    32
    33
    34
    35
    36
    37
    38
    39
    40
    41
    42
    43
    44
    45
    46
    47
    48
    49
    50
    51
    52
    53
    54
    55
    56
    57
    58
    59
    60
    61
    62
    63
    64
    65
    66
    67
    68
    69
    70
    71
    72
    package main
    
    import (
    	"fmt"
    	"github.com/huaweicloud/huaweicloud-sdk-go-v3/core/auth/basic"
        dataartsstudio "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/dataartsstudio/v1"
    	"github.com/huaweicloud/huaweicloud-sdk-go-v3/services/dataartsstudio/v1/model"
        region "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/dataartsstudio/v1/region"
    )
    
    func main() {
        // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great security risks. It is recommended that the AK and SK be stored in ciphertext in configuration files or environment variables and decrypted during use to ensure security.
        // In this example, AK and SK are stored in environment variables for authentication. Before running this example, set environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment
        ak := os.Getenv("CLOUD_SDK_AK")
        sk := os.Getenv("CLOUD_SDK_SK")
        projectId := "{project_id}"
    
        auth, err := basic.NewCredentialsBuilder().
            WithAk(ak).
            WithSk(sk).
            WithProjectId(projectId).
            SafeBuild()
    
        if err != nil {
            fmt.Println(err)
            return
        }
    
        hcClient, err := dataartsstudio.DataArtsStudioClientBuilder().
             WithRegion(region.ValueOf("<YOUR REGION>")).
             WithCredential(auth).
             SafeBuild()
    
    
        if err != nil {
            fmt.Println(err)
            return
        }
    
        client := dataartsstudio.NewDataArtsStudioClient(hcClient)
    
        request := &model.UpdateDataconnectionRequest{}
    	request.DataConnectionId = "{data_connection_id}"
    	dwConfigDataSourceVos:= "{\"mrsConnectionType\":\"agent\",\"clusterName\":\"mrs_3x_autotest_do_not_del\",\"kmsName\":\"KMS-1111\",\"clusterId\":\"353ff458-a560-413e-9b84-33f930cb8057\",\"kmsId\":\"a721616c-9a12-47b1-a805-3cfcd3e63cd7\",\"dbUserName\":\"xxxxxx\",\"dbPassword\":\"xxxxxx\"}"
    	var dwConfigDataSourceVosInterface interface{} = dwConfigDataSourceVos
    	agentIdDataSourceVos:= "91f81a12-75c5-43ce-aab8-7149ecef3b17"
    	agentNameDataSourceVos:= "cdm-4autotest-nodelete"
    	dwCategoryDataSourceVos:= "test"
    	descriptionDataSourceVos:= "Sample parameters."
    	var listDataSourceVosbody = []model.ApigDataSourceVo{
            {
                DwName: "test_hbase_01",
                DwType: "HBASE",
                DwConfig: &dwConfigDataSourceVosInterface,
                AgentId: &agentIdDataSourceVos,
                AgentName: &agentNameDataSourceVos,
                DwCategory: &dwCategoryDataSourceVos,
                Description: &descriptionDataSourceVos,
            },
        }
    	modeApigDataSourcesVo:= int32(0)
    	request.Body = &model.ApigDataSourcesVo{
    		DataSourceVos: &listDataSourceVosbody,
    		Mode: &modeApigDataSourcesVo,
    	}
    	response, err := client.UpdateDataconnection(request)
    	if err == nil {
            fmt.Printf("%+v\n", response)
        } else {
            fmt.Println(err)
        }
    }
    
  • Update an RDS for MySQL data connection.

     1
     2
     3
     4
     5
     6
     7
     8
     9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    28
    29
    30
    31
    32
    33
    34
    35
    36
    37
    38
    39
    40
    41
    42
    43
    44
    45
    46
    47
    48
    49
    50
    51
    52
    53
    54
    55
    56
    57
    58
    59
    60
    61
    62
    63
    64
    65
    66
    67
    68
    69
    70
    package main
    
    import (
    	"fmt"
    	"github.com/huaweicloud/huaweicloud-sdk-go-v3/core/auth/basic"
        dataartsstudio "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/dataartsstudio/v1"
    	"github.com/huaweicloud/huaweicloud-sdk-go-v3/services/dataartsstudio/v1/model"
        region "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/dataartsstudio/v1/region"
    )
    
    func main() {
        // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great security risks. It is recommended that the AK and SK be stored in ciphertext in configuration files or environment variables and decrypted during use to ensure security.
        // In this example, AK and SK are stored in environment variables for authentication. Before running this example, set environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment
        ak := os.Getenv("CLOUD_SDK_AK")
        sk := os.Getenv("CLOUD_SDK_SK")
        projectId := "{project_id}"
    
        auth, err := basic.NewCredentialsBuilder().
            WithAk(ak).
            WithSk(sk).
            WithProjectId(projectId).
            SafeBuild()
    
        if err != nil {
            fmt.Println(err)
            return
        }
    
        hcClient, err := dataartsstudio.DataArtsStudioClientBuilder().
             WithRegion(region.ValueOf("<YOUR REGION>")).
             WithCredential(auth).
             SafeBuild()
    
    
        if err != nil {
            fmt.Println(err)
            return
        }
    
        client := dataartsstudio.NewDataArtsStudioClient(hcClient)
    
        request := &model.UpdateDataconnectionRequest{}
    	request.DataConnectionId = "{data_connection_id}"
    	dwConfigDataSourceVos:= "{\"driverPath\":\"obs://obsbucket/driver/mysql-connector-java-5.1.44.jar\",\"ip\":\"192.168.1.174\",\"kmsName\":\"evs/default\",\"dbUserName\":\"********\",\"metadata.enableAutoCollection\":false,\"configStorageType\":\"USER_OBS\",\"metadata.enableRealtimeSync\":false,\"port\":\"3306\",\"cdmPropertyEnable\":false,\"kmsSpec\":\"AES_256\",\"kmsId\":\"2d921482-bece-4183-b332-11ce324510e8\",\"dbDriverName\":\"com.mysql.jdbc.Driver\",\"dbPassword\":\"********\"}"
    	var dwConfigDataSourceVosInterface interface{} = dwConfigDataSourceVos
    	agentIdDataSourceVos:= "fbc429c3-3952-4b99-af17-d043b7216000"
    	agentNameDataSourceVos:= "cdm-y60071169"
    	var listDataSourceVosbody = []model.ApigDataSourceVo{
            {
                DwName: "rds_mysql_connection",
                DwType: "RDS",
                DwConfig: &dwConfigDataSourceVosInterface,
                AgentId: &agentIdDataSourceVos,
                AgentName: &agentNameDataSourceVos,
            },
        }
    	visibleApigDataSourcesVo:= int32(1)
    	modeApigDataSourcesVo:= int32(0)
    	request.Body = &model.ApigDataSourcesVo{
    		DataSourceVos: &listDataSourceVosbody,
    		Visible: &visibleApigDataSourcesVo,
    		Mode: &modeApigDataSourcesVo,
    	}
    	response, err := client.UpdateDataconnection(request)
    	if err == nil {
            fmt.Printf("%+v\n", response)
        } else {
            fmt.Println(err)
        }
    }
    

For SDK sample code of more programming languages, see the Sample Code tab in API Explorer. SDK sample code can be automatically generated.

Status Codes

Status Code

Description

200

The data connection information is updated.

400

Bad request.

500

Internal server error.