O2System\Database\NoSql\Drivers\MongoDb\QueryBuilder

Complexity

Total Complexity

32

Size/Duplication

Total Lines	297
Duplicated Lines	0 %

Importance

Changes	2
Bugs	0	Features	0

12 Methods

Rating	Name	Duplication	Size	Complexity
A	countAllResults()	0	14	2
A	platformUpdateHandler()	0	22	2
A	platformReplaceBatchHandler()	0	8	2
A	platformReplaceHandler()	0	8	2
A	prepareWhereIn()	0	15	6
A	platformUpdateBatchHandler()	0	33	3
A	prepareWhere()	0	13	5
A	platformInsertHandler()	0	7	2
A	platformDeleteHandler()	0	7	2
A	platformDeleteBatchHandler()	0	7	2
A	countAll()	0	11	2
A	platformInsertBatchHandler()	0	7	2

<?php

/**

 * This file is part of the O2System Framework package.

 *

 * For the full copyright and license information, please view the LICENSE

 * file that was distributed with this source code.

 *

 * @author         Steeve Andrian Salim

 * @copyright      Copyright (c) Steeve Andrian Salim

 */

// ------------------------------------------------------------------------


namespace O2System\Database\NoSql\Drivers\MongoDb;


// ------------------------------------------------------------------------


use O2System\Database\NoSql\Abstracts\AbstractQueryBuilder;

use O2System\Database\NoSql\DataStructures\Query\BuilderCache;


/**

 * Class QueryBuilder

 *

 * @package O2System\Database\Drivers\MySql

 */

class QueryBuilder extends AbstractQueryBuilder

{

    /**

     * QueryBuilder::countAll

     *

     * Returns numbers of query result.

     *

     * @access  public

     * @return int|string

     * @throws \O2System\Spl\Exceptions\RuntimeException

     */

    public function countAll()

    {

        $totalDocuments = 0;


        $result = $this->conn->query($this->builderCache);


        if ($result->count()) {

            $totalDocuments = $result->count();

        }


        return $totalDocuments;

    }


    //--------------------------------------------------------------------


    /**

     * QueryBuilder::countAllResult

     *

     * Returns numbers of total documents.

     *

     * @param bool $reset Whether perform reset Query Builder or not

     *

     * @return int

     * @access   public

     */

    public function countAllResults($reset = true)

    {

        $cursor = $this->conn->server->executeCommand('neo_app',

            new \MongoDb\Driver\Command(['count' => 'posts']));


        $result = current($cursor->toArray());


        $totalDocuments = 0;


        if (isset($result->n)) {

            $totalDocuments = (int)$result->n;

        }


        return $totalDocuments;

    }


    //--------------------------------------------------------------------


    /**

     * QueryBuilder::prepareWhereIn

     *

     * @param string|array $field

     * @param null|mixed   $value

     * @param string       $cacheKey

     */

    protected function prepareWhere($field, $value = null, $cacheKey)

    {

        if (is_array($field)) {

            foreach ($field as $name => $value) {

                $this->prepareWhere($name, $value, $cacheKey);

            }

        } elseif (isset($value)) {


            if ($field === '_id') {

                $value = new \MongoDb\BSON\ObjectID($value);

            }


            $this->builderCache->store($cacheKey, [$field => $value]);

        }

    }


    //--------------------------------------------------------------------


    /**

     * QueryBuilder::prepareWhereIn

     *

     * @param       $field

     * @param array $values

     * @param       $cacheKey

     */

    protected function prepareWhereIn($field, array $values = [], $cacheKey)

    {

        if (is_array($field)) {

            foreach ($field as $name => $values) {

                $this->prepareWhereIn($name, $values, $cacheKey);

            }

        } elseif (count($values)) {


            if ($field === '_id') {

                foreach ($values as $key => $value) {

                    $values[ $key ] = new \MongoDb\BSON\ObjectID($value);

                }

            }


            $this->builderCache->store($cacheKey, [$field => $values]);

        }

    }


    //--------------------------------------------------------------------


    /**

     * QueryBuilder::platformInsertHandler

     *

     * @param BuilderCache $builderCache

     *

     * @return bool

     * @throws \O2System\Spl\Exceptions\RuntimeException

     */

    protected function platformInsertHandler(BuilderCache $builderCache)

    {

        if ($builderCache->from) {

The property from does not exist on O2System\Database\NoSql\DataStructures\Query\BuilderCache. Since you implemented __get, consider adding a @property annotation.

            return $this->conn->execute($builderCache, ['method' => 'insert']);

        }


        return false;

    }


    //--------------------------------------------------------------------


    /**

     * AbstractQueryBuilder::platformInsertBatchHandler

     *

     * @param BuilderCache $builderCache

     *

     * @return bool

     * @throws \O2System\Spl\Exceptions\RuntimeException

     */

    protected function platformInsertBatchHandler(BuilderCache $builderCache)

    {

        if ($builderCache->from) {

The property from does not exist on O2System\Database\NoSql\DataStructures\Query\BuilderCache. Since you implemented __get, consider adding a @property annotation.

            return $this->conn->execute($builderCache, ['method' => 'insert']);

        }


        return false;

    }


    //--------------------------------------------------------------------


