DocumentDB 显示特定实体类型的所有文档

Question

我有一个通用的 IDocumentDbRepository 存储库，用于为 DocumentDB 提供基本的 CRUD 操作，以及用于与特定实体的附加操作的特定存储库，它继承或实现了此接口和类。

    public interface IDocumentDbRepository<T> where T : class
{
    //IEnumerable<T> GetItems();
    Task<IEnumerable<T>> GetItemsAsync();
    Task<T> GetItemAsync(T id);
    Task<T> AddDocumentAsync(T item);
    Task<T> UpdateDocumentAsync(T id, T item);
    Task DeletedocumentAsync(T id);
}

public class DocumentDbRepository<T> : IDocumentDbRepository<T> where T : class
{
    private readonly string AuthKey;
    private readonly string EndpointUri;
    private readonly string DatabaseId;
    private readonly string CollectionId;
    private static DocumentClient client;


    public DocumentDbRepository(IOptions<DocumentDbSettings> DocumentDbConfig)
    {
        this.DatabaseId = DocumentDbConfig.Value.DatabaseName;
        this.CollectionId = DocumentDbConfig.Value.CollectionName;
        this.AuthKey = DocumentDbConfig.Value.AuthKey;
        this.EndpointUri = DocumentDbConfig.Value.EndpointUri;
        client = new DocumentClient(new Uri(EndpointUri), AuthKey);
    }

public async Task<IEnumerable<T>> GetItemsAsync()
{
     IDocumentQuery<T> query = client.CreateDocumentQuery<T>(
     UriFactory.CreateDocumentCollectionUri(DatabaseId, CollectionId))
     .AsDocumentQuery();

    List<T> results = new List<T>();
    while (query.HasMoreResults)
    {
        results.AddRange(await query.ExecuteNextAsync<T>());
    }
    return results;
}

   // public IEnumerable<T> GetItems()
   // {
   //     var results = client.CreateDocumentQuery<T>//(UriFactory.CreateDocumentCollectionUri(DatabaseId, CollectionId)).ToList();
   //   return results;
   // }
//methods

在我的特定 Employee 存储库中，我的目标是仅返回 Employee 类型的文档

public interface IEmployeeRepository : IDocumentDbRepository<Employee>
{
    List<Employee> GetAllEmployees();
}

public class EmployeeRepository : DocumentDbRepository<Employee>, IEmployeeRepository
{
    public EmployeeRepository(IOptions<DocumentDbSettings> DocumentDbConfig) : base(DocumentDbConfig)
    {

    }

    public List<Employee> GetAllEmployees()
    {
        return GetItems().Where(x => x.GetType() == typeof(Employee)).ToList(); 
    }
}

我在我的控制器中调用GetAllEmployees 方法以仅在我的视图中列出Employee 类型的文档，但它不起作用，并且列出了具有任何实体类型的所有文档。我做错了什么？

public IActionResult Index()
{
    return View(_employeeRepository.GetAllEmployees());
}

Answer 1

好的，有几件事。

首先你不应该像这样在CreateDocumentQuery 上调用.ToList();。它将通过网络进行多次同步调用，以返回数据库中的每个文档。这将导致疯狂的 RU/s 和非常糟糕的性能。

使用AsDocumentQuery 并调用ExecuteNextAsync 而query.HasMoreResults。

其次，当您调用 ToList() 方法时，所有内容都作为 Employee 返回，因为您以这种方式查询它。你基本上是说，“把这个集合中的所有东西都作为员工退还给我，然后再把员工退还给我”。在这个阶段，他们都是员工。

您真正需要的是文档中的某种type 属性，您可以在调用ToList 之前使用该属性进行查询。

我建议您检查collection sharing 在Cosmonaut 中的工作方式。听起来完全符合您的需要。

Here 是在不阻塞线程的情况下异步调用 ToList 方法的方法。

免责声明：我是 Cosmonaut 的创造者。