resetting methods

Author: ziaratban

src/ActiveRecord.php

@@ -533,6 +533,14 @@ public function batchInsert($attributes = null){
             return self::flushBatchInsert();
     }
 
+    /**
+     * resetting batch insert
+    */
+    public static function resetBatchInsert(){
+        self::$batchInsertQueue = 0;
+        self::$batchInsertCommand->document = [];
+    }
+
     /**
      * execute batch insert operations in queue and reset anything
      * this method is not continue when not exists any insert operations in queue
@@ -542,19 +550,10 @@ public static function flushBatchInsert(){
         if(self::$batchInsertQueue === 0)
             return;
         $result = self::$batchInsertCommand->executeBatch(static::collectionName());
-        self::$batchInsertQueue = 0;
-        self::$batchInsertCommand->document = [];
+        self::resetBatchInsert();
         return $result;
     }
 
-    /**
-     * resetting queue
-    */
-    public static function resetBatchInsert(){
-        self::$batchInsertQueue = 0;
-        self::$batchInsertCommand->document = [];
-    }
-
     /**
      * checking if current ActiveRecord class has documents in queue for update
      * @return bool
@@ -612,6 +611,14 @@ public static function batchUpdateAll($attributes, $condition = [], $options = [
             return self::flushBatchUpdate();
     }
 
+    /**
+     * resetting batch update
+    */
+    public static function resetBatchUpdate(){
+        self::$batchUpdateQueue = 0;
+        self::$batchUpdateCommand->document = [];
+    }
+
     /**
      * execute batch update operations in queue and reset anything
      * this method is not continue when not exists any update operations in queue
@@ -621,8 +628,7 @@ public static function flushBatchUpdate(){
         if(self::$batchUpdateQueue === 0)
             return;
         $result = self::$batchUpdateCommand->executeBatch(static::collectionName());
-        self::$batchUpdateQueue = 0;
-        self::$batchUpdateCommand->document = [];
+        self::resetBatchUpdate();
         return $result;
     }
 
@@ -684,6 +690,14 @@ public function batchDeleteAll($condition = [], $options = []){
             return self::flushBatchDelete();
     }
 
+    /**
+     * resetting batch delete
+    */
+    public static function resetBatchDelete(){
+        self::$batchDeleteQueue = 0;
+        self::$batchDeleteCommand->document = [];
+    }
+
     /**
      * execute batch delete operations in queue and reset anything
      * this method is not continue when not exists any delete operations in queue
@@ -693,8 +707,7 @@ public static function flushBatchDelete(){
         if(self::$batchDeleteQueue === 0)
             return;
         $result = self::$batchDeleteCommand->executeBatch(static::collectionName());
-        self::$batchDeleteQueue = 0;
-        self::$batchDeleteCommand->document = [];
+        self::resetBatchDelete();
         return $result;
     }