Java Azure Cosmos DB (SQL API) Database の作成方法 No.14

投稿日 投稿者 kumoman

自己投資の一つとしてチャレンジしている Programming の Java の独習状況を Blog で公開しています。今回は Azure Cosmos DB (SQL API) で Database, Container および Item を作成する方法について紹介します。
(In English: Java – Create Database on Azure Cosmos DB (SQL API) Database No.14)

Summary

▼1. Azure Cosmos DB の種類

Azure Cosmos DB は NoSQL Database で以下のようにいくつかの API (種類) があります (2020年7月時点)。

– Core (SQL)
– Azure Cosmos DB for MongoDB API
– Casandra
– Azure Table
– Gremlin (graph)

今回は Core (SQL) の SQL API で Database, Container (Collection) および  item (データ) を作成する Java のコードを紹介します。

▼2. 事前準備

2-1. Cosmos DBトライアルアカウントの作成

以下のサイトから無料で利用できる Azure Cosmos DB を用意します。Azure を利用するために必要な Subscription を用意する必要もありません。
https://azure.microsoft.com/ja-jp/try/cosmosdb/

2-2. Maven auto-import を IntelliJ IDEA で有効にする

ubuntu で IntelliJ IDEA をインストールしています。詳細はこちら IntelliJ IDEA の利用 auto-import を有効にする方法 No.13

▼3. Cosmos DB の Database, Container およびデータの作成するコード

3-1. Java コードの作成

Database, Container および Item (データ) を作成します。
end_point  の xxx と、master_key の xxx は、それぞれ利用する Cosmos DB のアカウント名とキーに書き換えます。Family class を作成して、データを container に入れています。順番としては以下となります。

——————–
#1, Database 作成
#2, Container 作成 (Provisioning RU/s 400)
#3, Item （データ）作成
——————–

import com.azure.cosmos.*;
import com.azure.cosmos.models.*;
import com.azure.cosmos.util.CosmosPagedIterable;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.util.Collections;

public class CreateDBCosmosDBv {
    protected static final Logger log = LoggerFactory.getLogger(CreateDBCosmosDBv.class);

    public static class Family{
        public String id;
        public String lastName;
        public boolean isRegistered;
       public String getId(){
            return id;
        }

       public String getLastName(){
            return lastName;
        }

        public Family(String idv,String lastnamev,boolean isv){
            id=idv;
            lastName=lastnamev;
            isRegistered=isv;
        }
    }

    public static void main(String... args) {
        String databaseName = "testdb";
        String end_point = "https://YourCosmosDBAccountName.documents.azure.com:443";
        String master_key = "xxxx";
        String containerName = "coll";
        log.info("Prepare for data");
        Family family = new Family("1","Travase",false);
        try (CosmosClient cosmosClient = new CosmosClientBuilder().endpoint(end_point).key(master_key).gatewayMode(GatewayConnectionConfig.getDefaultConfig()).consistencyLevel(ConsistencyLevel.SESSION).connectionSharingAcrossClientsEnabled(true).contentResponseOnWriteEnabled(true).userAgentSuffix("My-Application-clienttest").preferredRegions(Collections.singletonList("West US")).buildClient()){
            log.info("The connection to Cosmos DB succeeded.");
            log.info("Create DB");
            CosmosDatabaseResponse databaseResponse = cosmosClient.createDatabaseIfNotExists(databaseName);
            CosmosDatabase database = cosmosClient.getDatabase(databaseResponse.getProperties().getId());
            log.info("Create container with 400 RU/s");
            CosmosContainerProperties containerProperties = new CosmosContainerProperties(containerName, "/lastName");
            CosmosContainerResponse cosmosContainerResponse = database.createContainerIfNotExists(containerProperties, ThroughputProperties.createManualThroughput(400));
            log.info("Set Container");
            CosmosContainer container = database.getContainer(containerName);
            log.info("Create item using container. Use lastName as partitionKey for the item");
            CosmosItemRequestOptions cosmosItemRequestOptions = new CosmosItemRequestOptions();
            log.info("insert data into items");
            CosmosItemResponse<Family> item = container.createItem(family, new PartitionKey(family.getLastName()),cosmosItemRequestOptions);
        }catch(CosmosException e){
            e.printStackTrace();
        }
    }
}

