MongoDB Scala Driver：Seq被整体推入数组而非逐个元素的问题求助

问题原因 #

你遇到的问题是pushEach将整个ID序列当作单个元素插入数组，而非逐个推入。核心原因是Java集合转换为Scala Seq时处理不当，且直接传入Seq会被MongoDB驱动识别为单一元素，而非可遍历的元素集合。

解决方案 #

需要两步修正：

• 正确转换Java集合为Scala原生Seq，确保元素类型准确
• 使用Scala可变参数展开操作符，让pushEach逐个处理每个ID

修正后的代码 #

import scala.jdk.CollectionConverters._
import scala.util.{Success, Failure}
import org.mongodb.scala.model.Updates.pushEach
import org.mongodb.scala.model.Filters.equal

val resIdFuture = formsCol.insertMany(documents).toFuture().map { res =>
  println("[InsertResult] ", res.getInsertedIds)
  // 将Java Collection转为Scala Seq，保证元素类型为ObjectId
  res.getInsertedIds.values().asScala.toSeq
}

// 用for推导式优化异步流程，避免嵌套回调
for {
  formIds <- resIdFuture
  updateResult <- orgCol.updateOne(equal("_id", orgId), pushEach("forms", formIds:_*)).toFuture()
} yield {
  println("Result of org form ids push: ", updateResult)
}
.onComplete {
  case Success(_) => println("Complete result")
  case Failure(ex) => println("Exception during operation: ", ex)
}

关键修改点说明 #

1. 集合类型转换：
   用res.getInsertedIds.values().asScala.toSeq替代原有的toArray.toSeq，通过CollectionConverters的asScala方法将Java集合转为Scala原生Iterable，再转为Seq，避免了Object类型数组带来的类型模糊问题，确保每个元素都是ObjectId类型。

2. 可变参数展开：
   在pushEach中添加:_*操作符，将Seq[ObjectId]展开为可变参数传入，让驱动将每个ID作为独立元素推入forms数组，而非把整个Seq当作单个元素插入。

3. 异步流程优化：
   用for推导式替代嵌套的onComplete，让异步代码逻辑更清晰，同时统一处理整个操作链的异常，减少回调嵌套带来的复杂度。

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