resourceConnection = $resourceConnection; } /** * Multiple delete stock source links * * @param StockSourceLinkInterface[] $links * @return void */ public function execute(array $links) { if (!count($links)) { return; } $connection = $this->resourceConnection->getConnection(); $tableName = $this->resourceConnection->getTableName( StockSourceLinkResourceModel::TABLE_NAME_STOCK_SOURCE_LINK ); $whereSql = $this->buildWhereSqlPart($links); $connection->delete($tableName, $whereSql); } /** * Build WHERE part of the delete SQL query * * @param StockSourceLinkInterface[] $links * @return string */ private function buildWhereSqlPart(array $links): string { $connection = $this->resourceConnection->getConnection(); $condition = []; foreach ($links as $link) { $skuCondition = $connection->quoteInto( StockSourceLinkInterface::SOURCE_CODE . ' = ?', $link->getSourceCode() ); $sourceCodeCondition = $connection->quoteInto( StockSourceLinkInterface::STOCK_ID . ' = ?', $link->getStockId() ); $condition[] = '(' . $skuCondition . ' AND ' . $sourceCodeCondition . ')'; } return implode(' OR ', $condition); } }