在Slick（Scala）中使用sql批量执行多个插入语句答案

【问题标题】：Excecuting multiple Insert statements in a batch using sqlu in Slick(Scala)在Slick（Scala）中使用sql批量执行多个插入语句
【发布时间】：2020-12-21 23:18:33
【问题描述】：

我目前有以下内容，每条记录一次执行一条。

private var db: Option[DatabaseDef] = ....
typedRecords.foreach(publishToDatabase(_))

def publishToDatabase(record: T): Unit = {
        Await.result(runDatabaseAction(record), getQueryTimeOut(settings))
}

  private def runDatabaseAction(record: T): Future[Int] = {
    db.get.run(
      executeStreamingAction(record, settings)
        .transactionally
        .withStatementParameters(statementInit = _.setQueryTimeout(getQueryTimeOut(settings).toSeconds.toInt)))
  }

override def executeStreamingAction(record: TFFactDataIngestionMessage, settings: GSConnectorSettings):
  DBIOAction[Int, NoStream, Effect with Effect.Transactional] = {

    val sqlUAction =
      sqlu"""
          INSERT INTO ...
        """

    sqlUAction.transactionally
  }

db.get.run 方法不接受动作数组。

正在寻找一种立即发布 typedRecords 的方法，知道如何转换。

【问题讨论】：

标签： scala slick

【解决方案1】：

您必须使用一元运算符链接 DBIO 序列：

db.run(
  operation1
    .flatMap(_ => operation2)
    .flatMap(_ => operation3)
    ...
    .transactionally
)

如果你更喜欢理解：

// you don't have to ditch the results with _, you can do whatever you want
db.run(
  (
    for {
      _ <- operation1
      _ <- operation2
      ...
    } yield ()
  ).transactionally
)

或者如果你想把List[DBIO[A]] 变成DBIO[List[A]]

db.run(
  DBIO.sequence(operations).transactionally
)

【讨论】：

它们都在一个事务中执行吗？使用 db.run(DBIO.sequence(operations)) 获得 Future[Seq[Int]] 的返回类型，这似乎是，但想确认。
DBIO 的内容（您的查询的抽象描述）如果您通过.transactionally 方法告诉它以事务方式运行。如果您不调用它，则不能假设它将是一笔交易。在您的示例 (db.run(DBIO.sequence(operations))) 中，您没有使用它，所以我不会假设它。