From 4a84113b83062a7cee13d4f62b79d5ff1f611966 Mon Sep 17 00:00:00 2001 From: Starainrt Date: Sun, 7 Apr 2024 16:13:32 +0800 Subject: [PATCH] bug fix --- parse.go | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/parse.go b/parse.go index 7dc2ba5..4ea535b 100644 --- a/parse.go +++ b/parse.go @@ -491,8 +491,10 @@ func parseBinlogWithFilter(r io.Reader, parse *replication.BinlogParser, filter } } } - tx.Txs = txs - if len(txs) == 0 && matched { + if !matched { + tx.Txs = txs + } + if len(tx.Txs) == 0 && matched { return true } return fn(tx)