Method parseRow

database/binlog/rows_event.go:334–370

(
	usedColumns []ColumnDescriptor,
	data []byte)

}

func (p *baseRowsEventParser) parseRow(
	usedColumns []ColumnDescriptor,
	data []byte) (
	row RowValues,
	remaining []byte,
	err error) {

	numCols := len(usedColumns)
	nullBits, remaining, err := readBitArray(data, numCols)
	if err != nil {
		return nil, nil, err
	}

	values := make(RowValues, numCols, numCols)
	for idx, descriptor := range usedColumns {
		if nullBits[idx] {
			if !descriptor.IsNullable() {
				return nil, nil, errors.Newf(
					"Null value in non-nullable column: %d table: %s",
					descriptor.IndexPosition(),
					string(p.context.TableName()))
			}
			values[idx] = nil
			continue
		}

		var val interface{}
		val, remaining, err = descriptor.ParseValue(remaining)
		if err != nil {
			return nil, nil, err
		}

		values[idx] = val
	}

	return values, remaining, nil
}

//
// WriteRowsEventParser -------------------------------------------------------