From 6eecb93b9c5f49548ca0e5b6a7cd40d746e6ccb8 Mon Sep 17 00:00:00 2001
From: starainrt <i@b612.me>
Date: Mon, 3 Jul 2023 14:46:11 +0800
Subject: [PATCH] bug fix

---
 parse.go | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/parse.go b/parse.go
index 703c55e..678490f 100644
--- a/parse.go
+++ b/parse.go
@@ -622,7 +622,9 @@ func parseBinlogWithFilter(r io.Reader, parse *replication.BinlogParser, filter
 				if !matchTbs(ev.DB, ev.TB) {
 					continue
 				}
-				tx.validSchemaCount++
+				if ev.DB != "" && ev.TB != "" {
+					tx.validSchemaCount++
+				}
 				tx.Txs = append(tx.Txs, TxDetail{
 					StartPos:        startPos,
 					EndPos:          int(h.LogPos),