Data\MongoDataSet

Complexity

Total Complexity

15

Size/Duplication

Total Lines	98
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	2

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	getTable()	0	11	2
A	setupMongoClient()	0	16	3
A	setupMongoManager()	0	16	3
A	__construct()	0	21	3
A	tableExists()	0	9	2
A	find()	0	6	1
A	count()	0	5	1

<?php
namespace Data;

function MongofillAutoload($classname)
{
    $classname = str_replace('/', '\\', $classname);
    $classname = ltrim($classname, '\\');
    $namespace = '';
    if($lastNsPos = strrpos($classname, '\\'))
    {
        $namespace = substr($classname, 0, $lastNsPos);
        $classname = substr($classname, $lastNsPos + 1);
    }
    if(strlen($namespace))
    {
        $namespace .= DIRECTORY_SEPARATOR;
    }
    $filename = __DIR__.'/../libs/mongofill/src/'.$namespace.$classname.'.php';
    if(is_readable($filename))
    {
        require $filename;
    }
}

class MongoDataSet extends DataSet
{
    protected $client;
    protected $manager;
    protected $db;
    protected $db_name;

    function __construct($params)

It is generally recommended to explicitly declare the visibility for methods.

    {
        $this->client = null;
        $this->mangaer = null;

The property mangaer does not exist. Did you maybe forget to declare it?

        $this->db = null;
        $this->db_name = null;
        if(class_exists('MongoClient'))
        {
            $this->setupMongoClient($params);
        }
        else if(class_exists('\MongoDB\Driver\Manager'))
        {
            $this->setupMongoManager($params);
        }
        else
        {
            require __DIR__.'/../libs/mongofill/src/functions.php';
            autoLoadHandler('\Data\MongofillAutoload');
            $this->setupMongoClient($params);
        }
    }

    function tableExists($name)

It is generally recommended to explicitly declare the visibility for methods.

    {
        $collections = $this->db->getCollectionNames();
        if(in_array($name, $collections))
        {
            return true;
        }
        return false;
    }

    function getTable($name)

It is generally recommended to explicitly declare the visibility for methods.

    {
        if($this->db !== null)
        {
            return new MongoDataTable($this->db->selectCollection($name));

The method selectCollection cannot be called on $this->db (of type null).

        }
        else
        {
            return new MongoDataTable($this, $name);
        }
    }

    private function setupMongoClient($params)
    {
        if($params === false)
        {
            return;
        }
        if(isset($params['user']))
        {
            $this->client = new \MongoClient('mongodb://'.$params['host'].'/'.$params['db'], array('username'=>$params['user'], 'password'=>$params['pass']));
        }
        else
        {
            $this->client = new \MongoClient('mongodb://'.$params['host'].'/'.$params['db']);
        }
        $this->db = $this->client->selectDB($params['db']);
    }

    private function setupMongoManager($params)
    {
        if($params === false)
        {
            return;
        }
        if(isset($params['user']))
        {
            $this->manager = new \MongoDB\Driver\Manager('mongodb://'.$params['user'].':'.$params['pass'].'@'.$params['host'].'/'.$params['db']);
        }
        else
        {
            $this->manager = new \MongoDB\Driver\Manager('mongodb://'.$params['host'].'/'.$params['db']);
        }
        $this->db_name = $params['db'];
    }

    public function find($query = array(), $fields = array(), $collectionName)
    {
        $namespace = $this->db_name.'.'.$collectionName;
        $dbQuery = new \MongoDB\Driver\Query($query, $fields);
        return $this->manager->executeQuery($namespace, $dbQuery);
    }

    public function count($query = array(), $options = array(), $collectionName)

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

    {
        $cmd = new \MongoDB\Driver\Command(['count'=>$collectionName, 'query'=>$query]);
        return $this->manager->executeCommand($this->db_name, $cmd);
    }
}
/* vim: set tabstop=4 shiftwidth=4 expandtab: */