CosmosAsyncDatabase Classe
- java.
lang. Object - com.
azure. cosmos. CosmosAsyncDatabase
- com.
public class CosmosAsyncDatabase
Executar bancos de dados de leitura e exclusão, atualizar a taxa de transferência do banco de dados e executar operações em recursos filho
Resumo do método
Métodos herdados de java.lang.Object
Detalhes do método
createClientEncryptionKey
public Mono
Cria uma chave de criptografia do cliente após a assinatura em que a operação será executada. O Mono após a conclusão bem-sucedida conterá uma única resposta de recurso com a chave de criptografia do cliente criada. Em caso de falha, o Mono erro será.
Parameters:
Returns:
createContainer
public Mono
Cria um contêiner do 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)
);
Após a assinatura, a operação será executada. O Mono após a conclusão bem-sucedida conterá uma resposta de contêiner cosmos com o contêiner criado. Em caso de falha, o Mono erro será.
Parameters:
Returns:
createContainer
public Mono
Cria um contêiner do 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)
);
Após a assinatura, a operação será executada. O Mono após a conclusão bem-sucedida conterá uma resposta de contêiner cosmos com o contêiner criado. Em caso de falha, o Mono erro será.
Parameters:
Returns:
createContainer
public Mono
Cria um contêiner do Cosmos com propriedades de taxa de transferência personalizadas.
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)
);
Após a assinatura, a operação será executada. O Mono após a conclusão bem-sucedida conterá uma resposta de contêiner cosmos com o contêiner criado. Em caso de falha, o Mono erro será.
Parameters:
Returns:
createContainer
public Mono
Cria um contêiner.
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)
);
Parameters:
Returns:
createContainer
public Mono
Cria um contêiner do 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)
);
Após a assinatura, a operação será executada. O Mono após a conclusão bem-sucedida conterá uma resposta de contêiner cosmos com o contêiner criado. Em caso de falha, o Mono erro será.
Parameters:
Returns:
createContainer
public Mono
Cria um contêiner do 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)
);
Após a assinatura, a operação será executada. O Mono após a conclusão bem-sucedida conterá uma resposta de contêiner cosmos com o contêiner criado. Em caso de falha, o Mono erro será.
Parameters:
Returns:
createContainerIfNotExists
public Mono
Cria um contêiner do Cosmos se ele não existir no serviço.
CosmosContainerProperties containerProperties =
new CosmosContainerProperties(containerId, partitionKeyDefinition);
cosmosAsyncDatabase.createContainerIfNotExists(containerProperties)
.subscribe(
cosmosContainerResponse -> System.out.println(cosmosContainerResponse),
throwable -> System.out.println("Failed to create container: " + throwable)
);
Após a assinatura, a operação será executada. O Mono após a conclusão bem-sucedida conterá uma resposta de contêiner cosmos com o contêiner criado ou existente. Em caso de falha, o Mono erro será.
Parameters:
Returns:
createContainerIfNotExists
public Mono
Cria um contêiner do Cosmos se ele não existir no serviço.
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)
);
As propriedades de taxa de transferência só serão usadas se o contêiner especificado não existir e, portanto, um novo contêiner for criado.
Após a assinatura, a operação será executada. O Mono após a conclusão bem-sucedida conterá uma resposta de contêiner cosmos com o contêiner criado ou existente. Em caso de falha, o Mono erro será.
Parameters:
Returns:
createContainerIfNotExists
public Mono
Cria um contêiner do Cosmos se ele não existir no serviço.
CosmosContainerProperties containerProperties =
new CosmosContainerProperties(containerId, partitionKeyDefinition);
cosmosAsyncDatabase.createContainerIfNotExists(containerProperties)
.subscribe(
cosmosContainerResponse -> System.out.println(cosmosContainerResponse),
throwable -> System.out.println("Failed to create container: " + throwable)
);
Após a assinatura, a operação será executada. O Mono após a conclusão bem-sucedida conterá uma resposta de contêiner cosmos com o contêiner criado. Em caso de falha, o Mono erro será.
Parameters:
Returns:
createContainerIfNotExists
public Mono
Cria um contêiner do Cosmos se ele não existir no serviço.
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)
);
As propriedades de taxa de transferência só serão usadas se o contêiner especificado não existir e, portanto, um novo contêiner for criado.
Após a assinatura, a operação será executada. O Mono após a conclusão bem-sucedida conterá uma resposta de contêiner cosmos com o contêiner criado. Em caso de falha, o Mono erro será.
Parameters:
Returns:
createUser
public Mono
Cria um usuário Após a assinatura, a operação será executada. O Mono após a conclusão bem-sucedida conterá uma única resposta de recurso com o usuário criado. Em caso de falha, o Mono erro será.
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)
);
Parameters:
Returns:
delete
public Mono
Exclui o banco de dados atual do Cosmos.
CosmosAsyncDatabase database = cosmosAsyncClient
.getDatabase("<YOUR DATABASE NAME>");
database.delete().subscribe(databaseResponse -> {
System.out.println(databaseResponse);
},
throwable -> {
throwable.printStackTrace();
});
Após a assinatura, a operação será executada. O Mono após a conclusão bem-sucedida conterá uma resposta de banco de dados cosmos com o banco de dados excluído. Em caso de falha, o Mono erro será.
Returns:
delete
public Mono
Exclui o banco de dados atual do Cosmos ao especificar opções de solicitação adicionais.
CosmosAsyncDatabase database = cosmosAsyncClient
.getDatabase("<YOUR DATABASE NAME>");
database.delete().subscribe(databaseResponse -> {
System.out.println(databaseResponse);
},
throwable -> {
throwable.printStackTrace();
});
Após a assinatura, a operação será executada. O Mono após a conclusão bem-sucedida conterá uma resposta de banco de dados cosmos com o banco de dados excluído. Em caso de falha, o Mono erro será.
Parameters:
Returns:
getClientEncryptionKey
public CosmosAsyncClientEncryptionKey getClientEncryptionKey(String id)
Obtém um objeto CosmosAsyncClientEncryptionKey sem fazer uma chamada de serviço
Parameters:
Returns:
getContainer
public CosmosAsyncContainer getContainer(String id)
Obtém um objeto CosmosAsyncContainer sem fazer uma chamada de serviço
Parameters:
Returns:
getId
public String getId()
Obtenha a ID do CosmosAsyncDatabase.
Returns:
getUser
public CosmosAsyncUser getUser(String id)
Obtém o usuário.
Parameters:
Returns:
queryClientEncryptionKeys
public CosmosPagedFlux
Consultar chaves de criptografia de cliente cosmos em um banco de dados.
Após a assinatura, a operação será executada. O CosmosPagedFlux<T> conterá uma ou várias respostas de feed das chaves de criptografia de cliente obtidas. Em caso de falha, o CosmosPagedFlux<T> erro será.
Parameters:
Returns:
queryClientEncryptionKeys
public CosmosPagedFlux
Consultar chaves de criptografia de cliente cosmos em um banco de dados.
Após a assinatura, a operação será executada. O CosmosPagedFlux<T> conterá uma ou várias respostas de feed das chaves de criptografia de cliente obtidas. Em caso de falha, o CosmosPagedFlux<T> erro será.
Parameters:
Returns:
queryClientEncryptionKeys
public CosmosPagedFlux
Consultar chaves de criptografia de cliente cosmos em um banco de dados.
Após a assinatura, a operação será executada. O CosmosPagedFlux<T> conterá uma ou várias respostas de feed das chaves de criptografia de cliente obtidas. Em caso de falha, o CosmosPagedFlux<T> erro será.
Parameters:
Returns:
queryClientEncryptionKeys
public CosmosPagedFlux
Consultar chaves de criptografia de cliente cosmos em um banco de dados.
Após a assinatura, a operação será executada. O CosmosPagedFlux<T> conterá uma ou várias respostas de feed das chaves de criptografia de cliente obtidas. Em caso de falha, o CosmosPagedFlux<T> erro será.
Parameters:
Returns:
queryContainers
public CosmosPagedFlux
Consultar contêineres do Cosmos em um banco de dados cosmos.
cosmosAsyncDatabase.queryContainers("SELECT * FROM DB_NAME")
.byPage()
.flatMap(containerPropertiesFeedResponse -> {
for (CosmosContainerProperties properties : containerPropertiesFeedResponse.getResults()) {
System.out.println(properties);
}
return Flux.empty();
})
.subscribe();
Após a assinatura, a operação será executada. O CosmosPagedFlux<T> conterá uma ou várias respostas de feed dos contêineres obtidos. Em caso de falha, o CosmosPagedFlux<T> erro será.
Parameters:
Returns:
queryContainers
public CosmosPagedFlux
Consultar contêineres do Cosmos em um banco de dados cosmos.
cosmosAsyncDatabase.queryContainers("SELECT * FROM DB_NAME")
.byPage()
.flatMap(containerPropertiesFeedResponse -> {
for (CosmosContainerProperties properties : containerPropertiesFeedResponse.getResults()) {
System.out.println(properties);
}
return Flux.empty();
})
.subscribe();
Após a assinatura, a operação será executada. O CosmosPagedFlux<T> conterá uma ou várias respostas de feed dos contêineres obtidos. Em caso de falha, o CosmosPagedFlux<T> erro será.
Parameters:
Returns:
queryContainers
public CosmosPagedFlux
Consultar contêineres do Cosmos em um banco de dados cosmos.
cosmosAsyncDatabase.queryContainers("SELECT * FROM DB_NAME")
.byPage()
.flatMap(containerPropertiesFeedResponse -> {
for (CosmosContainerProperties properties : containerPropertiesFeedResponse.getResults()) {
System.out.println(properties);
}
return Flux.empty();
})
.subscribe();
Após a assinatura, a operação será executada. O CosmosPagedFlux<T> conterá uma ou várias respostas de feed dos contêineres obtidos. Em caso de falha, o CosmosPagedFlux<T> erro será.
Parameters:
Returns:
queryContainers
public CosmosPagedFlux
Consultar contêineres do Cosmos em um banco de dados cosmos.
cosmosAsyncDatabase.queryContainers("SELECT * FROM DB_NAME")
.byPage()
.flatMap(containerPropertiesFeedResponse -> {
for (CosmosContainerProperties properties : containerPropertiesFeedResponse.getResults()) {
System.out.println(properties);
}
return Flux.empty();
})
.subscribe();
Após a assinatura, a operação será executada. O CosmosPagedFlux<T> conterá uma ou várias respostas de feed dos contêineres obtidos. Em caso de falha, o CosmosPagedFlux<T> erro será.
Parameters:
Returns:
queryUsers
public CosmosPagedFlux
Consultar usuários do Cosmos em um banco de dados.
Após a assinatura, a operação será executada. O CosmosPagedFlux<T> conterá uma ou várias respostas de feed dos usuários obtidos. Em caso de falha, o CosmosPagedFlux<T> erro será.
Parameters:
Returns:
queryUsers
public CosmosPagedFlux
Consultar usuários do Cosmos em um banco de dados.
Após a assinatura, a operação será executada. O CosmosPagedFlux<T> conterá uma ou várias respostas de feed dos usuários obtidos. Em caso de falha, o CosmosPagedFlux<T> erro será.
Parameters:
Returns:
queryUsers
public CosmosPagedFlux
Consultar usuários do Cosmos em um banco de dados.
Após a assinatura, a operação será executada. O CosmosPagedFlux<T> conterá uma ou várias respostas de feed dos usuários obtidos. Em caso de falha, o CosmosPagedFlux<T> erro será.
Parameters:
Returns:
queryUsers
public CosmosPagedFlux
Consultar usuários do Cosmos em um banco de dados.
Após a assinatura, a operação será executada. O CosmosPagedFlux<T> conterá uma ou várias respostas de feed dos usuários obtidos. Em caso de falha, o CosmosPagedFlux<T> erro será.
Parameters:
Returns:
read
public Mono
Lê um banco de dados. Busque os detalhes e as propriedades de um banco de dados com base em seu identificador exclusivo.
CosmosAsyncDatabase database = cosmosAsyncClient
.getDatabase("<YOUR DATABASE NAME>");
database.read().subscribe(databaseResponse -> {
System.out.println(databaseResponse);
},
throwable -> {
throwable.printStackTrace();
});
Após a assinatura, a operação será executada. O Mono após a conclusão bem-sucedida conterá uma única resposta de banco de dados cosmos com o banco de dados de leitura. Em caso de falha, o Mono erro será.
Returns:
read
public Mono
Lê um banco de dados. Busque os detalhes e as propriedades de um banco de dados com base em seu identificador exclusivo.
CosmosAsyncDatabase database = cosmosAsyncClient
.getDatabase("<YOUR DATABASE NAME>");
database.read().subscribe(databaseResponse -> {
System.out.println(databaseResponse);
},
throwable -> {
throwable.printStackTrace();
});
Após a assinatura, a operação será executada. O Mono após a conclusão bem-sucedida conterá uma resposta de banco de dados cosmos com o banco de dados de leitura. Em caso de falha, o Mono erro será.
Parameters:
Returns:
readAllClientEncryptionKeys
public CosmosPagedFlux
Lê todas as chaves de criptografia do cliente Cosmos em um banco de dados.
Após a assinatura, a operação será executada. O CosmosPagedFlux<T> conterá uma ou várias respostas de feed das chaves de criptografia de cliente do Cosmos de leitura. Em caso de falha, o CosmosPagedFlux<T> erro será.
Returns:
readAllClientEncryptionKeys
public CosmosPagedFlux
Lê todas as chaves de criptografia do cliente Cosmos em um banco de dados.
Após a assinatura, a operação será executada. O CosmosPagedFlux<T> conterá uma ou várias respostas de feed das chaves de criptografia de cliente do Cosmos de leitura. Em caso de falha, o CosmosPagedFlux<T> erro será.
Parameters:
Returns:
readAllContainers
public CosmosPagedFlux
Lê todos os contêineres do Cosmos.
cosmosAsyncDatabase.readAllContainers()
.byPage()
.flatMap(containerPropertiesFeedResponse -> {
for (CosmosContainerProperties properties : containerPropertiesFeedResponse.getResults()) {
System.out.println(properties);
}
return Flux.empty();
})
.subscribe();
Após a assinatura, a operação será executada. O CosmosPagedFlux<T> conterá uma ou várias respostas de feed dos contêineres de leitura. Em caso de falha, o CosmosPagedFlux<T> erro será.
Returns:
readAllContainers
public CosmosPagedFlux
Lê todos os contêineres do Cosmos.
cosmosAsyncDatabase.readAllContainers()
.byPage()
.flatMap(containerPropertiesFeedResponse -> {
for (CosmosContainerProperties properties : containerPropertiesFeedResponse.getResults()) {
System.out.println(properties);
}
return Flux.empty();
})
.subscribe();
Após a assinatura, a operação será executada. O CosmosPagedFlux<T> conterá uma ou várias respostas de feed dos contêineres de leitura. Em caso de falha, o CosmosPagedFlux<T> erro será.
Parameters:
Returns:
readAllUsers
public CosmosPagedFlux
Lê todos os usuários do Cosmos em um banco de dados.
cosmosAsyncDatabase.readAllUsers()
.byPage()
.flatMap(userPropertiesFeedResponse -> {
for (CosmosUserProperties properties : userPropertiesFeedResponse.getResults()) {
System.out.println(properties);
}
return Flux.empty();
})
.subscribe();
Após a assinatura, a operação será executada. O CosmosPagedFlux<T> conterá uma ou várias respostas de feed dos usuários do Cosmos de leitura. Em caso de falha, o CosmosPagedFlux<T> erro será.
Returns:
readThroughput
public Mono
Obtém a taxa de transferência do banco de dados.
cosmosAsyncDatabase.readThroughput()
.subscribe(throughputResponse -> {
System.out.println(throughputResponse);
},
throwable -> {
throwable.printStackTrace();
});
Returns:
replaceThroughput
public Mono
Define a taxa de transferência provisionada para um contêiner na medição de Solicitações por Unidade no serviço do Azure Cosmos.
ThroughputProperties autoscaledThroughput = ThroughputProperties
.createAutoscaledThroughput(autoScaleMaxThroughput);
cosmosAsyncDatabase.replaceThroughput(autoscaledThroughput)
.subscribe(throughputResponse -> {
System.out.println(throughputResponse);
},
throwable -> {
throwable.printStackTrace();
});
Parameters:
Returns:
upsertUser
public Mono
Fazer upsert de um usuário. O Upsert criará um novo usuário se ele não existir ou substituirá o existente se existir. Após a assinatura, a operação será executada. O Mono após a conclusão bem-sucedida conterá uma única resposta de recurso com o usuário criado. Em caso de falha, o Mono erro será.
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)
);
Parameters:
Returns:
Aplica-se a
Azure SDK for Java
Comentários
Brevemente: Ao longo de 2024, vamos descontinuar progressivamente o GitHub Issues como mecanismo de feedback para conteúdos e substituí-lo por um novo sistema de feedback. Para obter mais informações, veja: https://aka.ms/ContentUserFeedback.
Submeter e ver comentários