(data []byte, binary bool)
| 273 | } |
| 274 | |
| 275 | func (c *Conn) readResultset(data []byte, binary bool) (*Result, error) { |
| 276 | // column count |
| 277 | count, _, n := LengthEncodedInt(data) |
| 278 | |
| 279 | if n-len(data) != 0 { |
| 280 | return nil, ErrMalformPacket |
| 281 | } |
| 282 | |
| 283 | result := &Result{ |
| 284 | Resultset: NewResultset(int(count)), |
| 285 | } |
| 286 | |
| 287 | if err := c.readResultColumns(result); err != nil { |
| 288 | return nil, errors.Trace(err) |
| 289 | } |
| 290 | |
| 291 | if err := c.readResultRows(result, binary); err != nil { |
| 292 | return nil, errors.Trace(err) |
| 293 | } |
| 294 | |
| 295 | return result, nil |
| 296 | } |
| 297 | |
| 298 | func (c *Conn) readResultsetStreaming(data []byte, binary bool, result *Result, perRowCb SelectPerRowCallback) error { |
| 299 | columnCount, _, n := LengthEncodedInt(data) |
no test coverage detected