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 {