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