scala mongodb在过滤器中的使用

import org.mongodb.scala._
import org.mongodb.scala.bson.collection.immutable.Document
import org.mongodb.scala.model.Filters._

object ScalaMongoDBExample {
  def main(args: Array[String]): Unit = {
    // 创建MongoDB客户端
    val mongoClient: MongoClient = MongoClient()

    // 连接到数据库
    val database: MongoDatabase = mongoClient.getDatabase("mydb")

    // 获取集合
    val collection: MongoCollection[Document] = database.getCollection("mycollection")

    // 创建过滤器
    val filter = equal("name", "John")

    // 查询文档
    val result: FindObservable[Document] = collection.find(filter)

    // 处理查询结果
    result.subscribe(
      (doc: Document) => println(doc.toJson),
      (error: Throwable) => println(s"查询出错：${error.getMessage}"),
      () => println("查询完成")
    )

    // 关闭MongoDB客户端
    mongoClient.close()
  }
}