Doobie for Scala / Play框架中的事务

Question

我有一个关于doobie交易的问题。我看过这里的文档，它看起来一次只能处理一个查询？

有没有可能有这样的东西？

sql'''
begin;
select * from table where id=1 for update;
update table set id=2 where tabletest=2;
commit'''

任何想法或更多的例子/文件，任何人可以指出我将非常感谢！谢谢你！！

Answer 1

当您应用Transactor时，您正在事务中运行事务

query.transact(transactor)

但这并不意味着您必须在一行中运行整个事务：

val operations = for {
  myClass <- sql"""SELECT a, b, c, FROM table_x WHERE ...""".query[MyClass].to[List]
  updatedRows <- sql"""UPDATE table_x SET ... WHERE""".update.run
} yield someResult

operations.transact(transctor)

基本上，您可以将每个查询/更新转换为ConnectionIO，它是一个monad -您可以使用Cat中的所有一元/应用/函数式操作- flatMap、map、mapN、tupled等-将这些ConnectionIO组合成更大的ConnectionIO，并在完成后运行它们(您已经构建了查询，但到目前为止还没有执行它们！)将.transact(transactor)转换为在事务中计算的实际结果。BEGIN-COMMIT-or-ROLLBACK是由那个.transact(transactor)处理的，这就是为什么你不自己编写它的原因。

请参阅带有此FAQ的Doobie documentation (如何在同一事务中执行多项操作？)尤其是。