Method pushConn

IceFireDB-SQLProxy/internal/mysql/proxy.go:171–192

(mysqlConn *client.Conn, err error, pool *client.Pool)

}

func (m *mysqlProxy) pushConn(mysqlConn *client.Conn, err error, pool *client.Pool) {
	if errors.Is(err, mysql.ErrBadConn) {
		mysqlConn.Close()
		return
	}
	if mysqlConn.IsInTransaction() {
		return
	}
	if err != nil {
		if err := mysqlConn.Rollback(); err != nil {
			mysqlConn.Close()
			return
		}
	}
	if mysqlConn.IOErr() != nil {
		mysqlConn.Close()
		return
	}
	if mysqlConn.Conn != nil {
		pool.PutConn(mysqlConn)
	}
}