CosmosAsyncDatabase Classe

public Mono createClientEncryptionKey(CosmosClientEncryptionKeyProperties keyProperties)

Crée une clé de chiffrement client après l’abonnement, l’opération sera effectuée. En Mono cas de réussite de l’exécution, le contient une seule réponse de ressource avec la clé de chiffrement client créée. En cas d’échec, l’erreur Mono sera générée.

Paramètres:

Retours:

public Mono createContainer(CosmosContainerProperties containerProperties)

Crée un conteneur 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)
     );

Après l’abonnement, l’opération est effectuée. En Mono cas de réussite de l’exécution, le contient une réponse de conteneur Cosmos avec le conteneur créé. En cas d’échec, l’erreur Mono sera générée.

Paramètres:

Retours:

public Mono createContainer(CosmosContainerProperties containerProperties, CosmosContainerRequestOptions options)

Crée un conteneur 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)
     );

Après l’abonnement, l’opération est effectuée. En Mono cas de réussite de l’exécution, le contient une réponse de conteneur Cosmos avec le conteneur créé. En cas d’échec, l’erreur Mono sera générée.

Paramètres:

Retours:

public Mono createContainer(CosmosContainerProperties containerProperties, ThroughputProperties throughputProperties)

Crée un conteneur Cosmos avec des propriétés de débit personnalisées.

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)
     );

Après l’abonnement, l’opération est effectuée. En Mono cas de réussite de l’exécution, le contient une réponse de conteneur Cosmos avec le conteneur créé. En cas d’échec, l’erreur Mono sera générée.

Paramètres:

Retours:

public Mono createContainer(CosmosContainerProperties containerProperties, ThroughputProperties throughputProperties, CosmosContainerRequestOptions options)

Crée un conteneur.

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)
     );

Paramètres:

Retours:

public Mono createContainer(String id, String partitionKeyPath)

Crée un conteneur 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)
     );

Après l’abonnement, l’opération est effectuée. En Mono cas de réussite de l’exécution, le contient une réponse de conteneur Cosmos avec le conteneur créé. En cas d’échec, l’erreur Mono sera générée.

Paramètres:

Retours:

public Mono createContainer(String id, String partitionKeyPath, ThroughputProperties throughputProperties)

Crée un conteneur 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)
     );

Après l’abonnement, l’opération est effectuée. En Mono cas de réussite de l’exécution, le contient une réponse de conteneur Cosmos avec le conteneur créé. En cas d’échec, l’erreur Mono sera générée.

Paramètres:

Retours:

public Mono createContainerIfNotExists(CosmosContainerProperties containerProperties)

Crée un conteneur Cosmos s’il n’existe pas sur le service.

CosmosContainerProperties containerProperties =
     new CosmosContainerProperties(containerId, partitionKeyDefinition);
 cosmosAsyncDatabase.createContainerIfNotExists(containerProperties)
     .subscribe(
         cosmosContainerResponse -> System.out.println(cosmosContainerResponse),
         throwable -> System.out.println("Failed to create container: " + throwable)
     );

Après l’abonnement, l’opération est effectuée. En Mono cas de réussite de l’exécution, le contient une réponse de conteneur Cosmos avec le conteneur créé ou existant. En cas d’échec, l’erreur Mono sera générée.

Paramètres:

Retours:

public Mono createContainerIfNotExists(CosmosContainerProperties containerProperties, ThroughputProperties throughputProperties)

Crée un conteneur Cosmos s’il n’existe pas sur le service.

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)
     );

Les propriétés de débit ne sont utilisées que si le conteneur spécifié n’existe pas et qu’un conteneur est alors créé.

Après l’abonnement, l’opération est effectuée. En Mono cas de réussite de l’exécution, le contient une réponse de conteneur Cosmos avec le conteneur créé ou existant. En cas d’échec, l’erreur Mono sera générée.

Paramètres:

Retours:

public Mono createContainerIfNotExists(String id, String partitionKeyPath)

Crée un conteneur Cosmos s’il n’existe pas sur le service.

CosmosContainerProperties containerProperties =
     new CosmosContainerProperties(containerId, partitionKeyDefinition);
 cosmosAsyncDatabase.createContainerIfNotExists(containerProperties)
     .subscribe(
         cosmosContainerResponse -> System.out.println(cosmosContainerResponse),
         throwable -> System.out.println("Failed to create container: " + throwable)
     );

Après l’abonnement, l’opération est effectuée. En Mono cas de réussite de l’exécution, le contient une réponse de conteneur Cosmos avec le conteneur créé. En cas d’échec, l’erreur Mono sera générée.

Paramètres:

Retours:

public Mono createContainerIfNotExists(String id, String partitionKeyPath, ThroughputProperties throughputProperties)

