如何在 Scala Slick 中运行补丁/部分数据库更新？

Question

我们想使用 Slick (3.0.0) 运行补丁/部分 UPDATE，以便我们只修改记录中的一些字段。究竟哪些字段将被准确更新只有在运行时才能知道。

例如，对于REST PATCH request。

目前我们首先运行SELECT 以获取原始记录，然后运行UPDATE，但最好在单个SQL 语句中执行此操作。

类似这样的：

def patchPerson(name: Option[String], age: Option[Int]) = {
   people.filter(_.name === "M Odersky")
       .map(p => 
           (name, age) match {
              case (Some(_), Some(_)) => (p.name, p.age)
              case (Some(_), None)    => (p.name)
              case (None   , Some(_)) => (p.age)
           }
       )
       .update(
           (name, age) match {
              case (Some(_), Some(_)) => (name.get, age.get)
              case (Some(_), None)    => (name.get)
              case (None   , Some(_)) => (age.get)
           }
       )
}

（请忽略这里丑陋的代码）

上面没有编译并出现以下错误消息：

找不到匹配的形状。 Slick 不知道如何映射给定的 类型。可能的原因： Table[T] 中的 T 与您的 * 不匹配 投影。或者您在查询中使用不受支持的类型（例如 scala 列表）。所需级别：slick.lifted.FlatShapeLevel 源类型： 对象解包类型：T 打包类型：G

还有：

方法映射的参数不足：（隐式形状： slick.lifted.Shape[_ <: slick.lifted.flatshapelevel t g>

我认为这是因为 Slick 期望元组长度和类型与 filter 和 update 函数的结果相匹配。

我们已经尝试使用 Slick heterogeneous list 类，但这似乎也期望长度和类型匹配。

有没有办法在 Slick 中编写此代码，以便我们可以通过一次数据库调用更新记录中的任意数量的字段？

Answer 1

为什么不在构造更新查询之前进行模式匹配？

def patchPerson(name: Option[String], age: Option[Int]) = {
   val query = people.filter(_.name === "M Odersky")
   (name, age) match {
     case (Some(name), Some(age)) =>
       query.map(p => (p.name, p.age)).update(name, age)
     case (Some(name), None) =>
       query.map(p => p.name).update(name)
     case (None, Some(age)) =>
       query.map(p => p.age).update(age)
   }
}

Answer 2

我最好的猜测是运行plain SQL query

即使 SQL 查询有 2 个部分，关系数据库管理系统（postgresql、mysql 等）也能够在后台调整查询。

我不确定在这种情况下 Slick 是否能够优化，但在某些情况下它本身也可以optimizes the queries。

典型更新：

def updateRecord(id: Long, field1: Int) = {
    db.withSession {
      self.filter(_.id === id).map(_.field1).update(field1)
    }
}

进行您的更新类型需要像您一样的更多逻辑。如果您只在运行时知道要更改哪些字段，请不要认为可以简化。但是您可以强制更新，使用记录中字段的现有值作为后备（可能导致数据库上的更新超出其应有的数量）

def updateRecord(id: Long, field1: Option[Int], field2: Option[Int]) = {
    db.withSession {
        self.filter(_.id === id).map(_.field1, _.field2).update(field1.getOrElse(existingValue1), field2.getOrElse(existingValue2)) 
    }
}

Answer 3

你已经得到了@pedrorijo91 和@thirstycow 所写的答案，但我会尝试解释为什么这不起作用。

我没有使用过 slick 3，但我猜测它是因为 map 函数没有返回一致的类型来运行更新。作为一个思想实验，如果您在 map 上打断电话，您认为该类型会是什么？

val partialQuery:??? = people.filter(_.name === "M Odersky")
       .map(p => 
           (name, age) match {
              case (Some(_), Some(_)) => (p.name, p.age)
              case (Some(_), None)    => (p.name)
              case (None   , Some(_)) => (p.age)
           }
       );

val fullQuery:??? = partialQuery.update {
       (name, age) match {
          case (Some(_), Some(_)) => (name.get, age.get)
          case (Some(_), None)    => (name.get)
          case (None   , Some(_)) => (age.get)
       }    
}

匹配器在编译时返回不同的“形状”，我​​猜这将恢复为任何类型。