在Entity Framework Core 2.0中如何将DbDataReader转为Task<IEnumerable<TEntity>>？

我看到你在EF Core 2.0里调用存储过程时遇到了DbDataReader转换的问题，你的代码里有几个关键错误，导致了运行时异常，下面我来帮你修正并解释原因：

你的代码中的核心问题 #

1. 错误的类型转换：reader.Cast<Task<IEnumerable<TEntity>>>()完全不符合逻辑——DbDataReader是用来读取数据库返回的行数据的，它根本不是Task<IEnumerable<TEntity>>类型，直接Cast肯定会抛出类型转换异常。
2. 未使用异步操作的正确姿势：你用了异步方法的外壳，但内部调用的是OpenConnection()、ExecuteReader()这些同步方法，没有真正实现异步，还会阻塞线程。
3. 不安全的dynamic变量使用：dynamic temp没有被正确赋值，即使Cast成功，后续await temp也会因为类型错误失败。

修复方案 #

下面提供两种可行的修复方式，你可以根据自己的场景选择：

方案1：使用EF Core内置的扩展方法（推荐） #

EF Core提供了ReaderToListAsync扩展方法，可以自动将DbDataReader的数据映射到你的实体类，前提是实体属性名和存储过程返回的列名匹配（大小写不敏感，也可以通过DataAnnotation/Fluent API配置列名映射）。

using System.Data;
using System.Globalization;
using System.Threading.Tasks;
using Microsoft.EntityFrameworkCore;

private async Task<IEnumerable<TEntity>> InvokeStoredProcedureAsync(string entityName)
{
    var storedProcedureName = string.Format(CultureInfo.InvariantCulture, "sp_{0}BulkSelect", entityName);
    
    // 使用using块确保DbContext和资源被正确释放
    using (var myDbContext = new MyDbContext(_options))
    {
        // 异步打开数据库连接
        await myDbContext.Database.OpenConnectionAsync();
        
        // 创建并配置存储过程命令
        using var cmd = myDbContext.Database.GetDbConnection().CreateCommand();
        cmd.CommandType = CommandType.StoredProcedure;
        cmd.CommandText = storedProcedureName;
        
        // 异步执行命令并获取reader
        using var reader = await cmd.ExecuteReaderAsync();
        
        // 利用EF Core扩展方法将reader转换为实体列表
        var result = await myDbContext.Set<TEntity>().ReaderToListAsync(reader);
        
        return result;
    }
}

方案2：手动实现反射映射（适用于无法使用内置扩展的场景） #

如果你的场景不适合用内置扩展，可以通过反射手动将DbDataReader的每一行映射到TEntity：

using System;
using System.Collections.Generic;
using System.Data;
using System.Globalization;
using System.Linq;
using System.Reflection;
using System.Threading.Tasks;

private async Task<IEnumerable<TEntity>> InvokeStoredProcedureAsync(string entityName)
{
    var storedProcedureName = string.Format(CultureInfo.InvariantCulture, "sp_{0}BulkSelect", entityName);
    var resultList = new List<TEntity>();
    
    using (var myDbContext = new MyDbContext(_options))
    {
        await myDbContext.Database.OpenConnectionAsync();
        
        using var cmd = myDbContext.Database.GetDbConnection().CreateCommand();
        cmd.CommandType = CommandType.StoredProcedure;
        cmd.CommandText = storedProcedureName;
        
        using var reader = await cmd.ExecuteReaderAsync();
        
        // 获取TEntity的可写属性，建立列名（小写）到属性的映射字典
        var propertyMap = typeof(TEntity).GetProperties(BindingFlags.Public | BindingFlags.Instance)
            .Where(p => p.CanWrite)
            .ToDictionary(p => p.Name.ToLower(), p => p);
        
        // 异步读取每一行数据并映射到实体
        while (await reader.ReadAsync())
        {
            var entity = Activator.CreateInstance<TEntity>();
            
            for (int i = 0; i < reader.FieldCount; i++)
            {
                var columnName = reader.GetName(i).ToLower();
                if (propertyMap.TryGetValue(columnName, out var property))
                {
                    // 处理DBNull的情况，避免赋值错误
                    var value = reader.IsDBNull(i) ? null : reader.GetValue(i);
                    property.SetValue(entity, value);
                }
            }
            
            resultList.Add(entity);
        }
    }
    
    return resultList;
}

额外的优化建议 #

• 依赖注入DbContext：如果你的项目使用了依赖注入，建议通过构造函数注入MyDbContext，而不是手动new，这样可以利用EF Core的生命周期管理，避免资源泄漏。
• 处理异常：可以在代码中添加try-catch块，捕获数据库操作可能抛出的异常（比如连接失败、存储过程不存在等），并做相应的错误处理。

内容的提问来源于stack exchange，提问作者Vivek Nuna