System\Database

Complexity

Total Complexity

54

Size/Duplication

Total Lines	420
Duplicated Lines	0 %

Importance

Changes	3
Bugs	0	Features	0

27 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	2
A	table()	0	5	1
A	rows()	0	3	1
A	where()	0	14	2
A	isConnected()	0	3	1
A	orderBy()	0	5	1
A	groupBy()	0	5	1
A	connect()	0	18	2
A	join()	0	17	3
A	limit()	0	7	1
A	select()	0	5	1
A	having()	0	11	1
A	connection()	0	3	1
A	query()	0	26	5
A	setField()	0	12	2
A	from()	0	3	1
A	fetchStatmentExtra()	0	28	6
A	addToBindings()	0	9	2
A	reset()	0	25	1
A	fetch()	0	18	2
A	data()	0	16	2
A	fetchStatment()	0	19	4
A	lastId()	0	3	1
A	update()	0	19	3
A	fetchAll()	0	18	2
A	delete()	0	17	3
A	insert()	0	16	2

<?php

namespace System;

use PDO;
use PDOException;
use Exception;

class Database
{
  private $app;

  private static $connection;

  private $table;

  private $rows;

  private $lastId;

  private $data = [];

  private $bindings = [];

  private $selects = [];

  private $joins = [];

  private $wheres = [];

  private $havings = [];

  private $orderBy = [];

  private $limit;

  private $offset;

  private $groupBy = [];

  public function __construct(Application $app)
  {
    $this->app = $app;

    if (!$this->isConnected()) {

      $this->connect();
    }
  }

  private function isConnected()
  {
    return self::$connection instanceof PDO;
  }

  private function connect()
  {
    $data = $this->app->config['db'];

    extract($data);

    try {
      self::$connection = new PDO('mysql:host=' . $server . ';dbname=' . $dbname, $dbuser, $dbpass);

      self::$connection->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);

      self::$connection->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_OBJ);

