CosmosClient クラス
- java.
lang. Object - com.
azure. cosmos. CosmosClient
- com.
実装
public final class CosmosClient
implements Closeable
Azure Cosmos DB サービスのクライアント側の論理表現を提供します。 CosmosClient API の への呼び出しは、完了のためにブロックされます。
CosmosClient はスレッド セーフです。 効率的な接続管理とパフォーマンスを可能にするアプリケーションの有効期間ごとに、CosmosClient の 1 つのインスタンスを維持することをお勧めします。 CosmosClient の初期化は負荷の高い操作です。資格情報やネットワーク接続の検証には、初期化 CosmosClient インスタンスを使用しないでください。
メソッドの概要
メソッドの継承元: java.lang.Object
メソッドの詳細
close
public void close()
このインスタンスを CosmosClient 閉じます。
createDatabase
public CosmosDatabaseResponse createDatabase(CosmosDatabaseProperties databaseProperties)
Cosmos データベースを作成します。
CosmosDatabaseProperties databaseProperties = new CosmosDatabaseProperties(databaseName);
cosmosClient.createDatabase(databaseProperties);
パラメーター:
戻り値:
createDatabase
public CosmosDatabaseResponse createDatabase(CosmosDatabaseProperties databaseProperties, CosmosDatabaseRequestOptions options)
データベースを作成します。
CosmosDatabaseProperties databaseProperties = new CosmosDatabaseProperties(databaseName);
cosmosClient.createDatabase(databaseProperties);
パラメーター:
戻り値:
createDatabase
public CosmosDatabaseResponse createDatabase(CosmosDatabaseProperties databaseProperties, ThroughputProperties throughputProperties)
Cosmos データベースを作成します。
ThroughputProperties throughputProperties = ThroughputProperties
.createAutoscaledThroughput(autoScaleMaxThroughput);
cosmosClient.createDatabase(databaseName, throughputProperties);
パラメーター:
戻り値:
createDatabase
public CosmosDatabaseResponse createDatabase(CosmosDatabaseProperties databaseProperties, ThroughputProperties throughputProperties, CosmosDatabaseRequestOptions options)
Cosmos データベースを作成します。
ThroughputProperties throughputProperties = ThroughputProperties
.createAutoscaledThroughput(autoScaleMaxThroughput);
cosmosClient.createDatabase(databaseName, throughputProperties);
パラメーター:
戻り値:
createDatabase
public CosmosDatabaseResponse createDatabase(String id)
Cosmos データベースを作成します。
CosmosDatabaseProperties databaseProperties = new CosmosDatabaseProperties(databaseName);
cosmosClient.createDatabase(databaseProperties);
パラメーター:
戻り値:
createDatabase
public CosmosDatabaseResponse createDatabase(String id, ThroughputProperties throughputProperties)
Cosmos データベースを作成します。
ThroughputProperties throughputProperties = ThroughputProperties
.createAutoscaledThroughput(autoScaleMaxThroughput);
cosmosClient.createDatabase(databaseName, throughputProperties);
パラメーター:
戻り値:
createDatabaseIfNotExists
public CosmosDatabaseResponse createDatabaseIfNotExists(String id)
Cosmos データベースがサービスにまだ存在しない場合は作成します。
CosmosDatabaseProperties databaseProperties = new CosmosDatabaseProperties(databaseName);
cosmosClient.createDatabaseIfNotExists(databaseProperties);
パラメーター:
戻り値:
createDatabaseIfNotExists
public CosmosDatabaseResponse createDatabaseIfNotExists(String id, ThroughputProperties throughputProperties)
Cosmos データベースがサービスにまだ存在しない場合は作成します。
ThroughputProperties throughputProperties = ThroughputProperties
.createAutoscaledThroughput(autoScaleMaxThroughput);
cosmosClient.createDatabaseIfNotExists(databaseName, throughputProperties);
throughputProperties が使用されるのは、指定されたデータベースが存在せず、新しいデータベースが throughputProperties で作成される場合のみです。
パラメーター:
戻り値:
createGlobalThroughputControlConfigBuilder
public GlobalThroughputControlConfigBuilder createGlobalThroughputControlConfigBuilder(String databaseId, String containerId)
をビルド GlobalThroughputControlConfigするために使用するグローバル スループット制御構成ビルダーを作成します。
パラメーター:
戻り値:
getDatabase
public CosmosDatabase getDatabase(String id)
サービス呼び出しを行わずに Cosmos データベース インスタンスを取得します。
パラメーター:
戻り値:
queryDatabases
public CosmosPagedIterable
Cosmos データベースに対してクエリを実行します。
CosmosQueryRequestOptions options = new CosmosQueryRequestOptions();
CosmosPagedIterable<CosmosDatabaseProperties> databaseProperties =
cosmosClient.queryDatabases("select * from d", options);
databaseProperties.forEach(properties -> {
System.out.println(properties.getId());
});
パラメーター:
戻り値:
queryDatabases
public CosmosPagedIterable
Cosmos データベースに対してクエリを実行します。
CosmosQueryRequestOptions options = new CosmosQueryRequestOptions();
CosmosPagedIterable<CosmosDatabaseProperties> databaseProperties =
cosmosClient.queryDatabases("select * from d", options);
databaseProperties.forEach(properties -> {
System.out.println(properties.getId());
});
パラメーター:
戻り値:
readAllDatabases
public CosmosPagedIterable
すべての Cosmos データベースを読み取ります。
CosmosPagedIterable<CosmosDatabaseProperties> cosmosDatabaseProperties =
cosmosClient.readAllDatabases();
cosmosDatabaseProperties.forEach(databaseProperties -> {
System.out.println(databaseProperties);
});
戻り値:
適用対象
Azure SDK for Java