我正在使用
Scala的Slick和Postgresql.
我用单PK的桌子很好用.
现在我需要使用一个包含多个PK的表：
我用单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.
