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),