1

我正在使用 Scala 驱动程序为 Mongodb (1.1.1) 编写一种集成测试。

我有一个简单的插入查询，我可以使用 afuture或observer以这种方式管理它：

// with observer
driver.myCollection.insertOne(doc).subscribe(new Observer[Completed] {
      override def onNext(result: Completed) = /* do something */
      override def onComplete() = /* do something */
      override def onError(e: Throwable) = /* do something */
    })

// with future
val f = driver.myCollection.insertOne(doc).toFuture()
f onComplete {
      case Success(successMsg) => /* do something */
      case Failure(failureMsg) => /* do something */
    }
  }

我如何onError在Observer和/或Failure中进行测试Future？我怎样才能触发这种情况？

目前我正在使用Mongodb Embedded (flapdoodle).

如果我在测试开始时关闭 Mongodb，我会得到一个看起来与该错误无关的超时。

更新

我已添加WriteConcern到集合中：

database.getCollection(myCollection).withWriteConcern(WriteConcern.ACKNOWLEDGED)

但它不会改变任何东西。

期货/观察者返回的错误是否包括超时错误（由于某些原因导致数据库或网络关闭）？

4

1 回答 1

1

实现错误的一种方法是在集合上创建唯一索引，如下所述：https://docs.mongodb.com/manual/core/index-unique/ 创建唯一索引后，您可以插入一个项目，然后尝试再次插入它。这样你就会得到一个错误。

关于你的问题，如果抛出的超时也计入 onError 答案是肯定的，它很重要。这是我的代码片段：

def findByTitle(title:String)(implicit ec:ExecutionContext):Future[Option[Document]] = {
    val collection = db.getCollection("items")
    collection.find(equal("title", title))
      .toFuture()
      .recoverWith{case e:Throwable => {println("Simulated error happened"); println(e); Future.failed(e)}}
      .map{seq => if(seq.isEmpty) None else Some(seq.head)}
  }

在单击 UI 上触发此方法调用的按钮之前，我已经使用命令行命令停止了 MongoDB 服务net stop MongoDB（我在 Windows 上）。然后我触发了这个动作，过了一会儿，当超时触发时，我在控制台中看到了这个：

[info] p.c.s.NettyServer - Listening for HTTP on /0:0:0:0:0:0:0:0:9000

Server started, use Alt+D to stop

[info] play.api.Play - Application started (Dev)
Simulated error happened
com.mongodb.MongoTimeoutException: Timed out after 30000 ms while waiting for a server that matches ReadPreferenceServerSelector{readPreference=primary}. Client view of cluster state is {type=UNKNOWN, servers=[{address=localhost:27017, type=UNKNOWN, state=CONNECTING, exception={com.mongodb.MongoException: java.io.IOException: The remote computer refused the network connection.
}, caused by {java.io.IOException: The remote computer refused the network connection.
}}]
[error] application - 
....

所以你可以看到超时也被处理了，它应该是因为MongoTimeoutException是一个Throwable.

于 2016-07-17T15:13:55.543 回答