1

我正在使用 Scala、Mongo DB 和 mongo-scala 驱动程序简单示例将数据插入 Mongo。

libraryDependencies += "org.mongodb.scala" %% "mongo-scala-driver" % "2.9.0"

// step 1 : connect to mongo 
val mongoClient: MongoClient = MongoClient("mongodb://localhost:27017")

// step 2 : connect to db
val database: MongoDatabase = mongoClient.getDatabase("mydb")

// step 3 : get the collection 
val collection: MongoCollection[Document] = database.getCollection("test")

// step 4 : create document 
val doc: Document = Document("_id" -> 0, "name" -> "MongoDB", "type" -> "database", "count" -> 1, "info" -> Document("x" -> 203, "y" -> 102))

//step 5 : insert in to db 
collection.insertOne(doc).results();

在最后一步中results()找不到该方法，但他们在文档中给出了它。

4

1 回答 1

2

从文档中：

快速浏览中使用的助手

对于快速浏览，我们使用定义在Helpers.scala. 这些助手获取并打印结果，尽管这是异步代码的人为场景，但我们在开始下一个示例之前阻止了一个示例的结果，以确保数据库的状态。该Helpers对象提供以下方法：

  • 结果（）

    阻塞直到Observable完成并返回收集的结果

...

查看Quick Tour 的源代码，您将看到以下导入：

import tour.Helpers._
于 2020-07-08T13:08:00.563 回答