使用slick插入不起作用

Question

我是Scala的新手，并且一直在学习slick(3.1.1)。在编写特定代码将数据插入表中时，如果行不存在，则必须插入行，否则将更新该表中的特定列。对于单行更新，我编写了以下代码，它可以很好地工作：

 def updateDate(id: Int, country : Country, lastDate: DateTime)(implicit ec: ExecutionContext) =
        byPKC.applied((id, country, )).map(_.lastMessageDate).update(lastDate) flatMap {
          case 0 ⇒
            create(User.withLastDate(id, country, lastDate))
          case x ⇒ DBIO.successful(x)
        }

现在，我不确定如何在scala中为此执行批量操作。我尝试了以下方法，虽然效率不高，但应该可以工作，但是没有行插入到表中。

 def updateDates(ids: Set[Int], country: Country, lastDate: DateTime)(implicit ec: ExecutionContext) = {
    ids.foreach(e ⇒ updateDate(e, country, lastDate))
    DBIO.successful(1)
  }

如何在scala中进行批量写入？另外，为什么这个批量操作不起作用？任何帮助都将不胜感激。

Answer 1

对两部分问题的两部分回答。

如何在scala中进行批量写入？

您不能在SQL中进行批量更新；它根本不受支持。不过，您可以大容量插入。Slick支持在TableQuery上使用++=操作符进行批量插入。

为什么此批量操作不起作用？

您正在生成DBIO值，但是没有通过db.run()执行它们。DBIO是Scala操作到SQL的映射，但您必须先执行它，然后才能将其发送到数据库。