Method Prepare

IceFireDB-SQLProxy/pkg/mysql/client/stmt.go:174–224

(query string)

}

func (c *Conn) Prepare(query string) (*Stmt, error) {
	if err := c.writeCommandStr(COM_STMT_PREPARE, query); err != nil {
		return nil, errors.Trace(err)
	}

	data, err := c.ReadPacket()
	if err != nil {
		return nil, errors.Trace(err)
	}

	if data[0] == ERR_HEADER {
		return nil, c.handleErrorPacket(data)
	} else if data[0] != OK_HEADER {
		return nil, ErrMalformPacket
	}

	s := new(Stmt)
	s.conn = c

	pos := 1

	// for statement id
	s.id = binary.LittleEndian.Uint32(data[pos:])
	pos += 4

	// number columns
	s.columns = int(binary.LittleEndian.Uint16(data[pos:]))
	pos += 2

	// number params
	s.params = int(binary.LittleEndian.Uint16(data[pos:]))
	pos += 2

	// warnings
	s.warnings = int(binary.LittleEndian.Uint16(data[pos:]))
	pos += 2

	if s.params > 0 {
		if err := s.conn.readUntilEOF(); err != nil {
			return nil, errors.Trace(err)
		}
	}

	if s.columns > 0 {
		if err := s.conn.readUntilEOF(); err != nil {
			return nil, errors.Trace(err)
		}
	}

	return s, nil
}