From 58eec327ea13b8a271fd22d3997e4a551d6e5f4e Mon Sep 17 00:00:00 2001 From: starainrt Date: Tue, 25 Apr 2023 19:32:41 +0800 Subject: [PATCH] update --- parse.go | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/parse.go b/parse.go index 0217621..80aaf63 100644 --- a/parse.go +++ b/parse.go @@ -14,10 +14,11 @@ import ( type TxDetail struct { StartPos int EndPos int + RowCount int + Sql string Db string Table string SqlType string - RowCount int } type Transaction struct { @@ -27,8 +28,8 @@ type Transaction struct { StartPos int EndPos int Size int - SQLOrigin string RowsCount int + SQLOrigin string Txs []TxDetail } @@ -177,6 +178,7 @@ func parseBinlogDetail(r io.Reader, f func(Transaction)) error { EndPos: int(h.LogPos), Db: db, Table: tb, + Sql: sql, SqlType: sqlType, RowCount: int(rowCnt), })