From 79b68fe4331d4cce6d26b3feb53635b33624ecff Mon Sep 17 00:00:00 2001 From: starainrt Date: Fri, 30 Jun 2023 12:44:34 +0800 Subject: [PATCH] bug fix --- parse.go | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/parse.go b/parse.go index 0de8e49..52a1cd2 100644 --- a/parse.go +++ b/parse.go @@ -238,7 +238,7 @@ func ParseBinlogEvent(ev *replication.BinlogEvent) []BinlogEvent { case replication.WRITE_ROWS_EVENTv1, replication.WRITE_ROWS_EVENTv2: wrEvent := ev.Event.(*replication.RowsEvent) - sig.TB = string(wrEvent.Table.Schema) + sig.DB = string(wrEvent.Table.Schema) sig.TB = string(wrEvent.Table.Table) sig.Type = "insert" sig.RowCnt = uint32(len(wrEvent.Rows)) @@ -247,7 +247,7 @@ func ParseBinlogEvent(ev *replication.BinlogEvent) []BinlogEvent { replication.UPDATE_ROWS_EVENTv2: wrEvent := ev.Event.(*replication.RowsEvent) sig.DB = string(wrEvent.Table.Schema) - sig.DB = string(wrEvent.Table.Table) + sig.TB = string(wrEvent.Table.Table) sig.Type = "update" sig.RowCnt = uint32(len(wrEvent.Rows)) / 2 sig.Rows = wrEvent.Rows @@ -466,6 +466,9 @@ func parseBinlogWithFilter(r io.Reader, parse *replication.BinlogParser, filter tx.RowsCount += v.RowCount tx.Txs[k] = v } + if filter.OnlyShowGtid { + tx.EndPos = startPos - 1 + } tx.Size = tx.EndPos - tx.StartPos callFn(tx) }