我刚开始使用 slick，现在我面临着如何从两个表中检索一些数据的问题。我有一张桌子
class ExecutionTable(tag: Tag) extends Table[ExecTuple](tag, "execution") {
val id: Rep[String] = column[String]("id")
val executionDefinitionId: Rep[Long] = column[Long]("executionDefinitionId")
// other fields are omitted
def * = ???
}
和另一张桌子
class ServiceStatusTable(tag: Tag)
extends Table[(String, Option[String])](tag, "serviceStatus") {
def serviceId: Rep[String] = column[String]("serviceId")
def detail: Rep[String] = column[String]("detail")
def * = (serviceId, detail.?)
}
在 Dao 中，我将这两个表中的数据转换为一个业务对象
case class ServiceStatus(
id: String,
detail: Option[String] = None, //other fields
)
像这样
private lazy val getServiceStatusCompiled = Compiled {
(id: Rep[String], tenantId: Rep[String]) =>
for {
exec <- getExecutionById(id, tenantId)
status <- serviceStatuses if exec.id === status.serviceId
} yield mapToServiceStatus(exec, status)
}
然后
def getServiceStatus(id: String, tenantId: String)
: Future[Option[ServiceStatus]] = db
.run(getServiceStatusCompiled(id, tenantId).result.transactionally)
.map(_.headOption)
问题是，并非表中的所有条目都execution存在表中的条目serviceStatus。我无法修改表execution并向其添加字段，details因为它只是特定于服务的。当我运行查询时，以防万一从execution存在条目中的条目serviceStatus按预期工作。但如果 中没有条目serviceStatus，则返回 Future[None]。问题：status根据表中的现有条目serviceStatus或其他一些解决方法，是否有任何选项可以作为选项获得理解？
通常，如果连接条件在“右”表中找不到对应的记录，但结果仍应包含“左”表中的行，则使用左连接。在您的情况下，您可以执行以下操作：
Execution
.filter(...execution table filter...)
.joinLeft(ServiceStatus).on(_.id===_.serviceId)
这给你一对
(Execution, Rep[Option[ServiceStatus]])
并在查询执行后：
(Execution, Option[ServiceStatus])
本文收集自互联网，转载请注明来源。
如有侵权，请联系 [email protected] 删除。
我来说两句