Mongo C驱动使用mongoc_collection_count_documents遇$near查询报错

使用Mongo C驱动1.23.1版本（MongoDB服务器版本5.0.13）调用mongoc_collection_count_documents()函数，代码如下：

long long n = mongoc_collection_count_documents(collection, q, NULL, NULL, NULL, &error);

其中q为bson_t类型的查询条件变量。简单查询如{"score":20}可正常运行，但使用包含$near的地理查询（已为location字段创建2dsphere索引）时：

{
    "location" : {
        "$near" : {
            "$geometry" : {
                "type" : "Point",
                "coordinates" : [
                    2,
                    1
                ]
            },
            "$maxDistance" : 10
        }
    }
}

出现报错：

$geoNear, $near, and $nearSphere are not allowed in this context

但在Mongo Shell中使用db.c.count()执行相同查询却无报错。提出两个问题：

1. 为何Mongo Shell的count()可用但mongoc_collection_count_documents()不行？二者底层操作是否一致？
2. 如何在Mongo C驱动中实现含$near等地理查询的文档计数？

1. 底层操作差异原因 #

Mongo Shell的count()和C驱动的mongoc_collection_count_documents()底层实现并不完全一致：

• MongoDB 5.0及以后版本中，count()命令属于遗留命令，它会尝试使用索引满足$near查询，内部逻辑允许这种地理查询条件；
• 而mongoc_collection_count_documents()基于countDocuments命令实现，这是MongoDB推荐的新计数API，其语法规则明确禁止在查询条件中使用$near、$geoNear这类地理空间操作符——因为countDocuments本质是执行聚合操作，而聚合的$match阶段不支持$near（仅支持$geoWithin或$geoIntersects）。

2. C驱动实现地理查询计数的方案 #

有两种可行方式：

方式一：使用遗留的mongoc_collection_count()函数 #

C驱动提供了兼容旧版的mongoc_collection_count()函数，对应Mongo Shell的count()命令，可支持$near查询。示例代码：

long long n = mongoc_collection_count(collection, MONGOC_QUERY_NONE, q, 0, 0, NULL, &error);

注意：该函数属于遗留API，未来版本可能被废弃，仅建议在需要兼容旧逻辑时使用。

方式二：改用聚合管道实现计数 #

使用聚合管道的$geoNear阶段筛选符合地理条件的文档，再通过$count阶段统计数量，这是MongoDB推荐的标准做法。示例代码：

// 构建聚合管道
bson_t *pipeline = bson_new();
bson_t *geo_near_stage = bson_new();
BSON_APPEND_DOCUMENT_BEGIN(geo_near_stage, "$geoNear");
BSON_APPEND_DOCUMENT(geo_near_stage, "near", bson_new_from_json("{ \"type\": \"Point\", \"coordinates\": [2, 1] }", -1, NULL));
BSON_APPEND_DOUBLE(geo_near_stage, "maxDistance", 10.0);
BSON_APPEND_UTF8(geo_near_stage, "distanceField", "dist.calculated");
BSON_APPEND_BOOL(geo_near_stage, "spherical", true);
bson_append_document_end(geo_near_stage);

bson_t *count_stage = bson_new();
BSON_APPEND_UTF8(count_stage, "$count", "total");

// 将阶段加入管道
bson_append_array_begin(pipeline, NULL);
bson_append_document(pipeline, "0", geo_near_stage);
bson_append_document(pipeline, "1", count_stage);
bson_append_array_end(pipeline);

// 执行聚合
mongoc_cursor_t *cursor = mongoc_collection_aggregate(collection, MONGOC_AGGREGATE_NONE, pipeline, NULL, NULL);
const bson_t *result;
long long total = 0;
if (mongoc_cursor_next(cursor, &result)) {
    bson_iter_t iter;
    if (bson_iter_init_find(&iter, result, "total")) {
        total = bson_iter_as_int64(&iter);
    }
}

// 释放资源
mongoc_cursor_destroy(cursor);
bson_destroy(pipeline);
bson_destroy(geo_near_stage);
bson_destroy(count_stage);

这种方式符合MongoDB现代API规范，无废弃风险，同时能准确统计符合地理查询条件的文档数量。

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