OData查询过滤器下推与ODBC数据源适配问题咨询

我是OData新手，在ASP.NET Web API项目中使用OData搭配Dapper（而非EF）从SQL Server查询数据时，发现查询过滤器并未下推至数据库执行，现咨询以下两个问题：

1. 查询下推功能仅支持EF吗？
2. OData是否适用于所有具备ODBC驱动的数据源？

代码片段

public class InboundMetaDataController : ODataController
{
    DapperContext db = new DapperContext();

    [EnableQuery]
    public IQueryable<InboundMetaData> Get()
    {
        return GetInboundMeta();
    }

    public IEnumerable<InboundMetaData> GetInboundMetaRecords()
    {
        var query = "SELECT Id, DataSource, Client, DataPath FROM Datalake.InboundMetaData ";
        using (var connection = db.CreateConnection())
        {
            return connection.Query<InboundMetaData>(query).AsEnumerable();
        }
    }

    public IQueryable<InboundMetaData> GetInboundMeta()
    {
        IEnumerable<InboundMetaData> qry = GetInboundMetaRecords();
        return qry.AsQueryable();
    }
}

public class DapperContext
{

    private readonly string _connectionString = @"server=server1; database=test_db; Integrated Security=true; Encrypt=false";

    public IQueryable<InboundMetaData> InboundMetaData { get; internal set; }

    public IDbConnection CreateConnection()
        => new SqlConnection(_connectionString);
}

问题解答 #

Q1：查询下推功能仅支持EF吗？ #

不是。OData的查询下推核心是将OData查询表达式转换为目标数据源的查询语句，EF只是自带了成熟的IQueryable提供者，能自动完成这个转换。

你的代码里，GetInboundMeta()是把Dapper查询返回的内存集合（IEnumerable）转成IQueryable，此时的IQueryable是基于内存的，OData过滤器会在内存中过滤数据，而非下推到数据库——因为Dapper本身不提供IQueryable查询提供者，无法把OData的表达式翻译成SQL。

要实现Dapper+OData的查询下推，你可以：

• 手动解析OData查询选项（如$filter、$top），将其转换成对应的SQL片段，拼接到Dapper的查询语句中（必须做参数化处理，避免SQL注入）
• 使用第三方库（如Dapper.OData）帮你完成OData表达式到SQL的转换
• 自定义实现IQueryProvider，让Dapper支持IQueryable的查询转换

Q2：OData是否适用于所有具备ODBC驱动的数据源？ #

OData本身是REST数据协议，不直接绑定数据源驱动，只要你能实现OData查询到目标数据源查询语言的转换逻辑，就能适配带ODBC驱动的数据源。

但要注意：

• 不同数据源的查询语法存在差异（比如SQL Server和MySQL的函数、语法细节），你需要针对特定数据源做适配
• 如果数据源没有原生的IQueryable提供者，必须手动或通过第三方工具处理查询转换，否则只能在内存中处理OData查询，大数据量下性能极差
• ODBC驱动仅负责数据连接，OData的查询下推还需要你完成表达式到目标查询语言的转换

针对你当前代码的优化建议 #

你当前的代码会先加载全表数据到内存再过滤，性能极低。这里提供一个手动处理OData查询选项的示例（仅做演示，实际项目建议用成熟库）：

[EnableQuery]
public IActionResult Get(ODataQueryOptions<InboundMetaData> options)
{
    var sqlBuilder = new StringBuilder("SELECT Id, DataSource, Client, DataPath FROM Datalake.InboundMetaData");
    var parameters = new DynamicParameters();

    // 处理$filter（示例，需完善表达式解析和参数化）
    if (options.Filter != null)
    {
        // 注意：直接使用RawValue有SQL注入风险，实际需解析表达式树生成参数化SQL
        var filterExpression = options.Filter.RawValue;
        sqlBuilder.Append(" WHERE ").Append(filterExpression);
        // 示例：若Filter是Client eq 'test'，需将'test'转为参数
        // parameters.Add("@Client", "test");
    }

    // 处理$orderby、$top、$skip等其他查询选项...

    using (var connection = db.CreateConnection())
    {
        var result = connection.Query<InboundMetaData>(sqlBuilder.ToString(), parameters);
        return Ok(result);
    }
}

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