Respect\Structural\Driver\MongoDb\Driver

Complexity

Total Complexity

12

Size/Duplication

Total Lines	122
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

93.75%

Importance

Changes	3
Bugs	1	Features	1

10 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	factoryLegacy()	0	15	2
A	factory()	0	14	2
A	getConnection()	0	4	1
A	fetch()	0	4	1
A	find()	0	4	1
A	generateQuery()	0	4	1
A	insert()	0	4	1
A	update()	0	4	1
A	remove()	0	4	1

<?php

namespace Respect\Structural\Driver\MongoDb;

use Respect\Data\Collections\Collection;
use Respect\Structural\Driver as BaseDriver;
use Respect\Structural\Driver\Exception as DriverException;

class Driver implements BaseDriver
{
    /**
     * @var BaseDriver
     */
    private $connection;

    protected function __construct(BaseDriver $connection)
    {
        $this->connection = $connection;
    }

    /**
     * @param string $database
     * @param string $server
     * @param array  $options
     * @param array  $driverOptions
     *
     * @return Driver
     *
     * @throws DriverException
     */
    public static function factoryLegacy(
        $database,
        $server = 'mongodb://localhost:27017',
        array $options = ['connect' => false],
        array $driverOptions = []
    ) {
        if (!extension_loaded('mongo')) {
            throw DriverException::extensionNotLoaded('mongo');
        }

        $client = new \MongoClient($server, $options, $driverOptions);
        $driver = new MongoDriver($client, $database);

        return new self($driver);
    }

    /**
     * @param string $database
     * @param string $uri
     * @param array  $uriOptions
     * @param array  $driverOptions
     *
     * @return Driver
     *
     * @throws DriverException
     */
    public static function factory(
        $database,
        $uri = 'mongodb://localhost:27017',
        array $uriOptions = [],
        array $driverOptions = []
    ) {
        if (!extension_loaded('mongodb')) {
            throw DriverException::extensionNotLoaded('mongodb');
        }
        $client = new \MongoDB\Client($uri, $uriOptions, $driverOptions);
        $driver = new MongoDbDriver($client, $database);

        return new self($driver);
    }

    /**
     * @return Driver
     */
    public function getConnection()
    {
        return $this->connection;
    }

    /**
     * {@inheritdoc}
     */
    public function fetch(\Iterator $cursor)
    {
        return $this->getConnection()->fetch($cursor);
    }

    /**
     * {@inheritdoc}
     */
    public function find($collection, array $query = [])
    {
        return $this->getConnection()->find($collection, $query);
    }

    /**
     * {@inheritdoc}
     */
    public function generateQuery(Collection $collection)
    {
        return $this->getConnection()->generateQuery($collection);
    }

    /**
     * @param Collection $collection
     * @param $document
     *
     * @return void
     */
    public function insert($collection, $document)
    {
        $this->getConnection()->insert($collection, $document);
    }

    /**
     * {@inheritdoc}
     */
    public function update($collection, $criteria, $document)
    {
        $this->getConnection()->update($collection, $criteria, $document);
    }

    /**
     * {@inheritdoc}
     */
    public function remove($collection, $criteria)
    {
        $this->getConnection()->remove($collection, $criteria);
    }
}