问题标签 [mongodb-scala]

在MongoDB Scala 驱动程序中，ScalaObservable.foreach并没有像我预期的那样阻塞。由于它返回 Unit 我也不能用.toFuture它来等待。

等待的惯用方式是什么？我的程序退出得太早了。

作为一种解决方法，我已替换.foreach为.map(f).toFuturewhere f: _ => Unit，然后阻止未来。

我正在尝试在 Scala 中打印 MongoDB 查询的结果

抛出的错误是：Cannot resolve symbol printResults。建议使用mongo-scala-driverversion的其他一些问题的答案1.2，因为 printResults() 未针对 version1.1及以下版本实现

SBT 文件：

尝试使用手动打印：

导致以下信息：

信息：ReadPreferenceServerSelector{readPreference=primary} 从集群描述 ClusterDescription{type=UNKNOWN, connectionMode=SINGLE, serverDescriptions=[ServerDescription{address=localhost:27017, type=UNKNOWN, state=CONNECTING}]} 中没有选择服务器。在超时前等待 30000 毫秒

有没有办法在控制台中查看检索到的结果？

我正在尝试创建一个与 Javascript Object 对应的文档Map[String, Any]。当我尝试插入一个新文档时，我会得到这个异常：

org.bson.codecs.configuration.CodecConfigurationException：找不到类 java.lang.Object 的编解码器。

这是我的测试文档说明：

这是编解码器注册表：

我写了一个小应用程序并将其推送到github 上。

目前，我的解决方法是序列化Map[String, Any]并将其保存为字符串。

所以，我的问题是，我必须做什么才能Map[String, Any]在 mongodb 中用作我的动态对象的类型？或者我可以做其他事情来让它工作吗？

在 Scala 中，我编写了两个 MongoDB 可观察对象，并在传递自定义执行上下文时调用了 observable。对 observable 的调用是在第一个 observable 上进行的，但自定义执行上下文不会传播到第二个 observable。

为了帮助说明这一点，我编写了以下自包含的代码：

输出如下：

我期望在执行“INSERT”可观察对象时仅将“自定义池”用作执行上下文，而不是使用 Thread-2 和 Thread-4。如此处文档中所述：

MongoDB 观察 API

具体来说，它说：为未来的操作使用特定的执行上下文

为什么自定义线程池不用于“插入”可观察对象？

我正在使用官方的 mongo scala 驱动程序：http: //mongodb.github.io/mongo-scala-driver/。

我想做这样的查询：

所以在scala代码中我正在做：

但在所有结果中我看到：

从 mongo 驱动程序日志中，我看到它的发送：

如果我在 mongo 中执行此查询，它会很好地计算这些记录。知道如何解决这个问题吗？

谢谢！

如果没有找到这样的字段，是否有可能说服 Mongodb 驱动程序使用案例类字段的默认值？

当前出现错误：

PS我知道将它作为选项不会引发错误，接下来我需要编写getOrElse("...")我想避免的额外代码。

我正在使用 MongoDB 的 Scala 驱动程序建立连接并在类中插入文档。我正在关注此链接中提到的他们的官方文档。（http://mongodb.github.io/mongo-scala-driver/2.6/getting-started/quick-tour/）

我在 Windows 10 上运行 MongoDB，并且在集群设置中独立运行。当我运行 scala 代码时，我看到以下日志条目和错误，但没有任何反应。

日志信息：

SBT 文件：

斯卡拉代码：

有人指出我做错了什么吗？

如果可能的话，我想在 insertOne 操作后返回 mongo 生成的 ObjectId()

如果不可能，我知道可以生成一个，但是如何确保它是唯一的？

在我的项目中，mongodb 查询响应太慢，并且随着数据的增加同样恶化。我正在尝试优化查询。我尝试搜索 scala 代码来打印解释查询计划和执行查询所需的时间。

在 mongo shell 中，我们可以得到如下所述的执行计划。我需要 scala 中的等效 API。

还是有什么方法可以让我们知道查询迟缓的根本原因？

我可以使用此查询直接查询 mongodb，但是在使用Filters#in{key: {$in: [/faq/]}}时如何复制它？

in("key", Seq("/faq/"))不起作用，因为它作为字符串传递。