代码之家 › 专栏 › 技术社区 › Shawellaby

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

aspnetboilerplate repository-pattern asynchronous entity-framework c#

Shawellaby · 技术社区 · 7 年前

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的好处,但我怀疑我仍然需要在自定义类中实现它们。

非常感谢您的帮助。我还在这里找路。

1 回复 | 直到 7 年前

Alper Ebicoglu 6 年前

在Aspnetboilerplate中执行存储过程(选择记录)示例代码:

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