      self::$connection->exec('SET NAMES utf8');

    } catch (PDOException $e) {

      throw new Exception($e->getMessage());
    }
  }

  public function connection()
  {
    return self::$connection;
  }

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

    return $this;
  }

  public function select(...$select)
  {
    $this->selects = array_merge($this->selects, $select);

    return $this;
  }

  public function join($join, $localId = null, $forginId = null)
  {
    if (!$localId) {

      $localId = trim($join, 's') . '_id';
    }

    if (!$forginId) {

      $forginId = 'id';
    }

    $sql = $join . ' ON ' . $this->table . '.' . $localId . ' = ' . $join . '.' . $forginId;

    $this->joins[] = $sql;

    return $this;
  }

  public function where(...$bindings)
  {
    $sql = array_shift($bindings);

    if (is_array($bindings[0])) {

      $bindings = $bindings[0];
    }

    $this->addToBindings($bindings);

    $this->wheres[] = $sql;

    return $this;
  }

  public function having()
  {
    $bindings = func_get_args();

    $sql = array_shift($bindings);

    $this->addToBindings($bindings);

    $this->havings[] = $sql;

    return $this;
  }

  public function groupBy(...$arguments)
  {
    $this->groupBy = $arguments;

    return $this;
  }

  public function limit($limit, $offset = 0)
  {
    $this->limit = $limit;

    $this->offset = $offset;

    return $this;
  }

  public function rows()
  {
    return $this->rows;
  }

  public function orderBy($orderBy, $sort = 'ASC')
  {
    $this->orderBy = [$orderBy, $sort];

    return $this;
  }

  public function fetch($table = null)
  {
    if ($table) {

      $this->table($table);
    }

    $sql = $this->fetchStatment();

    $sql = $this->fetchStatmentExtra($sql);

    $query = $this->query($sql, $this->bindings);

    $result = $query->fetch();

    $this->rows = $query->rowCount();

    return $result;
  }

  public function fetchAll($table = null)
  {
    if ($table) {

      $this->table($table);
    }

    $sql = $this->fetchStatment();

    $sql = $this->fetchStatmentExtra($sql);

    $query = $this->query($sql, $this->bindings);

    $results = $query->fetchall();

    $this->rows = $query->rowCount();

    return $results;
  }

  private function fetchStatment()
  {
    $sql = 'SELECT ';

    $sql .= $this->selects ? implode(', ', $this->selects) : '*';

    $sql .= ' FROM ' . $this->table . ' ';

    if (!empty($this->joins)) {

      $sql .= 'LEFT JOIN ' . implode(' ', $this->joins);
    }

    if (!empty($this->wheres)) {

      $sql .= ' WHERE ' . implode(' ', $this->wheres);
    }

    return $sql;
  }

  private function fetchStatmentExtra($sql)
  {
    if (!empty($this->havings)) {

      $sql .= ' HAVING ' . implode(' ', $this->havings) . ' ';
    }

    if (!empty($this->orderBy)) {

      $sql .= ' ORDER BY ' . implode(' ', $this->orderBy);
    }

    if ($this->limit) {

      $sql .= ' LIMIT ' . $this->limit;
    }

    if ($this->offset) {

      $sql .= ' OFFSET ' . $this->offset;
    }

    if (!empty($this->groupBy)) {

      $sql .= ' GROUP BY ' . implode(' ', $this->groupBy);
    }

    return $sql;
  }

  public function lastId()
  {
    return $this->lastId;
  }

  public function from($table)
  {
    return $this->table($table);
  }

  public function data($key, $value = null)
  {
    if (is_array($key)) {

      $this->data = array_merge($this->data, $key);

      $this->addToBindings($key);

    } else {

      $this->data[$key] = $value;

      $this->addToBindings($value);
    }

    return $this;
  }

  public function insert($table = null)
  {
    if ($table) {

      $this->table($table);
    }

    $sql = 'INSERT INTO ' . $this->table . ' SET ';

    $sql .= $this->setField();

    $this->query($sql, $this->bindings);

    $this->lastId = $this->connection()->lastInsertId();

    return $this;
  }

  public function update($table = null)
  {
    if ($table) {

      $this->table($table);
    }

    $sql = 'UPDATE ' . $this->table . ' SET ';

    $sql .= $this->setField();

    if (!empty($this->wheres)) {

      $sql .= ' WHERE ' . implode('', $this->wheres);
    }

    $this->query($sql, $this->bindings);

    return $this;
  }

  public function delete($table = null)
  {
    if ($table) {

      $this->table($table);
    }

    $sql = 'DELETE FROM ' . $this->table . ' ';

    if (!empty($this->wheres)) {

      $sql .= ' WHERE ' . implode('', $this->wheres);
    }

    $this->query($sql, $this->bindings);

    return $this;
  }

  private function setField()
  {
    $sql = '';

    foreach ($this->data as $key => $value) {

      $sql .= '`' . $key . '` = ? ,';
    }

    $sql = rtrim($sql, ' ,');

    return $sql;
  }

  private function addToBindings($value)
  {
    if (is_array($value)) {

      $this->bindings = array_merge($this->bindings, array_values($value));

    } else {

      $this->bindings[] = $value;
    }
  }

  public function query(...$bindings)
  {
    $sql = array_shift($bindings);

    if (count($bindings) == 1 and is_array($bindings[0])) {

      $bindings = $bindings[0];
    }

    try {
        $query = $this->connection()->prepare($sql);

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

          $query->bindValue($key + 1, _e($value));
        }

        $query->execute();

        $this->reset();

        return $query;

    } catch (PDOException $e) {

      throw new Exception($e->getMessage());
    }
  }

  private function reset()
  {
    $this->table = null;

    $this->rows = 0;

    $this->data = [];

    $this->bindings = [];

    $this->selects = [];

    $this->joins = [];

    $this->wheres = [];

    $this->havings = [];

    $this->orderBy = [];

    $this->limit = null;

    $this->offset = 0;

    $this->groupBy = [];
  }
}