fix SchemaRename not taking effect

a bug introduced in 6e95ce1.

misc: logs.

Author: ffffwh

drivers/mysql/mysql/binlog/binlog_reader.go

@@ -750,10 +750,12 @@ func (b *BinlogReader) setDtleQuery(query string) string {
 }
 
 func (b *BinlogReader) sendEntry(entriesChannel chan<- *common.BinlogEntryContext) {
-	if b.entryContext.Entry.IsPartOfBigTx() {
+	isBig := b.entryContext.Entry.IsPartOfBigTx()
+	if isBig {
 		b.HasBigTx.Add(1)
 	}
-	b.logger.Debug("sendEntry", "gno", b.entryContext.Entry.Coordinates.GNO, "events", len(b.entryContext.Entry.Events))
+	b.logger.Debug("sendEntry", "gno", b.entryContext.Entry.Coordinates.GNO, "events", len(b.entryContext.Entry.Events),
+		"isBig", isBig)
 	atomic.AddInt64(b.memory, int64(b.entryContext.Entry.Size()))
 	entriesChannel <- b.entryContext
 	atomic.AddUint32(&b.extractedTxCount, 1)

drivers/mysql/mysql/extractor.go

@@ -433,6 +433,7 @@ func (e *Extractor) inspectTables() (err error) {
 		}
 		for _, doDb := range doDbs {
 			schemaCtx := common.NewSchemaContext(doDb.TableSchema)
+			schemaCtx.TableSchemaRename = doDb.TableSchemaRename
 			e.replicateDoDb[doDb.TableSchema] = schemaCtx
 
 			existedTables, err := sql.ShowTables(e.db, doDb.TableSchema, e.mysqlContext.ExpandSyntaxSupport)