我正在尝试使用c驱动程序创建一个mongodb聚合管道,该驱动程序包括redact和一个项目。我尝试了下面所示的几种方法,但在每种情况下都只执行管道的第一阶段。appendStage似乎不追加下一个阶段。那么,如何使用c mongodb驱动程序使一个redact后跟一个项目呢?请注意,fluent接口并不直接支持redact,而是显示了另一篇文章,使用下面的代码来完成它,这对第一阶段是有效的。
我使用的是2.4.3版本的C驱动程序和MongoDB 3.4.4版本
string redactJson = System.IO.File.ReadAllText(@"redactTest.json");
string projectJson = System.IO.File.ReadAllText(@"projectTest.json");
var collection = Database.GetCollection<BsonDocument>("Forecasts");
var redact = BsonDocument.Parse(redactJson);
var project = BsonDocument.Parse(projectJson);
var aggregatonPipeline = collection.Aggregate();
aggregatonPipeline.AppendStage<BsonDocument>(redact);
aggregatonPipeline.AppendStage<BsonDocument>(project);
var list = aggregatonPipeline.ToList();
或者类似的代码
var pipeline = collection.Aggregate().AppendStage<BsonDocument>(redact);
pipeline.AppendStage<BsonDocument>(project);
var list = pipeline.ToList();
我的聚合json如下所示
redacttest.json版本:
{
$redact: {
$cond: {
if: {
$gt: [{ $size: { "$setIntersection": [ "$tags", ["STLW", "G"]]}}, 0]
},
then: "$$DESCEND",
else: "$$PRUNE"
}
}
}
项目测试.json
{
"$project":
{
"_id": 0,
"title": 1,
"year": 1,
"subsections.subtitle": 1,
"subsections.content": 1
}
}
源文件是
{
_id: 1,
title: "123 Department Report",
tags: [ "G", "STLW" ],
year: 2014,
subsections: [
{
subtitle: "Section 1: Overview",
tags: [ "SI", "G" ],
content: "Section 1: This is the content of section 1."
},
{
subtitle: "Section 2: Analysis",
tags: [ "STLW" ],
content: "Section 2: This is the content of section 2."
},
{
subtitle: "Section 3: Budgeting",
tags: [ "TK" ],
content: {
text: "Section 3: This is the content of section3.",
tags: [ "HCS" ]
}
}
]
}
最佳答案
collection.Aggregate()
公开fluent聚合接口,并通过方法链接将阶段附加到管道。
有点像
var pipeline= collection.Aggregate().AppendStage<BsonDocument>(redact).AppendStage<BsonDocument>(project);
var list = pipeline.ToList();
每次添加一个阶段时,您的用法将覆盖前面的阶段。