Fix begin in an exist transaction error

This commit is contained in:
wangzc 2023-07-08 23:38:06 +08:00
parent 2066138684
commit fc61ff333b

View File

@ -672,6 +672,8 @@ func (db *DB) Begin(opts ...*sql.TxOptions) *DB {
tx.Statement.ConnPool, err = beginner.BeginTx(tx.Statement.Context, opt) tx.Statement.ConnPool, err = beginner.BeginTx(tx.Statement.Context, opt)
case ConnPoolBeginner: case ConnPoolBeginner:
tx.Statement.ConnPool, err = beginner.BeginTx(tx.Statement.Context, opt) tx.Statement.ConnPool, err = beginner.BeginTx(tx.Statement.Context, opt)
case TxCommitter:
// ignore begin function to continue exist transaction
default: default:
err = ErrInvalidTransaction err = ErrInvalidTransaction
} }