Udostępnij przez

Jak pisać procedury składowane i wyzwalacze w usłudze Azure Cosmos DB przy użyciu interfejsu API zapytań Języka JavaScript

  • Dotyczy: ✅ NoSQL

Usługa Azure Cosmos DB umożliwia wykonywanie zoptymalizowanych zapytań przy użyciu płynnego interfejsu języka JavaScript bez znajomości języka SQL, który może służyć do pisania procedur składowanych lub wyzwalaczy. Aby dowiedzieć się więcej na temat obsługi interfejsu API zapytań języka JavaScript w usłudze Azure Cosmos DB, zobacz Artykuł Praca ze zintegrowanym interfejsem API zapytań języka JavaScript w usłudze Azure Cosmos DB .

Procedura składowana używająca API zapytań JavaScript

Poniższy przykładowy kod to przykład użycia interfejsu API zapytań JavaScript w kontekście procedury składowanej. Procedura składowana wstawia element Azure Cosmos DB określony przez parametr wejściowy i aktualizuje dokument metadanych, używając metody __.filter(), przy czym wartości minSize, maxSize i totalSize są oparte na właściwości rozmiaru elementu wejściowego.

Uwaga / Notatka

__ (podwójne podkreślenie) to alias getContext().getCollection() używany podczas korzystania z interfejsu API zapytań Języka 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.");
}

Dalsze kroki

Zapoznaj się z następującymi artykułami, aby dowiedzieć się więcej o procedurach składowanych, wyzwalaczach i funkcjach zdefiniowanych przez użytkownika w usłudze Azure Cosmos DB:

  • Last updated on