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))
我在 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))