Method TestRealWriteRowsV1

database/binlog/rows_event_test.go:497–587

(c *C)

}

func (s *RowsEventSuite) TestRealWriteRowsV1(c *C) {
	s.WriteEvent(
		mysql_proto.LogEventType_TABLE_MAP_EVENT,
		uint16(0),
		[]byte{
			// table id + flags
			35, 0, 0, 0, 0, 0,
			1, 0,
			// db length + name
			8,
			115, 104, 97, 114, 100, 55, 54, 54, 0,
			// table length + name
			22,
			100, 101, 114, 105, 118, 101, 100, 95, 109, 101, 116,
			97, 100, 97, 116, 97, 95, 115, 116, 111, 114, 101, 0,
			// # columns + column types
			7,
			3, 254, 1, 252, 1, 1, 252,
			// metadata
			4,
			254, 45, 2, 3,
			// null bits
			8})

	s.WriteEvent(
		mysql_proto.LogEventType_WRITE_ROWS_EVENT_V1,
		uint16(0),
		[]byte{
			// table id + row flags
			35, 0, 0, 0, 0, 0,
			1, 0,
			// # columns + used columns bit map
			7, 255,
			// rows data
			136,
			// col 0
			41, 215, 45, 12,
			// col 1
			43,
			56, 97, 115, 99, 87, 73, 95, 66, 106, 57,
			99, 73, 118, 107, 116, 69, 89, 79, 85, 102,
			48, 48, 49, 110, 98, 90, 77, 79, 103, 89,
			54, 84, 107, 87, 101, 79, 88, 109, 80, 75,
			48, 122, 115,
			29, 1, 1,
			// col 6
			0, 0, 0})

	c.Log(s.src.Bytes())

	event, err := s.NextEvent()
	c.Log(err)
	c.Assert(err, IsNil)

	context, ok := event.(*TableMapEvent)
	c.Assert(ok, IsTrue)

	// sanity check