Method writeOK

IceFireDB-SQLProxy/pkg/mysql/server/resp.go:9–29

(r *Result)

)

func (c *Conn) writeOK(r *Result) error {
	if r == nil {
		r = &Result{}
	}

	r.Status |= c.status

	data := make([]byte, 4, 32)

	data = append(data, OK_HEADER)

	data = append(data, PutLengthEncodedInt(r.AffectedRows)...)
	data = append(data, PutLengthEncodedInt(r.InsertId)...)

	if c.capability&CLIENT_PROTOCOL_41 > 0 {
		data = append(data, byte(r.Status), byte(r.Status>>8))
		data = append(data, byte(r.Warnings), byte(r.Warnings>>8))
	}

	return c.WritePacket(data)
}

func (c *Conn) WriteError(e error) error {
	return c.writeError(e)