MAGETWO-70066: Significant degradation of Catalog Permissions indexer with big number of customer groups

Author: AVoskoboinikov

lib/internal/Magento/Framework/DB/Adapter/AdapterInterface.php

@@ -464,7 +464,7 @@ public function insertMultiple($table, array $data);
      *      array('value1', 'value2')
      *
      * @param   string $table
-     * @param   array $columns  the data array column map
+     * @param   string[] $columns  the data array column map
      * @param   array $data
      * @return  int
      */

lib/internal/Magento/Framework/DB/Adapter/Pdo/Mysql.php

@@ -1973,12 +1973,13 @@ public function insertMultiple($table, array $data)
      *      array('value1', 'value2')
      *
      * @param   string $table
-     * @param   array $columns
+     * @param   string[] $columns
      * @param   array $data
-     * @return  int
-     * @throws  \Zend_Db_Exception
+     * @param   int $strategy
+     * @return int
+     * @throws \Zend_Db_Exception
      */
-    public function insertArray($table, array $columns, array $data)
+    public function insertArray($table, array $columns, array $data, $strategy = 0)
     {
         $values       = [];
         $bind         = [];
@@ -1990,10 +1991,16 @@ public function insertArray($table, array $columns, array $data)
             $values[] = $this->_prepareInsertData($row, $bind);
         }
 
-        $insertQuery = $this->_getInsertSqlQuery($table, $columns, $values);
+        switch ($strategy) {
+            case self::INSERT_ON_DUPLICATE:
+                $query = $this->_getReplaceSqlQuery($table, $columns, $values);
+                break;
+            default:
+                $query = $this->_getInsertSqlQuery($table, $columns, $values);
+        }
 
         // execute the statement and return the number of affected rows
-        $stmt   = $this->query($insertQuery, $bind);
+        $stmt   = $this->query($query, $bind);
         $result = $stmt->rowCount();
 
         return $result;
@@ -3635,6 +3642,26 @@ protected function _getInsertSqlQuery($tableName, array $columns, array $values)
         return $insertSql;
     }
 
+    /**
+     * Return replace sql query
+     *
+     * @param string $tableName
+     * @param array $columns
+     * @param array $values
+     * @return string
+     */
+    protected function _getReplaceSqlQuery($tableName, array $columns, array $values)
+    {
+        $tableName = $this->quoteIdentifier($tableName, true);
+        $columns   = array_map([$this, 'quoteIdentifier'], $columns);
+        $columns   = implode(',', $columns);
+        $values    = implode(', ', $values);
+
+        $replaceSql = sprintf('REPLACE INTO %s (%s) VALUES %s', $tableName, $columns, $values);
+
+        return $replaceSql;
+    }
+
     /**
      * Return ddl type
      *