Data\MongoDataSet

Complexity

Total Complexity

22

Size/Duplication

Total Lines	151
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	2

Importance

Changes

0

11 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	21	3
A	tableExists()	0	9	2
A	getTable()	0	11	2
A	setupMongoClient()	0	16	3
A	setupMongoManager()	0	16	3
A	find()	0	6	1
A	insert()	0	13	2
A	remove()	0	8	1
A	update()	0	20	3
A	count()	0	6	1
A	runCommand()	0	7	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(), $options = array(), $collectionName)
    {
        $namespace = $this->db_name.'.'.$collectionName;
        $dbQuery = new \MongoDB\Driver\Query($query, $options);
        return $this->manager->executeQuery($namespace, $dbQuery);
    }

    public function insert(&$document, $options = array(), $collectionName)
    {
        $namespace = $this->db_name.'.'.$collectionName;
        $dbWrite = new \MongoDB\Driver\BulkWrite();
        $id = $dbWrite->insert($document);
        $res = $this->manager->executeBulkWrite($namespace, $dbWrite, $options);
        if($res->getInsertedCount() === 1)
        {
            $document['_id'] = $id;
            return true;
        }
        return false;
    }

    public function remove($criteria = array(), array $options = array(), $collectionName)
    {
        $namespace = $this->db_name.'.'.$collectionName;
        $dbWrite = new \MongoDB\Driver\BulkWrite();
        $dbWrite->delete($criteria);
        $res = $this->manager->executeBulkWrite($namespace, $dbWrite, $options);
        return $res->getDeletedCount() >= 1;
    }

    public function update($criteria, $new_object, $options = array(), $collectionName)
    {
        $namespace = $this->db_name.'.'.$collectionName;
        $dbWrite = new \MongoDB\Driver\BulkWrite();
        try {
            $dbWrite->update($criteria, $new_object, $options);
        } catch(\MongoDB\Driver\Exception\InvalidArgumentException $e) {

The class MongoDB\Driver\Exception\InvalidArgumentException does not exist. Did you forget a USE statement, or did you not list all dependencies?

            if(isset($new_object['$set']['']))
            {
                unset($new_object['$set']['']);
                $dbWrite->update($criteria, $new_object, $options);
            }
            else
            {
                throw $e;
            }
        }
        $res = $this->manager->executeBulkWrite($namespace, $dbWrite, $options);
        return $res->getModifiedCount() === 1;
    }

    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]);
        $cursor = $this->manager->executeCommand($this->db_name, $cmd);
        return $cursor->toArray()[0]->n;
    }

    public function runCommand($cmd)
    {
        $cmd = new \MongoDB\Driver\Command($cmd);
        $cursor = $this->manager->executeCommand($this->db_name, $cmd);
        $ret = $cursor->toArray();
        return $ret[0]['ok'];
    }
}
/* vim: set tabstop=4 shiftwidth=4 expandtab: */