Slick 3.0:从 Option 内部的数据库获取结果的惯用方式(Scala Play Framework)
Slick 3.0: Idiomatic way to GET results from the database inside of Option (Scala Play Framework)
我有一个 API
的代码,它允许我从数据库中检索和对象,return 使用 Slick 3.0
的 JSON
对象:
// Model
case class Thing(id: Option[Int], name: String)
object Thing {
implicit val teamWrites = Json.writes[Thing]
}
class Things(tag: Tag) extends Table[Thing](tag, "thing") {
def id = column[Int]("id", O.PrimaryKey, O.AutoInc)
def name = column[String]("name")
def * = (id.?, name) <> ((Thing.apply _).tupled, Thing.unapply)
}
object Things {
private val db = Database.forConfig("h2mem1")
private object things extends TableQuery[Things](tag ⇒ new Things(tag)) {
def all = things.result
}
private def filterQuery(id: Int): Query[Things, Thing, Seq] =
things.filter(_.id === id)
def findById(id: Int): Future[Thing] = db.run(filterQuery(id).result.head)
}
// Controller
class ThingController extends Controller {
def get(id: Int) = Action.async {
Things.findById(id).map(thing => Ok(Json.obj("result" -> thing)))
}
}
问题是如果我查询一个不在数据库中的对象,我会得到一个异常。我想做的是在 Future
中得到一个 Option
,它是 return 从 Model
编辑的,以便能够写出这样的东西:
// Controller
class ThingController extends Controller {
def get(id: Int) = Action.async {
Things.findById(id).map {
case None => NotFound(Json.obj("error" -> "Not Found")))
case Some(thing) => Ok(Json.obj("result" -> thing)))
}
}
}
有道理吗?
只需对结果调用 headOption
而不是 head
:
def findById(id: Int): Future[Option[Thing]] = db.run(filterQuery(id).result.headOption)
我有一个 API
的代码,它允许我从数据库中检索和对象,return 使用 Slick 3.0
的 JSON
对象:
// Model
case class Thing(id: Option[Int], name: String)
object Thing {
implicit val teamWrites = Json.writes[Thing]
}
class Things(tag: Tag) extends Table[Thing](tag, "thing") {
def id = column[Int]("id", O.PrimaryKey, O.AutoInc)
def name = column[String]("name")
def * = (id.?, name) <> ((Thing.apply _).tupled, Thing.unapply)
}
object Things {
private val db = Database.forConfig("h2mem1")
private object things extends TableQuery[Things](tag ⇒ new Things(tag)) {
def all = things.result
}
private def filterQuery(id: Int): Query[Things, Thing, Seq] =
things.filter(_.id === id)
def findById(id: Int): Future[Thing] = db.run(filterQuery(id).result.head)
}
// Controller
class ThingController extends Controller {
def get(id: Int) = Action.async {
Things.findById(id).map(thing => Ok(Json.obj("result" -> thing)))
}
}
问题是如果我查询一个不在数据库中的对象,我会得到一个异常。我想做的是在 Future
中得到一个 Option
,它是 return 从 Model
编辑的,以便能够写出这样的东西:
// Controller
class ThingController extends Controller {
def get(id: Int) = Action.async {
Things.findById(id).map {
case None => NotFound(Json.obj("error" -> "Not Found")))
case Some(thing) => Ok(Json.obj("result" -> thing)))
}
}
}
有道理吗?
只需对结果调用 headOption
而不是 head
:
def findById(id: Int): Future[Option[Thing]] = db.run(filterQuery(id).result.headOption)