如何在Entity Framework中使用存储过程+存储库+工作模式单元？

Question

我首先使用Entity Framework代码创建MVC Web应用程序项目.在这个项目中,我将使用通用存储库和工作单元模式.另外,我想使用存储过程来获取list by和get-list方法.

如何将存储过程与通用存储库和工作单元模式一起使用？

Answer 1

添加到您的通用存储库

public IEnumerable<T> ExecWithStoreProcedure(string query, params object[] parameters)
{
        return _context.Database.SqlQuery<T>(query, parameters);
}

然后你就可以用任何unitofwork/repository来调用它

IEnumerable<Products> products = 
             _unitOfWork.ProductRepository.ExecWithStoreProcedure(
             "spGetProducts @bigCategoryId",
             new SqlParameter("bigCategoryId", SqlDbType.BigInt) { Value = categoryId } 
      );

Answer 2

您不应该尝试使用具有UoW/Repository模式的SP,因为它们很难在代码中控制,并且通常不会映射回相同的实体类型.UoW和Repository模式更适合直接使用ADO.NET而不是Entity Framework,因为EF已经是Repository模式.在使用SP时,我建议将CQRS作为更好的模式.通过@sunil和我对它的评论来阐述答案,我创建了一个专门用于处理存储过程的类.它也很容易模拟和测试.

public class ProcedureManager : IProcedureManager
{
    internal DbContext Context;

    public ProcedureManager(DbContext context)
    {
        Context = context;
    }

    //When you expect a model back (async)
    public async Task<IList<T>> ExecWithStoreProcedureAsync<T>(string query, params object[] parameters)
    {
        return await Context.Database.SqlQuery<T>(query, parameters).ToListAsync();
    }

    //When you expect a model back
    public IEnumerable<T> ExecWithStoreProcedure<T>(string query)
    {
        return Context.Database.SqlQuery<T>(query);
    }

    // Fire and forget (async)
    public async Task ExecuteWithStoreProcedureAsync(string query, params object[] parameters)
    {
        await Context.Database.ExecuteSqlCommandAsync(query, parameters);
    }

    // Fire and forget
    public void ExecuteWithStoreProcedure(string query, params object[] parameters)
    {
        Context.Database.ExecuteSqlCommand(query, parameters);
    }
}