データベース/ SQL Tx検出コミットまたはロールバック

Question

データベース/ SQLとドライバパッケージとTxを使用すると、トランザクションがコミットまたはロールバックされていないかどうかを検出することはできません。エラーの種類を判断するためにエラーを調べます。私はTxオブジェクトからコミットされているかどうかを判断できるようにしたいと思います。確かに、Txを使用する関数で別の変数を定義して設定することはできますが、かなりの数があり、毎回2回（変数と代入）です。私はまた、必要に応じてロールバックを行う遅延関数を持っており、bool変数を渡す必要があります。

コミットまたはロールバック後にTx変数をnilに設定しても問題はありません.GCはメモリを回復しますか、それともno-noですか、それとも良い方法がありますか？

Answer 1

なぜこれを行う必要がありますか？ Begin()を呼び出す関数は、Commit()またはRollback()も呼び出して、適切なエラーを返す必要があります。例えば

、このコードは、エラーが返されるかどうかに応じてコミットまたはロールバックん：私は、私がコミットまたはロールバックするかどうかを確認するためにerrorをチェックしていますか

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 
} 

注意してください。ただし、上記の例ではパニックを処理しません。

私はすべてのデータベースルーチンでコミット/ロールバックロジックを行うのが好きではありません。そのため、通常はトランザクションハンドラでラップします。この線に沿って何か：これは私が代わりにこれを行うことができます

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 
     } 
    }) 
} 

注意してください。

私の実際の実装では、Commit()またはRollback()への不要な呼び出しを防ぐために、* sql.Txの代わりにインターフェイスを渡します。

はここで実証するための簡単なスニペットですか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