MAGETWO-34269: quote_items are not deleted after delete product using import/export functionality

Author: Olexii Korshenko

app/code/Magento/CatalogImportExport/Model/Import/Product.php

@@ -10,6 +10,8 @@
 
 use Magento\Framework\App\Filesystem\DirectoryList;
 use Magento\CatalogImportExport\Model\Import\Product\RowValidatorInterface as ValidatorInterface;
+use Magento\Framework\Model\Resource\Db\TransactionManagerInterface;
+use Magento\Framework\Model\Resource\Db\ObjectRelationProcessor;
 
 /**
  * Import entity product model
@@ -373,6 +375,16 @@ class Product extends \Magento\ImportExport\Model\Import\Entity\AbstractEntity
      */
     protected $masterAttributeCode = 'sku';
 
+    /**
+     * @var ObjectRelationProcessor
+     */
+    protected $objectRelationProcessor;
+
+    /**
+     * @var TransactionManagerInterface
+     */
+    protected $transactionManager;
+
     /**
      * @param \Magento\Core\Helper\Data $coreData
      * @param \Magento\ImportExport\Helper\Data $importExportData
@@ -439,6 +451,8 @@ public function __construct(
         Product\SkuProcessor $skuProcessor,
         Product\CategoryProcessor $categoryProcessor,
         Product\Validator $validator,
+        ObjectRelationProcessor $objectRelationProcessor,
+        TransactionManagerInterface $transactionManager,
         array $data = []
     ) {
         $this->_eventManager = $eventManager;
@@ -463,6 +477,8 @@ public function __construct(
         $this->skuProcessor = $skuProcessor;
         $this->categoryProcessor = $categoryProcessor;
         $this->validator = $validator;
+        $this->objectRelationProcessor = $objectRelationProcessor;
+        $this->transactionManager = $transactionManager;
         parent::__construct($coreData, $importExportData, $importData, $config, $resource, $resourceHelper, $string);
         $this->_optionEntity = isset(
             $data['option_entity']
@@ -504,6 +520,7 @@ public function setParameters(array $params)
      * Delete products.
      *
      * @return $this
+     * @throws \Exception
      */
     protected function _deleteProducts()
     {
@@ -518,12 +535,20 @@ protected function _deleteProducts()
                 }
             }
             if ($idToDelete) {
-                $this->_connection->query(
-                    $this->_connection->quoteInto(
-                        "DELETE FROM `{$productEntityTable}` WHERE `entity_id` IN (?)",
-                        $idToDelete
-                    )
-                );
+                $this->transactionManager->start($this->_connection);
+                try {
+                    $this->objectRelationProcessor->delete(
+                        $this->transactionManager,
+                        $this->_connection,
+                        $productEntityTable,
+                        $this->_connection->quoteInto('entity_id IN (?)', $idToDelete),
+                        ['entity_id' => $idToDelete]
+                    );
+                    $this->transactionManager->commit();
+                } catch (\Exception $e) {
+                    $this->transactionManager->rollBack();
+                    throw $e;
+                }
             }
         }
         return $this;

lib/internal/Magento/Framework/Model/Resource/Db/ObjectRelationProcessor.php

@@ -36,6 +36,7 @@ public function delete(
      *
      * @param string $table
      * @param array $involvedData
+     * @return void
      */
     public function validateDataIntegrity($table, array $involvedData)
     {