Slick 3：insertOrUpdate 不工作

Question

我在 Postgre 中使用 slicksql 9.6.1，Plya！ 2.5 和 play-slick 2.0.2.

（我也使用 slick-pg 0.14.3，但我认为它在这里没有任何改变。）

我正在以非常直接的方式使用 insertOrUpdate，但我仍然遇到一个独特的异常。

我使用 insertOrUpdate 进行了一个非常简单的测试：如果我运行它几次我总是得到一个 sql 异常：

ERROR: duplicate key value violates unique constraint "ga_client_id_pkey"
  Detail: Key (client_id)=(1885746393.1464005051) already exists

然而，我的 table 是以 client_id 为主键定义的：

def clientId = column[String]("client_id", O.PrimaryKey)

并在sql中定义如下：

client_id    TEXT NOT NULL UNIQUE PRIMARY KEY

测试的函数只是：

db.run(gaClientIds.insertOrUpdate(gaClientId))

并且控制器只是调用这个方法而不做任何其他事情。

奇怪的是，多次启动方法本身不会导致错误，但控制器会导致错误，尽管它只调用方法。

insertOrUpdate slick 函数还不确定还是我遗漏了什么？

Answer 1

insertOrUpdate 仅在 MySQL 驱动程序中受支持

http://slick.lightbend.com/doc/3.2.1/supported-databases.html

您可以试试这个库，它可以实现 insertOrUpdate/upsert

https://github.com/tminglei/slick-pg

这就是我们在当前项目中使用它的方式。

import com.github.tminglei.slickpg._
import com.typesafe.config.ConfigFactory
import slick.basic.Capability

object DBComponent {

  private val config = ConfigFactory.load()

  val driver = config.getString("rdbms.properties.driver") match {
    case "org.h2.Driver" => slick.jdbc.H2Profile
    case _               => MyPostgresProfile
  }

  import driver.api._

  val db: Database = Database.forConfig("rdbms.properties")

}

trait MyPostgresProfile extends ExPostgresProfile {

  // Add back `capabilities.insertOrUpdate` to enable native `upsert` support; for postgres 9.5+
  override protected def computeCapabilities: Set[Capability] =
    super.computeCapabilities + slick.jdbc.JdbcCapabilities.insertOrUpdate

  override val api: MyAPI.type = MyAPI

  object MyAPI extends API
}

object MyPostgresProfile extends MyPostgresProfile

Slick 3：insertOrUpdate 不工作

Slick 3: insertOrUpdate not working

postgresql

slick

upsert