使用 Entity Framework 和 .net Core 执行 SP

Question

我使用 .net 核心和实体框架创建了一个 Web api 项目。 这使用了一个存储过程，它返回由实体框架定义的数据库表的大部分属性。

实体框架不会带回表的所有列。当我调用 api 时出现错误，抱怨当我使用 执行存储过程时找不到丢失的列，

_context.Set<TableFromSql>().FromSql("execute dbo.spr_GetValue").ToList();

我创建了另一个模型类，它定义了从 SP 带回的属性（称为 NewClass）。

_context.Set<NewClass>().FromSql("execute dbo.spr_GetValue").ToList();

这可行，但只是想检查是否存在 SP 应仅从数据库返回模型类的约定。

Answer 1

SQL 查询必须返回实体或查询类型的所有属性的数据

这个限制是在将sql查询结果映射到Model时造成的。它遍历模型中的属性并尝试从查询结果中检索值。如果模型属性在query result 中不存在，则会抛出错误。

如果您想返回所需的列而不是所有列，一种选择是通过Query 定义返回的模型。

对于您的演示代码，您可以在OnModelCreating 中定义它。

builder.Query<TableFromSql>();

注意，为此，您需要确保TableFromSql 中的所有属性都存在于execute dbo.spr_GetValue 中。

另一种方式，您可以实现自己的FromSql，它将添加条件以检查查询结果中是否存在属性。

    public static class DbContextExtensions
{
    public static List<T> RawSqlQuery<T>(this DbContext context,string query)
    {
        using (var command = context.Database.GetDbConnection().CreateCommand())
        {
            command.CommandText = query;
            command.CommandType = CommandType.Text;

            context.Database.OpenConnection();

            using (var result = command.ExecuteReader())
            {
                var entities = new List<T>();

                return DataReaderMapToList<T>(result);
            }
        }
    }
    public static List<T> DataReaderMapToList<T>(IDataReader dr)
    {
        List<T> list = new List<T>();
        T obj = default(T);
        while (dr.Read())
        {
            obj = Activator.CreateInstance<T>();
            foreach (PropertyInfo prop in obj.GetType().GetProperties())
            {
                if (ColumnExists(dr, prop.Name))
                {
                    if (!object.Equals(dr[prop.Name], DBNull.Value))
                    {

                        prop.SetValue(obj, dr[prop.Name], null);
                    }
                }
            }
            list.Add(obj);
        }
        return list;
    }
    public static bool ColumnExists(IDataReader reader, string columnName)
    {

        return reader.GetSchemaTable()
                     .Rows
                     .OfType<DataRow>()
                     .Any(row => row["ColumnName"].ToString() == columnName);
    }
}

使用上面的代码：

        var result = _context.RawSqlQuery<ToDoItemVM>("execute [dbo].[get_TodoItem]");