MongoDBでネストされた配列にフィルタリング条件を設定する方法($filterと$condの使い方)

MongoDBでネストされた配列にフィルタリング条件を設定するには

MongoDBのaggregate()内で$filterと$condを使用すると、配列に対して柔軟なフィルタリング条件を設定できます。$filterは、指定した条件に基づいて配列の部分集合(条件を満たす要素のみ)を返却する演算子です。さらに、内部で$mapや$anyElementTrue、$indexOfBytesなどを組み合わせることで、ネストされた配列の中から特定の値を持つ要素だけを抽出できます。

この記事では、「Messages」というネストされた配列の中から、特定の文字列("Hello")を含むドキュメントだけを絞り込む方法を、実際のコード例とともに解説します。

1. コレクションとドキュメントの作成

まず、insertOne()メソッドを使って、ネストされた配列を持つドキュメントを含むコレクションを作成します。

> db.demo725.insertOne(
...     {
...         "details": {
...             "userMessages": [
...                 {
...                     "Messages": [
...                         { "Message": "Hello" },
...                         { "Message": "How" },
...                         { "Message": "are" }
...                     ]
...                 },
...                 {
...                     "Messages": [
...                         { "Message": "Good" },
...                         { "Message": "Bye" }
...                     ]
...                 },
...                 {
...                     "Messages": [
...                         { "Message": "Hello" },
...                         { "Message": "Bye" }
...                     ]
...                 }
...             ]
...         }
...     }
... );
{
    "acknowledged" : true,
    "insertedId" : ObjectId("5eab16cd43417811278f5893")
}

2. コレクション内の全ドキュメントを表示する

find()メソッドを使うと、コレクション内のすべてのドキュメントを表示できます。

> db.demo725.find();

上記のクエリを実行すると、次のような出力が得られます。

{ "_id" : ObjectId("5eab16cd43417811278f5893"), "details" : { "userMessages" : [ { "Messages" : [ { "Message" : "Hello" }, { "Message" : "How" }, { "Message" : "are" } ] }, { "Messages" : [ { "Message" : "Good" }, { "Message" : "Bye" } ] }, { "Messages" : [ { "Message" : "Hello" }, { "Message" : "Bye" } ] } ] } }

3. ネストされた配列にフィルタリング条件を設定するクエリ

次のクエリでは、aggregate()内の$addFieldsステージで$filterを使用し、各userMessages要素の中のMessages配列に「Hello」という文字列が含まれているかどうかを判定しています。条件を満たす要素のみが出力に残ります。

> db.demo725.aggregate([
...     {
...         $addFields: {
...             "details.userMessages": {
...                 $filter: {
...                     input: "$details.userMessages",
...                     as: "out",
...                     cond: {
...                         $anyElementTrue: {
...                             $map: {
...                                 input: "$$out.Messages",
...                                 in: { $gte: [ { $indexOfBytes: [ "$$this.Message", "Hello" ] }, 0 ] }
...                             }
...                         }
...                     }
...                 }
...             }
...         }
...     }
... ]).pretty()

クエリのポイント解説

• $addFields: 既存のフィールド「details.userMessages」を、フィルタリング済みの新しい配列で上書きします。
• $filter: input(対象配列)、as(各要素を参照するための変数名)、cond(残す要素を判定する条件)を指定します。
• $map + $anyElementTrue: 各要素の「Messages」配列を走査し、1つでも条件を満たす要素があればtrueを返します。
• $indexOfBytes: 指定した文字列("Hello")が見つかった位置を返します。見つからない場合は-1を返すため、$gteで0以上かどうかを判定することで「存在するかどうか」を確認できます。

4. 実行結果

上記の集計クエリを実行すると、次のような出力が得られます。「Hello」を含まない2番目の要素({ "Message": "Good" }と{ "Message": "Bye" }のみのグループ)が除外されている点に注目してください。

{
    "_id" : ObjectId("5eab16cd43417811278f5893"),
    "details" : {
        "userMessages" : [
            {
                "Messages" : [
                    {
                        "Message" : "Hello"
                    },
                    {
                        "Message" : "How"
                    },
                    {
                        "Message" : "are"
                    }
                ]
            },
            {
                "Messages" : [
                    {
                        "Message" : "Hello"
                    },
                    {
                        "Message" : "Bye"
                    }
                ]
            }
        ]
    }
}

まとめ

MongoDBでネストされた配列を条件付きで絞り込みたい場合は、$filterを基本としつつ、$mapや$anyElementTrue、$indexOfBytesなどの演算子を組み合わせることで、深い階層の配列に対しても柔軟な検索条件を実現できます。部分一致や特定キーワードの有無を判定したいケースで特に役立つテクニックなので、ぜひ活用してみてください。