你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站，请访问 https://docs.azure.cn。
CosmosAsyncDatabase 类
- java.
lang. Object - com.
azure. cosmos. CosmosAsyncDatabase
- com.
public class CosmosAsyncDatabase
执行读取和删除数据库、更新数据库吞吐量，以及对子资源执行操作
方法摘要
方法继承自 java.lang.Object
方法详细信息
createClientEncryptionKey
public Mono
在订阅后创建客户端加密密钥，该操作将执行。 成功完成后， Mono 将包含单个资源响应，其中包含创建的客户端加密密钥。 如果失败， 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 将包含创建用户的单个资源响应。 如果失败，将 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>将包含获取的客户端加密密钥的一个或多个源响应。 如果失败， CosmosPagedFlux<T> 将出错。
参数:
返回:
queryClientEncryptionKeys
public CosmosPagedFlux
查询数据库中的 cosmos 客户端加密密钥。
订阅后将执行该操作。 CosmosPagedFlux<T>将包含获取的客户端加密密钥的一个或多个源响应。 如果失败， CosmosPagedFlux<T> 将出错。
参数:
返回:
queryClientEncryptionKeys
public CosmosPagedFlux
查询数据库中的 cosmos 客户端加密密钥。
订阅后将执行该操作。 CosmosPagedFlux<T>将包含获取的客户端加密密钥的一个或多个源响应。 如果失败， CosmosPagedFlux<T> 将出错。
参数:
返回:
queryClientEncryptionKeys
public CosmosPagedFlux
查询数据库中的 cosmos 客户端加密密钥。
订阅后将执行该操作。 CosmosPagedFlux<T>将包含获取的客户端加密密钥的一个或多个源响应。 如果失败， 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>将包含所获取容器的一个或多个源响应。 如果失败， 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>将包含所获取容器的一个或多个源响应。 如果失败， 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>将包含所获取容器的一个或多个源响应。 如果失败， 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>将包含所获取容器的一个或多个源响应。 如果失败， CosmosPagedFlux<T> 将出错。
参数:
返回:
queryUsers
public CosmosPagedFlux
查询数据库中的 cosmos 用户。
订阅后将执行该操作。 CosmosPagedFlux<T>将包含已获取用户的一个或多个源响应。 如果失败， CosmosPagedFlux<T> 将出错。
参数:
返回:
queryUsers
public CosmosPagedFlux
查询数据库中的 cosmos 用户。
订阅后将执行该操作。 CosmosPagedFlux<T>将包含已获取用户的一个或多个源响应。 如果失败， CosmosPagedFlux<T> 将出错。
参数:
返回:
queryUsers
public CosmosPagedFlux
查询数据库中的 cosmos 用户。
订阅后将执行该操作。 CosmosPagedFlux<T>将包含已获取用户的一个或多个源响应。 如果失败， CosmosPagedFlux<T> 将出错。
参数:
返回:
queryUsers
public CosmosPagedFlux
查询数据库中的 cosmos 用户。
订阅后将执行该操作。 CosmosPagedFlux<T>将包含已获取用户的一个或多个源响应。 如果失败， CosmosPagedFlux<T> 将出错。
参数:
返回:
read
public Mono
读取数据库。 根据数据库的唯一标识符提取数据库的详细信息和属性。
CosmosAsyncDatabase database = cosmosAsyncClient
.getDatabase("<YOUR DATABASE NAME>");
database.read().subscribe(databaseResponse -> {
System.out.println(databaseResponse);
},
throwable -> {
throwable.printStackTrace();
});
订阅后将执行该操作。 Mono成功完成时的 将包含单个 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 客户端加密密钥的一个或多个源响应。 如果失败， CosmosPagedFlux<T> 将出错。
返回:
readAllClientEncryptionKeys
public CosmosPagedFlux
读取数据库中的所有 cosmos 客户端加密密钥。
订阅后将执行该操作。 CosmosPagedFlux<T>将包含读取 cosmos 客户端加密密钥的一个或多个源响应。 如果失败， 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>将包含读取容器的一个或多个源响应。 如果失败， 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>将包含读取容器的一个或多个源响应。 如果失败， 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 用户的一个或多个源响应。 如果失败， 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 将包含创建用户的单个资源响应。 如果失败， 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)
);
参数:
返回:
