2

这是代码：

ProjectionDefinition<Accountant> projDefAccountant = Builders<Accountant>.Projection
                    .Include(x => x.Id)
                    .Include(x => x.Name);

ProjectionDefinition<Client> projDefClient = Builders<Client>.Projection
                    .Include(c => c.Name)
                    .Include(c => c.Address)
                    .Include(c => c.Occupation);

IMongoCollection<Accountant> collection = mongoDatabase.GetCollection<Accountant>("accountants");
IMongoCollection<Client> foreignCollection = mongoDatabase.GetCollection<Client>("clients");

                var results = collection.Aggregate()
                    .Project<Accountant>(projDefAccountant)
                    .Lookup<Accountant, Client, Accountant>(
                        foreignCollection: foreignCollection,
                        localField: ac => ac.BestClientsIds,
                        foreignField: c => c.Id,
                        @as: ac => ac.MyClients
                    ).ToList().AsQueryable();

我可以使用第一个投影"projDefAccountant"来限制我想要从"accountants"集合中删除哪些字段。有没有办法"projDefClient"在连接集合上强制执行投影，"clients"以便连接不返回所有字段，而只返回"projDefClient"? 谢谢。

4

1 回答 1

1

您可以将$lookup 与自定义管道一起使用，您的聚合可能如下所示：

db.accountants.aggregate([
    { "$project" : { "_id" : 1, "Name" : 1, BestClientsIds: 1 } }, 
    { 
        "$lookup" : { 
            "from" : "clients", 
            "let" : { "best_client_ids" : "$BestClientsIds" }, 
            "pipeline" : [
                { "$match" : { "$expr" : { "$in" : [ "$_id", "$$best_client_ids"] } } }, 
                { "$project": { Name: 1, Address: 1, Occupation: 1} }
            ], 
            as: "MyClients"}
    }    
]);

蒙戈游乐场

在 C# 中，有一个重载版本.Lookup允许您以几乎强类型的方式运行该方法。这是签名：

IAggregateFluent<TNewResult> Lookup<TForeignDocument, TAsElement, TAs, TNewResult>(
        IMongoCollection<TForeignDocument> foreignCollection,
        BsonDocument let,
        PipelineDefinition<TForeignDocument, TAsElement> lookupPipeline,
        FieldDefinition<TNewResult, TAs> @as,
        AggregateLookupOptions<TForeignDocument, TNewResult> options = null)
        where TAs : IEnumerable<TAsElement>;

您可以修改projDefAccountant以使其包含以下BestClientsIds字段：

ProjectionDefinition<Accountant> projDefAccountant = Builders<Accountant>.Projection
            .Include(x => x.Id)
            .Include(x => x.Name)
            .Include(x => x.BestClientsIds);

然后更容易指定let和$match阶段，BsonDocument但其余部分保持强类型：

var filter = new BsonDocumentFilterDefinition<Client>(BsonDocument.Parse("{ $expr: { $in: [ '$_id', '$$ids' ] } }"));

PipelineDefinition< Client, Client> pipeline = new PipelineStagePipelineDefinition<Client, Client>(
    new IPipelineStageDefinition[]
    {
        PipelineStageDefinitionBuilder.Match(filter),
        PipelineStageDefinitionBuilder.Project<Client, Client>(projDefClient),
    });

ExpressionFieldDefinition<Accountant, Client[]> fieldDef 
    = new ExpressionFieldDefinition<Accountant, Client[]>(f => f.MyClients);

var letDef = BsonDocument.Parse("{ ids: '$BestClientsIds' }");


var results = collection.Aggregate()
    .Project<Accountant>(projDefAccountant)
    .Lookup<Client, Client, Client[], Accountant>(
        foreignCollection: foreignCollection,
        let: letDef,
        lookupPipeline: pipeline,
        @as: fieldDef
    ).ToList().AsQueryable();
于 2020-04-01T02:21:16.827 回答