Scala操作MongoDB用$cond和$not更新字段结果异常求助

你遇到的问题核心是Scala代码中没有使用MongoDB的更新管道（Update Pipeline）语法。在MongoDB Shell中直接使用数组形式的更新语句时，MongoDB会将其解析为聚合式更新，执行$cond表达式；但如果在Scala中仅用普通的$set操作传递$cond文档，MongoDB会把这个文档当作普通字段值存储，而非执行表达式逻辑。

需要使用更新管道的方式执行updateMany，让MongoDB解析并执行$cond条件表达式。以下是具体实现步骤和代码示例：

1. 确认依赖版本 #

确保你的MongoDB Scala驱动版本支持更新管道（要求驱动版本≥4.0，对应MongoDB服务器版本≥4.2，你的5.0.9完全满足）。

2. 正确的Scala代码实现 #

方式一：使用MongoDB Scala驱动的API构建管道 #

import org.mongodb.scala._
import org.mongodb.scala.model._

// 获取目标集合
val collection: MongoCollection[Document] = mongoDatabase.getCollection("your_collection_name")

// 定义过滤条件（示例为更新所有文档，可替换为你的业务过滤规则）
val filter = Filters.empty

// 构建更新管道：通过$cond判断camp1是否存在，设置对应值
val updatePipeline = Seq(
  Updates.set(
    "camp1",
    Aggregates.cond(
      Filters.exists("camp1"), // 判断camp1字段是否存在
      "value2",                // 存在时设置的值
      "values"                 // 不存在时设置的值
    )
  )
)

// 执行updateMany并处理结果
collection.updateMany(filter, updatePipeline).subscribe(
  result => println(s"成功更新 ${result.getModifiedCount} 条文档"),
  error => println(s"更新失败：${error.getMessage}")
)

方式二：直接用Document构建管道（更贴近Shell语法） #

如果你习惯Shell的写法，也可以直接构造Document数组作为更新管道：

import org.mongodb.scala._
import org.mongodb.scala.bson.Document

val collection: MongoCollection[Document] = mongoDatabase.getCollection("your_collection_name")
val filter = Filters.empty

val updatePipeline = Seq(
  Document(
    "$set" -> Document(
      "camp1" -> Document(
        "$cond" -> Document(
          "if" -> Document("$exists" -> Seq("$camp1", true)),
          "then" -> "value2",
          "else" -> "values"
        )
      )
    )
  )
)

collection.updateMany(filter, updatePipeline).subscribe(...)

关键注意点 #

• 不要使用普通的Updates.set("camp1", Document("$cond" -> ...))直接作为更新参数，这种写法会将$cond文档当作普通值存储。
• 更新管道必须以数组（Seq/List）形式传递给updateMany，MongoDB才会将其解析为聚合式更新逻辑。

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