Respect\Structural\Driver\MongoDb\Driver

Complexity

Total Complexity

12

Size/Duplication

Total Lines	127
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

93.75%

Importance

Changes	2
Bugs	0	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\Structural\Driver\Exception as DriverException;
use MongoDB\Client as MongoDBClient;
use Respect\Data\Collections\Collection;
use Respect\Structural\Driver as BaseDriver;

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

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

It seems like $connection of type object<Respect\Structural\Driver> is incompatible with the declared type object<MongoDB\Client> of property $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;
    }

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

The method fetch() does not seem to exist on object<MongoDB\Client>.

    }

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

The method find() does not seem to exist on object<MongoDB\Client>.

    }

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

The method generateQuery() does not seem to exist on object<MongoDB\Client>.

    }

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

The method insert() does not seem to exist on object<MongoDB\Client>.

    }

    public function update($collection, $criteria, $document)
    {
        $this->getConnection()->update($collection, $criteria, $document);

The method update() does not seem to exist on object<MongoDB\Client>.

    }

    /**
     * @param string $collection
     * @param array  $criteria
     */
    public function remove($collection, $criteria)
    {
        $this->getConnection()->remove($collection, $criteria);

The method remove() does not seem to exist on object<MongoDB\Client>.

    }
}