在 Play Framework 中使用编写 Slick 3.0 Scala 查询的“正确”方式

Question

我使用的是 Slick 3.0，而且（当然）几乎所有的示例都涵盖了 Slick 2.x。事情发生了变化，坦率地说，看起来更加复杂，而不是更少。

这是一个例子：我想通过 id 获取一个对象（一个 GPPerson）。这就是我现在所拥有的，它似乎非常冗长......比 Slick 2.x 更详细：

def get(id: GPID): Option[GPPerson] = Await.result(
    db.run(
        people.filter(_.id === id).result), Duration.Inf
    ).headOption

在 Slick 2.x 中，由于隐式等原因，事情变得更容易了。不过以上似乎是我想出的最简洁的表达方式了。

它也没有真正解决我需要添加的异常处理。

Answer 1

几个月前我开始在一个新项目中使用 Slick 3.0，我也有同样的问题。这是我的理解：

Slick 3.0 专为非阻塞异步（反应式）应用程序而设计。显然，它现在意味着 Akka + Play / Spray。在这个世界中，您主要与 Futures 交互，这就是 Slick 的 db.run 返回 Future 的原因。使用 Await.result 没有意义 - 如果您需要阻塞调用，最好返回到 2.x。

但是，如果您使用反应式堆栈，您将立即获得好处。例如，Spray 是一个完全非阻塞的库，可以很好地使用 onComplete 指令与 Futures 一起工作。您可以调用一个方法，该方法在 Spray 路由中使用来自 Slick 的结果返回 Future，然后将该结果与 onComplete 一起使用。在这种情况下，整个响应-回复管道是非阻塞的。

您还提到了异常处理，所以这正是您的做法 - 使用 Futures。

所以根据我的经验，我会按照以下方式编写您的方法：

def get(id: GPID): Future[Option[GPPerson]] = db.run(
  people.filter(_.id === id).result.map(_.headOption)
)

然后使用 Future。

Answer 2

你可以这样做。

def syncResult[R](action:slick.dbio.DBIOAction[R, slick.dbio.NoStream, scala.Nothing]):R = {
    import scala.concurrent.duration.Duration

    val db = Database.forConfig("db")
    try {
      Await.result(db.run(action), Duration.Inf)
    } finally db.close
  }

def get(id: GPID): Option[GPPerson] = syncResult { people.filter(_.id === id).result.headOption }