From d06ca1131e3f5aa69c74e451365943e8272cd72f Mon Sep 17 00:00:00 2001
From: hebo <xiaobiao@jd.com>
Date: Fri, 30 Aug 2019 12:50:20 +0800
Subject: [PATCH] return when parse auth info failed

---
 session-dealer/mysql/session.go | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git a/session-dealer/mysql/session.go b/session-dealer/mysql/session.go
index eed1289..16410e8 100644
--- a/session-dealer/mysql/session.go
+++ b/session-dealer/mysql/session.go
@@ -270,11 +270,10 @@ func (ms *MysqlSession) GenerateQueryPiece() (qp model.QueryPiece) {
 	var mqp *model.PooledMysqlQueryPiece
 	var querySQLInBytes []byte
 	if ms.cachedStmtBytes[0] > 32 {
-		var userName, dbName string
-		var err error
-		userName, dbName, err = parseAuthInfo(ms.cachedStmtBytes)
+		userName, dbName, err := parseAuthInfo(ms.cachedStmtBytes)
 		if err != nil {
 			log.Errorf("parse auth info failed <-- %s", err.Error())
+			return
 		}
 		ms.visitUser = &userName
 		ms.visitDB = &dbName