refatalsakka / framework

Core/System/Database.php

Indentation +123 added lines, -123 removed lines

@@ -8,92 +8,92 @@ 
 
 class Database
 {
-  private $app;
+    private $app;
 
-  private static $connection;
+    private static $connection;
 
-  private $table;
+    private $table;
 
-  private $rows;
+    private $rows;
 
-  private $lastId;
+    private $lastId;
 
-  private $data = [];
+    private $data = [];
 
-  private $bindings = [];
+    private $bindings = [];
 
-  private $selects = [];
+    private $selects = [];
 
-  private $joins = [];
+    private $joins = [];
 
-  private $wheres = [];
+    private $wheres = [];
 
-  private $havings = [];
+    private $havings = [];
 
-  private $orderBy = [];
+    private $orderBy = [];
 
-  private $limit;
+    private $limit;
 
-  private $offset;
+    private $offset;
 
-  private $groupBy = [];
+    private $groupBy = [];
 
-  public function __construct(Application $app)
-  {
+    public function __construct(Application $app)
+    {
     $this->app = $app;
 
     if (! $this->isConnected()) {
-      $this->connect();
+        $this->connect();
+    }
     }
-  }
 
-  private function isConnected()
-  {
+    private function isConnected()
+    {
     return self::$connection instanceof PDO;
-  }
+    }
 
-  private function connect()
-  {
+    private function connect()
+    {
     $data = $this->app->config['db'];
 
     extract($data);
 
     try {
-      self::$connection  = new PDO('mysql:host=' . $server . ';dbname=' . $dbname, $dbuser, $dbpass);
+        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_ERRMODE, PDO::ERRMODE_EXCEPTION);
 
-      self::$connection->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_OBJ);
+        self::$connection->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_OBJ);
 
-      self::$connection->exec('SET NAMES utf8');
+        self::$connection->exec('SET NAMES utf8');
 
     } catch (PDOException $e) {
 
-      throw new Exception($e->getMessage());
+        throw new Exception($e->getMessage());
+    }
     }
-  }
 
-  public function connection()
-  {
+    public function connection()
+    {
     return self::$connection;
-  }
+    }
 
-  public function table($table)
-  {
+    public function table($table)
+    {
     $this->table = $table;
 
     return $this;
-  }
+    }
 
-  public function select(...$select)
-  {
+    public function select(...$select)
+    {
     $this->selects = array_merge($this->selects, $select);
 
     return $this;
-  }
+    }
 
-  public function join($join, $localId = null, $forginId = null)
-  {
+    public function join($join, $localId = null, $forginId = null)
+    {
     if (! $localId)  $localId =  trim($join, 's' ). '_id';
 
     if (! $forginId) $forginId =  'id';
@@ -103,10 +103,10 @@ 
     $this->joins[] = $sql;
 
     return $this;
-  }
+    }
 
-  public function where(...$bindings)
-  {
+    public function where(...$bindings)
+    {
     $sql = array_shift($bindings);
 
     if (is_array($bindings[0])) $bindings = $bindings[0];
@@ -116,10 +116,10 @@ 
     $this->wheres[] = $sql;
 
     return $this;
-  }
+    }
 
-  public function having()
-  {
+    public function having()
+    {
     $bindings = func_get_args();
 
     $sql = array_shift($bindings);
@@ -129,40 +129,40 @@ 
     $this->havings[] = $sql;
 
     return $this;
-  }
+    }
 
-  public function groupBy(...$arguments)
-  {
+    public function groupBy(...$arguments)
+    {
     $this->groupBy = $arguments;
 
     return $this;
-  }
+    }
 
-  public function limit($limit, $offset = 0)
-  {
+    public function limit($limit, $offset = 0)
+    {
     $this->limit = $limit;
 
     $this->offset = $offset;
 
     return $this;
-  }
+    }
 
-  public function rows()
-  {
+    public function rows()
+    {
     return $this->rows;
-  }
+    }
 
-  public function orderBy($orderBy, $sort = 'ASC')
-  {
+    public function orderBy($orderBy, $sort = 'ASC')
+    {
     $this->orderBy = [$orderBy, $sort];
 
     return $this;
-  }
+    }
 
-  public function fetch($table = null)
-  {
+    public function fetch($table = null)
+    {
     if ($table) {
-      $this->table($table);
+        $this->table($table);
     }
 
     $sql = $this->fetchStatment();
@@ -174,12 +174,12 @@ 
     $this->rows = $query->rowCount();
 
     return $result;
-  }
+    }
 
-  public function fetchAll($table = null)
-  {
+    public function fetchAll($table = null)
+    {
     if ($table) {
-      $this->table($table);
+        $this->table($table);
     }
 
     $sql = $this->fetchStatment();
@@ -191,10 +191,10 @@ 
     $this->rows = $query->rowCount();
 
     return $results;
-  }
+    }
 
