Блог

У меня есть коллекция employees, которая выглядит так:

 {
_id
company_id
job_type
name
age
...
}
  

И запрос на удаление, который выглядит как:

 val criteria = Criteria.where("company_id").isEqualTo(companyId).and("job_type").isEqualTo(jobType)
val query = Query(criteria).limit(3)
  

Когда я запускаю его как:

 mongoTemplate.remove(query, null, "collection_name")
  

Это отлично работает 🙂

Покупайте, когда я запускаю его в массовых операциях, таких как:

 val bulkOp = mongoTemplate.bulkOps(BulkOperations.BulkMode.UNORDERED, null, "collection_name")
bulkOp.remove(query)
...
bulkOp.execute()
  

Он удаляет все документы для этой компании и типа задания, полностью игнорируя limit=3

Есть ли решение проблемы?

Массовая запись с параметрами курсора не поддерживается и противоположна тому, для чего предназначена массовая запись — курсор используется для итеративной обработки результатов и многократного обращения к серверу. С другой стороны, массовые обновления выполняются в пакетном режиме на стороне сервера.

Причина, по которой remove работает при использовании шаблона mongo, находится за сценой, которую он создает multiple queries для извлечения всех совпадений для запроса и получения идентификаторов, за которыми следует другой вызов для удаления этих идентификаторов.

Вы также можете сделать то же самое, собрав идентификаторы перед запуском запроса remove в mongodb для массового использования.