ReactiveMongo 与 MongoConnectionOptions 连接

ReactiveMongo connect with MongoConnectionOptions

我在 reactivemongo 版本 0.15.x 中使用 MongoConnectionOptions 连接到我的 MongoDB。现在我更新到 0.20.11.

MongoConnectionOptions 伴随对象的 apply() 函数现已弃用。弃用警告说要使用 MongoConnectionOptions 的构造函数。不幸的是,这个构造函数是包私有的。

我不想使用已弃用的 apply 函数,主要是因为我的 scala 编译器选项不允许出现警告。 (我真的不想改变这个)。

官方文档仅对弃用版本进行说明:http://reactivemongo.org/releases/0.1x/documentation/tutorial/connect-database.html

如何使用连接选项连接到数据库?

工厂 MongoConnectionOptions(..) 将在下一个主要版本 1 中重构。0.x。

无论如何,你可以使用 .default + .copy(..):

import reactivemongo.api.MongoConnectionOptions

MongoConnectionOptions.default.copy(appName = "Foo")

此外,选项可以准备(从配置文件或以编程方式)作为 URI 字符串。

val host = "localhost"
val port = 27017

reactivemongo.api.MongoConnection.connect(s"mongodb://${host}:${port}")

我使用以下语法并且对我来说工作正常:

val host = "localhost"
val port = "27017"
val db_name = "test"
val mongoUri = "mongodb://" + host + ":" + port + "/" + db_name
val driver = new AsyncDriver
val database = for {
  uri <- MongoConnection.fromString(mongoUri)
  con <- driver.connect(uri)
  dn <- Future(uri.db.get)
  db <- con.database(dn)
} yield db

val bsonCollection: Future[BSONCollection] = database.map(_.collection(collectionName))