数据库/ sql发送 - 检测提交或回滚

Question

使用数据库/ sql和驱动程序包和Tx，它不可能检测事务是否已提交或回滚而不尝试另一个事件并接收到错误结果，然后检查错误以确定错误的类型。我希望能够从Tx对象中确定是否已提交。当然，我可以在使用Tx的函数中定义和设置另一个变量，但我有相当多的变量，并且每次都是2次（变量和赋值）。如果需要，我还有一个延迟函数来执行回滚，并且它需要通过bool变量。

在提交或回滚之后将Tx变量设置为零并且GC是否能够恢复任何内存，或者是否否，还是有更好的选择吗？

Answer 1

为什么你甚至需要这样做？调用Begin()的函数也应该调用Commit()或Rollback()并返回适当的错误。

例如，这个代码提交或回滚取决于是否会返回一个错误：

func (s Service) DoSomething() (err error) { 
    tx, err := s.db.Begin() 
    if err != nil { 
     return 
    } 
    defer func() { 
     if err != nil { 
      tx.Rollback() 
      return 
     } 
     err = tx.Commit() 
    }() 
    if _, err = tx.Exec(...); err != nil { 
     return 
    } 
    if _, err = tx.Exec(...); err != nil { 
     return 
    } 
    // ... 
    return 
} 

通知我如何检查error，看我是否应该提交或回滚。然而，上面的例子并没有处理恐慌。

我不喜欢在每个数据库例程上执行提交/回滚逻辑，所以我通常将它们包装在一个事务处理程序中。沿此线的东西：

func Transact(db *sql.DB, txFunc func(*sql.Tx) error) (err error) { 
    tx, err := db.Begin() 
    if err != nil { 
     return 
    } 
    defer func() { 
     if p := recover(); p != nil { 
      tx.Rollback() 
      panic(p) // re-throw panic after Rollback 
     } else if err != nil { 
      tx.Rollback() 
     } else { 
      err = tx.Commit() 
     } 
    }() 
    err = txFunc(tx) 
    return err 
} 

这让我做这件事，而不是：

func (s Service) DoSomething() error { 
    return Transact(s.db, func (tx *sql.Tx) error { 
     if _, err := tx.Exec(...); err != nil { 
      return err 
     } 
     if _, err := tx.Exec(...); err != nil { 
      return err 
     } 
    }) 
} 

注意，如果我的事务中的任何恐慌它的自动交易处理程序处理。

在我的实际实施中，我通过一个接口而不是* sql.Tx来防止对Commit()或Rollback()的不必要的调用。

这里有一个简单的代码片段演示了如何defer作品（打印纸4，而不是5）：

package main 

func test() (i int) { 
    defer func() { 
     i = 4 
    }() 
    return 5 
} 

func main() { 
    println(test()) 
} 

http://play.golang.org/p/0OinYDWFlx