如何解决MongoDriver for Scala + http4s:如何检查 createCollection() 是否抛出异常?
我是 Scala - http4s 初学者。
我必须使用带有 http4s 的 Scala 为我的工作创建一个 MVC 应用程序,但我面临以下问题:
我无法在存储库中捕获 mongo 驱动程序异常
我的任务之一是为某些请求创建新数据库,因此我开始在我的存储库中设计函数“createDatabase”。
根据{{3}}:
MongoDatabase 实例提供了与数据库交互的方法,但该数据库可能实际上并不存在,只会在通过某种方式插入数据时创建;例如创建集合或插入文档
所以我的代码是:
def createDatabase(databaseName: String) = {
IO.fromFuture(IO {
MongoClient("con_string").getDatabase(databaseName).createCollection("any_name").head()
})
}
期望将创建一个包含名称为“any_name”的集合的新数据库。
如果使用已经存在的数据库名称调用createDatabase,操作将失败,在控制台输出:
com.mongodb.MongoCommandException: 命令失败,错误 48 (NamespaceExists): '集合已经存在。 NS: NewDbTest.customers' 在服务器 localhost:27017 上。完整的响应是 {"ok": 0.0,"errmsg": "Collection already exists. NS: NewDbTest.customers","code": 48,"codeName": "NamespaceExists"}
我尝试使用 try {} catch、Try {}、withRecover() 等等,希望能捕获此异常并以异常消息响应,但没有任何效果。
一些例子:
def createDatabase(databaseName: String) = {
IO.fromFuture(IO {
try {
MongoClient("con_string").getDatabase(databaseName).createCollection("any_name").head()
}
catch {
case e: MongoCommandException => println("we have exception")
Future.successful(e.getErrorMessage)
}
})
}
def createDatabase(databaseName: String) = {
IO.fromFuture(IO {
client.getDatabase(databaseName).createCollection("any_name").map(operation => Try {operation}).head()
})
}
def createDatabase(databaseName: String) = {
IO.fromFuture(IO {
client.getDatabase(databaseName).createCollection("any_name").head() recover {
case exception: Exception => Future.successful(exception.getMessage)
}
})
}
由于保密工作协议,一些片段被混淆。
请帮我。
谢谢!
解决方法
使用 atempt
def createDatabase(databaseName: String) = {
IO.fromFuture(IO {
MongoClient("con_string").getDatabase(databaseName).createCollection("any_name").head()
}).attempt
}
然而,似乎无论发生什么,错误信息都是由 logger 在 DEBUG 级别打印的。所以我也将日志级别更改为 INFO。
Logger.getRootLogger.setLevel(Level.INFO)
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。