scala – Slick 3 – upsert工作太慢了

发布时间：2020-12-16 10:00:17 所属栏目：安全来源：网络整理

导读：我使用流动代码来插入列表项 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(tb

我使用流动代码来插入列表项

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的项目列表,upsert需要~10秒.它太长了…

我认为,大部分时间都需要编译查询.

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

解决方法

使用编译的查询( docs). AFAIK,插入的编译查询在光滑2.0之后可用.

此外,要插入列表,您应该执行批处理操作,而不是逐个插入记录.

所以,在Slick-3.0中,对于插入,你应该这样做：

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

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

编辑：我不认为,光滑支持批量insertOrUpdate语句.如果底层数据库支持批量insertOrUpdate,则最快的方法是编写纯SQL.否则编译的insertOrUpdate查询应该快得多.

代码应该是这样的

items.map(tblCompiled.insertOrUpdate)

（编辑：李大同）

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