4

例如,我有一些带有一些参数的实体和两个数据库表,代表这些实体:

 entity                 param
╔════╦═════════╗       ╔═══════════╦════════╗
║ id ║ name    ║       ║ entity_id ║ value  ║
╠════╬═════════╣       ╠═══════════╬════════╣
║ 1  ║ "One"   ║       ║ 1         ║ "aaa"  ║
║ 2  ║ "Two"   ║       ║ 1         ║ "bbb"  ║
║ 3  ║ "Three" ║       ║ 1         ║ "ccc"  ║
╚════╩═════════╝       ╚═══════════╩════════╝

还有一个 scala 模型:

case class Entity(id: Long, name: String, params: Seq[String])

我想通过 检索这些数据Doobie,但我不能直接对Entity实例执行此操作,原因params是字符串的序列,而不仅仅是字符串:

val sql = sql"select e.id, e.name, p.value from entity e left join param p on e.id = p.entity_id"

sql.query[Entity].to[Seq]   //Error Cannot find or construct a Read instance for type: Entity

有什么技巧可以提供Get实例Seq吗?

如果没有,Doobie提供检索此类数据的方法是什么:

  1. 编写原语而不是Entitytype:
    sql.query[(Long, String, String)].to[Seq]并将这个 Seq 元组组合到Entity实例中。
    可能不方便,因为表可能有很多列,导致将这个长元组复制粘贴到每个新查询。
  2. 将此原语组合到另一个案例类中:
    case class EntityRow(id: Long, name: String)
    case class ParamRow(value: String)
    sql.query[(EntityRow, ParamRow)].to[Seq]并组合到Entity实例中,如1..
  3. 喜欢2.,但使用HNil:
    val entity = Long :: String :: HNil
    val param = String :: HNil
    sql.query[entity ++ param].to[Seq]并像 in 一样组合到Entity实例1.
    我不知道这种方式有什么优点或缺点,因为shapeless对我来说是新事物。
  4. 使用两个单独的查询检索数据:
    val entities = sql"select id, name from entity".query[EntityRow].to[Seq]
    val params = sql"select value from param".query[ParamRow].to[Seq]
    可能不像通过单个查询那样高效。
  5. 还有什么办法吗?

谢谢。

4

1 回答 1

4

您的案例类Entity期望params与 id 和 name 列作为字符串列表组合在一起,
而 sql 查询select e.id, e.name, p.value from entity e left join param p on e.id = p.entity_id将返回包含 id、name 和 value 的行

joined entity
╔════╦═════════╦════════╗
║ id ║ name    ║ value  ║
╠════╬═════════╬════════╣
║ 1  ║ "One"   ║ "aaa"  ║
║ 1  ║ "One"   ║ "bbb"  ║
║ 1  ║ "One"   ║ "ccc"  ║
║ 2  ║ "Two"   ║        ║
║ 3  ║ "Three" ║        ║
╚════╩═════════╩════════╝

这不完全是你想要的。为此,我们需要像下面这样重写 sql 查询

val entities = sql"select e.id, e.name, GROUP_CONCAT(p.value SEPARATOR ',') as params from entity e left join param p on e.id = p.entity_id group by e.id, e.name".query[Entity]  

现在您可以轻松地将您的 sql 查询输出映射到您的案例类。

于 2019-11-16T11:33:08.637 回答