-  private function fetchStatment()
-  {
+    private function fetchStatment()
+    {
     $sql = 'SELECT ';
 
     $sql .= $this->selects ? implode(', ', $this->selects) : '*';
@@ -203,74 +203,74 @@ 
 
     if (!empty($this->joins)) {
 
-      $sql .= 'LEFT JOIN ' . implode(' ', $this->joins);
+        $sql .= 'LEFT JOIN ' . implode(' ', $this->joins);
     }
 
     if (!empty($this->wheres)) {
 
-      $sql .= ' WHERE ' . implode(' ', $this->wheres);
+        $sql .= ' WHERE ' . implode(' ', $this->wheres);
     }
 
     if (!empty($this->havings)) {
 
-      $sql .= ' HAVING ' . implode(' ', $this->havings) . ' ';
+        $sql .= ' HAVING ' . implode(' ', $this->havings) . ' ';
     }
 
     if (!empty($this->orderBy)) {
 
-      $sql .= ' ORDER BY ' . implode (' ', $this->orderBy);
+        $sql .= ' ORDER BY ' . implode (' ', $this->orderBy);
     }
 
     if ($this->limit) {
 
-      $sql .= ' LIMIT ' . $this->limit;
+        $sql .= ' LIMIT ' . $this->limit;
     }
 
     if ($this->offset) {
 
-      $sql .= ' OFFSET ' . $this->offset;
+        $sql .= ' OFFSET ' . $this->offset;
     }
 
     if (!empty($this->groupBy)) {
-      $sql .= ' GROUP BY ' . implode(' ' , $this->groupBy);
+        $sql .= ' GROUP BY ' . implode(' ' , $this->groupBy);
     }
 
     return $sql;
-  }
+    }
 
-  public function lastId()
-  {
+    public function lastId()
+    {
     return $this->lastId;
-  }
+    }
 
-  public function from($table)
-  {
+    public function from($table)
+    {
     return $this->table($table);
-  }
+    }
 
-  public function data($key, $value = null)
-  {
+    public function data($key, $value = null)
+    {
     if (is_array($key)) {
 
-      $this->data = array_merge($this->data, $key);
+        $this->data = array_merge($this->data, $key);
 
-      $this->addToBindings($key);
+        $this->addToBindings($key);
 
     } else {
 
-      $this->data[$key] = $value;
+        $this->data[$key] = $value;
 
-      $this->addToBindings($value);
+        $this->addToBindings($value);
 
     }
 
     return $this;
-  }
+    }
 
-  public function insert($table = null)
-  {
+    public function insert($table = null)
+    {
     if ($table) {
-      $this->table($table);
+        $this->table($table);
     }
 
     $sql = 'INSERT INTO ' . $this->table . ' SET ';
@@ -282,12 +282,12 @@ 
     $this->lastId = $this->connection()->lastInsertId();
 
     return $this;
-  }
+    }
 
-  public function update($table = null)
-  {
+    public function update($table = null)
+    {
     if ($table) {
-      $this->table($table);
+        $this->table($table);
     }
 
     $sql = 'UPDATE ' . $this->table . ' SET ';
@@ -295,69 +295,69 @@ 
     $sql .= $this->setField();
 
     if (!empty($this->wheres)) {
-      $sql .= ' WHERE ' . implode('', $this->wheres);
+        $sql .= ' WHERE ' . implode('', $this->wheres);
     }
 
     $this->query($sql, $this->bindings);
 
     return $this;
-  }
+    }
 
-  public function delete($table = null)
-  {
+    public function delete($table = null)
+    {
     if ($table) {
-      $this->table($table);
+        $this->table($table);
     }
 
     $sql = 'DELETE FROM ' . $this->table . ' ';
 
     if (!empty($this->wheres)) {
-      $sql .= ' WHERE ' . implode('', $this->wheres);
+        $sql .= ' WHERE ' . implode('', $this->wheres);
     }
 
     $this->query($sql, $this->bindings);
 
     return $this;
-  }
+    }
 
-  private function setField()
-  {
+    private function setField()
+    {
     $sql = '';
 
     foreach($this->data as $key => $value) {
 
-      $sql .= '`' . $key . '` = ? ,';
+        $sql .= '`' . $key . '` = ? ,';
     }
 
     $sql = rtrim($sql, ' ,');
 
     return $sql;
-  }
+    }
 
-  private function addToBindings($value)
-  {
+    private function addToBindings($value)
+    {
     if (is_array($value)) {
 
-      $this->bindings = array_merge($this->bindings, array_values($value));
+        $this->bindings = array_merge($this->bindings, array_values($value));
     } else {
 
-      $this->bindings[] = $value;
+        $this->bindings[] = $value;
+    }
     }
-  }
 
-  public function query(...$bindings)
-  {
+    public function query(...$bindings)
+    {
     $sql = array_shift($bindings);
 
     if (count($bindings) == 1 AND is_array($bindings[0])) {
-      $bindings = $bindings[0];
+        $bindings = $bindings[0];
     }
 
     try {
         $query = $this->connection()->prepare($sql);
 
         foreach ($bindings as $key => $value) {
-          $query->bindValue($key + 1, _e($value));
+            $query->bindValue($key + 1, _e($value));
         }
 
         $query->execute();
@@ -368,12 +368,12 @@ 
 
     } catch (PDOException $e) {
 
-      throw new Exception($e->getMessage());
+        throw new Exception($e->getMessage());
+    }
     }
-  }
 
-  private function reset()
-  {
+    private function reset()
+    {
     $this->table = null;
 
     $this->rows = 0;
@@ -397,5 +397,5 @@ 
     $this->offset = 0;
 
     $this->groupBy = [];
-  }
+    }
 }
\ No newline at end of file