Slick 3 - upsert 工作太慢

【问题标题】：Slick 3 - upsert works too slowSlick 3 - upsert 工作太慢
【发布时间】：2015-09-23 09:15:54
【问题描述】：

我对@987654321@ 使用流动代码列表items

case class Item(id: String, text: String)

class Items(tag: Tag) extends Table[Item](tag, "items"){
    ...
}

val tbl = TableQuery[Items]

def insertItems(items: List[Item]):Future[Int] = {
    val q = DBIO.sequence(items.map(tbl.insertOrUpdate).toSeq).map(_.sum)
    db.run(q)
}

对于长度为 2000 的 items 列表，upsert 需要大约 10 秒。太长了……

我认为，大部分时间都需要编译查询。

我应该如何重写insertItems来加速呢？

【问题讨论】：

标签： scala slick

【解决方案1】：

使用compiled queries(docs)。 AFAIK，在 slick 2.0 之后可以使用已编译的插入查询。

另外，要插入一个列表，你应该做一个批处理操作，而不是一个一个地插入一条记录。

因此，在 Slick-3.0 中，对于插入，您应该这样做：

val tblCompiled = Compiled(TableQuery[Items])
tblCompiled ++= items

然后运行另一个查询以获取所需列的总和。

编辑：我不认为，slick 支持批量 insertOrUpdate 语句。如果底层数据库支持批量插入或更新，最快的方法是编写纯 SQL。否则编译的insertOrUpdate 查询应该很快。

代码应该类似于

items.map(tblCompiled.insertOrUpdate)

【讨论】：