带有理解的Scala事务块

Posted

技术标签:

【中文标题】带有理解的Scala事务块【英文标题】:Scala transactional block with for comprehension 【发布时间】:2012-06-05 22:18:45 【问题描述】:

被我创建的 DAO 层卡住了;在单一情况下工作得很好,但是当需要在事务块中保留几个 bean 实例时,我发现我已经把自己编码到了一个角落。为什么?查看下面的 DAO 创建方法:

def create(e: Entity): Option[Int] =
  db.handle withSession  implicit ss: Session=>
    catching( mapper.insert(e) ) option match 
      case Some(success) => Some(Query(sequenceID))
      case None => None
    
  

在会话块中发生的查询设置为自动提交,因此我无法将多个持久性操作包装在事务块中。例如,这是一个处理新成员订阅的简化理解

val result = for
  u <- user.dao.create(ubean)
  m <- member.dao.create(mbean)
  o <- order.dao.create(obean)
 yield (u,m,o)
result match 
  case Some((a,b,c)) => // all good
  case _ => // failed, need to rollback here

我可以手动执行查询,但速度很快就很难看

db.handle withSession  implicit ss: Session=>
  ss.withTransaction 
    val result = for
      u <- safe( UserMapper.insert(ubean) )
      ...
    
    def safe(q: Query[_]) = 
      catching( q ) option match 
        case Some(success) => Some(Query(sequenceID))
        case None => None
      
  

因为我最终会重复错误处理,因此必须在整个应用程序中提供数据库、会话等,而不是封装在 DAO 层中

这里有人对如何解决这个问题有一些明智的建议吗?我真的很喜欢 for comprehension 的简洁性,Scala 摇滚 ;-),想法赞赏!

【问题讨论】:

【参考方案1】:

好的,除非有人有更好的主意,否则我将采用以下方法:

由于 DAO 到实体是一对一的关系,并且 ScalaQuery 自动提交在会话块中执行的查询,因此通过我的 DAO 实现不可能在单独的实体上执行多个插入。

解决方法是创建一个不绑定到特定实体的 GenericDAO,它提供事务查询功能,并将错误处理提取到父 trait 中

    def createMember(...): Boolean = 
      db.handle withSession  implicit ss: Session=>
        ss.withTransaction 
          val result = for
            u <- safeInsert( UserMapper.insert(ubean) )(ss)
            ...
          
          ...

在控制器层,实现变为dao.createMember(...),这非常好,imo,事务性插入使用安全的理解,很酷的东西。

【讨论】:

以上是关于带有理解的Scala事务块的主要内容,如果未能解决你的问题,请参考以下文章

spring事务解析

Spring的事务管理

“事务”的个人理解,特性

redis事务

什么叫mysql事务?

使用 Spark Scala 运行最后一小时事务的总和