recycle connect when execute begin statment error (#108)

* recycle connect when execute begin statment error
XiaoMi · Sep 16, 2020 · 8279947 · 8279947
1 parent b065ccb
commit 8279947
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/proxy/server/executor.go b/proxy/server/executor.go
@@ -361,10 +361,14 @@ func (se *SessionExecutor) getTransactionConn(sliceName string) (pc *backend.Poo
 
 		if !se.isAutoCommit() {
 			if err = pc.SetAutoCommit(0); err != nil {
+				pc.Close()
+				pc.Recycle()
 				return
 			}
 		} else {
 			if err = pc.Begin(); err != nil {
+				pc.Close()
+				pc.Recycle()
 				return
 			}
 		}