Сборка $ или запрос с использованием словаря <string, List <string>>

Question

Я борюсь здесь. Я новичок в том, чтобы делать что-либо, даже отдаленно сложное в монго.

Учитывая следующие документы в монго:

{ Id = 1, SharedId = "K1", Tag = "V1" }
{ Id = 2, SharedId = "K1", Tag = "V2" }
{ Id = 3, SharedId = "K1", Tag = "V3" }
{ Id = 4, SharedId = "K2", Tag = "V1" }
{ Id = 5, SharedId = "K2", Tag = "V2" }
{ Id = 6, SharedId = "K2", Tag = "V3" }

У меня есть метод GetRecords(Dictionary<string, List<string>> docs), для которого ключ SharedId, а список содержит список Tags. Пример:

[
    { "K1", [ "V1", , "V3" ] },
    { "K2", [ "V2", "V3" ] }
]

Я хотел бы извлечь следующие записи:

1, 3, 5, 6

Мой текущий метод выглядит следующим образом.

GetRecords(Dictionary<string, List<string>> docs)
{
    var filter = Builders<Dto>.Filter.Where(d =>
        !string.IsNullOrEmpty(d.SharedId) &&
        docs.Keys.Contains(d.SharedId))
}

Попытка получить что-то большее, чем то, что я использую, выдает много ошибок из Монго, обычно NotSupported и т. Д. Что-то вроде docs[d.SharedId].Any(i => docs.Contains(i)) делает mongodriver довольно расстроенным.

Answer 1

Из обозначения в вашем вопросе немного неясно, имеете ли вы в виду подобную структуру (показывающую сериализованную форму JSON):

{ "K1": [ "V1", "V3" ], "K2": [ "V2", "V3" ] } 

Или вот так:

[
  { "K1": [ "V1", "V3" ] },
  { "K2": [ "V2", "V3" ] }
]

В любом случае, вы либо итерируете пары «ключ / значение» в единственном словаре, либо почти то же самое для «списка словарей».

Конечный результат означает построение запроса из любой начальной формы:

      {
        "$or" : [
            {
              "SharedId" : "K1",
              "Tag" : { "$in" : [ "V1", "V3" ] }
            },
            {
              "SharedId" : "K2",
              "Tag" : { "$in" : [ "V2", "V3" ] }
            }
        ]
      }

И основной способ сделать это - использовать foreach для итерации и составить список FilterDefinition, который вы затем передаете в Builders<T>.Filter.Or

Пример списка с таким кодом:

using MongoDB.Bson;
using MongoDB.Driver;
using Newtonsoft.Json;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace ConsoleApp2
{
  class Program
  {
    static void Main(string[] args)
    {
      MainAsync().Wait();
    }

    static async Task MainAsync()
    {
      var client = new MongoClient();
      var db = client.GetDatabase("test");
      var entities = db.GetCollection<Entity>("entities");

      try
      {
        /*
         * Meaning a serialized structure like:
         * { "K1": [ "V1", "V2" ], "K2": [ "V2", "V3" ] } 
         */
        Dictionary<string, List<string>> dict = new Dictionary<string, List<string>>
        {
          { "K1", new List<string> { "V1", "V3" } },
          { "K2", new List<string> { "V2", "V3" } }
        };

        string output = JsonConvert.SerializeObject(dict);
        Console.WriteLine(output);

        /*
         *  Meaning a serialized structure like:
         *  [
         *    { "K1": [ "V1", "V2" ] },
         *    { "K2": [ "V2", "V3" ] }
         *  ]
         */
        List<Dictionary<string, List<string>>> alt = new List<Dictionary<string, List<string>>>
        {
          {  new Dictionary<string, List<string>> { { "K1", new List<string> {  "V1", "V3" } } } },
          {  new Dictionary<string, List<string>> { { "K2", new List<string> {  "V2", "V3" } } } },
        };

        string output2 = JsonConvert.SerializeObject(alt);
        Console.WriteLine(output2);

        // Build query from 'dict' form
        List<FilterDefinition<Entity>> orConditions = new List<FilterDefinition<Entity>>();
        foreach (KeyValuePair<string, List<string>> entry in dict)
        {
          orConditions.Add(
            Builders<Entity>.Filter.Eq(p => p.SharedId, entry.Key) &
            Builders<Entity>.Filter.Where(p => entry.Value.Contains(p.Tag))
          );
        };
        var query1 = Builders<Entity>.Filter.Or(orConditions);
        /*
         * Builds -
          {
            "$or" : [
                {
                  "SharedId" : "K1",
                  "Tag" : { "$in" : [ "V1", "V3" ] }
                },
                {
                  "SharedId" : "K2",
                  "Tag" : { "$in" : [ "V2", "V3" ] }
                }
            ]
          }
        */
        Console.WriteLine("Output 1");
        var cursor1 = await entities.Find(query1).ToListAsync();
        foreach (var doc in cursor1)
        {
          Console.WriteLine(doc.ToBsonDocument());
        }

        // Build the query from 'alt' form
        orConditions = new List<FilterDefinition<Entity>>(); // clear the list

        foreach(var item in alt)
        {
          foreach(KeyValuePair<string,List<string>> entry in item)
          {
            orConditions.Add(
              Builders<Entity>.Filter.Eq(p => p.SharedId, entry.Key) &
              Builders<Entity>.Filter.Where(p => entry.Value.Contains(p.Tag))
            );
          }
        }

        var query2 = Builders<Entity>.Filter.Or(orConditions);

        /* Serializes just the same */
        Console.WriteLine("Output 2");
        var cursor2 = await entities.Find(query2).ToListAsync();
        foreach (var doc in cursor2)
        {
          Console.WriteLine(doc.ToBsonDocument());
        }


      }
      catch (Exception ex)
      {
        Console.WriteLine(ex);
      }

    }
  }

  public class Entity
  {
    public int id;
    public string SharedId { get; set; }
    public string Tag { get; set; }
  }
}

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

{"K1":["V1","V3"],"K2":["V2","V3"]}
[{"K1":["V1","V3"]},{"K2":["V2","V3"]}]
Output 1
{ "_id" : 1, "SharedId" : "K1", "Tag" : "V1" }
{ "_id" : 3, "SharedId" : "K1", "Tag" : "V3" }
{ "_id" : 5, "SharedId" : "K2", "Tag" : "V2" }
{ "_id" : 6, "SharedId" : "K2", "Tag" : "V3" }
Output 2
{ "_id" : 1, "SharedId" : "K1", "Tag" : "V1" }
{ "_id" : 3, "SharedId" : "K1", "Tag" : "V3" }
{ "_id" : 5, "SharedId" : "K2", "Tag" : "V2" }
{ "_id" : 6, "SharedId" : "K2", "Tag" : "V3" }