如何解决在 Slick(Scala) 中使用 sqlu 批量执行多个插入语句
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 的方法,不知道如何转换。
解决方法
您必须使用一元运算符链接 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
)
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。