Crée un conteneur Cosmos s’il n’existe pas sur le service.

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)
     );

Les propriétés de débit ne sont utilisées que si le conteneur spécifié n’existe pas et qu’un conteneur est alors créé.

Après l’abonnement, l’opération est effectuée. En Mono cas de réussite de l’exécution, le contient une réponse de conteneur Cosmos avec le conteneur créé. En cas d’échec, l’erreur Mono sera générée.

Paramètres:

Retours:

public Mono createUser(CosmosUserProperties userProperties)

Crée un utilisateur Après l’abonnement, l’opération sera effectuée. En Mono cas de réussite de l’exécution, le contient une seule réponse de ressource avec l’utilisateur créé. En cas d’échec, l’erreur Mono sera générée.

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)
     );

Paramètres:

Retours:

public Mono delete()

Supprime la base de données Cosmos actuelle.

CosmosAsyncDatabase database = cosmosAsyncClient
     .getDatabase("<YOUR DATABASE NAME>");
 database.delete().subscribe(databaseResponse -> {
         System.out.println(databaseResponse);
     },
     throwable -> {
         throwable.printStackTrace();
     });

Après l’abonnement, l’opération est effectuée. En Mono cas de réussite de l’exécution, le contient une réponse de base de données Cosmos avec la base de données supprimée. En cas d’échec, l’erreur Mono sera générée.

Retours:

public Mono delete(CosmosDatabaseRequestOptions options)

Supprime la base de données Cosmos actuelle tout en spécifiant des options de requête supplémentaires.

CosmosAsyncDatabase database = cosmosAsyncClient
     .getDatabase("<YOUR DATABASE NAME>");
 database.delete().subscribe(databaseResponse -> {
         System.out.println(databaseResponse);
     },
     throwable -> {
         throwable.printStackTrace();
     });

Après l’abonnement, l’opération est effectuée. En Mono cas de réussite de l’exécution, le contient une réponse de base de données Cosmos avec la base de données supprimée. En cas d’échec, l’erreur Mono sera générée.

Paramètres:

Retours:

public CosmosAsyncClientEncryptionKey getClientEncryptionKey(String id)

Obtient un objet CosmosAsyncClientEncryptionKey sans effectuer d’appel de service

Paramètres:

Retours:

public CosmosAsyncContainer getContainer(String id)

Obtient un objet CosmosAsyncContainer sans effectuer d’appel de service

Paramètres:

Retours:

public String getId()

Obtenez l’ID de CosmosAsyncDatabase.

Retours:

public CosmosAsyncUser getUser(String id)

Obtient l’utilisateur.

Paramètres:

Retours:

public CosmosPagedFlux queryClientEncryptionKeys(SqlQuerySpec querySpec)

Requête pour les clés de chiffrement du client cosmos dans une base de données.

Après l’abonnement, l’opération est effectuée. contient CosmosPagedFlux<T> une ou plusieurs réponses de flux des clés de chiffrement client obtenues. En cas d’échec, l’erreur CosmosPagedFlux<T> will.

Paramètres:

Retours:

public CosmosPagedFlux queryClientEncryptionKeys(SqlQuerySpec querySpec, CosmosQueryRequestOptions options)

Requête pour les clés de chiffrement du client cosmos dans une base de données.

Après l’abonnement, l’opération est effectuée. contient CosmosPagedFlux<T> une ou plusieurs réponses de flux des clés de chiffrement client obtenues. En cas d’échec, l’erreur CosmosPagedFlux<T> will.

Paramètres:

Retours:

public CosmosPagedFlux queryClientEncryptionKeys(String query)

Requête pour les clés de chiffrement du client cosmos dans une base de données.

Après l’abonnement, l’opération est effectuée. contient CosmosPagedFlux<T> une ou plusieurs réponses de flux des clés de chiffrement client obtenues. En cas d’échec, l’erreur CosmosPagedFlux<T> will.

Paramètres:

Retours:

public CosmosPagedFlux queryClientEncryptionKeys(String query, CosmosQueryRequestOptions options)

Requête pour les clés de chiffrement du client cosmos dans une base de données.

Après l’abonnement, l’opération est effectuée. contient CosmosPagedFlux<T> une ou plusieurs réponses de flux des clés de chiffrement client obtenues. En cas d’échec, l’erreur CosmosPagedFlux<T> will.

Paramètres:

Retours:

public CosmosPagedFlux queryContainers(SqlQuerySpec querySpec)

Interrogez les conteneurs cosmos dans une base de données cosmos.

cosmosAsyncDatabase.queryContainers("SELECT * FROM DB_NAME")
     .byPage()
     .flatMap(containerPropertiesFeedResponse -> {
         for (CosmosContainerProperties properties : containerPropertiesFeedResponse.getResults()) {
             System.out.println(properties);
         }
         return Flux.empty();
     })
     .subscribe();

