metadataPool = $metadataPool; } /** * @param string $entityType * @param string $identifier * @param array $context * @return array * @throws \Exception */ public function execute($entityType, $identifier, $context = []) { $metadata = $this->metadataPool->getMetadata($entityType); $select = $metadata->getEntityConnection()->select() ->from(['t' => $metadata->getEntityTable()]) ->where($metadata->getIdentifierField() . ' = ?', $identifier); foreach ($context as $field => $value) { $select->where( $metadata->getEntityConnection()->quoteIdentifier($field) . ' = ?', $value ); } $data = $metadata->getEntityConnection()->fetchRow($select); return $data ?: []; } }