(conn net.Conn)
| 60 | } |
| 61 | |
| 62 | func (s *Server) handleConn(conn net.Conn) { |
| 63 | h, err := mys.NewConn(conn, s.mysqlUser, s.mysqlPassword, NewCursor(s)) |
| 64 | |
| 65 | if err != nil { |
| 66 | log.WithError(err).Error("process connection failed") |
| 67 | return |
| 68 | } |
| 69 | |
| 70 | for { |
| 71 | err = h.HandleCommand() |
| 72 | if err != nil { |
| 73 | return |
| 74 | } |
| 75 | } |
| 76 | } |
| 77 | |
| 78 | // Shutdown ends the server. |
| 79 | func (s *Server) Shutdown() { |