如何创建可提供动态结构数据集及参数的C# Controller？

问题背景 #

基于SQL Server开发了一套高度动态扩展的数据采集存储系统，属于特殊数据库范畴——可通过调用存储过程动态创建表、视图、存储过程及函数来生成各类数据列表，每种实体的输出结构由其数据定义决定。在编写查询和数据交付接口时，这些数据库对象确实存在，但提前完全未知。

核心痛点 #

• 数据集结构在软件运行时动态生成，ASP.NET MVC中常用的IEnumerable<T>要求编译时已知类型，无法直接适配
• 期望完全由数据库驱动数据提供逻辑，包括运行时才能确定的存储过程名称及参数
• 熟悉.NET Framework框架开发，但对MVC不熟悉，查阅相关资料未找到匹配方案，不想从零构建自定义Web服务，期望复用ASP.NET MVC节省时间

可行方案 #

方案1：使用dynamic类型与ExpandoObject适配动态数据集 #

利用.NET的dynamic类型和ExpandoObject封装运行时动态生成的数据结构，绕过编译时类型检查限制。

实现步骤

1. 数据库查询层动态转换
   执行存储过程或查询后，将DataTable逐行转换为ExpandoObject，列名作为属性名，列值作为属性值：

public IEnumerable<dynamic> ExecuteDynamicQuery(string procName, SqlParameter[] parameters)
{
    using (var conn = new SqlConnection(ConfigurationManager.ConnectionStrings["YourConn"].ConnectionString))
    {
        conn.Open();
        using (var cmd = new SqlCommand(procName, conn))
        {
            cmd.CommandType = CommandType.StoredProcedure;
            cmd.Parameters.AddRange(parameters);
            using (var reader = cmd.ExecuteReader())
            {
                while (reader.Read())
                {
                    var expando = new ExpandoObject();
                    var expandoDict = (IDictionary<string, object>)expando;
                    for (int i = 0; i < reader.FieldCount; i++)
                    {
                        expandoDict.Add(reader.GetName(i), reader.IsDBNull(i) ? null : reader.GetValue(i));
                    }
                    yield return expando;
                }
            }
        }
    }
}

2. Controller接口返回动态数据
   在Controller的Action中直接返回JsonResult，将动态集合序列化为JSON：

public JsonResult GetDynamicData(string procName, Dictionary<string, object> paramValues)
{
    var parameters = paramValues.Select(kv => new SqlParameter(kv.Key, kv.Value ?? DBNull.Value)).ToArray();
    var dynamicData = ExecuteDynamicQuery(procName, parameters);
    return Json(dynamicData, JsonRequestBehavior.AllowGet);
}

注：ASP.NET MVC 5+中，可通过JsonRequestBehavior.AllowGet允许GET请求，也可根据需求配置CORS和请求方法。

方案2：自定义DynamicModelBinder实现动态参数绑定 #

针对运行时确定的存储过程参数，实现自定义ModelBinder解析请求参数，无需提前定义实体类。

实现步骤

1. 编写自定义ModelBinder

public class DynamicParamBinder : IModelBinder
{
    public object BindModel(ControllerContext controllerContext, ModelBindingContext bindingContext)
    {
        var request = controllerContext.HttpContext.Request;
        var paramDict = new Dictionary<string, object>();
        
        // 解析QueryString参数
        foreach (var key in request.QueryString.AllKeys)
        {
            if (!string.IsNullOrEmpty(key))
            {
                paramDict.Add(key, request.QueryString[key]);
            }
        }
        
        // 解析POST请求体（JSON格式）
        if (request.HttpMethod.Equals("POST", StringComparison.OrdinalIgnoreCase))
        {
            request.InputStream.Position = 0;
            var jsonStr = new StreamReader(request.InputStream).ReadToEnd();
            var postParams = JsonConvert.DeserializeObject<Dictionary<string, object>>(jsonStr);
            foreach (var kv in postParams)
            {
                paramDict[kv.Key] = kv.Value;
            }
        }
        
        return paramDict;
    }
}

2. 在Action中使用自定义Binder

public JsonResult ExecuteProc(string procName, [ModelBinder(typeof(DynamicParamBinder))] Dictionary<string, object> parameters)
{
    var sqlParams = parameters.Select(kv => new SqlParameter(kv.Key, kv.Value ?? DBNull.Value)).ToArray();
    var result = ExecuteDynamicQuery(procName, sqlParams);
    return Json(result, JsonRequestBehavior.AllowGet);
}

方案3：直接返回序列化的DataTable #

若无需对象化结构，可直接将查询返回的DataTable序列化为JSON，JsonResult可直接处理该类型：

public JsonResult GetDataTable(string procName, Dictionary<string, object> parameters)
{
    DataTable dt = new DataTable();
    using (var conn = new SqlConnection(ConfigurationManager.ConnectionStrings["YourConn"].ConnectionString))
    {
        conn.Open();
        using (var cmd = new SqlCommand(procName, conn))
        {
            cmd.CommandType = CommandType.StoredProcedure;
            cmd.Parameters.AddRange(parameters.Select(kv => new SqlParameter(kv.Key, kv.Value ?? DBNull.Value)).ToArray());
            using (var adapter = new SqlDataAdapter(cmd))
            {
                adapter.Fill(dt);
            }
        }
    }
    return Json(dt, JsonRequestBehavior.AllowGet);
}

关键注意事项 #

• 权限校验：动态传入存储过程名称和参数存在安全风险，必须添加严格的权限控制，禁止调用未授权存储过程，同时校验参数合法性避免SQL注入
• 结构缓存：对于高频调用的存储过程，可缓存其列元数据，减少每次查询的元数据获取开销
• 异常处理：添加完善的异常捕获逻辑，返回明确的错误信息（如存储过程不存在、参数类型不匹配等）

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