diff --git a/main.cpp b/main.cpp
index b696ff1..5623846 100644
--- a/main.cpp
+++ b/main.cpp
@@ -262,11 +262,12 @@ void handle_watch_video(Video &video, bool mark_only) {
 }
 
 void handle_mark_all_videos_watched(Channel &channel) {
-    sqlite3_exec(db, "BEGIN TRANSACTION;", nullptr, nullptr, nullptr);
-    for(Video &video: videos[channel.id]) {
-        video.set_flag(db, kWatched);
+    {
+        db_transaction transaction;
+        for(Video &video: videos[channel.id]) {
+            video.set_flag(db, kWatched);
+        }
     }
-    sqlite3_exec(db, "COMMIT TRANSACTION;", nullptr, nullptr, nullptr);
     channel.load_info(db);
 }
 
diff --git a/yt.cpp b/yt.cpp
index e695dcd..e8eace1 100644
--- a/yt.cpp
+++ b/yt.cpp
@@ -158,7 +158,7 @@ void Channel::fetch_new_videos(sqlite3 *db, progress_info *info, std::optional<s
         {"key", yt_config.api_key},
     };
 
-    sqlite3_exec(db, "BEGIN TRANSACTION;", nullptr, nullptr, nullptr);
+    db_transaction transaction;
 
     int processed = 0;
     bool abort = false;
@@ -210,8 +210,6 @@ void Channel::fetch_new_videos(sqlite3 *db, progress_info *info, std::optional<s
             break;
         }
     }
-
-    sqlite3_exec(db, "COMMIT TRANSACTION;", nullptr, nullptr, nullptr);
 }
 
 void Channel::load_info(sqlite3 *db)