release all locks on session end (#1569)

dolthub · Jan 31, 2023 · 642c208 · 642c208
1 parent a7e02ba
commit 642c208
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/server/handler.go b/server/handler.go
@@ -149,11 +149,17 @@ func (h *Handler) ConnectionClosed(c *mysql.Conn) {
 		h.sm.CloseConn(c)
 		return
 	}
+
+	_, err = h.e.LS.ReleaseAll(ctx)
+	if err != nil {
+		logrus.Errorf("unable to release all locks on session close: %s", err)
+	}
+
 	h.sm.CloseConn(c)
 
 	// If connection was closed, kill its associated queries.
 	ctx.ProcessList.Kill(c.ConnectionID)
-	if err := h.e.Analyzer.Catalog.UnlockTables(ctx, c.ConnectionID); err != nil {
+	if err = h.e.Analyzer.Catalog.UnlockTables(ctx, c.ConnectionID); err != nil {
 		logrus.Errorf("unable to unlock tables on session close: %s", err)
 	}