为 slick 构建通用 DAO

Question

我厌倦了总是执行以下类似的操作，以便为我的每个域实体使用 slick 进行数据库访问。

database withSession {
  implicit session =>
    val entities = TableQuery[EntityTable]
    val id = //Some ID
    val q = for {
      e <- entities if e.id === id
    } yield (e)
    val entity = q.first
}

（注意：EntityTable 的定义如 here 所述）

所以我决定我需要一个通用的数据库访问对象来为我处理这个问题。用法应该类似于

[...]
val entityDAO = new GenericDAO[Entity, EntityTable, String]()
[...]

database withSession {   implicit session =>
    val id = // Some ID
    val entity = entityDAO.get(id)
}

我对实现 GenericDAO 的尝试如下所示

class GenericDAO[T, TB, PK](implicit session: Session) {
  val entities = TableQuery[TB] // Line 1

  def get(id: PK): T = {
    val q = for {
      e <- entities
    } yield (e)
    val res: T = q.first
    res
  }
}

但是第 1 行给我留下了一个编译器错误，指出 TB 参数有问题。

此行有多个标记 - 类型参数 [TB] 不符合任何重载替代值的界限：[E <: scala.slick.lifted.abstracttable>]]=> scala.slick.lifted.TableQuery[E,E#TableElementType] [E <: scala.slick.lifted.abstracttable>]]（缺点：scala.slick.lifted.Tag => E)scala.slick.lifted.TableQuery[E,E#TableElementType] - 重载方法值的类型参数数量错误适用于替代方案：[E <: scala.slick.lifted.abstracttable>]]=> scala.slick.lifted.TableQuery[E,E#TableElementType] [E <:> scala.slick.lifted.AbstractTable[]]（缺点：scala.slick.lifted.Tag => E)scala.slick.lifted.TableQuery[E,E#TableElementType]

对这个问题有什么建议吗？或者也许我错了，它应该以另一种方式实现。我愿意接受任何解决方案。谢谢！

Answer 1

首先，你可以写

val entities = TableQuery[EntityTable] // put in a central place for re-use

然后

database.withSession(
    (for {
      e <- entities if e.id === /*Some ID*/
    } yield e).first()(_)
)

或者这个

database.withSession(entities.filter(_.id === /*Some ID*/).first()(_))

或者这个

val get = entities.findBy(_.id) // <- reuse this
database.withSession(get(/*Some ID*/).first()(_))

为简洁起见。这可能会让你的整个 DAO 变得不必要（这很棒:)！）。

关于您收到的错误消息。 TableQuery[TB]是一个宏，是TableQuery(tag => new TB(tag))的简写，TB必须是Table，并且支持对象创建。您不能只在从 DAO 包装器获得的无约束类型参数上使用 TableQuery 宏。您可以约束TB <: Table[_]，但它仍然不支持对象创建，您无法在Scala 中进行约束。您只能为您的 DAO 提供一个工厂（一种常见的模式是获取一个作为隐式参数），但是当您只需编写一次 TableQuery 并将其存储在全局可访问的位置时，这一切都没有意义。

更新：

快捷方式适用于所有这些方法的方式相同。这是普通的 Scala。您只需将方法转换为函数并将其传递给高阶函数 withSession，这需要从会话到任何事物的函数。请注意，有些 Slick 方法有一个空参数列表，需要()(_) 才能将它们转换为函数，而有些只有隐式参数列表，只需要(_)。例如。 database.withSession(entities.filter(_.id === /*Some ID*/).delete(_)).

如果您想知道_。 Scala 将方法与函数区分开来。 def foo(a: A, b: B, ...): R 是一种方法，但可以使用foo _ 转换为(A,B,C) => R 类型的函数。这种转换称为 eta 扩展和谷歌搜索，因为它会出现更多信息。有时，当需要一个函数但您提供了一个方法时，Scala 编译器会推断出_，而您不必显式编写它。您还可以提供一些参数并使用_ 代替您还不想应用的参数。在这种情况下，您部分应用该方法并返回一个函数。这就是我们在这里所做的。我们在方法通常期望会话的地方使用_，并返回一个需要会话的函数。当您必须使用_ 或(_) 或()(_) 时，与方法签名以及隐式参数列表、空方法、具有空参数列表的方法之间的细节相互作用有关，这是值得研究的一般Scala知识一点。

Answer 2

这对我帮助很大。一个完整的通用 dao https://gist.github.com/lshoo/9785645