实体框架存储过程

实体框架存储过程详解

基础概念

实体框架(Entity Framework)是微软推出的一个对象关系映射(ORM)框架，它允许开发人员以面向对象的方式操作数据库。存储过程(Stored Procedure)是预先编译并存储在数据库中的一组SQL语句，可以接受参数、执行操作并返回结果。

在实体框架中使用存储过程主要有两种方式：

通过函数导入(Function Import)将存储过程映射为方法
直接执行SQL命令调用存储过程

优势

性能优化：存储过程是预编译的，执行效率通常高于动态SQL
安全性：减少SQL注入风险，可以精细控制权限
业务逻辑封装：将复杂逻辑封装在数据库层
减少网络流量：只需传递参数而非完整SQL语句
复用性：多个应用可以共享同一存储过程

类型与应用场景

查询型存储过程：用于复杂查询，返回结果集
- 场景：多表联合查询、分页查询、复杂条件筛选

操作型存储过程：执行插入、更新、删除操作
- 场景：事务性操作、批量数据处理
混合型存储过程：同时包含查询和操作
- 场景：业务逻辑复杂的操作，如订单处理

在EF中使用存储过程的方法

1. 通过函数导入(推荐方式)

// 假设有一个名为GetCustomerOrders的存储过程
// 1. 在EDMX设计器中右键→"从数据库更新模型"
// 2. 选择存储过程→完成
// 3. 右键存储过程→"添加函数导入"

// 使用示例
using (var context = new YourDbContext())
{
    var customerIdParameter = new ObjectParameter("CustomerID", 1);
    var orders = context.GetCustomerOrders(customerIdParameter).ToList();
    
    foreach (var order in orders)
    {
        Console.WriteLine($"Order ID: {order.OrderID}, Date: {order.OrderDate}");
    }
}

2. 直接执行SQL命令

using (var context = new YourDbContext())
{
    var customerId = 1;
    var orders = context.Database.SqlQuery<OrderDTO>(
        "EXEC GetCustomerOrders @CustomerID",
        new SqlParameter("CustomerID", customerId)
    ).ToList();
}

常见问题与解决方案

问题1：存储过程返回多个结果集

解决方案：

using (var context = new YourDbContext())
{
    // 使用DbDataReader处理多个结果集
    var cmd = context.Database.Connection.CreateCommand();
    cmd.CommandText = "EXEC GetCustomerAndOrders @CustomerID";
    cmd.Parameters.Add(new SqlParameter("CustomerID", 1));
    
    context.Database.Connection.Open();
    var reader = cmd.ExecuteReader();
    
    // 第一个结果集：客户信息
    var customers = ((IObjectContextAdapter)context)
        .ObjectContext
        .Translate<Customer>(reader, "Customers", MergeOption.AppendOnly);
    
    // 移动到下一个结果集
    reader.NextResult();
    
    // 第二个结果集：订单信息
    var orders = ((IObjectContextAdapter)context)
        .ObjectContext
        .Translate<Order>(reader, "Orders", MergeOption.AppendOnly);
    
    context.Database.Connection.Close();
}

问题2：存储过程输出参数获取

解决方案：

using (var context = new YourDbContext())
{
    var totalCountParam = new SqlParameter
    {
        ParameterName = "@TotalCount",
        SqlDbType = SqlDbType.Int,
        Direction = ParameterDirection.Output
    };
    
    var results = context.Database.SqlQuery<Order>(
        "EXEC GetOrdersByDateRange @StartDate, @EndDate, @TotalCount OUTPUT",
        new SqlParameter("@StartDate", DateTime.Today.AddDays(-7)),
        new SqlParameter("@EndDate", DateTime.Today),
        totalCountParam
    ).ToList();
    
    int totalCount = (int)totalCountParam.Value;
    Console.WriteLine($"Total orders: {totalCount}");
}

问题3：EF Core中使用存储过程

在EF Core中，直接执行SQL是主要方式：

// EF Core示例
using (var context = new YourDbContext())
{
    var orders = context.Orders
        .FromSqlRaw("EXEC GetCustomerOrders @CustomerID", 
            new SqlParameter("CustomerID", 1))
        .ToList();
}