Как выполнить поиск с помощью конвейера и разрешить параметры в C # (MongoDB.Driver 2.7.2) - PullRequest
Новая
       8

Как выполнить поиск с помощью конвейера и разрешить параметры в C # (MongoDB.Driver 2.7.2)

0 голосов
/ 22 января 2019

Мне нужно выполнить следующий запрос в MongoDB в моем коде C #. Я использую MongoDB.Driver 2.7.2 и MongoDB 4.0.

Я бы хотел использовать $ lookup, а не $ project / $ unwind, чтобы предотвратить присвоение имен каждому из возможных полей коллекции. 

db.getCollection('Collection1').aggregate([  
    { "$match" : { "Id" : 1 } },
        { "$lookup": {
            "from": "Collection2",
            "let": { collection1Id : "$Id" },
            "pipeline": [
                { $match:
                    { $expr:
                        { $and:
                            [
                                { $eq : [ "$Collection1Id",  "$$collection2Id" ] },
                                { $in : [ "$_id" , [1, 2, 3]] }
                            ]
                            }
                        }
                    }
            ],
            "as": "item"
        }
    } 
])

Я ожидаю, что выходные данные Collection1 объединяются с Collection2 при нескольких условиях объединения.

1 Ответ

0 голосов
/ 24 января 2019

Поскольку вы не указали конкретное сопоставление классов и примеры документов, в ответе ниже будет использоваться BsonDocument тип и пример данных из руководства $ lookup: укажите несколько условий соединения с помощью lookup 

BsonArray subpipeline = new BsonArray();

subpipeline.Add(
    new BsonDocument("$match",new BsonDocument(
        "$expr", new BsonDocument(
        "$and", new BsonArray { 
             new BsonDocument("$eq", new BsonArray{"$stock_item", "$$order_item"} ), 
             new BsonDocument("$gte", new BsonArray{"$instock", "$$order_qty"} )
             }  
        )
    ))
);

var lookup = new BsonDocument("$lookup", 
                 new BsonDocument("from", "warehouses")
                             .Add("let", 
                                 new BsonDocument("order_item", "$item")
                                             .Add("order_qty", "$ordered"))
                             .Add("pipeline", subpipeline)
                             .Add("as", "stockdata")
);

var results = collection.Aggregate()
                        .Match(new BsonDocument("_id", 1))
                        .AppendStage<BsonDocument>(lookup).ToEnumerable();

foreach (var x in results)
{
    Console.WriteLine(x.ToJson());
}

Обратите внимание, что поддержка более выразительного $ lookup с использованием PipelineDefinitionBuilder доступна для версии 2.8.x. Для получения дополнительной информации см. CSHARP-2013

...