MongoDbの集計結果でelemMatchを満たすサブ文書のみを返す

Question

文書の埋め込み配列から一致するエントリだけを返し、これを実践的に見つけることができない集約パイプラインを作成する方法をいくつか試しました。

私の非常に不器用でエラーを起こしやすいアプローチを避けるMongoDBの機能はありますか？

「ワークショップ」コレクション内の文書は、次のようになります...

{ 
    "_id": ObjectId("57064a294a54b66c1f961aca"), 
    "type": "normal", 
    "version": "v1.4.5", 
    "invitations": [], 
    "groups": [ 
    { 
     "_id": ObjectId("57064a294a54b66c1f961acb"), 
     "role": "facilitator" 
    }, 
    { 
     "_id": ObjectId("57064a294a54b66c1f961acc"), 
     "role": "contributor" 
    }, 
    { 
     "_id": ObjectId("57064a294a54b66c1f961acd"), 
     "role": "broadcaster" 
    }, 
    { 
     "_id": ObjectId("57064a294a54b66c1f961acf"), 
     "role": "facilitator" 
    } 
    ] 
} 

ときにグループメンバーがワークショップに与えられた役割を割り当てられるようにグループの配列の各エントリが一意のIDを提供しますその塩漬けされたIDを持つURLをヒットします。

ObjectId("57064a294a54b66c1f961acb")のようなグループ配列のエントリに一致する_idがある場合、私は集約パイプラインからこのような単一のレコードを返す必要があります - 基本的に埋め込みグループ配列から一致するエントリを返します。この例では

{ 
     "_id": ObjectId("57064a294a54b66c1f961acb"), 
     "role": "facilitator", 
     "workshopId": ObjectId("57064a294a54b66c1f961aca") 
    }, 

、workshopIdは、親文書を識別するために余分なフィールドとして追加されているが、残りの部分は、整合_idを有する元のグループエントリからALLフィールドであるべきです。

私が採用しているアプローチはこれを達成することはできますが、問題は多く、おそらく効率的ではありません（フィルタ句を繰り返します）。

return workshopCollection.aggregate([ 
    {$match:{groups:{$elemMatch:{_id:groupId}}}}, 
    {$unwind:"$groups"}, 
    {$match:{"groups._id":groupId}}, 
    {$project:{ 
     _id:"$groups._id", 
     role:"$groups.role", 
     workshopId:"$_id", 
    }}, 
]).toArray(); 

さらに悪いことに、それが明示的にエントリから名前のフィールドが含まれているので、それがレコードに追加されている任意の将来のフィールドを省略します。私はまた、配列エントリのフィールドが何であるか分からない限り、このルックアップ操作を '招待状'や他の組み込み名前付き配列の場合に一般化することはできません。

私は、パイプラインの$プロジェクト段階で$または$ elemMatch演算子を使用するのが正しいアプローチであるのか疑問に思っていますが、これまで無視されていたか、パイプライン実行時にオペレータの有効性エラーが発生しました。ドキュメントの配列からだけ一致するエントリを返すために -

QUESTION

はこのかなり主流の問題で私を助ける別の集計演算子または別のアプローチはありますか？

Answer 1

以下の実装は、任意のクエリを処理し、結果を「トップレベルのドキュメント」として提供し、パイプラインでの重複フィルタリングを回避します。

function retrieveArrayEntry(collection, arrayName, itemMatch){ 
    var match = {}; 
    match[arrayName]={$elemMatch:itemMatch}; 
    var project = {}; 
    project[arrayName+".$"] = true; 
    return collection.findOne(
     match, 
     project 
    ).then(function(doc){ 
     if(doc !== null){ 
      var result = doc[arrayName][0]; 
      result._docId = doc._id; 
      return result; 
     } 
     else{ 
      return null; 
     } 
    }); 
} 

それは...そうのように呼び出すことができ

retrieveArrayEntry(workshopCollection, "groups", {_id:ObjectId("57064a294a54b66c1f961acb")}) 

しかし、それはするのではなく、収集findOne（...）メソッドに依存して集計（...）そうに制限されます第1の一致するアレイエントリを第1の一致するドキュメントから提供する。配列一致句を参照する射影は、findXXX（）メソッドと同じ方法で集計（...）によって明らかに不可能です。

さらに一般的な（ただし、混乱させて非効率的な）実装では、一致する複数のドキュメントとサブドキュメントを取得できます。これは、MongoDbがunpackMatchメソッドを使ってDocumentとSubdocumentのマッチングの構文一貫性を保つのが難しいことを回避します。 ...（Within a mongodb $match, how to test for field MATCHING , rather than field EQUALLINGで説明したように） '一致' の基準のために必要な構文に転送

{greetings:{_id:ObjectId("437908743")}} 

...ます...次の実装を導く

{"greetings._id":ObjectId("437908743")} 

...

function unpackMatch(pathPrefix, match){ 
    var unpacked = {}; 
    Object.keys(match).map(function(key){ 
     unpacked[pathPrefix + "." + key] = match[key]; 
    }) 
    return unpacked; 
} 

function retrieveArrayEntries(collection, arrayName, itemMatch){ 

    var matchDocs = {}, 
     projectItems = {}, 
     unwindItems = {}, 
     matchUnwoundByMap = {}; 

    matchDocs.$match={}; 
    matchDocs.$match[arrayName]={$elemMatch:itemMatch}; 

    projectItems.$project = {}; 
    projectItems.$project[arrayName]=true; 

    unwindItems.$unwind = "$" + arrayName; 

    matchUnwoundByMap.$match = unpackMatch(arrayName, itemMatch); 

    return collection.aggregate([matchDocs, projectItems, unwindItems, matchUnwoundByMap]).toArray().then(function(docs){ 
     return docs.map(function(doc){ 
      var result = doc[arrayName]; 
      result._docId = doc._id; 
      return result; 
     }); 
    }); 
}