Skip to content

Commit 665cf80

Browse files
committed
fix commit and rollback
1 parent c2bddfc commit 665cf80

File tree

2 files changed

+12
-12
lines changed

2 files changed

+12
-12
lines changed

internal/xsql/fake_tx.go

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -27,12 +27,12 @@ func (tx *fakeTx) Commit() (err error) {
2727
defer func() {
2828
onDone(err)
2929
}()
30-
if tx.conn.isClosed() {
31-
return errClosedConn
32-
}
3330
defer func() {
3431
tx.conn.currentTx = nil
3532
}()
33+
if tx.conn.isClosed() {
34+
return errClosedConn
35+
}
3636
return nil
3737
}
3838

@@ -41,12 +41,12 @@ func (tx *fakeTx) Rollback() (err error) {
4141
defer func() {
4242
onDone(err)
4343
}()
44-
if tx.conn.isClosed() {
45-
return errClosedConn
46-
}
4744
defer func() {
4845
tx.conn.currentTx = nil
4946
}()
47+
if tx.conn.isClosed() {
48+
return errClosedConn
49+
}
5050
return nil
5151
}
5252

internal/xsql/tx.go

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -33,12 +33,12 @@ func (tx *tx) Commit() (err error) {
3333
defer func() {
3434
onDone(err)
3535
}()
36-
if tx.conn.isClosed() {
37-
return errClosedConn
38-
}
3936
defer func() {
4037
tx.conn.currentTx = nil
4138
}()
39+
if tx.conn.isClosed() {
40+
return errClosedConn
41+
}
4242
_, err = tx.tx.CommitTx(tx.ctx)
4343
if err != nil {
4444
return tx.conn.checkClosed(xerrors.WithStackTrace(err))
@@ -51,12 +51,12 @@ func (tx *tx) Rollback() (err error) {
5151
defer func() {
5252
onDone(err)
5353
}()
54-
if tx.conn.isClosed() {
55-
return errClosedConn
56-
}
5754
defer func() {
5855
tx.conn.currentTx = nil
5956
}()
57+
if tx.conn.isClosed() {
58+
return errClosedConn
59+
}
6060
if tx.conn.currentTx == nil {
6161
return nil
6262
}

0 commit comments

Comments
 (0)