我正在尝试使用 FakeDbSet 制作 FakeDbContext 来进行单元测试。
但是我收到以下错误（见下文）。我正在扩展 DbSet，因此通常应该实现 IDbAsyncEnumerable。当我实现它时，它说它没有用。
例外：
System.InvalidOperationException：源 IQueryable 没有 实施 IDbAsyncEnumerable。仅有的 实现 IDbAsyncEnumerable 的源可用于实体 框架异步操作。欲了解更多详情，请参阅 http://go.microsoft.com/fwlink/?LinkId=287068。
FakeDbSet 类：
public abstract class FakeDbSet<TEntity> : DbSet<TEntity>, IEnumerable<TEntity>, IQueryable, IDbAsyncEnumerable<TEntity> where TEntity : Entity, new()
{
#region Private Fields
private readonly ObservableCollection<TEntity> _items;
private readonly IQueryable _query;
#endregion Private Fields
protected FakeDbSet()
{
_items = new ObservableCollection<TEntity>();
_query = _items.AsQueryable();
}
public Expression Expression { get { return _query.Expression; } }
public Type ElementType { get { return _query.ElementType; } }
public IQueryProvider Provider { get { return _query.Provider; } }
public override TEntity Add(TEntity entity)
{
_items.Add(entity);
return entity;
}
public override TEntity Remove(TEntity entity)
{
_items.Remove(entity);
return entity;
}
public override TEntity Attach(TEntity entity)
{
switch (entity.ObjectState)
{
case ObjectState.Modified:
_items.Remove(entity);
_items.Add(entity);
break;
case ObjectState.Deleted:
_items.Remove(entity);
break;
case ObjectState.Unchanged:
case ObjectState.Added:
_items.Add(entity);
break;
default:
throw new ArgumentOutOfRangeException();
}
return entity;
}
public override TEntity Create() { return new TEntity(); }
public override TDerivedEntity Create<TDerivedEntity>() { return Activator.CreateInstance<TDerivedEntity>(); }
public override ObservableCollection<TEntity> Local { get { return _items; } }
IEnumerator<TEntity> IEnumerable<TEntity>.GetEnumerator()
{
return _items.GetEnumerator();
}
Type IQueryable.ElementType
{
get { return _items.AsQueryable().ElementType; }
}
Expression IQueryable.Expression
{
get { return _items.AsQueryable().Expression; }
}
IQueryProvider IQueryable.Provider
{
get { return _items.AsQueryable().Provider; }
}
这是代码要点。在要点的最后一个文件中，这就是错误发生的地方。 要点代码
在我的例子中，异常是由于使用了错误的
ToListAsync它来自：
using System.Data.Entity;
而不是
using Microsoft.EntityFrameworkCore;
更改命名空间修复了错误。
异常消息提供的链接中明确提到了您的情况 (http://go.microsoft.com/fwlink/?LinkId=287068)。缺少的成分是 IDbAsyncQueryProvider，您应该从 Provider 属性返回它。
只需浏览链接即可到达样板实现。
我能补充的不多，我只引用基本短语：
为了使用异步查询，我们需要做更多的工作。如果我们尝试将 Moq DbSet 与 GetAllBlogsAsync 方法一起使用，我们将得到以下异常：
System.InvalidOperationException：源 IQueryable 未实现 IDbAsyncEnumerable。只有实现 IDbAsyncEnumerable 的源才能用于实体框架异步操作。有关更多详细信息，请参阅 http://go.microsoft.com/fwlink/?LinkId=287068。
为了使用异步方法，我们需要创建一个内存中的 DbAsyncQueryProvider 来处理异步查询。虽然可以使用 Moq 设置查询提供程序，但在代码中创建测试双实现要容易得多。该实现的代码如下：
等等...
我从here重命名了示例测试类，以删除单词
TestDbAsyncEnumerableDbAsyncEnumerator<T>DbAsyncQueryProvider<TEntity>然后我添加了下面的扩展类，这样你现在就可以做...
var data = new List<Blog>
{
new Blog { Name = "BBB" },
new Blog { Name = "ZZZ" },
new Blog { Name = "AAA" },
}.AsAsyncQueryable(); // <<== new extension method
这不仅在单元测试中很有用，而且当您想要实现一个
IQueryable<T>query.ToAsyncArray()public static class AsyncQueryableExtensions
{
public static IQueryable<TElement> AsAsyncQueryable<TElement>(this IEnumerable<TElement> source)
{
return new DbAsyncEnumerable<TElement>(source);
}
public static IDbAsyncEnumerable<TElement> AsDbAsyncEnumerable<TElement>(this IEnumerable<TElement> source)
{
return new DbAsyncEnumerable<TElement>(source);
}
public static EnumerableQuery<TElement> AsAsyncEnumerableQuery<TElement>(this IEnumerable<TElement> source)
{
return new DbAsyncEnumerable<TElement>(source);
}
public static IQueryable<TElement> AsAsyncQueryable<TElement>(this Expression expression)
{
return new DbAsyncEnumerable<TElement>(expression);
}
public static IDbAsyncEnumerable<TElement> AsDbAsyncEnumerable<TElement>(this Expression expression)
{
return new DbAsyncEnumerable<TElement>(expression);
}
public static EnumerableQuery<TElement> AsAsyncEnumerableQuery<TElement>(this Expression expression)
{
return new DbAsyncEnumerable<TElement>(expression);
}
}
对于使用上面讨论的 Microsoft 样板代码的人们来说，这里有一个快速帮助器类，可以将您的模拟数据转换为异步结果。只需添加到 MS 代码的底部并使用类似的内容进行调用
var fakeDateAsMockAsyncQueryResult = new MockAsyncData<SomeType>().MockAsyncQueryResult(fakeDataList.AsQueryable());
......
internal class MockAsyncData<T> where T : class
{
public Mock<DbSet<T>> MockAsyncQueryResult(IQueryable<T> data)
{
var mockSet = new Mock<DbSet<T>>();
mockSet.As<IDbAsyncEnumerable<T>>()
.Setup(m => m.GetAsyncEnumerator())
.Returns(new TestDbAsyncEnumerator<T>(data.GetEnumerator()));
mockSet.As<IQueryable<T>>()
.Setup(m => m.Provider)
.Returns(new TestDbAsyncQueryProvider<T>(data.Provider));
mockSet.As<IQueryable<T>>().Setup(m => m.Expression).Returns(data.Expression);
mockSet.As<IQueryable<T>>().Setup(m => m.ElementType).Returns(data.ElementType);
mockSet.As<IQueryable<T>>().Setup(m => m.GetEnumerator()).Returns(data.GetEnumerator());
return mockSet;
}
}
它与 MS 示例中的代码相同，但通用且可在许多不同的单元测试中重用。
解决我的IDbAsyncEnumerable问题：
将我的项目目标从 .NetFramework 4.0 更改为 .NetFramework 4.5
重新安装EntityFramework 6.1.3Nuget 包。
此时，我的 Visual Studio IDE Show Potencial Fixes 顾问允许我引用 System.Data.Entity.Infrastruct 命名空间
使用System.Data.Entity.Infrastruction;
对我来说，我回来了
synchronous queryablereturn Enumerable.Empty<MyType>().AsQueryable();对于返回类型为
asynchronous queryable_dbConext.MyType.AsQueryable()我通过删除此行解决了问题
return Enumerable.Empty<MyType>().AsQueryable();没有实现
IDbAsyncQueryProvider