bug fix

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