Après l’abonnement, l’opération est effectuée. contient CosmosPagedFlux<T> une ou plusieurs réponses de flux des conteneurs obtenus. En cas d’échec, l’erreur CosmosPagedFlux<T> will.

Paramètres:

Retours:

public CosmosPagedFlux queryContainers(SqlQuerySpec querySpec, CosmosQueryRequestOptions options)

Interrogez les conteneurs cosmos dans une base de données cosmos.

cosmosAsyncDatabase.queryContainers("SELECT * FROM DB_NAME")
     .byPage()
     .flatMap(containerPropertiesFeedResponse -> {
         for (CosmosContainerProperties properties : containerPropertiesFeedResponse.getResults()) {
             System.out.println(properties);
         }
         return Flux.empty();
     })
     .subscribe();

Après l’abonnement, l’opération est effectuée. contient CosmosPagedFlux<T> une ou plusieurs réponses de flux des conteneurs obtenus. En cas d’échec, l’erreur CosmosPagedFlux<T> will.

Paramètres:

Retours:

public CosmosPagedFlux queryContainers(String query)

Interrogez les conteneurs cosmos dans une base de données cosmos.

cosmosAsyncDatabase.queryContainers("SELECT * FROM DB_NAME")
     .byPage()
     .flatMap(containerPropertiesFeedResponse -> {
         for (CosmosContainerProperties properties : containerPropertiesFeedResponse.getResults()) {
             System.out.println(properties);
         }
         return Flux.empty();
     })
     .subscribe();

Après l’abonnement, l’opération est effectuée. contient CosmosPagedFlux<T> une ou plusieurs réponses de flux des conteneurs obtenus. En cas d’échec, l’erreur CosmosPagedFlux<T> will.

Paramètres:

Retours:

public CosmosPagedFlux queryContainers(String query, CosmosQueryRequestOptions options)

Interrogez les conteneurs cosmos dans une base de données cosmos.

cosmosAsyncDatabase.queryContainers("SELECT * FROM DB_NAME")
     .byPage()
     .flatMap(containerPropertiesFeedResponse -> {
         for (CosmosContainerProperties properties : containerPropertiesFeedResponse.getResults()) {
             System.out.println(properties);
         }
         return Flux.empty();
     })
     .subscribe();

Après l’abonnement, l’opération est effectuée. contient CosmosPagedFlux<T> une ou plusieurs réponses de flux des conteneurs obtenus. En cas d’échec, l’erreur CosmosPagedFlux<T> will.

Paramètres:

Retours:

public CosmosPagedFlux queryUsers(SqlQuerySpec querySpec)

Requête pour les utilisateurs cosmos dans une base de données.

Après l’abonnement, l’opération est effectuée. contient CosmosPagedFlux<T> une ou plusieurs réponses de flux des utilisateurs obtenus. En cas d’échec, l’erreur CosmosPagedFlux<T> will.

Paramètres:

Retours:

public CosmosPagedFlux queryUsers(SqlQuerySpec querySpec, CosmosQueryRequestOptions options)

Requête pour les utilisateurs cosmos dans une base de données.

Après l’abonnement, l’opération est effectuée. contient CosmosPagedFlux<T> une ou plusieurs réponses de flux des utilisateurs obtenus. En cas d’échec, l’erreur CosmosPagedFlux<T> will.

Paramètres:

Retours:

public CosmosPagedFlux queryUsers(String query)

Requête pour les utilisateurs cosmos dans une base de données.

Après l’abonnement, l’opération est effectuée. contient CosmosPagedFlux<T> une ou plusieurs réponses de flux des utilisateurs obtenus. En cas d’échec, l’erreur CosmosPagedFlux<T> will.

Paramètres:

Retours:

public CosmosPagedFlux queryUsers(String query, CosmosQueryRequestOptions options)

Requête pour les utilisateurs cosmos dans une base de données.

Après l’abonnement, l’opération est effectuée. contient CosmosPagedFlux<T> une ou plusieurs réponses de flux des utilisateurs obtenus. En cas d’échec, l’erreur CosmosPagedFlux<T> will.

Paramètres:

Retours:

public Mono read()

Lit une base de données. Récupérez les détails et les propriétés d’une base de données en fonction de son identificateur unique.

CosmosAsyncDatabase database = cosmosAsyncClient
     .getDatabase("<YOUR DATABASE NAME>");
 database.read().subscribe(databaseResponse -> {
         System.out.println(databaseResponse);
     },
     throwable -> {
         throwable.printStackTrace();
     });

Après l’abonnement, l’opération est effectuée. Une Mono fois la saisie terminée, le contient une seule réponse de base de données cosmos avec la base de données en lecture. En cas d’échec, l’erreur Mono will.

Retours:

