CosmosDB самостоятельно присоединяется через linq - PullRequest
Новая
       22

CosmosDB самостоятельно присоединяется через linq

0 голосов
/ 29 июня 2018

У меня есть коллекция документов с документами, похожими на следующие 

{
  id: "123123541234"
  items: [
    {Name = "Item 1", Amount = 12.12},
    {Name = "Item 2", Amount = 4.00},
  ]
}

Я могу написать sql самосоединенный запрос, подобный следующему, чтобы вернуть то, что я хочу: 

select c.id, i.Name, i.Amount
from c
join i in c.items

Как видите, мой документ с идентификатором 123123541234 будет дублирован, один раз для каждого элемента во вложенном массиве, поэтому вывод будет выглядеть так: 

[ 
  {id = "123123541234", Name = "Item 1", Amount = 12.12 }, 
  {id = "123123541234", Name = "Item 2", Amount = 4.00} 
]

Однако я бы хотел использовать linq для написания этого запроса, чтобы сохранить сильные ссылки на мои объекты и определение типа. Я не вижу, как я могу сделать этот тип "сплющивания" через linq,

TL; DR: как сделать самостоятельное соединение через linq с cosmosdb?

1 Ответ

0 голосов
/ 30 июня 2018

Предположим, что ваши типы выглядят примерно так - 

public class Container
{
    [JsonProperty(PropertyName = "id")]
    public string Id { get; set; }

    [JsonProperty(PropertyName = "items")]
    public Item[] Items { get; set; }
}

public class Item
{
    public string Name  { get; set; }
    public double Amount { get; set; }
}

public class FlattenedContainer
{
    public string Id { get; set; }
    public string Name { get; set; }
    public double Amount { get; set; }
}

Вот как вы могли это сделать - 

var response = client.CreateDocumentQuery<Container>
            (
                UriFactory.CreateDocumentCollectionUri(...),
                new FeedOptions { ... }
            )
            .SelectMany(c => c.Items
                .Select(i => new FlattenedContainer 
                { 
                    Id = c.Id, 
                    Name = i.Name, 
                    Amount = i.Amount 
                }))
            .AsDocumentQuery();

var results = new List<FlattenedContainer>();
while (response.HasMoreResults)
{
    results.AddRange(await response.ExecuteNextAsync<FlattenedContainer>());
}
...