diff --git a/client/resp.go b/client/resp.go
index 16b25935d..f6a445201 100644
--- a/client/resp.go
+++ b/client/resp.go
@@ -317,6 +317,10 @@ func (c *Conn) readResultRows(result *Result, isBinary bool) (err error) {
 			break
 		}
 
+		if data[0] == ERR_HEADER {
+			return c.handleErrorPacket(data)
+		}
+
 		result.RowDatas = append(result.RowDatas, data)
 	}