Soupmix\SQL

Complexity

Total Complexity

40

Size/Duplication

Total Lines	220
Duplicated Lines	10 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

61.43%

Importance

Changes	2
Bugs	1	Features	0

13 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	connect()	0	13	1
A	create()	0	3	1
A	drop()	0	4	1
A	truncate()	0	3	1
A	createIndexes()	0	3	1
A	insert()	0	8	2
A	update()	0	4	1
A	delete()	0	8	2
A	get()	0	4	1
C	find()	22	75	16
A	query()	0	4	1
C	buildFilter()	0	58	11

<?php

namespace Soupmix;
/*
SQL Adapter
*/

use Doctrine\DBAL\DriverManager;

class SQL implements Base
{
    public $conn = null;
    private $defaults = [
        'db_name'   => 'default',
        'user_name' => '',
        'password'  => '',
        'host'      => '127.0.0.1',
        'port'      => 3306,
        'charset'   => 'utf8',
        'driver'    => 'pdo_mysql',
    ];

    public function __construct($config)
    {
        $config = array_merge($this->defaults, $config);
        $this->connect($config);
    }

    public function connect($config)
    {
        $connectionParams = array(
            'dbname' => $config['db_name'],
            'user' => $config['user_name'],
            'password' => $config['password'],
            'host' => $config['host'],
            'port' => $config['port'],
            'charset' => $config['charset'],
            'driver' => $config['driver'],
        );
        $this->conn = DriverManager::getConnection($connectionParams);
    }

    public function create($collection)
    {
    }

    public function drop($collection)
    {

    }

    public function truncate($collection)
    {
    }

    public function createIndexes($collection, $indexes)
    {
    }

    public function insert($collection, $values)
    {
        $insertion = $this->conn->insert($collection, $values);
        if($insertion !== 0) {
            return $this->conn->lastInsertId();
        }
        return null;
    }

    public function update($collection, $filter, $values)
    {
        return $this->conn->update($collection, $values, $filter);
    }

    public function delete($collection, $filter)
    {
        $numberOfDeletedItems = $this->conn->delete($collection, $filter);
        if ($numberOfDeletedItems>0) {
            return 1;
        }
        return 0;
    }

    public function get($collection, $docId)
    {
        return $this->conn->fetchAssoc('SELECT * FROM '.$collection.' WHERE id = ?', array($docId));
    }

    public function find($collection, $filters, $fields = null, $sort = null, $start = 0, $limit = 25, $debug = false)
    {
        $result = null;
        $queryBuilder = $this->conn->createQueryBuilder();
        $queryBuilder->from($collection);
        if ($filters !== null) {
            foreach ($filters as $key => $value) {
                if (strpos($key, '__')!==false) {
                    $sqlOptions = self::buildFilter([$key=>$value]);

                    if(in_array($sqlOptions['method'], ['in','notIn',''])){

This code seems to be duplicated across your project.

                        $queryBuilder->andWhere(
                            $queryBuilder->expr()->{$sqlOptions['method']}( $sqlOptions['key'], $sqlOptions['value'])
                        );
                    }
                    else{
                        $queryBuilder->andWhere(
                            $sqlOptions['key']
                            . ' ' . $sqlOptions['operand']
                            . ' ' . $queryBuilder->createNamedParameter($sqlOptions['value']));
                    }


                } elseif (strpos($key, '__') === false && is_array($value)) {
                    foreach ($value as $orValue) {
                        $subKey = array_keys($orValue)[0];
                        $subValue = $orValue[$subKey];
                        if (strpos($subKey, '__')!==false) {
                            $sqlOptions = self::buildFilter([$subKey=>$subValue]);

                            if(in_array($sqlOptions['method'], ['in','notIn',''])){

This code seems to be duplicated across your project.

                                $queryBuilder->orWhere(
                                    $queryBuilder->expr()->{$sqlOptions['method']}( $sqlOptions['key'], $sqlOptions['value'])
                                );
                            }
                            else{
                                $queryBuilder->orWhere(
                                    $sqlOptions['key']
                                    . ' ' . $sqlOptions['operand']
                                    . ' ' . $queryBuilder->createNamedParameter($sqlOptions['value']));
                            }
                        } else {
                            $queryBuilder->orWhere($subKey . '=' . $queryBuilder->createNamedParameter($subValue));
                        }
                    }
                } else {
                    $queryBuilder->andWhere($key . "=" . $queryBuilder->createNamedParameter($value));
                }
            }
        }
        if ($sort !== null) {
            $params['sort'] = '';

$params was never initialized. Although not strictly required by PHP, it is generally a good practice to add $params = array(); before regardless.

            foreach ($sort as $sort_key => $sort_dir) {
                if ($params['sort']!='') {
                    $params['sort'] .= ',';
                }
                $queryBuilder->addOrderBy($sort_key, $sort_dir);
            }
        }
        $queryBuilderForResult = clone $queryBuilder;
        $queryBuilder->select(" COUNT(*) AS total ");
        $stmt = $this->conn->executeQuery($queryBuilder->getSql(), $queryBuilder->getParameters());
        $count = $stmt->fetchAll(\PDO::FETCH_ASSOC);
        $numberOfSet = 0;
        if (isset($count[0]['total']) && ($count[0]['total']>0)) {
            $numberOfSet = $count[0]['total'];
            $fields = ($fields === null) ? "*" : $fields;
            $queryBuilderForResult->select($fields)
                ->setFirstResult($start)
                ->setMaxResults($limit);
            $stmt = $this->conn->executeQuery($queryBuilderForResult->getSql(), $queryBuilderForResult->getParameters());
            $result = $stmt->fetchAll(\PDO::FETCH_ASSOC);
        }
        return ['total' => $numberOfSet, 'data' => $result];
    }

    public function query($query)
    {
        // reserved
    }

    public static function buildFilter($filter)
    {
        $key = array_keys($filter)[0];
        $value = $filter[$key];
        $operator = ' = ';
        $method = 'eq';
        if (strpos($key, '__')!==false) {
            preg_match('/__(.*?)$/i', $key, $matches);
            $operator = $matches[1];
            switch ($operator) {
                case 'gte':
                    $operator = ' >= ';
                    $method = 'gte';
                    break;
                case 'gt':
                    $operator = ' > ';
                    $method = 'gt';
                    break;
                case 'lte':
                    $operator = ' <= ';
                    $method = 'lte';
                    break;
                case 'lt':
                    $operator = ' < ';
                    $method = 'lt';
                    break;
                case 'in':
                    $operator = ' IN ';
                    $method = 'in';
                    break;
                case 'nin':
                    $operator = ' NOT IN ';
                    $method = 'notIn';
                    break;
                case 'not':
                    $operator = ' != ';
                    $method = 'not';
                    break;
                case 'wildcard':
                    $operator = ' LIKE ';
                    $method = 'like';
                    $value = str_replace(array('?','*'), array('_','%'), $value);
                    break;
                case 'prefix':
                    $operator = ' LIKE ';
                    $method = 'like';
                    $value = $value.'%';
                    break;
            }
        }
        return [
            'key'       => str_replace($matches[0], '', $key),

The variable $matches does not seem to be defined for all execution paths leading up to this point.

            'operand'   => $operator,
            'method'    => $method,
            'value'     => $value
        ];

    }


}