Micayael\NativeQueryFromFileBuilderBundle\Service\NativeQueryBuilder

Complexity

Total Complexity

13

Size/Duplication

Total Lines	105
Duplicated Lines	0 %

Importance

Changes	2
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	1
A	findFromSqlKey()	0	25	4
A	findScalarFromSqlKey()	0	9	1
B	findOneFromSqlKey()	0	33	6
A	changeEntityManager()	0	3	1

<?php

namespace Micayael\NativeQueryFromFileBuilderBundle\Service;

use Doctrine\ORM\EntityManagerInterface;
use Doctrine\ORM\NonUniqueResultException;
use Doctrine\ORM\NoResultException;
use Doctrine\ORM\Query\ResultSetMappingBuilder;
use Micayael\NativeQueryFromFileBuilderBundle\Helper\NativeQueryBuilderHelper;
use Symfony\Component\Cache\Adapter\AdapterInterface;
use Symfony\Component\EventDispatcher\EventDispatcherInterface;

class NativeQueryBuilder implements NativeQueryBuilderInterface
{
    /**
     * @var EntityManagerInterface
     */
    private $em;

    /**
     * @var EventDispatcherInterface|null
     */
    private $eventDispatcher;

    /**
     * @var AdapterInterface|null
     */
    private $cache;

    private $helper;

    public function __construct(EntityManagerInterface $em, ?EventDispatcherInterface $eventDispatcher, ?AdapterInterface $cache, array $config)
    {
        $this->em = $em;
        $this->eventDispatcher = $eventDispatcher;
        $this->cache = $cache;

        $this->helper = new NativeQueryBuilderHelper($this->eventDispatcher, $this->cache, $config);
    }

    public function changeEntityManager(EntityManagerInterface $em)
    {
        $this->em = $em;
    }

    public function findOneFromSqlKey(string $key, array $params = [], ResultSetMappingBuilder $rsm = null)
    {
        try {
            $sql = $this->helper->getSqlFromYamlKey($key, $params);

            $ret = [];

            if ($rsm) {
                $nativeQuery = $this->em
                    ->createNativeQuery($sql, $rsm);

                foreach ($params as $key => $value) {
                    $nativeQuery->setParameter($key, $value);
                }

                $ret[] = $nativeQuery->getSingleResult();
            } else {
                $ret = $this->em

The function Doctrine\DBAL\Connection::fetchAll() has been deprecated: Use fetchAllAssociative()

                    ->getConnection()
                    ->fetchAll($sql, $params);
            }

            if (empty($ret)) {
                return null;
            }

            if (count($ret) > 1) {
                throw new NonUniqueResultException(sprintf('Se han encontrado %d filas', count($ret)));
            }

            return $ret[0];
        } catch (NoResultException $e) {
            return null;
        }
    }

    public function findFromSqlKey(string $key, array $params = [], ?string $orderBy, ResultSetMappingBuilder $rsm = null): array
    {
        if ($orderBy) {
            $params['orderby'] = $orderBy;
        }

        $sql = $this->helper->getSqlFromYamlKey($key, $params);

        if ($rsm) {
            $nativeQuery = $this->em
                ->createNativeQuery($sql, $rsm)
            ;

            foreach ($params as $key => $value) {
                $nativeQuery->setParameter($key, $value);
            }

            $ret = $nativeQuery->getResult();
        } else {
            $ret = $this->em

The function Doctrine\DBAL\Connection::fetchAll() has been deprecated: Use fetchAllAssociative()

                ->getConnection()
                ->fetchAll($sql, $params);
        }

        return $ret;
    }

    public function findScalarFromSqlKey(string $key, array $params = [])
    {
        $sql = $this->helper->getSqlFromYamlKey($key, $params);

        $ret = $this->em

The function Doctrine\DBAL\Connection::fetchColumn() has been deprecated: Use fetchOne() instead.

            ->getConnection()
            ->fetchColumn($sql, $params);

        return $ret;
    }
}