複数のオブジェクト配列ドキュメントのMongodbデカルト積

Question

C＃/ Linqまたは生のMongodbのいずれかを理解しようとすると、複数の配列をデカルト積としてどのように結合するかがわかります。

セイは、例えば、私は、次の二つの文書に絞り込まコレクションを持っていた：

[ 
{"movie":"starwars","showday":"monday"}, 
{"movie":"batman","showday":"thursday"}, 
{"movie":"sleepless","showday":"tuesday"} 
] 

[ 
{"actor":"angelina","location":"new york"}, 
{"actor":"jamie","location":"california"}, 
{"actor":"mcavoy","location":"arizona"} 
] 

はどのようにして、結果の次のタイプを生成するために、各配列内の各アイテムに参加することができますか？

[{"movie":"starwars","showday":"monday","actor":"angelina","location":"new york"}, 
{"movie":"batman","showday":"thursday","actor":"angelina","location":"new york"}, 
{"movie":"sleepless","showday":"tuesday","actor":"angelina","location":"new york"}, 
{"movie":"starwars","showday":"monday","actor":"jamie","location":"california"}, 
{"movie":"batman","showday":"thursday","actor":"jamie","location":"california"}, 
{"movie":"sleepless","showday":"tuesday","actor":"jamie","location":"california"}, 
{"movie":"starwars","showday":"monday","actor":"mcavoy","location":"arizona"}, 
{"movie":"batman","showday":"thursday","actor":"mcavoy","location":"arizona"}, 
{"movie":"sleepless","showday":"tuesday","actor":"mcavoy","location":"arizona"}] 

私はいくつでもドキュメントを扱うことができるソリューションを探しています。たとえば、この例では、3つのオブジェクト配列を持つ3番目のドキュメントがあり、配列内に27個のアイテムの結果セットを生成します。つまり、27個の行はそのままです。

C＃（Linq？）Mongodb Driverを使用してこのようなデータをクエリして返す方法を願っていますが、mongodb固有のクエリであっても、そこから論理を戻すことができます。ありがとうございます

Answer 1

以下の集約パイプラインを試すことができます。

注mergeObjectsアグリゲーション演算子は3.5.6 +開発リリースで公開されます。これは今後リリースされる3.6リリースになります。

db.collection.find(); 
{ 
"data" : [ 
    [ 
    { 
    "movie" : "starwars", 
    "showday" : "monday" 
    }, 
    { 
    "movie" : "batman", 
    "showday" : "thursday" 
    }, 
    { 
    "movie" : "sleepless", 
    "showday" : "tuesday" 
    } 
    ], 
    [ 
    { 
    "actor" : "angelina", 
    "location" : "new york" 
    }, 
    { 
    "actor" : "jamie", 
    "location" : "california" 
    }, 
    { 
    "actor" : "mcavoy", 
    "location" : "arizona" 
    } 
    ] 
] 
} 

条件式を使用した集約。

aggregate({ 
$project: { 
    cp: { 
    $reduce: { 
    input: "$data", 
    initialValue: { 
    $arrayElemAt: ["$data", 0] // Set the initial value to the first element of the arrays. 
    }, 
    in: { 
    $let: { 
     vars: { 
     currentr: "$$this", // Current processing element 
     currenta: "$$value" // Current accumulated value 
     }, 
     in: { 
     $cond: [{ // Conditional expression to return the accumulated value as initial value for first element 
     $eq: ["$$currentr", "$$currenta"] 
     }, 
     "$$currenta", 
     { // From second element onwards prepare the cartesian product 
     $reduce: { 
     input: { 
      $map: { 
      input: "$$currenta", 
      as: a"a", 
      in: { 
      $map: { 
      input: "$$currentr", 
      as: r"r", 
      in: { 
       $mergeObjects: ["$$a", "$$r"] // Merge accumulated value with the current processing element 
      } 
      } 
      } 
      } 
     }, 
     initialValue: [], 
     in: { 
     $concatArrays: ["$$value", "$$this"] // Reduce the merged values which will be used as accumulator for next element 
     } 
     } 
     }] 
     } 
    } 
    } 
    } 
    } 
} 
}); 

集約（$setUnionを使用）。

このソリューションは、条件式を抑制してより読みやすいパイプラインを提供するために追加されました。

aggregate({ 
$project: { 
    cp: { 
    $reduce: { 
    input: "$data", 
    initialValue: { 
    $arrayElemAt: ["$data", 0] // Set the initial value to the first element of the arrays. 
    }, 
    in: { 
    $let: { 
     vars: { 
     currentr: "$$this", // Current processing element 
     currenta: "$$value" // Current accumulated value 
     }, 
     in:{ 
     $reduce: { 
     input: { 
     $map: { 
      input: "$$currenta", 
      as: "a", 
      in: { 
      $map: { 
      input: "$$currentr", 
      as: "r", 
      in: { 
      $mergeObjects: ["$$a", "$$r"] // Merge accumulated value with the current processing element 
      } 
      } 
      } 
     } 
     }, 
     initialValue: [], 
     in: { 
     $setUnion: ["$$value", "$$this"] // Reduce the merged values which will be used as accumulator for next element 
     } 
     } 
     } 
    } 
    } 
    } 
    } 
} 
}); 

更新

両方の上記溶液が原因で第二の溶液中の誤った最初の溶液中$condと$setUnionの下アスヤKamskyのコメントによって示されるようにアレイ間の値を反復して動作しません。

正しい修正がinput: {$slice:["$data", 1, {$subtract:[{$size:"$data"},1]}]},

完全集約パイプラインのような最初の要素を除外するよう[ { } ]

それとも

変更inputのinitialValueと

先頭にある

aggregate({ 
$project: { 
    cp: { 
    $reduce: { 
    input: {$slice:["$data", 1, {$subtract:[{$size:"$data"},1]}]}, 
    initialValue: {$arrayElemAt:["$data",0]}, 
    in: { 
    $let: { 
     vars: { 
     currentr: "$$this", 
     currenta: "$$value" 
     }, 
     in:{ 
     $reduce: { 
     input: { 
     $map: { 
      input: "$$currenta", 
      as: "a", 
      in: { 
      $map: { 
      input: "$$currentr", 
      as: "r", 
      in: { 
      $mergeObjects: ["$$a", "$$r"] 
      } 
      } 
      } 
     } 
     }, 
     initialValue: [], 
     in: { 
     $concatArrays: ["$$value", "$$this"] 
     } 
     } 
     } 
    } 
    } 
    } 
    } 
} 
}); 

参照： Cartesian product of multiple arrays in JavaScript