|
12 | 12 | class DbStorage extends BaseDbStorage
|
13 | 13 | {
|
14 | 14 | /**
|
15 |
| - * @param array $data |
16 |
| - * @return \Magento\Framework\DB\Select |
| 15 | + * {@inheritDoc} |
17 | 16 | */
|
18 | 17 | protected function prepareSelect(array $data)
|
19 | 18 | {
|
20 |
| - if (!array_key_exists(UrlRewrite::ENTITY_ID, $data) |
21 |
| - || !array_key_exists(UrlRewrite::ENTITY_TYPE, $data) |
22 |
| - || !array_key_exists(UrlRewrite::STORE_ID, $data) |
23 |
| - ) { |
24 |
| - throw new \InvalidArgumentException( |
25 |
| - UrlRewrite::ENTITY_ID . ', ' . UrlRewrite::ENTITY_TYPE |
26 |
| - . ' and ' . UrlRewrite::STORE_ID . ' parameters are required.' |
27 |
| - ); |
| 19 | + $metadata = []; |
| 20 | + if (array_key_exists(UrlRewrite::METADATA, $data)) { |
| 21 | + $metadata = $data[UrlRewrite::METADATA]; |
| 22 | + unset($data[UrlRewrite::METADATA]); |
28 | 23 | }
|
29 | 24 |
|
30 | 25 | $select = $this->connection->select();
|
31 |
| - $select->from(['url_rewrite' => $this->resource->getTableName('url_rewrite')]) |
32 |
| - ->joinLeft( |
33 |
| - ['relation' => $this->resource->getTableName(Product::TABLE_NAME)], |
34 |
| - 'url_rewrite.url_rewrite_id = relation.url_rewrite_id' |
35 |
| - ) |
36 |
| - ->where( |
37 |
| - 'url_rewrite.entity_id IN (?)', |
38 |
| - $data[UrlRewrite::ENTITY_ID] |
39 |
| - ) |
40 |
| - ->where( |
41 |
| - 'url_rewrite.entity_type = ?', |
42 |
| - $data[UrlRewrite::ENTITY_TYPE] |
43 |
| - ) |
44 |
| - ->where('url_rewrite.store_id IN (?)', $data[UrlRewrite::STORE_ID]); |
45 |
| - if (array_key_exists(UrlRewrite::REDIRECT_TYPE, $data)) { |
46 |
| - $select->where( |
47 |
| - 'url_rewrite.redirect_type = ?', |
48 |
| - $data[UrlRewrite::REDIRECT_TYPE] |
49 |
| - ); |
| 26 | + $select->from([ |
| 27 | + 'url_rewrite' => $this->resource->getTableName(self::TABLE_NAME) |
| 28 | + ]); |
| 29 | + $select->joinLeft( |
| 30 | + ['relation' => $this->resource->getTableName(Product::TABLE_NAME)], |
| 31 | + 'url_rewrite.url_rewrite_id = relation.url_rewrite_id' |
| 32 | + ); |
| 33 | + |
| 34 | + foreach ($data as $column => $value) { |
| 35 | + $select->where('url_rewrite.' . $column . ' IN (?)', $value); |
50 | 36 | }
|
51 |
| - if (empty($data[UrlRewrite::METADATA]['category_id'])) { |
| 37 | + if (empty($metadata['category_id'])) { |
52 | 38 | $select->where('relation.category_id IS NULL');
|
53 | 39 | } else {
|
54 |
| - $select->where('relation.category_id = ?', $data[UrlRewrite::METADATA]['category_id']); |
| 40 | + $select->where( |
| 41 | + 'relation.category_id = ?', |
| 42 | + $metadata['category_id'] |
| 43 | + ); |
55 | 44 | }
|
| 45 | + |
56 | 46 | return $select;
|
57 | 47 | }
|
58 | 48 | }
|
0 commit comments