public Mono read(CosmosDatabaseRequestOptions options)

Lit une base de données. Récupérez les détails et les propriétés d’une base de données en fonction de son identificateur unique.

CosmosAsyncDatabase database = cosmosAsyncClient
     .getDatabase("<YOUR DATABASE NAME>");
 database.read().subscribe(databaseResponse -> {
         System.out.println(databaseResponse);
     },
     throwable -> {
         throwable.printStackTrace();
     });

Après l’abonnement, l’opération est effectuée. Une Mono fois la saisie terminée, le contient une réponse de base de données cosmos avec la base de données en lecture. En cas d’échec, l’erreur Mono will.

Paramètres:

Retours:

public CosmosPagedFlux readAllClientEncryptionKeys()

Lit toutes les clés de chiffrement du client Cosmos dans une base de données.

Après l’abonnement, l’opération est effectuée. contient CosmosPagedFlux<T> une ou plusieurs réponses de flux des clés de chiffrement client cosmos read. En cas d’échec, l’erreur CosmosPagedFlux<T> will.

Retours:

public CosmosPagedFlux readAllClientEncryptionKeys(CosmosQueryRequestOptions options)

Lit toutes les clés de chiffrement du client Cosmos dans une base de données.

Après l’abonnement, l’opération est effectuée. contient CosmosPagedFlux<T> une ou plusieurs réponses de flux des clés de chiffrement client cosmos read. En cas d’échec, l’erreur CosmosPagedFlux<T> will.

Paramètres:

Retours:

public CosmosPagedFlux readAllContainers()

Lit tous les conteneurs cosmos.

cosmosAsyncDatabase.readAllContainers()
     .byPage()
     .flatMap(containerPropertiesFeedResponse -> {
         for (CosmosContainerProperties properties : containerPropertiesFeedResponse.getResults()) {
             System.out.println(properties);
         }
         return Flux.empty();
     })
     .subscribe();

Après l’abonnement, l’opération est effectuée. contient CosmosPagedFlux<T> une ou plusieurs réponses de flux des conteneurs de lecture. En cas d’échec, l’erreur CosmosPagedFlux<T> will.

Retours:

public CosmosPagedFlux readAllContainers(CosmosQueryRequestOptions options)

Lit tous les conteneurs cosmos.

cosmosAsyncDatabase.readAllContainers()
     .byPage()
     .flatMap(containerPropertiesFeedResponse -> {
         for (CosmosContainerProperties properties : containerPropertiesFeedResponse.getResults()) {
             System.out.println(properties);
         }
         return Flux.empty();
     })
     .subscribe();

Après l’abonnement, l’opération est effectuée. contient CosmosPagedFlux<T> une ou plusieurs réponses de flux des conteneurs de lecture. En cas d’échec, l’erreur CosmosPagedFlux<T> will.

Paramètres:

Retours:

public CosmosPagedFlux readAllUsers()

Lit tous les utilisateurs cosmos dans une base de données.

cosmosAsyncDatabase.readAllUsers()
     .byPage()
     .flatMap(userPropertiesFeedResponse -> {
         for (CosmosUserProperties properties : userPropertiesFeedResponse.getResults()) {
             System.out.println(properties);
         }
         return Flux.empty();
     })
     .subscribe();

Après l’abonnement, l’opération est effectuée. contient CosmosPagedFlux<T> une ou plusieurs réponses de flux des utilisateurs cosmos de lecture. En cas d’échec, l’erreur CosmosPagedFlux<T> will.

Retours:

public Mono readThroughput()

Obtient le débit de la base de données.

cosmosAsyncDatabase.readThroughput()
     .subscribe(throughputResponse -> {
             System.out.println(throughputResponse);
         },
         throwable -> {
             throwable.printStackTrace();
         });

Retours:

public Mono replaceThroughput(ThroughputProperties throughputProperties)

Définit le débit approvisionné pour un conteneur dans la mesure des requêtes par unité dans le service Azure Cosmos.

ThroughputProperties autoscaledThroughput = ThroughputProperties
     .createAutoscaledThroughput(autoScaleMaxThroughput);
 cosmosAsyncDatabase.replaceThroughput(autoscaledThroughput)
     .subscribe(throughputResponse -> {
             System.out.println(throughputResponse);
         },
         throwable -> {
             throwable.printStackTrace();
         });

Paramètres:

Retours:

public Mono upsertUser(CosmosUserProperties userProperties)

Upsert un utilisateur. Upsert crée un utilisateur s’il n’existe pas, ou remplace l’utilisateur existant s’il le fait. Après l’abonnement, l’opération est effectuée. Une Mono fois la saisie terminée, le contient une seule réponse de ressource avec l’utilisateur créé. En cas d’échec, l’erreur Mono will.

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)
     );

Paramètres:

Retours: