diff --git a/src/db/sqlite/SqliteCapacitor.php b/src/db/sqlite/SqliteCapacitor.php
index 784eb6b..e7e5c60 100644
--- a/src/db/sqlite/SqliteCapacitor.php
+++ b/src/db/sqlite/SqliteCapacitor.php
@@ -221,6 +221,7 @@ class SqliteCapacitor extends CapacitorStorage {
             $commitThreshold--;
             if ($commitThreshold == 0) {
               $sqlite->commit();
+              $sqlite->beginTransaction();
               $commitThreshold = $channel->getEachCommitThreshold();
             }
           }