diff --git a/src/db/CapacitorStorage.php b/src/db/CapacitorStorage.php
index 4448654..fcc49fd 100644
--- a/src/db/CapacitorStorage.php
+++ b/src/db/CapacitorStorage.php
@@ -516,7 +516,7 @@ EOT;
           ]);
           if ($manageTransactions && $commitThreshold !== null) {
             $commitThreshold--;
-            if ($commitThreshold == 0) {
+            if ($commitThreshold <= 0) {
               $db->commit();
               $db->beginTransaction();
               $commitThreshold = $channel->getEachCommitThreshold();
@@ -579,7 +579,7 @@ EOT;
           ]);
           if ($manageTransactions && $commitThreshold !== null) {
             $commitThreshold--;
-            if ($commitThreshold == 0) {
+            if ($commitThreshold <= 0) {
               $db->commit();
               $db->beginTransaction();
               $commitThreshold = $channel->getEachCommitThreshold();