GaussDB​数据库能力-创建GaussDB数据库实例

版本说明：本示例配套的SDK版本为：3.0.89

1. 简介

2. 前置条件

3. 安装SDK

<dependency>    
    <groupId>com.huaweicloud.sdk</groupId>    
    <artifactId>huaweicloud-sdk-gaussdbforopengauss</artifactId>    
    <version>3.0.89</version>
</dependency>

4.代码示例

以下代码展示如何使用SDK创建实例：

import com.huaweicloud.sdk.core.auth.BasicCredentials;
import com.huaweicloud.sdk.core.auth.ICredential;
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.gaussdbforopengauss.v3.GaussDBforopenGaussClient;
import com.huaweicloud.sdk.gaussdbforopengauss.v3.model.CreateInstanceRequest;
import com.huaweicloud.sdk.gaussdbforopengauss.v3.model.OpenGaussHa;
import com.huaweicloud.sdk.gaussdbforopengauss.v3.model.OpenGaussInstanceRequest;
import com.huaweicloud.sdk.gaussdbforopengauss.v3.model.OpenGaussVolume;
import com.huaweicloud.sdk.gaussdbforopengauss.v3.model.OpenGaussDatastore;
import com.huaweicloud.sdk.gaussdbforopengauss.v3.model.CreateInstanceResponse;
import com.huaweicloud.sdk.gaussdbforopengauss.v3.region.GaussDBforopenGaussRegion;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/**
 * 创建GaussDB实例的示例代码
 */
public class CreateInstanceDemo {
    private static final Logger logger = LoggerFactory.getLogger(CreateInstanceDemo.class.getName());

    public static void main(String[] args) {
        String ak = "<YOUR AK>";
        String sk = "<YOUR SK>";

        ICredential auth = new BasicCredentials()
                .withAk(ak)
                .withSk(sk);

        GaussDBforopenGaussClient client = GaussDBforopenGaussClient.newBuilder()
                .withCredential(auth)
                .withRegion(GaussDBforopenGaussRegion.CN_NORTH_4)
                .build();
        CreateInstanceRequest request = new CreateInstanceRequest();
        OpenGaussInstanceRequest body = new OpenGaussInstanceRequest();

        // 协调节点数量
        body.withCoordinatorNum(1);
        // 分片数量
        body.withShardingNum(1);

        // 安全组ID
        body.withSecurityGroupId("<security_group_id>");
        // 子网的网络ID
        body.withSubnetId("<subnet_id>");
        // 虚拟私有云ID
        body.withVpcId("<vpc_id>");
        // 可用区ID
        body.withAvailabilityZone("<availability_zone>");
        // 区域ID
        body.withRegion(GaussDBforopenGaussRegion.CN_NORTH_4.getId());

        // 存储信息
        OpenGaussVolume volumeBody = new OpenGaussVolume();
        volumeBody.withType(OpenGaussVolume.TypeEnum.ESSD)
                .withSize(40);
        body.withVolume(volumeBody);

        // 规格码
        body.withFlavorRef("<flavor_ref>");

        // 密码
        body.withPassword("<password>");

        // 实例部署形态
        OpenGaussHa habody = new OpenGaussHa();
        habody.withMode(OpenGaussHa.ModeEnum.ENTERPRISE)
                .withConsistency(OpenGaussHa.ConsistencyEnum.STRONG)
                .withReplicationMode(OpenGaussHa.ReplicationModeEnum.SYNC);
        body.withHa(habody);

        OpenGaussDatastore dataStoreBody = new OpenGaussDatastore();
        dataStoreBody.withType(OpenGaussDatastore.TypeEnum.GAUSSDB_FOR_OPENGAUSS_);
        body.withDatastore(dataStoreBody);

        // 实例名称
        body.withName("<name>");
        request.withBody(body);
        try {
            CreateInstanceResponse response = client.createInstance(request);
            System.out.println(response.toString());
        } catch (ConnectionException | RequestTimeoutException e) {
            logger.error(e.toString());
        } catch (ServiceResponseException e) {
            logger.error(String.valueOf(e.getHttpStatusCode()));
            logger.error(e.toString());
        }
    }
}

您可以在 API Explorer 中直接运行调试该接口。