配列メンバーの集計条件の一致条件

あなたは、彼らが何をしているのかを理解せずに、いくつかの既存の答えを「マージ」しようとしているようです。ここで本当に必要なのは、 $ filter です。 および $ size

db.collection.aggregate([
  { "$project": {
    "total": {
      "$size": {
        "$filter": {
          "input": "$Array",
          "cond": { "$eq": [ "$$this.field1", "a" ] }
        }
      }
    }
  }}
])

または、 $ reduceを使用して「車輪の再発明」を行います。 ：

db.collection.aggregate([
  { "$project": {
    "total": {
      "$reduce": {
        "input": "$Array",
        "initialValue": 0,
        "in": {
          "$sum": [
            "$$value", 
            { "$cond": [{ "$eq": [ "$$this.field1", "a" ] }, 1, 0] }
        }
      }
    }
  }}
])

または、 $ unwind 、実際には $ group もう一度、一致数を「カウント」するために：

db.collection.aggregate([
  { "$unwind": "$Array" },
  { "$match": { "Array.field1": "a" } },
  { "$group": {
    "_id": "$_id",
    "total": { "$sum": 1 }
  }}
])

$ filterの場合 、 "cond" で指定された条件を満たさなかった要素を除いて、配列は実際にはそのまま残ります。 アレイから削除されます。出力として「配列」がまだあるので、<を使用できます。 code> $ size そのフィルター条件が処理された後に残っている配列要素の数を測定する演算子。

$ reduce 一方、配列要素を処理し、各要素に対する式と、 "initialValue"で初期化した格納された「アキュムレータ」値を提供します。 。この場合、同じ $ eq テストは、 $ cond内で適用されます。 オペレーター。これは「三元」またはif/ then / else ブール値を返すテスト済みの式がthenを返すことを可能にする条件演算子 trueの場合の値 またはelse falseの場合の値 。

その式では、 1を返します。 または0 それぞれ、その戻り値と現在の「アキュムレータ」 "$$ value"を加算した全体的な結果を提供します。 $ sum これらを足し合わせる演算子。

最終的なフォームでは、 $ unwindを使用しました アレイ上。これが実際に行うことは、配列メンバーを分解して、すべての配列メンバーと元のドキュメントの関連する親フィールドの「新しいドキュメント」を作成することです。これにより、すべてのアレイメンバーのメインドキュメントが効果的に「コピー」されます。

$ unwind ドキュメントの構造が「よりフラットな」形式に変更されます。これが、後続の $match 一致しないドキュメントを削除するパイプラインステージ。

  { "$group": {
    "_id": "$_id",
    "Array": { "$push": "$Array" },
    "total": { "$sum": 1 }
  }}