Comment écrire des procédures stockées et des déclencheurs dans Azure Cosmos DB à l’aide de l’API de requête JavaScript

  • Article

S’APPLIQUE À : NoSQL

Azure Cosmos DB vous permet d’envoyer des requêtes optimisées à l’aide d’une interface JavaScript fluide, sans avoir besoin de connaissances particulières en matière de langage SQL. Vous pouvez utiliser cette interface pour écrire des procédures stockées ou des déclencheurs. Pour en savoir plus sur la prise en charge de l’API de requête JavaScript dans Azure Cosmos DB, consultez l’article Working with JavaScript language-integrated query API with Azure Cosmos DB (Utilisation de l’API de requête avec langage intégré JavaScript avec Azure Cosmos DB).

Procédure stockée utilisant l’API de requête JavaScript

L’exemple de code suivant illustre comment l’API de requête JavaScript est utilisée dans le contexte d’une procédure stockée. La procédure stockée insère un élément Azure Cosmos DB, spécifié par un paramètre d’entrée, et met à jour un document de métadonnées à l’aide de la méthode __.filter(), avec minSize, maxSize et totalSize basés sur la propriété de taille de l’élément d’entrée.

Notes

__ (trait de soulignement double) est un alias pour getContext().getCollection() lors de l’utilisation de l’API de requête JavaScript.

/**
 * Insert an item and update metadata doc: minSize, maxSize, totalSize based on item.size.
 */
function insertDocumentAndUpdateMetadata(item) {
  // HTTP error codes sent to our callback function by CosmosDB server.
  var ErrorCode = {
    RETRY_WITH: 449,
  }

  var isAccepted = __.createDocument(__.getSelfLink(), item, {}, function(err, item, options) {
    if (err) throw err;

    // Check the item (ignore items with invalid/zero size and metadata itself) and call updateMetadata.
    if (!item.isMetadata && item.size > 0) {
      // Get the metadata. We keep it in the same container. it's the only item that has .isMetadata = true.
      var result = __.filter(function(x) {
        return x.isMetadata === true
      }, function(err, feed, options) {
        if (err) throw err;

        // We assume that metadata item was pre-created and must exist when this script is called.
        if (!feed || !feed.length) throw new Error("Failed to find the metadata item.");

        // The metadata item.
        var metaItem = feed[0];

        // Update metaDoc.minSize:
        // for 1st document use doc.Size, for all the rest see if it's less than last min.
        if (metaItem.minSize == 0) metaItem.minSize = item.size;
        else metaItem.minSize = Math.min(metaItem.minSize, item.size);

        // Update metaItem.maxSize.
        metaItem.maxSize = Math.max(metaItem.maxSize, item.size);

        // Update metaItem.totalSize.
        metaItem.totalSize += item.size;

        // Update/replace the metadata item in the store.
        var isAccepted = __.replaceDocument(metaItem._self, metaItem, function(err) {
          if (err) throw err;
          // Note: in case concurrent updates causes conflict with ErrorCode.RETRY_WITH, we can't read the meta again
          //       and update again because due to Snapshot isolation we will read same exact version (we are in same transaction).
          //       We have to take care of that on the client side.
        });
        if (!isAccepted) throw new Error("replaceDocument(metaItem) returned false.");
      });
      if (!result.isAccepted) throw new Error("filter for metaItem returned false.");
    }
  });
  if (!isAccepted) throw new Error("createDocument(actual item) returned false.");
}

Étapes suivantes

Consultez les articles suivants pour en savoir plus sur les procédures stockées, les déclencheurs et fonctions définies par l’utilisateur dans Azure Cosmos DB :