|
|
|
@ -95,10 +95,10 @@ func (bb *BranchBarrier) Call(tx *sql.Tx, busiCall BarrierBusiFunc) (rerr error) |
|
|
|
// CallWithDB the same as Call, but with *sql.DB
|
|
|
|
func (bb *BranchBarrier) CallWithDB(db *sql.DB, busiCall BarrierBusiFunc) error { |
|
|
|
tx, err := db.Begin() |
|
|
|
if err != nil { |
|
|
|
return err |
|
|
|
if err == nil { |
|
|
|
err = bb.Call(tx, busiCall) |
|
|
|
} |
|
|
|
return bb.Call(tx, busiCall) |
|
|
|
return err |
|
|
|
} |
|
|
|
|
|
|
|
func (bb *BranchBarrier) QueryPrepared(db *sql.DB) error { |
|
|
|
|