Slick Try(query(run)) 总是返回成功

Question

我使用的是 slick 3.2.1。我使用 operatorId 作为外键。

我的代码是这样的

def changeCommentStatus(changeRequest: StatusUpdateRequest(implicit ec: ExecutionContext): Future[Int] = {
    val changeStatusQuery = comments
      .filter(_.id inSetBind changeRequest.commentIds)
      .filter(_.status === changeRequest.prevStatus)
      .map(c => (c.operatorId, c.updatedAt, c.status))
      .update((Some(changeRequest.operatorId), Some(new Timestamp(System.currentTimeMillis())), changeRequest.status))
    db.run(changeStatusQuery)
  }
Try(changeCommentStatus(changeRequest)) match {
      case Success(response) => bla bla bla
      case Failure(f) => bla bla bla

我使用了违反外键但 Try 不能失败的 operatorId。我该如何解决？

Answer 1

使用DBIOAction#asTry 将DBIOAction[Int] 转换为DBIOAction[Try[Int]]，然后flatMap 得到结果：

def changeCommentStatus(...): Future[Int] = {
  val changeStatusQuery = comments
    .filter(...)
    .filter(...)
    .map(...)
    .update(...)
    .asTry
    .flatMap {
      case Success(res) => DBIO.successful(res)
      case Failure(t)   => DBIO.failed(t)
    }

  db.run(changeStatusQuery)
}

然后您可以通过以下方式对Future 进行模式匹配：

changeCommentStatus(changeRequest).onComplete {
  case Success(response) => ...
  case Failure(t)        => ...
}