Mongodbで一致するサブドキュメントの配列を一括更新します

異なるアレイ条件のマッチング

ポイントでそれを説明して、あなたの「チェンジセット」の最初の2つのアイテムを考えてください。 「シングル」を適用できます 複数のarrayFiltersでステートメントを更新します このように：

db.avail_rates_copy.updateOne(
  { "_id": 12345 },
  { 
    "$set": {
      "rates.$[one]": {
        "productId" : NumberInt(1234), 
        "rate" : 400.0, 
        "rateCardId": NumberInt(1),
        "month" : NumberInt(201801)
      },
      "rates.$[two]": {
        "productId" : NumberInt(1234), 
        "rate" : 500.0, 
        "rateCardId": NumberInt(1),
        "month" : NumberInt(201802)
      } 
    }
  },
  { 
    "arrayFilters": [
      {
        "one.productId": NumberInt(1234),
        "one.rateCardId": NumberInt(1),
        "one.month": NumberInt(201801)
      },
      {
        "two.productId": NumberInt(1234),
        "two.rateCardId": NumberInt(1),
        "two.month": NumberInt(201802)
      }
    ]
  }
)

実行すると、変更されたドキュメントは次のようになります。

{
        "_id" : 12345,
        "_class" : "com.example.ProductRates",
        "rates" : [
                {                             // Matched and changed this by one
                        "productId" : 1234,
                        "rate" : 400,
                        "rateCardId" : 1,
                        "month" : 201801
                },
                {                            // And this as two
                        "productId" : 1234,
                        "rate" : 500,
                        "rateCardId" : 1,
                        "month" : 201802
                },
                {
                        "productId" : 1234,
                        "rate" : 400,
                        "rateCardId" : 2,
                        "month" : 201803
                },
                {
                        "productId" : 1235,
                        "rate" : 500,
                        "rateCardId" : 1,
                        "month" : 201801
                },
                {
                        "productId" : 1235,
                        "rate" : 234,
                        "rateCardId" : 2,
                        "month" : 201803
                }
        ]
}

ここで、 arrayFiltersのリスト内で各「識別子」を指定することに注意してください。 次のように要素に一致する複数の条件を使用します：

  {
    "one.productId": NumberInt(1234),
    "one.rateCardId": NumberInt(1),
    "one.month": NumberInt(201801)
  },

したがって、各「条件」は効果的に次のようにマッピングされます。

  <identifier>.<property>

したがって、 "rates"を見ていることがわかります。 $ [] ：

 "rates.$[one]"

そして、 "rates"の各要素を調べます 条件に合うように。つまり、 "one" 識別子は、接頭辞 "one"の条件に一致します 同様に、接頭辞 "two"が付いた他の一連の条件についても同様です。 したがって、実際の更新ステートメントは、識別子に割り当てられた条件に一致するステートメントにのみ適用されます。

"rates"が必要な場合 オブジェクト全体ではなくプロパティの場合は、次のように表記します。

{ "$set": { "rates.$[one].rate": 400, "rates.$[two].rate": 500 } }

一致しないオブジェクトの追加

したがって、最初の部分は比較的簡単に理解できますが、前述のように、 $ push 「存在しない要素」については別の問題です。配列要素が「欠落している」と判断するには、基本的に「ドキュメント」レベルのクエリ条件が必要だからです。

そして、サーバーに発行されたその単一のステートメントは、基本的に4つを試行します 一致した配列要素の更新を試行するための操作と、3つごとの更新操作 $ pushを試みる「変更セット」 ドキュメントが「変更セット」の配列要素の条件と一致しないことが判明した場合。

したがって、結果は期待どおりです。

{
        "_id" : 12345,
        "_class" : "com.example.ProductRates",
        "rates" : [
                {                               // matched and updated
                        "productId" : 1234,
                        "rate" : 400,
                        "rateCardId" : 1,
                        "month" : 201801
                },
                {                               // matched and updated
                        "productId" : 1234,
                        "rate" : 500,
                        "rateCardId" : 1,
                        "month" : 201802
                },
                {
                        "productId" : 1234,
                        "rate" : 400,
                        "rateCardId" : 2,
                        "month" : 201803
                },
                {
                        "productId" : 1235,
                        "rate" : 500,
                        "rateCardId" : 1,
                        "month" : 201801
                },
                {
                        "productId" : 1235,
                        "rate" : 234,
                        "rateCardId" : 2,
                        "month" : 201803
                },
                {                              // This was appended
                        "productId" : 1235,
                        "rate" : 700,
                        "rateCardId" : 1,
                        "month" : 201802
                }
        ]
}

実際にbulkWrite（）と一致しなかった要素の数によって異なります 応答は、それらのステートメントのどれだけが実際にドキュメントに一致し、影響を与えたかについて報告します。この場合は2 「最初の」更新操作は既存の配列エントリと一致し、「最後の」変更更新はドキュメントに配列エントリが含まれていないことと一致し、 $ push 変更します。

結論

つまり、組み合わせたアプローチがあります。

• 質問の「更新」の最初の部分は非常に簡単で、単一のステートメントで実行できます。 、最初のセクションで示されているように。

• 「現在存在しない」配列要素がある2番目の部分 現在のドキュメント配列内では、実際にはを使用する必要があります。 BulkWrite（） 1つのリクエストで「複数の」操作を発行するため。

