From 393275a195f13a1c215205feb80b361460dfef0f Mon Sep 17 00:00:00 2001
From: starainrt <i@b612.me>
Date: Sat, 29 Apr 2023 12:05:15 +0800
Subject: [PATCH] add more info

---
 parse.go | 32 ++++++++++++++++++--------------
 1 file changed, 18 insertions(+), 14 deletions(-)

diff --git a/parse.go b/parse.go
index 5627d76..8899e02 100644
--- a/parse.go
+++ b/parse.go
@@ -12,13 +12,15 @@ import (
 )
 
 type TxDetail struct {
-	StartPos int
-	EndPos   int
-	RowCount int
-	Sql      string
-	Db       string
-	Table    string
-	SqlType  string
+	StartPos  int
+	EndPos    int
+	RowCount  int
+	Timestamp int64
+	Time      time.Time
+	Sql       string
+	Db        string
+	Table     string
+	SqlType   string
 }
 
 type Transaction struct {
@@ -189,13 +191,15 @@ func parseBinlogDetail(r io.Reader, f func(Transaction)) error {
 		default:
 			tx.EndPos = int(h.LogPos)
 			tx.Txs = append(tx.Txs, TxDetail{
-				StartPos: startPos,
-				EndPos:   int(h.LogPos),
-				Db:       db,
-				Table:    tb,
-				Sql:      sql,
-				SqlType:  sqlType,
-				RowCount: int(rowCnt),
+				StartPos:  startPos,
+				EndPos:    int(h.LogPos),
+				Db:        db,
+				Table:     tb,
+				Sql:       sql,
+				SqlType:   sqlType,
+				RowCount:  int(rowCnt),
+				Timestamp: int64(h.Timestamp),
+				Time:      time.Unix(int64(h.Timestamp), 0),
 			})
 		}
 	}