src/Core/CoreBundle/Manager/BaseManager.php line 46

Open in your IDE?
  1. <?php
  3. namespace App\Core\CoreBundle\Manager;
  5. use App\Core\CoreBundle\Traits\Containerable;
  6. use Doctrine\Common\Persistence\ObjectRepository;
  7. use Doctrine\ORM\EntityManagerInterface;
  9. abstract class BaseManager
  10. {
  12.     use Containerable;
  14.     /** @var ObjectRepository */
  15.     protected $repo;
  16.     protected $em;
  18.     public function __construct(EntityManagerInterface $em)
  19.     {
  20.         $this->em = $em;
  21.     }
  23.     public function removeAndFlush($entity)
  24.     {
  25.         $this->em->remove($entity);
  26.         $this->em->flush();
  27.     }
  29.     /**
  30.      * @return ObjectRepository
  31.      */
  33.     public function getRepository()
  34.     {
  35.         return $this->repo;
  36.     }
  38.     /**
  39.      * @return EntityManagerInterface
  40.      */
  41.     public function getManager()
  42.     {
  43.         return $this->em;
  44.     }
  46.     public function setRepository($repository)
  47.     {
  48.         $this->repo = $this->em->getRepository($repository);
  49.     }
  51.     public function findMany($criterias = array(), $orders = array(), $numbers = array(), $options = array())
  52.     {
  53.         $qb = $this->repo->findMany($criterias, $orders, $numbers, $options);
  55.         return (!isset($options['_locale'])) ? $this->repo->getManyResult($qb) : $this->repo->getManyResult($qb, $options['_locale']);
  56.     }
  58.     public function findOne($criterias = array(), $options = array())
  59.     {
  60.         $qb = $this->repo->findOne($criterias, $options);
  62.         return (!isset($options['_locale'])) ? $this->repo->getOneResult($qb) : $this->repo->getOneResult($qb, $options['_locale']);
  63.     }
  65.     public function find($id)
  66.     {
  67.         return $this->repo->find((int)$id);
  68.     }
  70.     public function findAll()
  71.     {
  72.         return $this->repo->findAll();
  73.     }
  75.     public function findBy($criterias = [], $orderBy = [], $limit = null, $offset = null)
  76.     {
  77.         return $this->repo->findBy($criterias, $orderBy, $limit, $offset);
  78.     }
  80.     public function findOneBy($criterias = [], $orderBy = [])
  81.     {
  82.         return $this->repo->findOneBy($criterias, $orderBy);
  83.     }
  85.     public function updateVisite($object, $_locale)
  86.     {
  87.         $object->setLocale($_locale);
  88.         $object->setCount($object->getCount() + 1);
  89.         $this->persistAndFlush($object);
  90.     }
  92.     public function persistAndFlush($entity)
  93.     {
  94.         $this->em->persist($entity);
  95.         $this->em->flush();
  96.     }
  98.     public function query($query)
  99.     {
  100.         $this->query = $query;
  101.         $this->statement = $this->em->getConnection()->prepare($query);
  102.         $this->statement->execute();
  104.         return $this;
  105.     }
  107.     public function getResult()
  108.     {
  109.         return $this->statement->fetchAll();
  110.     }
  112.     private function getLastID($tableName)
  113.     {
  114.         $dbName = getenv('DATABASE_NAME');
  116.         $sql = "SELECT `AUTO_INCREMENT` FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_SCHEMA = '$dbName' AND TABLE_NAME = '$tableName'";
  117.         $cnx = $this->em->getConnection();
  118.         $stmt = $cnx->prepare($sql);
  119.         $stmt->execute();
  120.         $fetchs = $stmt->fetchAll();
  122.         return (int)$fetchs[0]['AUTO_INCREMENT'];
  123.     }
  125. }