在 ASPNetBoilerplate 中从 SqlQuery 的自定义存储库访问 ToListAsync()

Question

我正在使用 ASP.Net 样板。我已经实现了 IRepository 来创建自定义存储库，因此我可以添加一个自定义方法来从存储过程返回数据。但是，无论我如何构建任务、异步或等待组件，我都会收到以下错误：

System.InvalidOperationException: The provider for the source IQueryable doesn't implement IDbAsyncQueryProvider. Only providers that implement IDbAsyncQueryProvider can be used for Entity Framework asynchronous operations. For more details see http://go.microsoft.com/fwlink/?LinkId=287068.

我的存储库看起来像：

namespace myApp.EntityFramework.Repositories
{
    public class TruckRepository : UHaulTrucks.HoustonRepositoryBase<DailyDockQuery>, ITruckRepository
    {

        public TruckRepository(IDbContextProvider<UHaulHoustonDbContext> dbContextProvider) : base(dbContextProvider)
        {

        }

  public IQueryable<DailyDockQuery> GetDailyDockQuery()
        {

           var ret = Context.Database.SqlQuery<DailyDockQuery>("exec Central_DailyDockQuery").AsQueryable();
            return ret;
        }
   }
}

还有我的服务：

public async Task<PagedResultOutput<DailyDockQueryListDto>> GetDailyDockQuery()
        {
            var query = _truckRepository.GetDailyDockQuery();

            var dailyCount = await query.CountAsync();


            var dailies = await query.ToListAsync();

            var dailiesDtos = dailies.MapTo<List<DailyDockQueryListDto>>();

            return new PagedResultOutput<DailyDockQueryListDto>(
                dailyCount,
                dailiesDtos
                );
        }

以上错误将在任何尝试执行异步方法时生成，例如：

var dailyCount = await query.CountAsync();

或

var dailies = await query.ToListAsync();

正如我所提到的，我已尝试使用任务和异步组合在存储库和服务中进行多种变体，但结果相同。我是用这种方式实现自定义存储库的新手，我怀疑虽然我应该从 IRepository 中获得 CountAsync 和 ToListAsync 的好处，但我仍然需要在自定义 class.

中实现它们

非常感谢任何帮助。仍在寻找我的路。

Answer 1

在 Aspnetboilerplate 中执行存储过程（select 条记录）示例代码：

public async Task<List<string>> GetUserNames()
{
    EnsureConnectionOpen();

    using (var command = CreateCommand("GetUsernames", CommandType.storedProcedure))
    {
        using (var dataReader = await command.ExecuteReaderAsync())
        {
            var result = new List<string>();

            while (dataReader.Read())
            {
                result.Add(dataReader["UserName"].ToString());
            }

            return result;
        }
    }
}

我强烈建议您阅读有关在 Aspnetboilerplate 中使用存储过程的文档。这里有您需要的一切：https://aspnetboilerplate.com/Pages/Documents/Articles/Using-Stored-Procedures,-User-Defined-Functions-and-Views/index.html

在 ASPNetBoilerplate 中从 SqlQuery 的自定义存储库访问 ToListAsync()

Accessing ToListAsync() from Custom Repository for SqlQuery in ASPNetBoilerplate

c#

asynchronous

entity-framework

repository-pattern

aspnetboilerplate