EmberDb\DocumentManager

Complexity

Total Complexity

11

Size/Duplication

Total Lines	75
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	getDatabasePath()	0	12	4
A	setDatabasePath()	0	4	1
A	insert()	0	5	1
A	insertMany()	0	5	1
A	find()	0	6	1
A	remove()	0	4	1
A	getCollection()	0	9	2

<?php
/**
 * Ember Db - An embeddable document database for php.
 * Copyright (C) 2016 Alexander During
 *
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation, either version 3 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program. If not, see <http://www.gnu.org/licenses/>.
 *
 * @link      http://github.com/alexanderduring/php-ember-db
 * @copyright Copyright (C) 2016 Alexander During
 * @license   http://www.gnu.org/licenses GNU General Public License v3.0
 */

namespace EmberDb;

use EmberDb\Collection\Collection;
use EmberDb\Filter\Filter;

/**
 * The class DocumentManager is responsible for acting as an interface to the database.
 */
class DocumentManager
{
    private $config = array();

    private $collections = [];



    public function getDatabasePath()
    {
        try {
            if (!array_key_exists('database', $this->config)) throw new Exception('The config has no entry with key "database".');
            if (!array_key_exists('path', $this->config['database'])) throw new Exception('The config has no entry with key "database/path".');
        }
        catch (Exception $exception) {
            throw new Exception('Missing config: '.$exception->getMessage());
        }

        return $this->config['database']['path'];
    }



    public function setDatabasePath($path)
    {
        $this->config['database']['path'] = $path;
    }



    public function insert($collectionName, Document $document)
    {
        $collection = $this->getCollection($collectionName);
        $collection->insert($document);
    }



    public function insertMany($collectionName, $documents)
    {
        $collection = $this->getCollection($collectionName);
        $collection->insertMany($documents);
    }



    /**
     * @return Document[]
     */
    public function find(string $collectionName, array $filterData = []): array
    {
        $filter = new Filter($filterData);

        return $this->getCollection($collectionName)->find($filter);
    }



    public function remove($collectionName)
    {
        $this->getCollection($collectionName)->remove();
    }



    private function getCollection(string $collectionName): Collection
    {
        if (!array_key_exists($collectionName, $this->collections)) {
            $collection = new Collection($collectionName, $this->getDatabasePath());
            $this->collections[$collectionName] = $collection;
        }

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