加入收藏 | 设为首页 | 会员中心 | 我要投稿 李大同 (https://www.lidatong.com.cn/)- 科技、建站、经验、云计算、5G、大数据,站长网!
当前位置: 首页 > 百科 > 正文

postgresql – 带有多个PK insertOrUpdate()的Scala的Slick抛出

发布时间:2020-12-13 16:14:40 所属栏目:百科 来源:网络整理
导读:我正在使用 Scala的Slick和PostgreSQL. 我用单PK的桌子很好用. 现在我需要使用一个包含多个PK的表: case class Report(f1: DateTime,f2: String,f3: Double)class Reports(tag: Tag) extends Table[Report](tag,"Reports") { def f1 = column[DateTime]("f1
我正在使用 Scala的Slick和PostgreSQL.
我用单PK的桌子很好用.
现在我需要使用一个包含多个PK的表:
case class Report(f1: DateTime,f2: String,f3: Double)

class Reports(tag: Tag) extends Table[Report](tag,"Reports") {
    def f1 = column[DateTime]("f1")
    def f2 = column[String]("f2")
    def f3 = column[Double]("f3")

    def * = (f1,f2,f3) <> (Report.tupled,Report.unapply)
    def pk = primaryKey("pk_report",(f1,f2))
}

val reports = TableQuery[Reports]

当我有空表并使用reports.insert(报告)时它运作良好.
但是当我使用reports.insertOrUpdate(report)时,我收到并且异常:

Exception in thread "main" org.postgresql.util.PSQLException: ERROR: syntax error at end of input
  Position: 76
    at org.postgresql.core.v3.QueryExecutorImpl.receiveErrorResponse(QueryExecutorImpl.java:2102)
    at org.postgresql.core.v3.QueryExecutorImpl.processResults(QueryExecutorImpl.java:1835)
    at org.postgresql.core.v3.QueryExecutorImpl.execute(QueryExecutorImpl.java:257)
    at org.postgresql.jdbc2.AbstractJdbc2Statement.execute(AbstractJdbc2Statement.java:500)
    at ....

我究竟做错了什么?怎么解决?

提前致谢.

PS.我尝试了解决方法 – 尝试通过以下方式实现“if exist update else insert”逻辑:

val len = reports.withFilter(_.f1 === report.f1).withFilter(_.f2 === report.f2).length.run.toInt
                    if(len == 1) {
                        println("Update: " + report)
                        reports.update(report)
                    } else {
                        println("Insert: " + report)
                        reports.insert(report)
                    }

但是我仍然在更新时遇到异常:

Exception in thread "main" org.postgresql.util.PSQLException: ERROR: duplicate key value violates unique constraint "pk_report"
  Detail: Key ("f1",f2)=(2014-01-31 04:00:00,addon_io.aha.connect) already exists.
关于你的初始问题,在具有复合键的表上的insertOrUpdate在Slick(至少使用PGSql)中被破坏,因此错误不在你身边.请参阅错误报告,例如: https://github.com/slick/slick/issues/966

所以你必须设计一个解决方法,但是“upsert”操作非常容易出现竞争条件,并且很难正确设计,因为PostgreSQL不提供本机功能来执行此操作.参见例如http://www.depesz.com/2012/06/10/why-is-upsert-so-complicated/

无论如何,执行不太容易出现竞争条件的操作的另一种方法是首先更新(如果该行不存在则不会执行任何操作),然后执行“插入选择”查询,该查询仅插入如果该行不存在.这就是Wlick Slick将使用单个PK在PostgreSQL上执行insertOrUpdate操作.但是,“插入选择”无法直接使用Slick完成,您将不得不回退直接SQL.

(编辑:李大同)

【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容!

    推荐文章
      热点阅读