Check that txn is closed
This commit is contained in:
parent
77f0fc9713
commit
a675790fef
1 changed files with 1 additions and 1 deletions
|
@ -393,7 +393,7 @@ func (e *executor) operate(ctx context.Context, stm sql.Statement) (res []interf
|
|||
// current statement, then commit or cancel
|
||||
// depending on the result error.
|
||||
|
||||
if loc {
|
||||
if loc && e.tx.Closed() == false {
|
||||
|
||||
// If there was an error with the query
|
||||
// then clear the queued changes and
|
||||
|
|
Loading…
Reference in a new issue