c# - .Net 核心单元测试错误 - 源 IQueryable 未实现 IAsyncEnumerable<...>
问题描述
我有一行代码在单元测试中失败,但在开发和生产中运行良好。
var result = await _mapper.ProjectTo<GetApplicationsResponse.Application>(pipelineContext.Query).ToListAsync(cancellationToken);
pipelineContext.Query
是IQueryable
.
我正在尝试进行的测试如下
[Fact]
public async Task Handle_Success_Returns_GetApplicationsResponse()
{
//Arrange
var sut = CreateSut();
_pipelineSteps
.Setup(steps => steps.GetEnumerator())
.Returns(() => new List<IPipelineStep<GetApplicationsContext>>
{
Mock.Of<IPipelineStep<GetApplicationsContext>>()
}.GetEnumerator());
_mapper.Setup(x => x.ConfigurationProvider)
.Returns(
() => new MapperConfiguration(
cfg =>
{
cfg.CreateMap<Entities.ApplicationsAggregate.Application, GetApplicationsResponse.Application>();
cfg.CreateMap<Entities.ApplicationsAggregate.SiteLocation, GetApplicationsResponse.SiteLocation>();
cfg.CreateMap<Entities.ApplicationsAggregate.SiteAddress, GetApplicationsResponse.SiteAddress>();
}));
//Act
var result = await sut.Handle(new GetApplicationsRequest(), default);
//Assert
result.Should().BeOfType<GetApplicationsResponse>();
_pipelineSteps.Verify(steps => steps.GetEnumerator(), Times.Once);
}
我在这方面的限制是我无法改变,_projectTo<...>
因为这是新的工作方法\标准。
因此,我将不胜感激能够通过此错误的任何帮助
System.InvalidOperationException:源 IQueryable 未实现 IAsyncEnumerable<TQ.Applications.Application.Queries.GetApplications.GetApplicationsResponse+Application>。只有实现 IAsyncEnumerable 的源才能用于实体框架异步操作。
- - 编辑 - -
之前忘了提到测试正在使用内存数据库
解决方案
问题是 ToListAsync 想要一个实现 IAsyncEnumerable 的序列,但 ProjectTo 没有给它。
您正在使用 EntityFrameworkCore 内存提供程序,我假设您将其注入 SUT 并在故障点被引用。这是主要问题,因为内存提供程序不提供实现 IAsyncEnumerable 的序列。ProjectTo 最终向 ToListAsync 提供了一个 IQueryable<T> ,这将不起作用。
至于如何解决,有两种方法。
- 懒惰/正确的方法:使用更好的 DbContext。
以下 LINQPad 示例使用EntityFrameworkCore.Testing.Moq创建一个可注入的 DbContext,该 DbContext 生成 IAsyncEnumerable 序列:
void Main()
{
var fixture = new Fixture();
var dataEntites = fixture.CreateMany<DataEntity>();
var expectedResult = dataEntites.Select(x => new BusinessEntity() { id = x.Id, code = x.Code });
var mapper = new Mapper(new MapperConfiguration(x => x.AddProfile(new MappingProfile())));
var pipelineContext = Create.MockedDbContextFor<PipelineContext>();
pipelineContext.Entities.AddRangeToReadOnlySource(dataEntites);
var sut = new SUT(mapper, pipelineContext);
var actualResult = sut.Handle().Result;
var compareLogic = new CompareLogic();
compareLogic.Config.IgnoreObjectTypes = true;
compareLogic.Config.IgnoreCollectionOrder = true;
var comparisonResult = compareLogic.Compare(expectedResult, actualResult);
Console.WriteLine($"Are the sequences equivalent: {comparisonResult.AreEqual}");
Console.WriteLine(expectedResult);
Console.WriteLine(actualResult);
}
public class SUT
{
IMapper _mapper;
PipelineContext _pipelineContext;
public SUT(IMapper mapper, PipelineContext pipelineContext)
{
_pipelineContext = pipelineContext;
_mapper = mapper;
}
public async Task<List<BusinessEntity>> Handle()
{
return await _mapper.ProjectTo<BusinessEntity>(_pipelineContext.Entities).ToListAsync();
}
}
public class PipelineContext : DbContext
{
public PipelineContext(DbContextOptions<PipelineContext> options) : base(options) { }
public virtual DbSet<DataEntity> Entities { get; set; }
protected override void OnModelCreating(ModelBuilder modelBuilder)
{
modelBuilder.Entity<DataEntity>().HasNoKey().ToView(nameof(DataEntity));
}
}
public class MappingProfile : Profile
{
public MappingProfile()
{
CreateMap<DataEntity, BusinessEntity>()
.ForMember(d => d.id, o => o.MapFrom(s => s.Id))
.ForMember(d => d.code, o => o.MapFrom(s => s.Code))
.ReverseMap();
}
}
public class DataEntity
{
public Guid Id { get; set; }
public string Code { get; set; }
}
public class BusinessEntity
{
public Guid id { get; set; }
public string code { get; set; }
}
这将返回:
显然,在没有最小可重复示例的情况下,我已经简化了这一点,但这不应该改变方法。我假设该集合基于属性名称(查询)是只读的,因此使用 AddToReadOnlySource 进行排列。如果它不是只读的,则可以改用 AddRange。
- 模拟映射器。
根据 JBogard 对该主题的评论,我大部分时间都使用真正的映射器。但是,您似乎愿意模拟它,您可以简单地模拟 ProjectTo 调用以返回所需的 IAsyncEnumerable 序列:
void Main()
{
var fixture = new Fixture();
var dataEntites = new AsyncEnumerable<DataEntity>(fixture.CreateMany<DataEntity>());
var expectedResult = new AsyncEnumerable<BusinessEntity>(dataEntites.Select(x => new BusinessEntity() { id = x.Id, code = x.Code }));
var mapperMock = new Mock<IMapper>();
mapperMock.Setup(x => x.ProjectTo<BusinessEntity>(It.IsAny<IQueryable<DataEntity>>(), It.IsAny<object>())).Returns(expectedResult);
var mapper = mapperMock.Object;
var sut = new SUT(mapper);
var actualResult = sut.Handle(dataEntites).Result;
var compareLogic = new CompareLogic();
compareLogic.Config.IgnoreObjectTypes = true;
compareLogic.Config.IgnoreCollectionOrder = true;
var comparisonResult = compareLogic.Compare(expectedResult, actualResult);
Console.WriteLine($"Are the sequences equivalent: {comparisonResult.AreEqual}");
Console.WriteLine(expectedResult);
Console.WriteLine(actualResult);
}
public class SUT
{
IMapper _mapper;
public SUT(IMapper mapper)
{
_mapper = mapper;
}
public async Task<List<BusinessEntity>> Handle(IQueryable<DataEntity> entities)
{
return await _mapper.ProjectTo<BusinessEntity>(entities).ToListAsync();
}
}
public class DataEntity
{
public Guid Id { get; set; }
public string Code { get; set; }
}
public class BusinessEntity
{
public Guid id { get; set; }
public string code { get; set; }
}
结果:
这使用了EntityFrameworkCore.Testing中的AsyncEnumerable类,您可以按原样使用它,也可以根据需要作为您自己实现的基础。
推荐阅读
- java - 如何将 mongodb 集合复制/克隆到另一个集合?
- android - 在 Fragment 中设置一个新的 ListAdapter
- python-3.x - python for循环中的多处理
- angular - 无法在发布请求Angular 6 Form组中传递值
- php - 如何修复“无法添加或更新子行:外键约束失败”
- c++ - C++中模板参数的类继承
- postgresql - 逻辑复制延迟 postgresql
- php - PHP Map 将键值用于关联数组
- c# - 如何发布使用 C# 创建的 COM-Visible 库
- ios - 如何修改 AudioUnit Buffer 的大小?