Skip to content

Commit 7037937

Browse files
dhlinsiddontang
authored andcommitted
fix error handling during querying result rows (go-mysql-org#429)
1 parent cb33eb8 commit 7037937

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

client/resp.go

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -317,6 +317,10 @@ func (c *Conn) readResultRows(result *Result, isBinary bool) (err error) {
317317
break
318318
}
319319

320+
if data[0] == ERR_HEADER {
321+
return c.handleErrorPacket(data)
322+
}
323+
320324
result.RowDatas = append(result.RowDatas, data)
321325
}
322326

0 commit comments

Comments
 (0)