EF Core 3.0 如何在ASP.NET Core MVC中动态获取存储过程可变列数据

EF Core 3.0 本身不直接支持无实体绑定的动态SQL结果查询，我们可以基于框架底层的ADO.NET连接能力封装实现，全程复用现有EF Core上下文的连接、事务逻辑，不需要引入额外第三方组件，和现有项目技术栈完全兼容。

方案1：封装DbContext扩展方法读取完全动态结果 #

适合返回列数量、类型完全不确定的场景，直接将结果转为动态对象集合。

扩展方法代码 #

using Microsoft.EntityFrameworkCore;
using System.Data;
using System.Data.Common;
using System.Dynamic;

public static class DbContextExtensions
{
    /// <summary>
    /// 执行SQL/存储过程返回动态对象集合
    /// </summary>
    /// <param name="sql">SQL语句/存储过程名称</param>
    /// <param name="parameters">SQL参数集合</param>
    /// <param name="commandType">命令类型，调用存储过程传CommandType.StoredProcedure</param>
    /// <returns>动态结构的结果集合</returns>
    public static async Task<List<dynamic>> ExecuteDynamicQueryAsync(this DbContext context, string sql, 
        IEnumerable<DbParameter> parameters = null, CommandType commandType = CommandType.Text)
    {
        var result = new List<dynamic>();
        var conn = context.Database.GetDbConnection();
        var originalConnState = conn.State;

        try
        {
            if (originalConnState != ConnectionState.Open)
                await conn.OpenAsync();

            using var command = conn.CreateCommand();
            command.CommandText = sql;
            command.CommandType = commandType;
            if (parameters != null)
            {
                foreach (var param in parameters)
                {
                    command.Parameters.Add(param);
                }
            }

            using var reader = await command.ExecuteReaderAsync();
            while (await reader.ReadAsync())
            {
                var dynamicObj = new ExpandoObject() as IDictionary<string, object>;
                for (int i = 0; i < reader.FieldCount; i++)
                {
                    var fieldName = reader.GetName(i);
                    var fieldValue = reader.IsDBNull(i) ? null : reader.GetValue(i);
                    dynamicObj.Add(fieldName, fieldValue);
                }
                result.Add(dynamicObj as dynamic);
            }
        }
        finally
        {
            if (originalConnState == ConnectionState.Closed)
                conn.Close();
        }
        return result;
    }
}

调用存储过程示例 #

// 构造存储过程参数，SqlServer用SqlParameter，其他数据库替换为对应参数类即可
var parameters = new List<SqlParameter>
{
    new SqlParameter("@UserId", 1001),
    new SqlParameter("@QueryDate", DateTime.Now)
};

// 调用扩展方法获取动态结果
var dynamicResult = await _yourDbContext.ExecuteDynamicQueryAsync(
    "存储过程名称", 
    parameters, 
    CommandType.StoredProcedure);

// 直接按返回列名访问字段，无需提前定义实体
var firstRowColumnValue = dynamicResult.FirstOrDefault()?.返回的列名;

方案2：基于无键实体临时映射（适合有部分固定字段的场景） #

如果存储过程返回结构在特定场景下有固定字段，可以用EF Core 3.0引入的无键实体特性绑定，实现类型安全的查询。

配置步骤 #

1. 在DbContext的OnModelCreating方法中配置无键实体，无需绑定物理表

protected override void OnModelCreating(ModelBuilder modelBuilder)
{
    // 配置无键实体，不会映射到数据库表，仅用于接收查询结果
    modelBuilder.Entity<你的临时DTO类>().HasNoKey();
}

2. 调用存储过程获取结果

var result = await _yourDbContext.Set<你的临时DTO类>()
    .FromSqlRaw("EXEC 存储过程名 @UserId,@QueryDate", new SqlParameter("@UserId",1001), new SqlParameter("@QueryDate",DateTime.Now))
    .ToListAsync();

注意事项 #

• EF Core 3.0中FromSqlRaw要求返回字段必须和绑定实体的属性完全对应，完全动态无固定结构的场景优先使用方案1。
• 方案1的扩展方法复用EF Core原有连接，不会产生额外连接开销，和现有EF Core事务逻辑完全兼容，不需要单独处理事务。
• 所有参数都要使用DbParameter传参，禁止直接拼接SQL字符串，避免SQL注入风险。
• 动态对象如果需要跨层传输，建议转为Dictionary<string, object>再传递，避免动态对象运行时解析异常。

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