database/sql Tx - Tespit veya Geri Alma Algılama

Question

Veritabanı/sql ve sürücü paketlerini ve Tx'i kullanarak, bir işlemin başka bir işlem yapmadan mı, yoksa geri alınıp alınmayacağını ve bir hata olarak algılandığını algılamayabilir. Sonuç ve daha sonra hatanın türünü belirlemek için hatayı incelemek. Tx nesnesinden kararlı olup olmadığına karar vermek istiyorum. Elbette, Tx kullanan fonksiyonda bir başka değişken tanımlayabilir ve ayarlayabilirim, fakat bende bunların bir numarası var ve her seferinde 2 kere (değişken ve atama). Ayrıca gerekirse Geri Alma işlemini yapmak için ertelenmiş bir işlevim var ve boole değişkenini geçirmesi gerekiyor.

Tx değişkeninin bir Kombinasyon veya Geri Alma işleminden sonra sıfırlanması ve GC'nin herhangi bir belleği kurtarması mı, yoksa hayır yok mu yoksa daha iyi bir alternatif mi olduğu kabul edilebilir mi?

Answer 1

Bunu neden yapmak zorunda kaldınız? Begin() numaralı çağrı, Commit() veya Rollback() numaralı telefonu çağırmalı ve uygun bir hata döndürmelidir. Ben kaydetme veya geri gerekip gerekmediğini görmek için error kontrol ediyorum nasıl

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 
} 

Bildirimi:

Örneğin, bu kod, bir kaydetme veya geri bir hata döndürdü olup olmamasına bağlı olarak yapar. Yukarıdaki örnek, ancak panik işlemez.

Her veritabanı rutininde commit/rollback mantığı yapmayı sevmiyorum, bu yüzden bunları genellikle bir işlem işleyicisine sardım. Bunun şey satırları: Bu bana yerine bunu sağlar

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 
} 

: my işlem içinde birşey panikler eğer otomatik işlem işleyici tarafından işlenir oldu o

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

dikkat edin.

Gerçek uygulamamda, istenmeyen aramaları Commit() veya Rollback() önlemek için * sql.Tx yerine bir arabirim iletiyorum.

İşte göstermek için basit bir parçacık İşte nasıl defer eserleri (baskılar 4 değil, 5):

package main 

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

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

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