使用Mongoose查询MongoDB返回不存在的冗余文档如何解决？

1. 检查stationId字段类型匹配问题 #

首先确认StationCurrentState Schema中stationId的字段类型，与数据库实际存储的stationId类型完全一致：

• 若Schema定义为stationId: Number但数据库存的是字符串类型的站点ID，Mongoose执行$in查询时的隐式类型转换会触发MongoDB索引匹配异常，返回多余结果。反过来Schema是String、数据库存Number也会出现同样问题。
• 修正Schema的字段类型和数据库存储保持一致即可解决该类匹配问题。

2. 显式配置Schema严格模式 #

Mongoose默认开启严格模式，但如果之前手动修改过相关配置，会导致残缺文档被返回，你可以在Schema定义时显式添加以下配置：

const stationCurrentStateSchema = new mongoose.Schema({
  stationId: { type: String, required: true }, // 此处类型与数据库实际存储对齐
  currentDischarge: Number,
  currentLevel: Number,
  date: Date,
  trend: String
}, {
  strict: true, // 严格模式：只返回Schema中定义过的字段，过滤非法字段文档
  strictQuery: true // 查询严格模式：拒绝查询Schema中未定义的字段
})

3. 确认集合名匹配 #

Mongoose会自动将模型名转为小写复数作为默认查询集合，比如StationCurrentState模型默认查询stationcurrentstates集合，如果你实际存储数据的集合名和自动生成的不一致，需要在Schema配置中显式指定：

}, {
  collection: "你的实际集合名"
})

同时确认Atlas聚合查询中$lookup的from字段和实际集合名完全一致，避免误查其他集合。

4. 验证及清理残缺数据 #

你可以直接在Atlas的Mongo Shell中执行原生查询验证结果：

// 替换为你的实际集合名和查询ID列表
db.stationcurrentstates.find({ stationId: { $in: ["152160050", "153140200"] } })

• 如果原生查询也返回多余文档，说明数据库中确实存在这些之前写入失败产生的残缺文档，你可以批量删除缺少必要字段的无效文档：

  db.stationcurrentstates.deleteMany({ currentLevel: { $exists: false } })
  

• 如果原生查询正常只有Mongoose返回多余结果，可以在查询时添加lean()方法禁用Mongoose文档实例化，直接返回原生JSON数据：

  StationCurrentState.find({ stationId: { $in: stationIdsList } }).lean()
  

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