Add more test for GTIDEvent and TableMapEvent

Author: huangjunwen

replication/event_test.go

@@ -48,3 +48,54 @@ func (_ *testDecodeSuite) TestMariadbGTIDEvent(c *C) {
 	c.Assert(ev.IsGroupCommit(), Equals, true)
 	c.Assert(ev.CommitID, Equals, uint64(0x1716151413121110))
 }
+
+func (_ *testDecodeSuite) TestGTIDEventMysql8NewFields(c *C) {
+
+	testcases := []struct {
+		data                           []byte
+		expectImmediateCommitTimestamp uint64
+		expectOriginalCommitTimestamp  uint64
+		expectTransactoinLength        uint64
+		expectImmediateServerVersion   uint32
+		expectOriginalServerVersion    uint32
+	}{
+		{
+			// master: mysql-5.7, slave: mysql-8.0
+			data:                           []byte("\x00Z\xa7*\u007fD\xa8\x11\xea\x94\u007f\x02B\xac\x19\x00\x02\x02\x01\x00\x00\x00\x00\x00\x00\x02v\x00\x00\x00\x00\x00\x00\x00w\x00\x00\x00\x00\x00\x00\x00\xc1G\x81\x16x\xa0\x85\x00\x00\x00\x00\x00\x00\x00\xfc\xc5\x03\x938\x01\x80\x00\x00\x00\x00"),
+			expectImmediateCommitTimestamp: 1583812517644225,
+			expectOriginalCommitTimestamp:  0,
+			expectTransactoinLength:        965,
+			expectImmediateServerVersion:   80019,
+			expectOriginalServerVersion:    0,
+		},
+		{
+			// mysql-5.7 only
+			data:                           []byte("\x00Z\xa7*\u007fD\xa8\x11\xea\x94\u007f\x02B\xac\x19\x00\x02\x03\x01\x00\x00\x00\x00\x00\x00\x025\x00\x00\x00\x00\x00\x00\x006\x00\x00\x00\x00\x00\x00\x00"),
+			expectImmediateCommitTimestamp: 0,
+			expectOriginalCommitTimestamp:  0,
+			expectTransactoinLength:        0,
+			expectImmediateServerVersion:   0,
+			expectOriginalServerVersion:    0,
+		},
+		{
+			// mysql-8.0 only
+			data:                           []byte("\x00\\\xcc\x103D\xa8\x11\xea\xbdY\x02B\xac\x19\x00\x03w\x00\x00\x00\x00\x00\x00\x00\x02x\x00\x00\x00\x00\x00\x00\x00y\x00\x00\x00\x00\x00\x00\x00j0\xb1>x\xa0\x05\xfc\xc3\x03\x938\x01\x00"),
+			expectImmediateCommitTimestamp: 1583813191872618,
+			expectOriginalCommitTimestamp:  1583813191872618,
+			expectTransactoinLength:        963,
+			expectImmediateServerVersion:   80019,
+			expectOriginalServerVersion:    80019,
+		},
+	}
+
+	for _, tc := range testcases {
+		ev := new(GTIDEvent)
+		err := ev.Decode(tc.data)
+		c.Assert(err, IsNil)
+		c.Assert(ev.ImmediateCommitTimestamp, Equals, tc.expectImmediateCommitTimestamp)
+		c.Assert(ev.OriginalCommitTimestamp, Equals, tc.expectOriginalCommitTimestamp)
+		c.Assert(ev.ImmediateServerVersion, Equals, tc.expectImmediateServerVersion)
+		c.Assert(ev.OriginalServerVersion, Equals, tc.expectOriginalServerVersion)
+	}
+
+}

replication/row_event.go

@@ -65,7 +65,7 @@ type TableMapEvent struct {
 
 	// ColumnName list all column names.
 	ColumnName       [][]byte
-	columnNameString []string
+	columnNameString []string // the same as ColumnName in string type, just for reuse
 
 	// GeometryType stores real type for geometry columns.
 	GeometryType []uint64

replication/row_event_test.go

@@ -764,6 +764,36 @@ func (_ *testDecodeSuite) TestDecodeDatetime2(c *C) {
 	}
 }
 
+func (_ *testDecodeSuite) TestTableMapNullable(c *C) {
+	/*
+		create table _null (c1 int null, c2 int not null default '2', c3 timestamp default now(), c4 text);
+	*/
+	nullables := []bool{true, false, false, true}
+	testcases := [][]byte{
+		// mysql 5.7
+		[]byte("z\x00\x00\x00\x00\x00\x01\x00\x04test\x00\x05_null\x00\x04\x03\x03\x11\xfc\x02\x00\x02\t"),
+		// mysql 8.0
+		[]byte("z\x00\x00\x00\x00\x00\x01\x00\x04test\x00\x05_null\x00\x04\x03\x03\x11\xfc\x02\x00\x02\t\x01\x01\x00\x02\x01\xe0\x04\f\x02c1\x02c2\x02c3\x02c4"),
+		// mariadb 10.4
+		[]byte("\x1e\x00\x00\x00\x00\x00\x01\x00\x04test\x00\x05_null\x00\x04\x03\x03\x11\xfc\x02\x00\x02\t"),
+		// mariadb 10.5
+		[]byte("\x1d\x00\x00\x00\x00\x00\x01\x00\x04test\x00\x05_null\x00\x04\x03\x03\x11\xfc\x02\x00\x02\t\x01\x01\x00\x02\x01\xe0\x04\f\x02c1\x02c2\x02c3\x02c4"),
+	}
+
+	for _, tc := range testcases {
+		tableMapEvent := new(TableMapEvent)
+		tableMapEvent.tableIDSize = 6
+		err := tableMapEvent.Decode(tc)
+		c.Assert(err, IsNil)
+		c.Assert(int(tableMapEvent.ColumnCount), Equals, len(nullables))
+		for i := 0; i < int(tableMapEvent.ColumnCount); i++ {
+			available, nullable := tableMapEvent.Nullable(i)
+			c.Assert(available, Equals, true)
+			c.Assert(nullable, Equals, nullables[i])
+		}
+	}
+}
+
 func (_ *testDecodeSuite) TestTableMapOptMetaNames(c *C) {
 	/*
 		CREATE TABLE `_types` (
@@ -967,7 +997,6 @@ func (_ *testDecodeSuite) TestTableMapOptMetaPrimaryKey(c *C) {
 	}
 
 	for _, tc := range testcases {
-
 		tableMapEvent := new(TableMapEvent)
 		tableMapEvent.tableIDSize = 6
 		err := tableMapEvent.Decode(tc.data)