EF 6 Plus 如何实现 Future 原生SQL查询功能？

EF 6 PLUS 内置的Deferred/Future系列方法默认仅适配IQueryable<T>类型的LINQ查询，而context.Database.SqlQuery返回的是DbRawSqlQuery<T>类型，因此没有原生支持对应方法，你可以通过以下两种方案实现需求：

方案1：自行扩展EF 6 PLUS适配原生SQL查询 #

直接针对DbRawSqlQuery<T>类型编写扩展方法，复用EF 6 PLUS的Future批处理逻辑：

using Z.EntityFramework.Plus;
using System.Data.Entity.Infrastructure;
using System.Data.SqlClient;

public static class SqlQueryFutureExtensions
{
    /// <summary>
    /// 为原生SQL查询添加Future批处理支持
    /// </summary>
    public static FutureQuery<T> Future<T>(this DbRawSqlQuery<T> sqlQuery)
    {
        return sqlQuery.AsQueryable().Future();
    }

    /// <summary>
    /// 为原生SQL查询添加FutureFirst支持
    /// </summary>
    public static FutureQuery<T> FutureFirst<T>(this DbRawSqlQuery<T> sqlQuery)
    {
        return sqlQuery.AsQueryable().DeferredFirst().Future();
    }

    /// <summary>
    /// 为原生SQL查询添加FutureSingle支持
    /// </summary>
    public static FutureQuery<T> FutureSingle<T>(this DbRawSqlQuery<T> sqlQuery)
    {
        return sqlQuery.AsQueryable().DeferredSingle().Future();
    }
}

扩展完成后即可直接使用你期望的写法调用：

// 参数化查询避免SQL注入
var param = new SqlParameter("@UserId", 1001);
var userFuture = context.Database.SqlQuery<SomeClass>("SELECT * FROM Users WHERE Id = @UserId", param).Future();
var orderFuture = context.Database.SqlQuery<Order>("SELECT * FROM Orders WHERE UserId = @UserId", param).Future();

// 首次访问结果时会一次性执行所有Future查询，仅1次数据库往返
var users = userFuture.ToList();
var orders = orderFuture.ToList();

方案2：使用EF6兼容的第三方批处理库 #

你也可以直接使用支持原生SQL Future的EF6兼容扩展包，这类包原生提供SqlQuery.Future()方法，无需自行编写扩展即可直接匹配你期望的代码写法。

注意事项 #

• 所有原生SQL查询请使用参数化写法，避免SQL注入风险
• 同上下文下的所有Future查询会在第一次访问任意Future结果时批量执行，实现减少数据库往返的优化效果

内容的提问来源于stack exchange，提问作者Ben.S