ADD setChunkSize in DatabaseHandler

Author: francerz

src/DatabaseHandler.php

@@ -31,6 +31,7 @@ class DatabaseHandler
     private $nestMerger;
 
     private $transactionStack = 0;
+    private $chunkSize = null;
 
     public function __construct(DriverInterface $driver)
     {
@@ -77,6 +78,11 @@ public function allowDeleteWithoutWhere($allow = true)
         $this->allowDeleteWithoutWhere = $allow;
     }
 
+    public function setChunkSize(?int $chunkSize)
+    {
+        $this->chunkSize = $chunkSize;
+    }
+
     public function executeSelect(SelectQuery $query): SelectResult
     {
         $query = QueryOptimizer::optimizeSelect($query);
@@ -236,11 +242,14 @@ public function executeUpsert(UpsertQuery $query): UpsertResult
         $insertedId = null;
         $success = true;
         if (!empty($inserts)) {
-            $insertQuery = Query::insertInto($query->getTable(), $inserts, $query->getColumns());
-            $insertResult = $this->executeInsert($insertQuery);
-            $numInserts += $insertResult->getNumRows();
-            $insertedId = $insertResult->getInsertedId();
-            $success &= $insertResult->success();
+            $insertChunks = array_chunk($inserts, $this->chunkSize ?? count($inserts));
+            foreach ($insertChunks as $chunk) {
+                $insertQuery = Query::insertInto($query->getTable(), $chunk, $query->getColumns());
+                $insertResult = $this->executeInsert($insertQuery);
+                $insertedId = $insertedId ?? $insertResult->getInsertedId();
+                $numInserts += $insertResult->getNumRows();
+                $success &= $insertResult->success();
+            }
         }
         if (!empty($updates) && !empty($query->getUpdateColumns())) {
             foreach ($updates as $u) {