Method TestDeleteRowsV2

database/binlog/rows_event_test.go:438–495

(c *C)

}

func (s *RowsEventSuite) TestDeleteRowsV2(c *C) {
	s.WriteEvent(
		mysql_proto.LogEventType_DELETE_ROWS_EVENT,
		uint16(0),
		[]byte{
			// table id
			testRowsTableId, 0, 0, 0, 0, 0,
			// table flags,
			14, 0,
			// extra metadata (total) length + 2
			7, 0,
			0, // RW_V_EXTRAINFO_TAG
			3, // info blob length
			'f', 'o', 'o',
			// # known columns
			5,
			// used column bits
			(1 + 2 + 8 + 16), // skipping the int24 column

			// ROW DATA:

			// Row 1: tiny = 1; short = 2; long = 4; longlong = 8
			0,    // null column bits
			1,    // tiny
			2, 0, // short
			4, 0, 0, 0, // long
			8, 0, 0, 0, 0, 0, 0, 0, // longlong
		})

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

	w, ok := event.(*DeleteRowsEvent)
	c.Assert(ok, IsTrue)

	c.Assert(w.Version(), Equals, mysql_proto.RowsEventVersion_V2)
	c.Check(w.TableId(), Equals, uint64(testRowsTableId))
	c.Check(w.RowsFlags(), Equals, uint16(14))
	c.Check(w.NumColumns(), Equals, 5)
	c.Check(w.ExtraRowInfoBytes(), DeepEquals, []byte("foo"))

	descriptors := s.context.ColumnDescriptors()
	expectedUsed := []ColumnDescriptor{
		descriptors[0],
		descriptors[1],
		descriptors[3],
		descriptors[4],
	}

	c.Check(w.UsedColumns(), DeepEquals, expectedUsed)

	rows := w.DeletedRows()
	c.Assert(len(rows), Equals, 1)

	expectedRow1 := RowValues{uint64(1), uint64(2), uint64(4), uint64(8)}
	c.Check(rows[0], DeepEquals, expectedRow1)
}