3-2. 実行結果

[main] INFO CreateDBCosmosDBv - Prepare for data
[main] INFO com.azure.cosmos.implementation.RxDocumentClientImpl - Initializing DocumentClient with serviceEndpoint [https://YourCosmosDBAccountName.documents.azure.com:443], connectionPolicy [ConnectionPolicy{requestTimeout=PT5S, connectionMode=GATEWAY, maxConnectionPoolSize=1000, idleConnectionTimeout=PT1M, userAgentSuffix='My-Application-clienttest', throttlingRetryOptions=RetryOptions{maxRetryAttemptsOnThrottledRequests=9, maxRetryWaitTime=PT30S}, endpointDiscoveryEnabled=true, preferredRegions=[West US], multipleWriteRegionsEnabled=true, proxyType=null, inetSocketProxyAddress=null, readRequestsFallbackEnabled=true, connectTimeout=null, idleEndpointTimeout=null, maxConnectionsPerEndpoint=0, maxRequestsPerConnection=0}], consistencyLevel [Session], directModeProtocol [Tcp]
[main] INFO com.azure.cosmos.implementation.http.SharedGatewayHttpClient - creating a new shared HttpClient
[parallel-1] INFO com.azure.cosmos.implementation.RxDocumentClientImpl - Getting database account endpoint from https://YourCosmosDBAccountName.documents.azure.com:443
[main] INFO CreateDBCosmosDBv - The connection to Cosmos DB succeeded.
[main] INFO CreateDBCosmosDBv - Create DB
[main] INFO CreateDBCosmosDBv - Create container with 400 RU/s
[reactor-http-epoll-2] INFO com.azure.cosmos.implementation.SessionContainer - Registering a new collection resourceId [xxxx] in SessionTokens
[main] INFO CreateDBCosmosDBv - Set Container
[main] INFO CreateDBCosmosDBv - Create item using container. Use lastName as partitionKey for the item
[main] INFO CreateDBCosmosDBv - insert data into items
WARNING: An illegal reflective access operation has occurred
WARNING: Illegal reflective access by com.fasterxml.jackson.module.afterburner.util.MyClassLoader (file:xxxx) to method java.lang.ClassLoader.findLoadedClass(java.lang.String)
WARNING: Please consider reporting this to the maintainers of com.fasterxml.jackson.module.afterburner.util.MyClassLoader
WARNING: Use --illegal-access=warn to enable warnings of further illegal reflective access operations
WARNING: All illegal access operations will be denied in a future release
[main] INFO com.azure.cosmos.implementation.RxDocumentClientImpl - Shutting down ...
[main] INFO com.azure.cosmos.implementation.RxDocumentClientImpl - Closing Global Endpoint Manager ...
[main] INFO com.azure.cosmos.implementation.RxDocumentClientImpl - Closing StoreClientFactory ...
[main] INFO com.azure.cosmos.implementation.RxDocumentClientImpl - Shutting down reactorHttpClient ...
[main] INFO com.azure.cosmos.implementation.http.SharedGatewayHttpClient - closing one reference to the shared HttpClient, the number of remaining references is 0
[main] INFO com.azure.cosmos.implementation.http.SharedGatewayHttpClient - All references to shared HttpClient are closed. Closing the underlying HttpClient
[main] INFO com.azure.cosmos.implementation.RxDocumentClientImpl - Shutting down completed.

3-3. Portal から確認

▼4. 参考情報

以上です。参考になりましたら幸いです。


コメントを残す

メールアドレスが公開されることはありません。 ※ が付いている欄は必須項目です