したがって、更新 、は1回の操作に対して「YES」です。しかし、違いを追加する 複数の操作を意味します。ただし、ここに示すように、2つのアプローチを組み合わせることができます。

コードを使用して「changeset」配列の内容に基づいてこれらのステートメントを作成する「凝った」方法はたくさんあるので、各メンバーを「ハードコーディング」する必要はありません。

JavaScriptの基本的なケースとして、mongoシェルの現在のリリースと互換性があります（オブジェクト拡散演算子をサポートしていません）：

db.getCollection('avail_rates_copy').drop();
db.getCollection('avail_rates_copy').insert(
  {
    "_id" : 12345,
    "_class" : "com.example.ProductRates",
    "rates" : [
      {
        "productId" : 1234,
        "rate" : 100,
        "rateCardId" : 1,
        "month" : 201801
      },
      {
        "productId" : 1234,
        "rate" : 200,
        "rateCardId" : 1,
        "month" : 201802
      },
      {
        "productId" : 1234,
        "rate" : 400,
        "rateCardId" : 2,
        "month" : 201803
      },
      {
        "productId" : 1235,
        "rate" : 500,
        "rateCardId" : 1,
        "month" : 201801
      },
      {
        "productId" : 1235,
        "rate" : 234,
        "rateCardId" : 2,
        "month" : 201803
      }
    ]
  }
);

var changeSet = [
  {
      "productId" : 1234, 
      "rate" : 400.0, 
      "rateCardId": 1,
      "month" : 201801
  }, 
  {
      "productId" : 1234, 
      "rate" : 500.0, 
      "rateCardId": 1,
      "month" : 201802
  }, 
  {

      "productId" : 1235, 
      "rate" : 700.0, 
      "rateCardId": 1,
      "month" : 201802
  }
];

var arrayFilters = changeSet.map((obj,i) => 
  Object.keys(obj).filter(k => k != 'rate' )
    .reduce((o,k) => Object.assign(o, { [`u${i}.${k}`]: obj[k] }) ,{})
);

var $set = changeSet.reduce((o,r,i) =>
  Object.assign(o, { [`rates.$[u${i}].rate`]: r.rate }), {});

var updates = [
  { "updateOne": {
    "filter": { "_id": 12345 },
    "update": { $set },
    arrayFilters
  }},
  ...changeSet.map(obj => (
    { "updateOne": {
      "filter": {
        "_id": 12345,
        "rates": {
          "$not": {
            "$elemMatch": Object.keys(obj).filter(k => k != 'rate')
              .reduce((o,k) => Object.assign(o, { [k]: obj[k] }),{})
          }
        }
      },
      "update": {
        "$push": {
          "rates": obj
        }
      }
    }}
  ))
];

db.getCollection('avail_rates_copy').bulkWrite(updates,{ ordered: true });

これにより、次のような「一括」更新操作のリストが動的に作成されます。

[
  {
    "updateOne": {
      "filter": {
        "_id": 12345
      },
      "update": {
        "$set": {
          "rates.$[u0].rate": 400,
          "rates.$[u1].rate": 500,
          "rates.$[u2].rate": 700
        }
      },
      "arrayFilters": [
        {
          "u0.productId": 1234,
          "u0.rateCardId": 1,
          "u0.month": 201801
        },
        {
          "u1.productId": 1234,
          "u1.rateCardId": 1,
          "u1.month": 201802
        },
        {
          "u2.productId": 1235,
          "u2.rateCardId": 1,
          "u2.month": 201802
        }
      ]
    }
  },
  {
    "updateOne": {
      "filter": {
        "_id": 12345,
        "rates": {
          "$not": {
            "$elemMatch": {
              "productId": 1234,
              "rateCardId": 1,
              "month": 201801
            }
          }
        }
      },
      "update": {
        "$push": {
          "rates": {
            "productId": 1234,
            "rate": 400,
            "rateCardId": 1,
            "month": 201801
          }
        }
      }
    }
  },
  {
    "updateOne": {
      "filter": {
        "_id": 12345,
        "rates": {
          "$not": {
            "$elemMatch": {
              "productId": 1234,
              "rateCardId": 1,
              "month": 201802
            }
          }
        }
      },
      "update": {
        "$push": {
          "rates": {
            "productId": 1234,
            "rate": 500,
            "rateCardId": 1,
            "month": 201802
          }
        }
      }
    }
  },
  {
    "updateOne": {
      "filter": {
        "_id": 12345,
        "rates": {
          "$not": {
            "$elemMatch": {
              "productId": 1235,
              "rateCardId": 1,
              "month": 201802
            }
          }
        }
      },
      "update": {
        "$push": {
          "rates": {
            "productId": 1235,
            "rate": 700,
            "rateCardId": 1,
            "month": 201802
          }
        }
      }
    }
  }
]

一般的な回答の「長い形式」で説明されているのと同じですが、もちろん、これらのステートメントをすべて作成するために、入力された「配列」コンテンツを使用するだけです。

このような動的オブジェクト構築は任意の言語で実行でき、すべてのMongoDBドライバーは、「操作」が許可されているある種の構造の入力を受け入れ、実際にサーバーに送信されて実行される前にBSONに変換されます。