CosmosAsyncDatabase クラス
- java.
lang. Object - com.
azure. cosmos. CosmosAsyncDatabase
- com.
public class CosmosAsyncDatabase
データベースの読み取りと削除、データベースのスループットの更新、子リソースに対する操作の実行
メソッドの概要
メソッドの継承元: java.lang.Object
メソッドの詳細
createClientEncryptionKey
public Mono
操作が実行されるサブスクリプションの後にクライアント暗号化キーを作成します。 Mono正常に完了すると、作成されたクライアント暗号化キーを持つ 1 つのリソース応答が含まれます。 エラーが発生した場合は、 Mono がエラーになります。
パラメーター:
戻り値:
createContainer
public Mono
Cosmos コンテナーを作成します。
CosmosContainerProperties containerProperties =
new CosmosContainerProperties(containerId, partitionKeyDefinition);
cosmosAsyncDatabase.createContainer(containerProperties)
.subscribe(
cosmosContainerResponse -> System.out.println(cosmosContainerResponse),
throwable -> System.out.println("Failed to create container: " + throwable)
);
サブスクリプションが完了すると、操作が実行されます。 Mono正常に完了すると、作成されたコンテナーを含む Cosmos コンテナーの応答が含まれます。 エラーが発生した場合は、 Mono がエラーになります。
パラメーター:
戻り値:
createContainer
public Mono
Cosmos コンテナーを作成します。
CosmosContainerProperties containerProperties =
new CosmosContainerProperties(containerId, partitionKeyDefinition);
cosmosAsyncDatabase.createContainer(containerProperties)
.subscribe(
cosmosContainerResponse -> System.out.println(cosmosContainerResponse),
throwable -> System.out.println("Failed to create container: " + throwable)
);
サブスクリプションが完了すると、操作が実行されます。 Mono正常に完了すると、作成されたコンテナーを含む Cosmos コンテナーの応答が含まれます。 エラーが発生した場合は、 Mono がエラーになります。
パラメーター:
戻り値:
createContainer
public Mono
カスタム スループット プロパティを使用して Cosmos コンテナーを作成します。
CosmosContainerProperties containerProperties =
new CosmosContainerProperties(containerId, partitionKeyDefinition);
ThroughputProperties throughputProperties =
ThroughputProperties.createAutoscaledThroughput(autoScaleMaxThroughput);
cosmosAsyncDatabase.createContainer(containerProperties, throughputProperties)
.subscribe(
cosmosContainerResponse -> System.out.println(cosmosContainerResponse),
throwable -> System.out.println("Failed to create container: " + throwable)
);
サブスクリプションが完了すると、操作が実行されます。 Mono正常に完了すると、作成されたコンテナーを含む Cosmos コンテナーの応答が含まれます。 エラーが発生した場合は、 Mono がエラーになります。
パラメーター:
戻り値:
createContainer
public Mono
コンテナーを作成します。
CosmosContainerProperties containerProperties =
new CosmosContainerProperties(containerId, partitionKeyDefinition);
cosmosAsyncDatabase.createContainer(
containerProperties,
throughput,
options
)
.subscribe(
cosmosContainerResponse -> System.out.println(cosmosContainerResponse),
throwable -> System.out.println("Failed to create container: " + throwable)
);
パラメーター:
戻り値:
createContainer
public Mono
Cosmos コンテナーを作成します。
ThroughputProperties throughputProperties =
ThroughputProperties.createAutoscaledThroughput(autoscaledThroughput);
cosmosAsyncDatabase.createContainer(
containerId,
partitionKeyPath,
throughputProperties
)
.subscribe(
cosmosContainerResponse -> System.out.println(cosmosContainerResponse),
throwable -> System.out.println("Failed to create container: " + throwable)
);
サブスクリプションが完了すると、操作が実行されます。 Mono正常に完了すると、作成されたコンテナーを含む Cosmos コンテナーの応答が含まれます。 エラーが発生した場合は、 Mono がエラーになります。
パラメーター:
戻り値:
createContainer
public Mono
Cosmos コンテナーを作成します。
ThroughputProperties throughputProperties =
ThroughputProperties.createAutoscaledThroughput(autoscaledThroughput);
cosmosAsyncDatabase.createContainer(
containerId,
partitionKeyPath,
throughputProperties
)
.subscribe(
cosmosContainerResponse -> System.out.println(cosmosContainerResponse),
throwable -> System.out.println("Failed to create container: " + throwable)
);
サブスクリプションが完了すると、操作が実行されます。 Mono正常に完了すると、作成されたコンテナーを含む Cosmos コンテナーの応答が含まれます。 エラーが発生した場合は、 Mono がエラーになります。
パラメーター:
戻り値:
createContainerIfNotExists
public Mono
Cosmos コンテナーがサービスに存在しない場合は作成します。
CosmosContainerProperties containerProperties =
new CosmosContainerProperties(containerId, partitionKeyDefinition);
cosmosAsyncDatabase.createContainerIfNotExists(containerProperties)
.subscribe(
cosmosContainerResponse -> System.out.println(cosmosContainerResponse),
throwable -> System.out.println("Failed to create container: " + throwable)
);
サブスクリプションが完了すると、操作が実行されます。 Mono正常に完了すると、作成されたコンテナーまたは既存のコンテナーを含む Cosmos コンテナーの応答が含まれます。 エラーが発生した場合は、 Mono がエラーになります。
パラメーター:
戻り値:
createContainerIfNotExists
public Mono
Cosmos コンテナーがサービスに存在しない場合は作成します。
CosmosContainerProperties containerProperties =
new CosmosContainerProperties(containerId, partitionKeyDefinition);
cosmosAsyncDatabase.createContainerIfNotExists(containerProperties, throughputProperties)
.subscribe(
cosmosContainerResponse -> System.out.println(cosmosContainerResponse),
throwable -> System.out.println("Failed to create container: " + throwable)
);
スループット プロパティは、指定されたコンテナーが存在せず、新しいコンテナーが作成される場合にのみ使用されます。
サブスクリプションが完了すると、操作が実行されます。 Mono正常に完了すると、作成されたコンテナーまたは既存のコンテナーを含む Cosmos コンテナーの応答が含まれます。 エラーが発生した場合は、 Mono がエラーになります。
パラメーター:
戻り値:
createContainerIfNotExists
public Mono
Cosmos コンテナーがサービスに存在しない場合は作成します。
CosmosContainerProperties containerProperties =
new CosmosContainerProperties(containerId, partitionKeyDefinition);
cosmosAsyncDatabase.createContainerIfNotExists(containerProperties)
.subscribe(
cosmosContainerResponse -> System.out.println(cosmosContainerResponse),
throwable -> System.out.println("Failed to create container: " + throwable)
);
サブスクリプションが完了すると、操作が実行されます。 Mono正常に完了すると、作成されたコンテナーを含む Cosmos コンテナーの応答が含まれます。 エラーが発生した場合は、 Mono がエラーになります。
パラメーター:
戻り値:
createContainerIfNotExists
public Mono
Cosmos コンテナーがサービスに存在しない場合は作成します。
CosmosContainerProperties containerProperties =
new CosmosContainerProperties(containerId, partitionKeyDefinition);
cosmosAsyncDatabase.createContainerIfNotExists(containerProperties, throughputProperties)
.subscribe(
cosmosContainerResponse -> System.out.println(cosmosContainerResponse),
throwable -> System.out.println("Failed to create container: " + throwable)
);
スループット プロパティは、指定されたコンテナーが存在せず、新しいコンテナーが作成される場合にのみ使用されます。
サブスクリプションが完了すると、操作が実行されます。 Mono正常に完了すると、作成されたコンテナーを含む Cosmos コンテナーの応答が含まれます。 エラーが発生した場合は、 Mono がエラーになります。
パラメーター:
戻り値:
createUser
public Mono
ユーザーの作成 サブスクリプションの後、操作が実行されます。 Mono正常に完了すると、作成されたユーザーとの 1 つのリソース応答が含まれます。 エラーが発生した場合は、 Mono がエラーになります。
String userId = "userId";
CosmosUserProperties userProperties = new CosmosUserProperties();
userProperties.setId(userId);
cosmosAsyncDatabase.createUser(userProperties)
.subscribe(
userResponse -> System.out.println(userResponse),
throwable -> System.out.println("Failed to create user: " + throwable)
);
パラメーター:
戻り値:
delete
public Mono
現在の Cosmos データベースを削除します。
CosmosAsyncDatabase database = cosmosAsyncClient
.getDatabase("<YOUR DATABASE NAME>");
database.delete().subscribe(databaseResponse -> {
System.out.println(databaseResponse);
},
throwable -> {
throwable.printStackTrace();
});
サブスクリプションが完了すると、操作が実行されます。 Mono正常に完了すると、削除されたデータベースに対する Cosmos データベース応答が含まれます。 エラーが発生した場合は、 Mono がエラーになります。
戻り値:
delete
public Mono
追加の要求オプションを指定しながら、現在の Cosmos データベースを削除します。
CosmosAsyncDatabase database = cosmosAsyncClient
.getDatabase("<YOUR DATABASE NAME>");
database.delete().subscribe(databaseResponse -> {
System.out.println(databaseResponse);
},
throwable -> {
throwable.printStackTrace();
});
サブスクリプションが完了すると、操作が実行されます。 Mono正常に完了すると、削除されたデータベースに対する Cosmos データベース応答が含まれます。 エラーが発生した場合は、 Mono がエラーになります。
パラメーター:
戻り値:
getClientEncryptionKey
public CosmosAsyncClientEncryptionKey getClientEncryptionKey(String id)
サービス呼び出しを行わずに CosmosAsyncClientEncryptionKey オブジェクトを取得します
パラメーター:
戻り値:
getContainer
public CosmosAsyncContainer getContainer(String id)
サービス呼び出しを行わずに CosmosAsyncContainer オブジェクトを取得します
パラメーター:
戻り値:
getId
public String getId()
CosmosAsyncDatabase の ID を取得します。
戻り値:
getUser
public CosmosAsyncUser getUser(String id)
ユーザーを取得します。
パラメーター:
戻り値:
queryClientEncryptionKeys
public CosmosPagedFlux
データベース内の Cosmos クライアント暗号化キーのクエリを実行します。
サブスクリプションが完了すると、操作が実行されます。 には CosmosPagedFlux<T> 、取得したクライアント暗号化キーの 1 つまたは複数のフィード応答が含まれます。 エラーが発生した場合、 は CosmosPagedFlux<T> エラーになります。
パラメーター:
戻り値:
queryClientEncryptionKeys
public CosmosPagedFlux
データベース内の Cosmos クライアント暗号化キーのクエリを実行します。
サブスクリプションが完了すると、操作が実行されます。 には CosmosPagedFlux<T> 、取得したクライアント暗号化キーの 1 つまたは複数のフィード応答が含まれます。 エラーが発生した場合、 は CosmosPagedFlux<T> エラーになります。
パラメーター:
戻り値:
queryClientEncryptionKeys
public CosmosPagedFlux
データベース内の Cosmos クライアント暗号化キーのクエリを実行します。
サブスクリプションが完了すると、操作が実行されます。 には CosmosPagedFlux<T> 、取得したクライアント暗号化キーの 1 つまたは複数のフィード応答が含まれます。 エラーが発生した場合、 は CosmosPagedFlux<T> エラーになります。
パラメーター:
戻り値:
queryClientEncryptionKeys
public CosmosPagedFlux
データベース内の Cosmos クライアント暗号化キーのクエリを実行します。
サブスクリプションが完了すると、操作が実行されます。 には CosmosPagedFlux<T> 、取得したクライアント暗号化キーの 1 つまたは複数のフィード応答が含まれます。 エラーが発生した場合、 は CosmosPagedFlux<T> エラーになります。
パラメーター:
戻り値:
queryContainers
public CosmosPagedFlux
Cosmos データベース内の Cosmos コンテナーのクエリを実行します。
cosmosAsyncDatabase.queryContainers("SELECT * FROM DB_NAME")
.byPage()
.flatMap(containerPropertiesFeedResponse -> {
for (CosmosContainerProperties properties : containerPropertiesFeedResponse.getResults()) {
System.out.println(properties);
}
return Flux.empty();
})
.subscribe();
サブスクリプションが完了すると、操作が実行されます。 には CosmosPagedFlux<T> 、取得したコンテナーの 1 つまたは複数のフィード応答が含まれます。 エラーが発生した場合、 は CosmosPagedFlux<T> エラーになります。
パラメーター:
戻り値:
queryContainers
public CosmosPagedFlux
Cosmos データベース内の Cosmos コンテナーのクエリを実行します。
cosmosAsyncDatabase.queryContainers("SELECT * FROM DB_NAME")
.byPage()
.flatMap(containerPropertiesFeedResponse -> {
for (CosmosContainerProperties properties : containerPropertiesFeedResponse.getResults()) {
System.out.println(properties);
}
return Flux.empty();
})
.subscribe();
サブスクリプションが完了すると、操作が実行されます。 には CosmosPagedFlux<T> 、取得したコンテナーの 1 つまたは複数のフィード応答が含まれます。 エラーが発生した場合、 は CosmosPagedFlux<T> エラーになります。
パラメーター:
戻り値:
queryContainers
public CosmosPagedFlux
Cosmos データベース内の Cosmos コンテナーのクエリを実行します。
cosmosAsyncDatabase.queryContainers("SELECT * FROM DB_NAME")
.byPage()
.flatMap(containerPropertiesFeedResponse -> {
for (CosmosContainerProperties properties : containerPropertiesFeedResponse.getResults()) {
System.out.println(properties);
}
return Flux.empty();
})
.subscribe();
サブスクリプションが完了すると、操作が実行されます。 には CosmosPagedFlux<T> 、取得したコンテナーの 1 つまたは複数のフィード応答が含まれます。 エラーが発生した場合、 は CosmosPagedFlux<T> エラーになります。
パラメーター:
戻り値:
queryContainers
public CosmosPagedFlux
Cosmos データベース内の Cosmos コンテナーのクエリを実行します。
cosmosAsyncDatabase.queryContainers("SELECT * FROM DB_NAME")
.byPage()
.flatMap(containerPropertiesFeedResponse -> {
for (CosmosContainerProperties properties : containerPropertiesFeedResponse.getResults()) {
System.out.println(properties);
}
return Flux.empty();
})
.subscribe();
サブスクリプションが完了すると、操作が実行されます。 には CosmosPagedFlux<T> 、取得したコンテナーの 1 つまたは複数のフィード応答が含まれます。 エラーが発生した場合、 は CosmosPagedFlux<T> エラーになります。
パラメーター:
戻り値:
queryUsers
public CosmosPagedFlux
データベース内の Cosmos ユーザーに対してクエリを実行します。
サブスクリプションが完了すると、操作が実行されます。 には CosmosPagedFlux<T> 、取得したユーザーの 1 つまたは複数のフィード応答が含まれます。 エラーが発生した場合、 は CosmosPagedFlux<T> エラーになります。
パラメーター:
戻り値:
queryUsers
public CosmosPagedFlux
データベース内の Cosmos ユーザーに対してクエリを実行します。
サブスクリプションが完了すると、操作が実行されます。 には CosmosPagedFlux<T> 、取得したユーザーの 1 つまたは複数のフィード応答が含まれます。 エラーが発生した場合、 は CosmosPagedFlux<T> エラーになります。
パラメーター:
戻り値:
queryUsers
public CosmosPagedFlux
データベース内の Cosmos ユーザーに対してクエリを実行します。
サブスクリプションが完了すると、操作が実行されます。 には CosmosPagedFlux<T> 、取得したユーザーの 1 つまたは複数のフィード応答が含まれます。 エラーが発生した場合、 は CosmosPagedFlux<T> エラーになります。
パラメーター:
戻り値:
queryUsers
public CosmosPagedFlux
データベース内の Cosmos ユーザーに対してクエリを実行します。
サブスクリプションが完了すると、操作が実行されます。 には CosmosPagedFlux<T> 、取得したユーザーの 1 つまたは複数のフィード応答が含まれます。 エラーが発生した場合、 は CosmosPagedFlux<T> エラーになります。
パラメーター:
戻り値:
read
public Mono
データベースを読み取ります。 一意の識別子に基づいて、データベースの詳細とプロパティをフェッチします。
CosmosAsyncDatabase database = cosmosAsyncClient
.getDatabase("<YOUR DATABASE NAME>");
database.read().subscribe(databaseResponse -> {
System.out.println(databaseResponse);
},
throwable -> {
throwable.printStackTrace();
});
サブスクリプションが完了すると、操作が実行されます。 Mono正常に完了すると、読み取りデータベースとの 1 つの Cosmos データベース応答が含まれます。 エラーが発生した場合、 は Mono エラーになります。
戻り値:
read
public Mono
データベースを読み取ります。 一意の識別子に基づいて、データベースの詳細とプロパティをフェッチします。
CosmosAsyncDatabase database = cosmosAsyncClient
.getDatabase("<YOUR DATABASE NAME>");
database.read().subscribe(databaseResponse -> {
System.out.println(databaseResponse);
},
throwable -> {
throwable.printStackTrace();
});
サブスクリプションが完了すると、操作が実行されます。 Mono正常に完了すると、読み取りデータベースに対する Cosmos データベースの応答が含まれます。 エラーが発生した場合は、 Mono がエラーになります。
パラメーター:
戻り値:
readAllClientEncryptionKeys
public CosmosPagedFlux
データベース内のすべての Cosmos クライアント暗号化キーを読み取ります。
サブスクリプションが完了すると、操作が実行されます。 には CosmosPagedFlux<T> 、読み取り Cosmos クライアント暗号化キーの 1 つまたは複数のフィード応答が含まれます。 エラーが発生した場合は、 CosmosPagedFlux<T> がエラーになります。
戻り値:
readAllClientEncryptionKeys
public CosmosPagedFlux
データベース内のすべての Cosmos クライアント暗号化キーを読み取ります。
サブスクリプションが完了すると、操作が実行されます。 には CosmosPagedFlux<T> 、読み取り Cosmos クライアント暗号化キーの 1 つまたは複数のフィード応答が含まれます。 エラーが発生した場合は、 CosmosPagedFlux<T> がエラーになります。
パラメーター:
戻り値:
readAllContainers
public CosmosPagedFlux
すべての Cosmos コンテナーを読み取ります。
cosmosAsyncDatabase.readAllContainers()
.byPage()
.flatMap(containerPropertiesFeedResponse -> {
for (CosmosContainerProperties properties : containerPropertiesFeedResponse.getResults()) {
System.out.println(properties);
}
return Flux.empty();
})
.subscribe();
サブスクリプションが完了すると、操作が実行されます。 には CosmosPagedFlux<T> 、読み取りコンテナーの 1 つまたは複数のフィード応答が含まれます。 エラーが発生した場合は、 CosmosPagedFlux<T> がエラーになります。
戻り値:
readAllContainers
public CosmosPagedFlux
すべての Cosmos コンテナーを読み取ります。
cosmosAsyncDatabase.readAllContainers()
.byPage()
.flatMap(containerPropertiesFeedResponse -> {
for (CosmosContainerProperties properties : containerPropertiesFeedResponse.getResults()) {
System.out.println(properties);
}
return Flux.empty();
})
.subscribe();
サブスクリプションが完了すると、操作が実行されます。 には CosmosPagedFlux<T> 、読み取りコンテナーの 1 つまたは複数のフィード応答が含まれます。 エラーが発生した場合は、 CosmosPagedFlux<T> がエラーになります。
パラメーター:
戻り値:
readAllUsers
public CosmosPagedFlux
データベース内のすべての Cosmos ユーザーを読み取ります。
cosmosAsyncDatabase.readAllUsers()
.byPage()
.flatMap(userPropertiesFeedResponse -> {
for (CosmosUserProperties properties : userPropertiesFeedResponse.getResults()) {
System.out.println(properties);
}
return Flux.empty();
})
.subscribe();
サブスクリプションが完了すると、操作が実行されます。 には CosmosPagedFlux<T> 、読み取り Cosmos ユーザーの 1 つまたは複数のフィード応答が含まれます。 エラーが発生した場合は、 CosmosPagedFlux<T> がエラーになります。
戻り値:
readThroughput
public Mono
データベースのスループットを取得します。
cosmosAsyncDatabase.readThroughput()
.subscribe(throughputResponse -> {
System.out.println(throughputResponse);
},
throwable -> {
throwable.printStackTrace();
});
戻り値:
replaceThroughput
public Mono
Azure Cosmos サービスのユニットあたりの要求数を測定して、コンテナーにプロビジョニングされるスループットを設定します。
ThroughputProperties autoscaledThroughput = ThroughputProperties
.createAutoscaledThroughput(autoScaleMaxThroughput);
cosmosAsyncDatabase.replaceThroughput(autoscaledThroughput)
.subscribe(throughputResponse -> {
System.out.println(throughputResponse);
},
throwable -> {
throwable.printStackTrace();
});
パラメーター:
戻り値:
upsertUser
public Mono
ユーザーをアップサートします。 Upsert は、存在しない場合は新しいユーザーを作成し、存在する場合は既存のユーザーを置き換えます。 サブスクリプションが完了すると、操作が実行されます。 Mono正常に完了すると、作成されたユーザーとの 1 つのリソース応答が含まれます。 エラーが発生した場合は、 Mono がエラーになります。
String userId = "userId";
CosmosUserProperties userProperties = new CosmosUserProperties();
userProperties.setId(userId);
cosmosAsyncDatabase.upsertUser(userProperties)
.subscribe(
userResponse -> System.out.println(userResponse),
throwable -> System.out.println("Failed to upsert user: " + throwable)
);
パラメーター:
戻り値:
適用対象
Azure SDK for Java