Respect\Structural\Driver\MongoDb\MongoDriver

Complexity

Total Complexity

10

Size/Duplication

Total Lines	99
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

96.55%

Importance

Changes	3
Bugs	0	Features	1

9 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	getDatabase()	0	4	1
A	getConnection()	0	4	1
A	fetch()	0	7	1
A	find()	0	7	1
A	createObjectId()	0	8	2
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;

class MongoDriver extends AbstractDriver
{
    /**
     * @var \MongoClient
     */
    private $connection;

    /**
     * @var \MongoDB
     */
    private $database;

    /**
     * Driver constructor.
     *
     * @param \MongoClient $connection
     * @param string       $database
     */
    public function __construct(\MongoClient $connection, $database)
    {
        $this->connection = $connection;
        $this->database = $connection->selectDB($database);
    }

    /**
     * @return \MongoDB
     */
    public function getDatabase()
    {
        return $this->database;
    }

    public function getConnection()
    {
        return $this->connection;
    }

    /**
     * @param \Iterator $cursor
     *
     * @return array
     */
    public function fetch(\Iterator $cursor)
    {
        $data = $cursor->current();
        $cursor->next();

        return $data;
    }

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

        return $cursor;
    }

    /**
     * @param int|string $id
     *
     * @return \MongoId|\MongoInt32
     */
    public function createObjectId($id)
    {
        if (is_int($id)) {
            return new \MongoInt32($id);
        }

        return new \MongoId($id);
    }

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

    public function update($collection, $criteria, $document)
    {
        $this->getDatabase()->selectCollection($collection)->update($criteria, $document);
    }

    public function remove($collection, $criteria)
    {
        $this->getDatabase()->selectCollection($collection)->remove($criteria);
    }
}