resourceConnection = $resourceConnection; } /** * @param array $skus * @return string[] */ public function execute(array $skus): array { $tableName = $this->resourceConnection->getTableName(SourceItem::TABLE_NAME_SOURCE_ITEM); $connection = $this->resourceConnection->getConnection(); $qry = $connection ->select() ->distinct() ->from($tableName, 'source_code') ->where('sku IN (?)', $skus); return $connection->fetchCol($qry); } }