diff --git a/internal/dao/sakila/sqlx.go b/internal/dao/sakila/sqlx.go
index 2c4731d0..5b76e5aa 100644
--- a/internal/dao/sakila/sqlx.go
+++ b/internal/dao/sakila/sqlx.go
@@ -42,7 +42,7 @@ func (s *sqlxServant) withTx(ctx context.Context, opts *sql.TxOptions, handle fu
 		return err
 	}
 	defer tx.Rollback()
-	if err = handle(tx); err == nil {
+	if err = handle(tx); err != nil {
 		return err
 	}
 	return tx.Commit()