diff --git a/dtmcli/barrier.go b/dtmcli/barrier.go
index 5cffeba..c502742 100644
--- a/dtmcli/barrier.go
+++ b/dtmcli/barrier.go
@@ -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 {