1

我想运行两个效果 f1 和 f2 更新两个不同的数据库表 t1 和 t2，同时保持在通用 F 上下文中。

    def update(model:Details): Update0 = sql"""Update details_compta
 set TRANSID=${model.transid}, ACCOUNT=${model.account}, SIDE=${model.side}, OACCOUNT=${model.oaccount},
 AMOUNT=${model.amount}, DUEDATE=${model.duedate}, TEXT=${model.text},  CURRENCY=${model.currency}, COMPANY=${model.company}
 where id =${model.id}""".update

}

def update(model: FinancialsTransaction): Update0 = sql"""Update master_compta
set OID=${model.oid}, COSTCENTER=${model.costcenter}, ACCOUNT=${model.account}, TRANSDATE=${model.transdate}
 , HEADERTEXT=${model.text}, FILE_CONTENT=${model.file_content}, TYPE_JOURNAL=${model.typeJournal}
,  PERIOD=${model.period}
 where id =${model.tid} AND POSTED=false""".update

}

我尝试了以下无法编译的方法：

  def update(model: FinancialsTransaction): F[Int] = {
val l1 = model.lines.map(SQL.FinancialsTransactionDetailsRepo.update(_)) :+ SQL.FinancialsTransactionRepo.update(
  model
)
l1.sequence.run.transact(transactor)

我收到以下错误：

doobie/DoobieRepository.scala:892:8: Cannot prove that doobie.util.update.Update0 <:< G[A].[error]     l1.sequence.run.transact(transactor)

PS：我想在单个事务和通用 F 上下文中运行这两种效果。我知道将 Connection[IO[]] 用于 F 时的解决方案。但如果可能的话，需要一个解决方案，同时保留在通用 F 上下文中。谢谢

4

1 回答 1

0

我通过引入辅助函数/方法解决了

  def getX[A](func: A => Update0, query: A): 
  ConnectionIO[Int] =
  for {
      response <- func(query).run
    } yield response 
  def getXX[A](func: List[A] => List[Update0], query: 
      List[A]): 
      List[ConnectionIO[Int]] =
   for {
       response <- func(query).map(_.run)
    } yield response
 }

使用这些功能我可以实现更新

     def update(model: FinancialsTransaction): F[List[Int]] = 
     {
   val result: List[ConnectionIO[Int]] = 
     getXX(SQL.FinancialsTransactionDetails.update, oldLines) 
     ++List(getX(SQL.FinancialsTransaction.update, model))

      result.sequence.transact(transactor)
 }

其中 SQL.FinancialsTransactionDetails.update 和 SQL.FinancialsTransaction.update 也是获取 SQL 更新语句并分别为单个和多个语句生成 Update0 的函数

    def update(model: FinancialsTransactionDetails): Update0 
       = sql"""Update details_compta
      set ACCOUNT=${model.account}, SIDE=${model.side}, 
        OACCOUNT=${model.oaccount},
        AMOUNT=${model.amount}, DUEDATE=${model.duedate}, 
        TEXT=${model.text},  CURRENCY=${model.currency}
      where id =${model.lid} """.update
        }
        override def update(model: FinancialsTransaction): 
         Update0 = sql"""Update master_compta
        set OID=${model.oid}, COSTCENTER=${model.costcenter}, 
             ACCOUNT=${model.account}, 
             TRANSDATE=${model.transdate},
            , HEADERTEXT=${model.text}, 
             FILE_CONTENT=${model.file_content}, 
             TYPE_JOURNAL=${model.typeJournal}
            ,  PERIOD=${model.period}
           where id =${model.tid} AND POSTED=false""".update
          }
于 2020-05-19T16:48:32.973 回答