Method parseStatus

database/binlog/query_event.go:304–375

(q *QueryEvent)

}

func (p *QueryEventParser) parseStatus(q *QueryEvent) error {
	data := q.statusBytes
	for len(data) > 0 {
		code := data[0]
		data = data[1:]

		var err error

		// XXX(patrick): maybe check for duplicate status.
		switch mysql_proto.QueryStatusCode_Type(code) {
		case mysql_proto.QueryStatusCode_FLAGS2:
			q.flags2 = new(uint32)
			data, err = readLittleEndian(data, q.flags2)

		case mysql_proto.QueryStatusCode_SQL_MODE:
			q.sqlMode = new(uint64)
			data, err = readLittleEndian(data, q.sqlMode)

		case mysql_proto.QueryStatusCode_CATALOG:
			return errors.New("V4 events does not support catalog status")

		case mysql_proto.QueryStatusCode_AUTO_INCREMENT:
			data, err = p.parseAutoIncStatus(data, q)

		case mysql_proto.QueryStatusCode_CHARSET:
			q.charset, data, err = readSlice(data, 6)

		case mysql_proto.QueryStatusCode_TIME_ZONE:
			data, err = p.parseTimeZone(data, q)

		case mysql_proto.QueryStatusCode_CATALOG_NZ:
			data, err = p.parseCatalogNz(data, q)

		case mysql_proto.QueryStatusCode_LC_TIME_NAMES:
			q.lcTimeNamesNumber = new(uint16)
			data, err = readLittleEndian(data, q.lcTimeNamesNumber)

		case mysql_proto.QueryStatusCode_CHARSET_DATABASE:
			q.charsetDatabaseNumber = new(uint16)
			data, err = readLittleEndian(data, q.charsetDatabaseNumber)

		case mysql_proto.QueryStatusCode_TABLE_MAP_FOR_UPDATE:
			q.tableMapForUpdate = new(uint64)
			data, err = readLittleEndian(data, q.tableMapForUpdate)

		case mysql_proto.QueryStatusCode_MASTER_DATA_WRITTEN:
			return errors.New(
				"V4 events does not support master data written status")

		case mysql_proto.QueryStatusCode_INVOKER:
			data, err = p.parseInvoker(data, q)

		case mysql_proto.QueryStatusCode_UPDATED_DB_NAMES:
			data, err = p.parseUpdatedDbNames(data, q)

		case mysql_proto.QueryStatusCode_MICROSECONDS:
			data, err = p.parseMircoseconds(data, q)