Add extra check for protocol-out-of-sync problems

xuegang · Jul 23, 2015 · 89d2f24 · 89d2f24
1 parent dc50b6a
commit 89d2f24
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/conn.go b/conn.go
@@ -1369,6 +1369,10 @@ func (rs *rows) Next(dest []driver.Value) (err error) {
 			return io.EOF
 		case 'D':
 			n := rs.rb.int16()
+			if err != nil {
+				conn.bad = true
+				errorf("unexpected DataRow after error %s", err)
+			}
 			if n < len(dest) {
 				dest = dest[:n]
 			}