Merge pull request #24 from 40t/fix_mysql_resolve

Fix mysql resolve
2019-06-06 19:05:00 +08:00 · 2019-06-06 19:05:00 +08:00 · bf05608086
parent c9248d507a 02c05cbbb7
commit bf05608086
1 changed files with 6 additions and 4 deletions
--- a/plugSrc/mysql/build/entry.go
+++ b/plugSrc/mysql/build/entry.go
@ -188,6 +188,7 @@ func (stm *stream) resolve() {
 	for {
 		select {
 		case packet := <- stm.packets:
+			if packet.length != 0 {
 				if packet.isClientFlow {
 					stm.resolveClientPacket(packet.payload, packet.seq)
 				} else {
@ -195,6 +196,7 @@ func (stm *stream) resolve() {
 				}
 			}
 		}
+	}
 }

 func (stm *stream) findStmtPacket (srv chan *packet, seq int) *packet {