JavaScript クエリ API を使用して Azure Cosmos DB でストアド プロシージャとトリガーを記述する方法

  • 適用対象: ✅ NoSQL

Azure Cosmos DB を使用すると、ストアド プロシージャやトリガーの記述に使用できる SQL 言語に関する知識がなくても、Fluent JavaScript インターフェイスを使用して最適化されたクエリを実行できます。 Azure Cosmos DB での JavaScript クエリ API のサポートの詳細については、Azure Cosmos DB での JavaScript 言語統合クエリ API の使用に 関する記事を参照してください。

JavaScript クエリ API を使用したストアド プロシージャ

次のコード サンプルは、ストアド プロシージャのコンテキストで JavaScript クエリ API を使用する方法の例です。 ストアド プロシージャは、入力パラメーターで指定された Azure Cosmos DB 項目を挿入し、入力項目のサイズ プロパティに基づいて minSize、maxSize、totalSize を指定して、 __.filter() メソッドを使用してメタデータ ドキュメントを更新します。

注

__ (二重アンダースコア) は、JavaScript クエリ API を使用するときに getContext().getCollection() するエイリアスです。

/**
 * 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.");
}

次のステップ

Azure Cosmos DB のストアド プロシージャ、トリガー、およびユーザー定義関数の詳細については、次の記事を参照してください。

  • 最終更新: