MAGETWO-66195: SQL Error during price reindexation process for custom profile

Author: irenelagno

app/code/Magento/Catalog/Model/ResourceModel/Product/Indexer/Eav/Source.php

@@ -15,6 +15,8 @@
  */
 class Source extends AbstractEav
 {
+    const TRANSIT_PREFIX = 'transit_';
+
     /**
      * Catalog resource helper
      *
@@ -361,4 +363,45 @@ private function saveDataFromSelect(\Magento\Framework\DB\Select $select, array
 
         $this->_saveIndexData($data);
     }
+
+    /**
+     * @inheritdoc
+     */
+    protected function _prepareRelationIndex($parentIds = null)
+    {
+        $connection = $this->getConnection();
+        $idxTable = $this->getIdxTable();
+
+        if (!$this->tableStrategy->getUseIdxTable()) {
+            $additionalIdxTable = $connection->getTableName(self::TRANSIT_PREFIX . $this->getIdxTable());
+            $connection->createTemporaryTableLike($additionalIdxTable, $idxTable);
+
+            $query = $connection->insertFromSelect(
+                $this->_prepareRelationIndexSelect($parentIds),
+                $additionalIdxTable,
+                []
+            );
+            $connection->query($query);
+
+            $select = $connection->select()->from($additionalIdxTable);
+            $query = $connection->insertFromSelect(
+                $select,
+                $idxTable,
+                [],
+                \Magento\Framework\DB\Adapter\AdapterInterface::INSERT_IGNORE
+            );
+            $connection->query($query);
+
+            $connection->dropTemporaryTable($additionalIdxTable);
+        } else {
+            $query = $connection->insertFromSelect(
+                $this->_prepareRelationIndexSelect($parentIds),
+                $idxTable,
+                [],
+                \Magento\Framework\DB\Adapter\AdapterInterface::INSERT_IGNORE
+            );
+            $connection->query($query);
+        }
+        return $this;
+    }
 }

app/code/Magento/Catalog/etc/di.xml

@@ -954,4 +954,10 @@
             <argument name="connectionName" xsi:type="string">indexer</argument>
         </arguments>
     </type>
+    <type name="Magento\Catalog\Model\ResourceModel\Product\Indexer\Eav\Source">
+        <arguments>
+            <argument name="tableStrategy" xsi:type="object">Magento\Catalog\Model\ResourceModel\Product\Indexer\TemporaryTableStrategy</argument>
+            <argument name="connectionName" xsi:type="string">indexer</argument>
+        </arguments>
+    </type>
 </config>

app/code/Magento/GroupedProduct/Model/ResourceModel/Product/Indexer/Price/Grouped.php

@@ -12,9 +12,10 @@
 
 class Grouped extends DefaultPrice implements GroupedInterface
 {
+    const TRANSIT_PREFIX = 'transit_';
+
     /**
-     * {@inheritdoc}
-     * @param null|array $entityIds
+     * @inheritdoc
      */
     protected function reindex($entityIds = null)
     {
@@ -26,13 +27,51 @@ protected function reindex($entityIds = null)
      * Use calculated price for relation products
      *
      * @param int|array $entityIds  the parent entity ids limitation
-     * @return \Magento\GroupedProduct\Model\ResourceModel\Product\Indexer\Price\Grouped
+     * @return $this
      */
     protected function _prepareGroupedProductPriceData($entityIds = null)
     {
         if (!$this->hasEntity() && empty($entityIds)) {
             return $this;
         }
+
+        $connection = $this->getConnection();
+        $table = $this->getIdxTable();
+
+        if (!$this->tableStrategy->getUseIdxTable()) {
+            $additionalIdxTable = $connection->getTableName(self::TRANSIT_PREFIX . $this->getIdxTable());
+            $connection->createTemporaryTableLike($additionalIdxTable, $table);
+            $query = $connection->insertFromSelect(
+                $this->_prepareGroupedProductPriceDataSelect($entityIds),
+                $additionalIdxTable,
+                []
+            );
+            $connection->query($query);
+
+            $select = $connection->select()->from($additionalIdxTable);
+            $query = $connection->insertFromSelect(
+                $select,
+                $table,
+                [],
+                \Magento\Framework\DB\Adapter\AdapterInterface::INSERT_ON_DUPLICATE
+            );
+            $connection->query($query);
+            $connection->dropTemporaryTable($additionalIdxTable);
+        } else {
+            $query = $this->_prepareGroupedProductPriceDataSelect($entityIds)->insertFromSelect($table);
+            $connection->query($query);
+        }
+        return $this;
+    }
+
+    /**
+     * Prepare data index select for Grouped products prices
+     *
+     * @param int|array $entityIds  the parent entity ids limitation
+     * @return \Magento\Framework\DB\Select
+     */
+    protected function _prepareGroupedProductPriceDataSelect($entityIds = null)
+    {
         $connection = $this->getConnection();
         $table = $this->getIdxTable();
         $linkField = $this->getMetadataPool()->getMetadata(ProductInterface::class)->getLinkField();
@@ -99,10 +138,6 @@ protected function _prepareGroupedProductPriceData($entityIds = null)
                 'store_field' => new \Zend_Db_Expr('cs.store_id')
             ]
         );
-
-        $query = $select->insertFromSelect($table);
-        $connection->query($query);
-
-        return $this;
+        return $select;
     }
 }