Method readResultsetStreaming

IceFireDB-SQLite/pkg/mysql/client/resp.go:298–321

(data []byte, binary bool, result *Result, perRowCb SelectPerRowCallback)

}

func (c *Conn) readResultsetStreaming(data []byte, binary bool, result *Result, perRowCb SelectPerRowCallback) error {
	columnCount, _, n := LengthEncodedInt(data)

	if n-len(data) != 0 {
		return ErrMalformPacket
	}

	if result.Resultset == nil {
		result.Resultset = NewResultset(int(columnCount))
	} else {
		// Reuse memory if can
		result.Reset(int(columnCount))
	}

	if err := c.readResultColumns(result); err != nil {
		return errors.Trace(err)
	}

	if err := c.readResultRowsStreaming(result, binary, perRowCb); err != nil {
		return errors.Trace(err)
	}

	return nil
}

func (c *Conn) readResultColumns(result *Result) (err error) {
	var i int = 0