From 18ff12f4244d5012c83f412c241fecd135811a2c Mon Sep 17 00:00:00 2001
From: w1ndyb0y <windyboy@163.com>
Date: Wed, 23 Dec 2020 14:04:06 +0800
Subject: [PATCH] add transaction in write

---
 utils/sqlite.go | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/utils/sqlite.go b/utils/sqlite.go
index 99df057..3e7592f 100644
--- a/utils/sqlite.go
+++ b/utils/sqlite.go
@@ -116,6 +116,8 @@ func LoadUnprocessed() {
 
 func processed(db *sql.DB, t telegram) {
 	getWriteLock()
+	tx, err := db.Begin()
+	checkDbErr(err, "error in begin update")
 	stmt, _ := db.Prepare(update)
 	result, err := stmt.Exec(t.id)
 	checkDbErr(err, "error in update telegram status")
@@ -123,6 +125,7 @@ func processed(db *sql.DB, t telegram) {
 	log.Println(t.id, " telegram update : ", id)
 	isWriting = false
 	log.Println("release lock")
+	tx.Commit()
 }
 
 func countTelegram() int64 {