Maslosoft\Mangan\Bridge\MongoDB

Complexity

Total Complexity

10

Size/Duplication

Total Lines	139
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	3

Importance

Changes	1
Bugs	0	Features	0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	1
A	getReadPreference()	0	4	1
A	_getClient()	0	4	1
A	_getFullCollectionName()	0	4	1
A	selectCollection()	0	9	2
A	command()	0	16	3
A	getGridFS()	0	4	1

<?php

/*
 * To change this license header, choose License Headers in Project Properties.
 * To change this template file, choose Tools | Templates
 * and open the template in the editor.
 */

namespace Maslosoft\Mangan\Bridge;

use MongoDB\Driver\Manager;

/**
 * MongoDB
 *
 * @author Piotr Maselkowski <pmaselkowski at gmail.com>
 */
class MongoDB
{

	const PROFILING_OFF = 0;
	const PROFILING_SLOW = 1;
	const PROFILING_ON = 2;
	const NAMESPACES_COLLECTION = 'system.namespaces';
	const INDEX_COLLECTION = 'system.indexes';

	/**
	 * @var int
	 */
	public $w = 1;

	/**
	 * @var int
	 */
	public $w_timeout = 10000;

	/**
	 * @var string
	 */
	private $name;

	/**
	 * @var MongoClient
	 */
	private $client;

	/**
	 *
	 * @var Manager
	 */
	private $manager;

	/**
	 * @var array
	 */
	private $collections = [];

	/**
	 * @var array
	 */
	private $readPreference;

	/**
	 * Creates a new database
	 *
	 * @param MongoClient $client - Database connection.
	 * @param string $name - Database name.
	 */
	public function __construct(MongoClient $client, $name)
	{
		$this->name = $name;
		$this->client = $client;
		$this->manager = new Manager();
		$this->readPreference = $client->getReadPreference();
	}

	/**
	 * Get the read preference for this database
	 *
	 * @return array
	 */
	public function getReadPreference()
	{
		return $this->readPreference;
	}

	/**
	 * @return MongoClient
	 */
	public function _getClient()
	{
		return $this->client;
	}

	public function _getFullCollectionName($collectionName)
	{
		return $this->name . '.' . $collectionName;
	}

	/**
	 * Gets a collection
	 *
	 * @param string $name - The collection name.
	 *
	 * @return MongoCollection - Returns a new collection object.
	 */
	public function selectCollection($name)
	{
		if (!isset($this->collections[$name]))
		{
			$this->collections[$name] = new MongoCollection($this, $name);
		}

		return $this->collections[$name];
	}

	/**
	 * Execute a database command
	 *
	 * @param array $command - The query to send.

There is no parameter named $command. Was it maybe removed?

	 * @param array $options - This parameter is an associative array of
	 *   the form array("optionname" => boolean, ...).
	 *
	 * @return array - Returns database response.
	 */
	public function command(array $cmd, array $options = [])
	{
		$timeout = MongoCursor::$timeout;
		if (!empty($options['timeout']))
		{
			$timeout = $options['timeout'];
		}

		$protocol = empty($options['protocol']) ? $this->client->_getWriteProtocol() : $options['protocol'];

The method _getWriteProtocol() does not seem to exist on object<Maslosoft\Mangan\Bridge\MongoClient>.

		$response = $protocol->opQuery(
				"{$this->name}.\$cmd", $cmd, 0, -1, 0, $timeout
		);

		return $response['result'][0];
	}

	/**
	 * Fetches toolkit for dealing with files stored in this database
	 *
	 * @param string $prefix - The prefix for the files and chunks
	 *   collections.
	 *
	 * @return MongoGridFS - Returns a new gridfs object for this database.
	 */
	public function getGridFS($prefix = 'fs')
	{
		return new MongoGridFS($this, $prefix);
	}

}