Inji\Db\InjiStorage\Query

Complexity

Total Complexity

14

Size/Duplication

Total Lines	59
Duplicated Lines	13.56 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
A	setDbOption()	0	3	1
A	where()	8	8	3
A	setTable()	0	3	1
A	select()	0	6	2
A	insert()	0	6	2
A	update()	0	6	2
A	delete()	0	6	2

<?php
/**
 * Created by IntelliJ IDEA.
 * User: inji
 * Date: 07.01.2018
 * Time: 16:39
 */

namespace Inji\Db\InjiStorage;

use \Inji\Tools;

class Query implements \Inji\Db\DriverQuery {
    /**
     * @var \Inji\Db\InjiStorage
     */
    public $connection;
    public $whereArray = [];
    public $table = [];
    public $dbOptions = [];

    public function __construct($connection) {
        $this->connection = $connection;
    }

    public function setDbOption($name, $value) {
        $this->dbOptions[$name] = $value;
    }

    public function where($col, $value = true, $comparision = '=', $concatenation = 'AND') {
        if (is_array($col) && !Tools::isAssoc($col)) {
            $this->whereArray[] = $col;
        } else {
            $this->whereArray[] = [$col, $value, $comparision, $concatenation];
        }
        return $this;
    }

    public function setTable($tableName) {
        $this->table = $tableName;
    }

    public function select($tableName = null) {
        if (!$tableName) {

The expression $tableName of type string|null is loosely compared to false; this is ambiguous if the string can be empty. You might want to explicitly use === null instead.

            $tableName = $this->table;
        }
        return new Result($this->connection->getItems($tableName, $this->whereArray, $this->dbOptions), $this);
    }

    public function insert(string $tableName, array $values) {
        if (!$tableName) {
            $tableName = $this->table;
        }
        return $this->connection->addItem($tableName, $values, $this->dbOptions);
    }

    public function update(string $tableName, array $values) {
        if (!$tableName) {
            $tableName = $this->table;
        }
        return $this->connection->updateItems($tableName, $this->whereArray, $values, $this->dbOptions);
    }

    public function delete(string $tableName='') {
        if (!$tableName) {
            $tableName = $this->table;
        }
        return $this->connection->deleteItems($tableName, $this->whereArray, $this->dbOptions);
    }

}