* @copyright 2019 Akeneo SAS (http://www.akeneo.com) */ final class SqlGetAttributes implements GetAttributes { /** @var Connection */ private $connection; public function __construct(Connection $connection) { $this->connection = $connection; } public function forCodes(array $attributeCodes): array { if (empty($attributeCodes)) { return []; } $query = <<connection->executeQuery( $query, ['attributeCodes' => $attributeCodes], ['attributeCodes' => Connection::PARAM_STR_ARRAY] )->fetchAllAssociative(); $attributes = []; foreach ($rawResults as $rawAttribute) { $properties = unserialize($rawAttribute['properties']); $attributes[$rawAttribute['code']] = new Attribute( $rawAttribute['code'], $rawAttribute['attribute_type'], $properties, boolval($rawAttribute['is_localizable']), boolval($rawAttribute['is_scopable']), $rawAttribute['metric_family'], $rawAttribute['default_metric_unit'], boolval($rawAttribute['decimals_allowed']), $rawAttribute['backend_type'], json_decode($rawAttribute['available_locale_codes']), boolval($rawAttribute['useable_as_grid_filter']) ); } return array_replace(array_fill_keys($attributeCodes, null), $attributes); } public function forCode(string $attributeCode): ?Attribute { $forCodes = $this->forCodes([$attributeCode]); if ([] === $forCodes) { return null; } return array_pop($forCodes); } public function forType(string $attributeType): array { $query = <<connection->executeQuery( $query, ['attribute_type' => $attributeType] )->fetchFirstColumn(); return $this->forCodes($codes); } }