在 Slick(Scala) 中使用 sql 批量执行多个 Insert 语句

Question

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

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 的方法，知道如何转换。

Answer 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
)

在 Slick(Scala) 中使用 sql 批量执行多个 Insert 语句

Excecuting multiple Insert statements in a batch using sqlu in Slick(Scala)

scala

slick