From c05a6a2a6dbf6b3894ac7dc4526b0954353b77af Mon Sep 17 00:00:00 2001 From: xaicron Date: Fri, 9 Nov 2018 20:45:42 +0900 Subject: [PATCH] Fix commit error handling. --- tm/transaction_block.go | 12 ++++-------- 1 file changed, 4 insertions(+), 8 deletions(-) diff --git a/tm/transaction_block.go b/tm/transaction_block.go index e757080..9f6e509 100644 --- a/tm/transaction_block.go +++ b/tm/transaction_block.go @@ -81,8 +81,7 @@ func Run(db SQL, f TxnFunc) error { tx.Rollback() return err } - tx.Commit() - return nil + return tx.Commit() } // RunWithContext begins transaction with context.Conntext around TxnFunc. @@ -97,8 +96,7 @@ func RunWithContext(ctx context.Context, opts *sql.TxOptions, db SQL, f TxnFunc) tx.Rollback() return err } - tx.Commit() - return nil + return tx.Commit() } // Runx begins transaction around TxnxFunc. @@ -113,8 +111,7 @@ func Runx(db SQLx, f TxnxFunc) error { tx.Rollback() return err } - tx.Commit() - return nil + return tx.Commit() } // RunxWithContext begins transaction with context.Conntext around TxnxFunc. @@ -129,6 +126,5 @@ func RunxWithContext(ctx context.Context, opts *sql.TxOptions, db SQLx, f TxnxFu tx.Rollback() return err } - tx.Commit() - return nil + return tx.Commit() }