HMLB\DDDBundle\Doctrine\ODM\MongoDB\AbstractMongoRepository

Complexity

Total Complexity

7

Size/Duplication

Total Lines	80
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	0

Importance

Changes	3
Bugs	0	Features	1

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	getAll()	0	4	1
A	get()	0	4	1
A	add()	0	4	1
A	getBy()	0	4	1
A	getOneBy()	0	4	1
A	createMongoIdFromIdentity()	0	4	1

<?php

namespace HMLB\DDDBundle\Doctrine\ODM\MongoDB;

use Doctrine\ODM\MongoDB\DocumentManager;
use Doctrine\ODM\MongoDB\DocumentRepository;
use MongoId;
use HMLB\DDD\Entity\AggregateRoot;
use HMLB\DDD\Entity\Repository;
use HMLB\DDD\Entity\Identity;

/**
 * Aggregate root repository implementation for ORM.
 *
 * @author Hugues Maignol <hugues@hmlb.fr>
 */
abstract class AbstractMongoRepository implements Repository
{
    /**
     * @var DocumentManager
     */
    protected $dm;
    /**
     * @var DocumentRepository
     */
    protected $documentRepository;

    public function __construct(DocumentManager $dm = null)
    {
        $this->dm = $dm;
        $this->documentRepository = $dm->getRepository($this->getClassName());
    }

    /**
     * @return AggregateRoot[]
     */
    public function getAll()
    {
        return $this->documentRepository->findAll();
    }

    /**
     * @param Identity $identity
     *
     * @return AggregateRoot
     */
    public function get(Identity $identity)
    {
        return $this->documentRepository->find($identity);
    }

    /**
     * @param AggregateRoot $document
     */
    public function add(AggregateRoot $document)
    {
        $this->dm->persist($document);
    }

    /**
     * Finds Entities by a set of criteria.
     *
     * @param array    $criteria Query criteria
     * @param array    $sort     Sort array for Cursor::sort()
     * @param int|null $limit    Limit for Cursor::limit()
     * @param int|null $skip     Skip for Cursor::skip()
     *
     * @return AggregateRoot[]
     */
    protected function getBy(array $criteria, array $sort = null, $limit = null, $skip = null)
    {
        return $this->documentRepository->findBy($criteria, $sort, $limit, $skip);
    }

    /**
     * Finds a single AggregateRoot by a set of criteria.
     *
     * @param array $criteria
     *
     * @return AggregateRoot
     */
    protected function getOneBy(array $criteria)
    {
        return $this->documentRepository->findOneBy($criteria);
    }

    /**
     * @param Identity $id
     *
     * @return MongoId
     */
    protected function createMongoIdFromIdentity(Identity $id)
    {
        return new MongoId((string) $id);
    }
}