Public Member Functions
	__construct (\Magento\Framework\App\ResourceConnection $resourceConnection, $insertIntoTable, $batchSize)

	insert (array $dataToInsert)

	flush ()

Detailed Description

Encapsulate logic that performs batch insert into table

Definition at line 12 of file BatchInsert.php.

Constructor & Destructor Documentation

◆ __construct()

__construct	(	\Magento\Framework\App\ResourceConnection	$resourceConnection,
			$insertIntoTable,
			$batchSize
	)

Parameters

\Magento\Framework\App\ResourceConnection	$resourceConnection
string	$insertIntoTable
int	$batchSize

Definition at line 49 of file BatchInsert.php.

       {
         $this->resourceConnection = $resourceConnection;
         $this->insertIntoTable = $insertIntoTable;
         $this->batchSize = $batchSize;
         $this->dataStorage = new \SplFixedArray($batchSize);
     }

Member Function Documentation

◆ flush()

flush ( )

Insert all data form $dataStorage to DB and clear $dataStorage

Returns: void

Definition at line 82 of file BatchInsert.php.

     {
         if ($this->currentStorageIndex > 0) {
             if ($this->currentStorageIndex < $this->batchSize) {
                 $this->dataStorage->setSize($this->currentStorageIndex);
             }
 
             $this->getDbConnection()
                 ->insertArray(
                     $this->insertIntoTable,
                     array_keys(reset($this->dataStorage)),
                     $this->dataStorage->toArray()
                 );
 
             $this->dataStorage = new \SplFixedArray($this->batchSize);
             $this->currentStorageIndex = 0;
         }
     }

◆ insert()

insert ( array $dataToInsert )

Save data to $dataStorage and automatically flush it to DB when storage size becomes equal to $batchSize

Parameters

array $dataToInsert

Returns: void

Definition at line 67 of file BatchInsert.php.

     {
         $this->dataStorage[$this->currentStorageIndex] = $dataToInsert;
         $this->currentStorageIndex++;
 
         if ($this->currentStorageIndex >= $this->batchSize) {
             $this->flush();
         }
     }

The documentation for this class was generated from the following file: