MongoDriver for Scala + http4s：如何检查 createCollection() 是否抛出异常？

Question

我是 Scala - http4s 初学者。
我必须使用带有 http4s 的 Scala 为我的工作创建一个 MVC 应用程序，我面临以下问题：

我无法在 Repository

中捕获 mongo 驱动程序异常

我的任务之一是为一些请求创建新的数据库，所以我开始在我的存储库中设计函数“createDatabase”。
根据 documentation :

MongoDatabase instance provides methods to interact with a database but the database might not actually exist and will only be created on the insertion of data via some means; e.g. the creation of a collection or the insertion of documents

所以我的代码是：

    def createDatabase(databaseName: String) = {
        IO.fromFuture(IO {
           MongoClient("con_string").getDatabase(databaseName).createCollection("any_name").head()
        })
    }

预计将创建一个包含名称为“any_name”的集合的新数据库。

如果使用已经存在的数据库名称调用createDatabase，操作将失败，控制台输出：

com.mongodb.MongoCommandException: Command failed with error 48 (NamespaceExists): 'Collection already exists. NS: NewDbTest.customers' on server localhost:27017. The full response is {"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)
            }
        })
    }

由于保密工作协议，一些片段被混淆了。
请帮我。
谢谢！

Answer 1

使用 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)

MongoDriver for Scala + http4s：如何检查 createCollection() 是否抛出异常？

MongoDriver for Scala + http4s : How to check if createCollection() throws an exception?

mongodb

scala

model-view-controller

cats-effect

http4s

我无法在 Repository