Scala中MongoDB countDocuments()查询远慢于Compass的问题求助

首先咱们先拆解下为啥你的Scala代码和Compass查询速度差这么多：

• Compass里的db.tbltrackerdata.find({},{}).count()在空查询条件下，MongoDB会直接读取集合的元数据返回估算文档数，这个操作几乎不耗时，所以只需要0.2秒。
• 而你Scala代码里用的countDocuments()，默认会执行精确计数——它会扫描集合里的所有文档来统计数量，自然要花2-2.5秒。

针对你动态where子句的场景，这里给你两个实用的优化方向：

1. 分场景选择计数方式 #

既然where子句是动态生成的，咱们可以加个判断：当没有过滤条件时用estimatedDocumentCount()（和Compass空查询的逻辑完全一致）；有条件时再用countDocuments()。修改后的代码如下：

def headResult[T](): T = Await.result(observable.head(), Duration(10, TimeUnit.SECONDS))
val database: MongoDatabase = mongoClient.getDatabase("dbname")
val collection: MongoCollection[Document] = database.getCollection("tablename")

// 替换成你生成动态where子句的逻辑
val dynamicFilter: Bson = // 你的动态条件生成代码

val recordCount = if (dynamicFilter == Document()) {
  // 空条件用估算计数，速度极快
  collection.estimatedDocumentCount().headResult()
} else {
  // 带条件时用精确计数
  collection.countDocuments(dynamicFilter).headResult()
}

2. 给高频查询字段加索引 #

如果你的动态where子句里有经常出现的过滤字段，一定要给这些字段创建索引——这样countDocuments()会利用索引扫描来计数，而不是全表扫描，速度会大幅提升。比如常用过滤字段是userId和createTime，可以在MongoDB shell里创建复合索引：

db.tbltrackerdata.createIndex({ userId: 1, createTime: -1 })

如果动态字段不固定，那可以给所有可能作为过滤条件的字段单独建单键索引，MongoDB会自动选择最合适的索引来执行计数查询。

另外，你也可以检查下MongoDB的读偏好设置，如果集群有从节点，把读请求指向从节点（比如设置ReadPreference.secondaryPreferred()），能减轻主节点压力的同时提升响应速度。

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