MongoDB C#驱动升级至2.5.0后，LINQ中$geoNear与IQueryable结合方法

我之前升级驱动时也碰到过一模一样的问题——2.x版本的LINQ生成聚合查询时，会把过滤、排序等逻辑放在前面，但$geoNear硬性要求作为聚合管道的第一个阶段，直接用LINQ会导致报错。下面是我实践过的两种可行方案，你可以根据自己的场景选择：

方案1：手动构建$geoNear起始阶段，追加LINQ生成的聚合阶段 #

这个方案适合你已经有现成的IQueryable查询（比如包含复杂过滤、排序逻辑），需要把地理查询放在最前面的场景：

步骤1：构建有效的$geoNear阶段 #

先写出你确认可用的$geoNear BsonDocument（基于你提供的示例补全）：

var geoNearStage = new BsonDocument
{
    { "$geoNear", new BsonDocument
        {
            { "near", new BsonDocument { { "type", "Point" }, { "coordinates", new BsonArray(new[] { 116.40, 39.90 }) } } }, // 替换成你的目标经纬度
            { "distanceField", "distance" }, // 存储计算出的距离的字段名
            { "spherical", true },
            { "maxDistance", 5000 } // 可选：最大搜索距离（单位米），按需添加
            // 其他$geoNear参数比如minDistance、includeLocs等都可以在这里配置
        }
    }
};

步骤2：将IQueryable转换为聚合阶段 #

假设你已经有一个包含业务逻辑的IQueryable<YourEntity>查询，比如：

var linqQuery = collection.AsQueryable()
    .Where(x => x.IsActive == true)
    .SortByDescending(x => x.CreatedAt)
    .Select(x => new { x.Id, x.Name, x.distance }); // 注意要包含distance字段

把这个LINQ查询转换成AggregateFluent并提取它的阶段：

var linqAggregate = linqQuery.ToAggregate();
var linqStages = linqAggregate.Stages;

步骤3：合并管道并执行 #

将$geoNear作为第一个阶段，再追加LINQ生成的所有阶段：

var combinedAggregate = collection.Aggregate()
    .AppendStage<BsonDocument>(geoNearStage)
    .AppendStages(linqStages)
    .As<YourProjectionType>(); // 替换成你的实体类或投影类型

var results = combinedAggregate.ToList();

方案2：将前置过滤逻辑嵌入$geoNear的query参数 #

如果你的IQueryable里有需要在地理查询之前执行的过滤条件（比如先筛选活跃的文档再做地理搜索），可以把这些条件直接放到$geoNear的query参数里，这样既满足$geoNear作为第一个阶段的要求，又能实现前置过滤：

var geoNearStage = new BsonDocument
{
    { "$geoNear", new BsonDocument
        {
            { "near", new BsonDocument { { "type", "Point" }, { "coordinates", new BsonArray(new[] { 116.40, 39.90 }) } } },
            { "distanceField", "distance" },
            { "spherical", true },
            // 把前置过滤条件放到query里
            { "query", new BsonDocument { { "IsActive", true } } }
        }
    }
};

// 后续直接追加LINQ的其他阶段（比如排序、投影）
var results = collection.Aggregate()
    .AppendStage<YourEntity>(geoNearStage)
    .SortByDescending(x => x.CreatedAt)
    .Select(x => new { x.Id, x.Name, x.distance })
    .ToList();

为什么升级后会出现这个问题？ #

MongoDB C#驱动2.x版本对LINQ到聚合的转换逻辑做了调整：1.x版本可能会把地理查询作为普通查询的一部分处理，而2.x版本会将所有LINQ操作统一转换成聚合管道阶段，但MongoDB本身规定$geoNear必须是聚合管道的第一个阶段，这就导致了直接用LINQ生成的聚合查询不符合要求，必须手动控制管道顺序。

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