Method TestBasic

database/binlog/table_map_event_test.go:18–65

(c *C)

var _ = Suite(&TableMapEventSuite{})

func (s *TableMapEventSuite) TestBasic(c *C) {
	s.WriteEvent(
		mysql_proto.LogEventType_TABLE_MAP_EVENT,
		uint16(0),
		[]byte{
			// table id
			76, 0, 0, 0, 0, 0,
			// flags
			1, 0,
			// db name length
			8,
			// db name
			115, 104, 97, 114, 100, 55, 54, 55, 0,
			// table name length
			30,
			// table name
			99, 97, 109, 101, 114, 97, 95, 117, 112, 108,
			111, 97, 100, 95, 105, 110, 100, 101, 120, 95,
			115, 117, 109, 109, 97, 114, 121, 95, 118, 51, 0,
			// number of columns
			2,
			3, 2,
			// metadata size
			0,
			// null bits
			2})

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

	c.Assert(event, NotNil)
	tm, ok := event.(*TableMapEvent)
	c.Assert(ok, IsTrue)
	c.Check(tm.TableId(), Equals, uint64(76))
	c.Check(tm.TableFlags(), Equals, uint16(1))
	c.Check(string(tm.DatabaseName()), Equals, "shard767")
	c.Check(string(tm.TableName()), Equals, "camera_upload_index_summary_v3")
	c.Check(tm.ColumnTypesBytes(), DeepEquals, []byte{3, 2})
	c.Check(tm.MetadataBytes(), DeepEquals, []byte{})
	c.Check(tm.NullColumnsBytes(), DeepEquals, []byte{2})

	descriptors := tm.ColumnDescriptors()
	c.Assert(len(descriptors), Equals, 2)
	c.Check(descriptors[0].Type(), Equals, mysql_proto.FieldType_LONG)
	c.Check(descriptors[0].IsNullable(), IsFalse)
	c.Check(descriptors[1].Type(), Equals, mysql_proto.FieldType_SHORT)
	c.Check(descriptors[1].IsNullable(), IsTrue)
}

func (s *TableMapEventSuite) TestTableWithMetadata(c *C) {
	s.WriteEvent(