    /**

     * QueryBuilder::platformUpdateHandler

     *

     * @param BuilderCache $builderCache

     *

     * @return bool

     * @throws \O2System\Spl\Exceptions\RuntimeException

     */

    protected function platformUpdateHandler(BuilderCache $builderCache)

    {

        if ($builderCache->from) {

The property from does not exist on O2System\Database\NoSql\DataStructures\Query\BuilderCache. Since you implemented __get, consider adding a @property annotation.

            // New sets document

            $collection = $builderCache->from;

            $sets = $builderCache->sets;

The property sets does not exist on O2System\Database\NoSql\DataStructures\Query\BuilderCache. Since you implemented __get, consider adding a @property annotation.

            // Get old document

            $document = $this->get()->first();

            $builderCache = new BuilderCache();

            $builderCache->store('from', $collection);

            $builderCache->store('where', ['_id' => $document->_id]);

The property _id does not exist on O2System\Database\DataObjects\Result\Row. Since you implemented __get, consider adding a @property annotation.

            $document = $document->getArrayCopy();

            unset($document[ '_id' ]);


            $builderCache->store('sets', array_merge($document, $sets));


            return $this->conn->execute($builderCache, ['method' => 'update']);

        }


        return false;

    }


    //--------------------------------------------------------------------


    /**

     * AbstractQueryBuilder::platformUpdateBatchHandler

     *

     * @param BuilderCache $builderCache

     *

     * @return bool

     * @throws \O2System\Spl\Exceptions\RuntimeException

     */

    protected function platformUpdateBatchHandler(BuilderCache $builderCache)

    {

        if ($builderCache->from) {

The property from does not exist on O2System\Database\NoSql\DataStructures\Query\BuilderCache. Since you implemented __get, consider adding a @property annotation.

            // New sets document

            $collection = $builderCache->from;

            $sets = $builderCache->sets;

The property sets does not exist on O2System\Database\NoSql\DataStructures\Query\BuilderCache. Since you implemented __get, consider adding a @property annotation.

            // Get all old documents

            $result = $this->get();


            $builderCache = new BuilderCache();

            $builderCache->store('from', $collection);


            $documentIds = [];

            $documents = [];


            foreach ($result as $document) {

                $document = $this->get()->first();

                $documentIds[] = $document->_id;

The property _id does not exist on O2System\Database\DataObjects\Result\Row. Since you implemented __get, consider adding a @property annotation.

                $document = $document->getArrayCopy();

                unset($document[ '_id' ]);


                $documents[] = array_merge($document, $sets);

            }


            $builderCache->store('whereIn', ['_id' => $documentIds]);

            $builderCache->store('sets', $documents);


            return $this->conn->execute($builderCache, ['method' => 'update']);

        }


        return false;

    }


    //--------------------------------------------------------------------


    /**

     * QueryBuilder::platformReplaceHandler

     *

     * @param BuilderCache $builderCache

     *

     * @return bool

     * @throws \O2System\Spl\Exceptions\RuntimeException

     */

    protected function platformReplaceHandler(BuilderCache $builderCache)

    {

        if ($builderCache->from) {

The property from does not exist on O2System\Database\NoSql\DataStructures\Query\BuilderCache. Since you implemented __get, consider adding a @property annotation.

            return $this->conn->execute($builderCache, ['method' => 'update']);

        }


        return false;

    }


    //--------------------------------------------------------------------


    /**

     * AbstractQueryBuilder::platformReplaceBatchHandler

     *

     * @param BuilderCache $builderCache

     *

     * @return bool

     * @throws \O2System\Spl\Exceptions\RuntimeException

     */

    protected function platformReplaceBatchHandler(BuilderCache $builderCache)

    {

        if ($builderCache->from) {

The property from does not exist on O2System\Database\NoSql\DataStructures\Query\BuilderCache. Since you implemented __get, consider adding a @property annotation.

            return $this->conn->execute($builderCache, ['method' => 'update']);

        }


        return false;

    }


    //--------------------------------------------------------------------


    /**

     * QueryBuilder::platformDeleteHandler

     *

     * @param BuilderCache $builderCache

     *

     * @return bool

     * @throws \O2System\Spl\Exceptions\RuntimeException

     */

    protected function platformDeleteHandler(BuilderCache $builderCache)

    {

        if ($builderCache->from) {

The property from does not exist on O2System\Database\NoSql\DataStructures\Query\BuilderCache. Since you implemented __get, consider adding a @property annotation.

            return $this->conn->execute($builderCache, ['method' => 'delete']);

        }


        return false;

    }


    //--------------------------------------------------------------------


    /**

     * AbstractQueryBuilder::platformDeleteBatchHandler

     *

     * @param BuilderCache $builderCache

     *

     * @return bool

     * @throws \O2System\Spl\Exceptions\RuntimeException

     */

    protected function platformDeleteBatchHandler(BuilderCache $builderCache)

    {

        if ($builderCache->from) {

The property from does not exist on O2System\Database\NoSql\DataStructures\Query\BuilderCache. Since you implemented __get, consider adding a @property annotation.

            return $this->conn->execute($builderCache, ['method' => 'delete']);

        }


        return false;

    }

}