如何在Mongoose的deleteMany方法中配置limit限制删除文档数量

问题原因 #

MongoDB 原生的 deleteMany 接口设计初衷就是删除所有匹配过滤条件的文档，本身不支持 limit 参数，你传入的 {limit:100} 会被底层驱动直接忽略，因此会删除所有符合条件的数据。

正确实现方案 #

方案1：全版本兼容方案

先查询符合条件的100条文档的_id，再基于_id批量删除，所有MongoDB版本都可使用，代码示例如下：

mongoose.connection.db.collection('sessions', async function (err, collection) {
  if (err) {
    console.error('获取集合失败：', err)
    return
  }
  try {
    // 仅查询符合条件的100条文档的_id，减少IO开销
    const toDeleteIds = await collection.find(
      { session: { $not: /.*passport.*/i } },
      { projection: { _id: 1 }, limit: 100 }
    ).toArray().then(list => list.map(item => item._id))

    const deleteRes = await collection.deleteMany({ _id: { $in: toDeleteIds } })
    console.log('删除成功，删除条数：', deleteRes.deletedCount)
  } catch (opErr) {
    console.error('删除操作失败：', opErr)
  }
})

方案2：MongoDB 5.0+ 高性能方案

如果你使用的MongoDB服务版本 >=5.0，可以直接用bulkWrite的deleteMany操作配置limit，省去先查询的步骤，性能更高：

mongoose.connection.db.collection('sessions', async function (err, collection) {
  if (err) {
    console.error('获取集合失败：', err)
    return
  }
  try {
    const deleteRes = await collection.bulkWrite([
      {
        deleteMany: {
          filter: { session: { $not: /.*passport.*/i } },
          limit: 100
        }
      }
    ])
    console.log('删除成功，删除条数：', deleteRes.deletedCount)
  } catch (opErr) {
    console.error('删除操作失败：', opErr)
  }
})

注意事项 #

如果你的业务场景并发较高，担心查询和删除的间隙有新的符合条件的数据插入导致多删，可以给整个操作加上事务包裹，保证原子性。

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