Merge pull request #426 from akeneo/release/v101.8.1

release/v101.8.1 into master

CHANGELOG.md

@@ -242,3 +242,8 @@
 ### Version 101.8.0 :
 * Add configurations to choose which cache to flush after each job (https://help.akeneo.com/magento2-connector/articles/16-configure-cache-flush.html)
 * Add configurations to choose which index to refresh after each job (https://help.akeneo.com/magento2-connector/articles/15-configure-index-refresh.html)
+
+### Version 101.8.1 :
+* Add index to "code" column in every job temporary tables
+* Add index to "identifier" column in product job temporary table
+* Add index to "attribute" column in option job temporary table

Helper/Import/Entities.php

@@ -403,6 +403,10 @@ public function matchEntity($pimKey, $entityTable, $entityKey, $import, $prefix
         /** @var string $tableName */
         $tableName = $this->getTableName($import);
 
+        /** @var string $codeIndexName */
+        $codeIndexName = $connection->getIndexName($tableName, 'code');
+        $connection->query('CREATE INDEX ' . $codeIndexName . ' ON ' . $tableName . ' (code(255));');
+
         $connection->delete($tableName, [$pimKey . ' = ?' => '']);
         /** @var string $akeneoConnectorTable */
         $akeneoConnectorTable = $this->getTable('akeneo_connector_entities');

Helper/Import/Option.php

@@ -60,6 +60,14 @@ public function matchEntity($pimKey, $entityTable, $entityKey, $import, $prefix
         /** @var string $tableName */
         $tableName = $this->getTableName($import);
 
+        /** @var string $codeIndexName */
+        $codeIndexName = $connection->getIndexName($tableName, 'code');
+        $connection->query('CREATE INDEX ' . $codeIndexName . ' ON ' . $tableName . ' (code(255));');
+
+        /** @var string $attributeIndexName */
+        $attributeIndexName = $connection->getIndexName($tableName, 'attribute');
+        $connection->query('CREATE INDEX ' . $attributeIndexName . ' ON ' . $tableName . ' (attribute(255));');
+
         $connection->delete($tableName, [$pimKey . ' = ?' => '']);
         /** @var string $akeneoConnectorTable */
         $akeneoConnectorTable = $this->getTable('akeneo_connector_entities');

Helper/Import/Product.php

@@ -356,6 +356,10 @@ public function matchEntity($pimKey, $entityTable, $entityKey, $import, $prefix
         /** @var string $tableName */
         $tableName = $this->getTableName($import);
 
+        /** @var string $codeIndexName */
+        $codeIndexName = $connection->getIndexName($tableName, 'code');
+        $connection->query('CREATE INDEX ' . $codeIndexName . ' ON ' . $tableName . ' (code(255));');
+
         $connection->delete($tableName, [$pimKey . ' = ?' => '']);
         /** @var string $akeneoConnectorTable */
         $akeneoConnectorTable = $this->getTable('akeneo_connector_entities');

Job/Product.php

@@ -1226,6 +1226,10 @@ public function matchEntities()
         /** @var string $tmpTable */
         $tmpTable = $this->entitiesHelper->getTableName($this->getCode());
 
+        /** @var string $identifierIndexName */
+        $identifierIndexName = $connection->getIndexName($tmpTable, 'identifier');
+        $connection->query('CREATE INDEX ' . $identifierIndexName . ' ON ' . $tmpTable . ' (identifier(255));');
+
         /** @var array $duplicates */
         $duplicates = $connection->fetchCol(
             $connection->select()->from($tmpTable, ['identifier'])->group('identifier')->having(

composer.json

@@ -12,7 +12,7 @@
     "http-interop/http-factory-guzzle": "^1.0"
   },
   "type": "magento2-module",
-  "version": "101.8.0",
+  "version": "101.8.1",
   "license": [
     "OSL-3.0",
     "AFL-3.0"