Consulta
Isso pode ser feito usando estrutura de agregação . Considere o próximo pipeline de agregação
db.collectionName.aggregate([
{
$group:
{
"_id": null,
"ds": { $push: "$$ROOT" },
"cs": { $push: "$c" }
}
}, /* (1) */
{ $unwind: "$ds" }, /* (2) */
{
$project:
{
"_id": "$ds._id",
"c": "$ds.c",
"cs": { $slice: [ "$cs", "$ds._id" ] }
}
}, /* (3): */
{ $unwind: "$cs" }, /* (4) */
{
$group:
{
"_id": "$_id",
"c": { $first: "$c" },
"csum": { $sum: "$cs" }
}
}, /* (5) */
{
$group:
{
"_id": null,
"ds": { $push: "$$ROOT" },
"gteC":
{
$push:
{
$cond:
{
if: { "$gte": [ "$csum", SET_DESIRED_VALUE_FOR_C_HERE ] },
then: "$$ROOT",
else: { }
}
}
}
}
}, /* (6) */
{
$project:
{
"_id": 0,
"docs":
{
$filter:
{
input: "$ds",
"as": "doc",
cond: { $lte: [ "$$doc.csum", { $min: "$gteC.csum" } ] }
}
}
}
}, /* (7) */
{ $unwind: "$docs" }, /* (8) */
{ $project: { "_id": "$docs._id", "c": "$docs.c" } } /* (9) */
]);
Resultados
Explicação
A idéia básica por trás disso é construir matriz auxiliar para cada documento da coleção (estágios 1-3 )
{ "_id" : 1, "c" : 2 } -> cs = [ 2 ]
{ "_id" : 2, "c" : 6 } -> cs = [ 2, 6 ]
{ "_id" : 3, "c" : 1 } -> cs = [ 2, 6, 1 ]
usando
$slice
operador de agregação de array e, em seguida, substitua-o pela soma de todos os elementos que ele contém (estágios 4-5 ) { "_id" : 1, "c" : 2 } -> csum = 2
{ "_id" : 2, "c" : 6 } -> csum = 8
{ "_id" : 3, "c" : 1 } -> csum = 9
usando
$unwind
estágio e $sum
operador de acumulador de grupo . Em seguida, construa outro array auxiliar de documentos com
csum >= C (estágio 6 ) /* Ex. (C = 8) */
gteC = [ { "_id" : 3, "c" : 1, "csum" : 9 }, { "_id" : 2, "c" : 6, "csum" : 8 } ]
A última etapa é recuperar todos os documentos com
csum <= Min { gteC.csum } . Isso é feito usando $filter
operador de agregação de array (estágio 7 ). No entanto, eu não certeza de que este é o mais eficiente pipeline de agregação (será grato por quaisquer sugestões de melhoria) para alcançar o que você deseja.
PS Antes de testar a consulta não esqueça de alterar o nome da coleção e substituir SET_DESIRED_VALUE_FOR_C_HERE.
