Maslosoft\Mangan\Bridge\MongoClient

Complexity

Total Complexity

4

Size/Duplication

Total Lines	167
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	selectDB()	0	9	2
A	getReadPreference()	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;

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

	const VERSION = 'mangan-shim';
	const DEFAULT_HOST = 'localhost';
	const DEFAULT_PORT = 27017;
	const DEFAULT_DATABASE = 'admin';
	const RP_PRIMARY = 'primary';
	const RP_PRIMARY_PREFERRED = 'primaryPreferred';
	const RP_SECONDARY = 'secondary';
	const RP_SECONDARY_PREFERRED = 'secondaryPreferred';
	const RP_NEAREST = 'nearest';
	const RP_DEFAULT_ACCEPTABLE_LATENCY_MS = 15;
	const DEFAULT_CONNECT_TIMEOUT_MS = 60000;
	const REPL_SET_CACHE_LIFETIME = 15; // in seconds
	const STATE_STARTUP = 0;
	const STATE_PRIMARY = 1;
	const STATE_SECONDARY = 2;
	const STATE_STR_PRIMARY = 'PRIMARY';
	const STATE_STR_SECONDARY = 'SECONDARY';
	const HEALTHY = 1;

	/**
	 * @var boolean
	 */
	public $connected = false;

	/**
	 * @var string
	 */
	public $boolean = false;

	/**
	 * @var string
	 */
	public $status;

	/**
	 * @var boolean
	 */
	public $persistent;

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

The property $options is not used and could be removed.

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

The property $username is not used and could be removed.

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

The property $password is not used and could be removed.

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

The property $database is not used and could be removed.

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

The property $uri is not used and could be removed.

	/**
	 * @var array<string>
	 */
	private $hosts = [];

The property $hosts is not used and could be removed.

	/**
	 * @var array<Protocol>
	 */
	public $protocols = [];

	/**
	 * @var array<Socket>
	 */
	private $sockets = [];

The property $sockets is not used and could be removed.

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

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

The property $replSet is not used and could be removed.

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

The property $replSetStatus is not used and could be removed.

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

The property $replSetConf is not used and could be removed.

	/**
	 * @var array
	 */
	private $readPreference = ['type' => self::RP_PRIMARY];

	/**
	 * @var int
	 */
	private $connectTimeoutMS;

The property $connectTimeoutMS is not used and could be removed.

	/**
	 * Holds a reference to the PRIMARY connection for replSet connections once it
	 * has been established
	 *
	 * @var Mongofill\Protocol
	 */
	private $primaryProtocol;

The property $primaryProtocol is not used and could be removed.

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

	/**
	 * Creates a new database connection object
	 *
	 * @param string $server - The server name. server should have the form:
	 *      mongodb://[username:password@]host1[:port1][,host2[:port2:],...]/db
	 * @param array $options - An array of options for the connection.
	 * @throws MongoConnectionException
	 */
	public function __construct($server = 'mongodb://localhost:27017', array $options = ['connect' => true])
	{
		$this->manager = new Manager($server, $options);
	}

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

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

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

}