caffeina-core / core

classes/SQL.php

Spacing +73 added lines, -73 removed lines

@@ -25,7 +25,7 @@ 
    * @param  array  $options  Options to pass to the PDO constructor
    * @return SQLConnection    The datasource resource
    */
-  public static function register($name, $dsn, $username=null, $password=null, $options=[]){
+  public static function register($name, $dsn, $username = null, $password = null, $options = []) {
     return self::$connections[$name] = new SQLConnection($dsn, $username, $password, $options);
   }
 
@@ -37,7 +37,7 @@ 
    * @param  array  $options  Options to pass to the PDO constructor
    * @return SQLConnection    The datasource resource
    */
-  public static function connect($dsn, $username=null, $password=null, $options=[]){
+  public static function connect($dsn, $username = null, $password = null, $options = []) {
     return self::register('default', $dsn, $username, $password, $options);
   }
 
@@ -46,8 +46,8 @@ 
    * @param  string $name The datasource name
    * @return bool       `true` if correctly changed
    */
-  public static function defaultTo($name){
-    if (isset(self::$connections[$name])){
+  public static function defaultTo($name) {
+    if (isset(self::$connections[$name])) {
       self::$current = $name;
       return true;
     } else return false;
@@ -58,11 +58,11 @@ 
    * @param  string $name The datasource name, omit for close all of them
    * @return bool       `true` if one or more datasource where closed
    */
-  public static function close($name=null){
+  public static function close($name = null) {
     if ($name === null) {
       foreach (self::$connections as $conn) $conn->close();
       return true;
-    } else if (isset(self::$connections[$name])){
+    } else if (isset(self::$connections[$name])) {
       self::$connections[$name]->close();
       return true;
     } else return false;
@@ -73,7 +73,7 @@ 
    * @param  strinf $name The datasource name
    * @return SQLConnect   The datasource connection
    */
-  public static function using($name){
+  public static function using($name) {
     if (empty(self::$connections[$name])) throw new \Exception("[SQL] Unknown connection named '$name'.");
     return self::$connections[$name];
   }
@@ -84,9 +84,9 @@ 
    * @param  array $args    The method arguments
    * @return mixed          The method return value
    */
-  public static function __callStatic($method, $args){
+  public static function __callStatic($method, $args) {
     if (empty(self::$connections[self::$current])) throw new \Exception("[SQL] No default connection defined.");
-    return call_user_func_array([self::$connections[self::$current],$method],$args);
+    return call_user_func_array([self::$connections[self::$current], $method], $args);
   }
 
 }
@@ -101,7 +101,7 @@ 
             $queries           = [],
             $last_exec_success = true;
 
-  public function __construct($dsn, $username=null, $password=null, $options=[]){
+  public function __construct($dsn, $username = null, $password = null, $options = []) {
     $this->connection = [
       'dsn'        => $dsn,
       'pdo'        => null,
@@ -111,20 +111,20 @@ 
         PDO::ATTR_ERRMODE              => PDO::ERRMODE_EXCEPTION,
         PDO::ATTR_DEFAULT_FETCH_MODE   => PDO::FETCH_ASSOC,
         PDO::ATTR_EMULATE_PREPARES     => true,
-      ],$options),
+      ], $options),
     ];
     // "The auto-commit mode cannot be changed for this driver" SQLite workaround
-    if (strpos($dsn,'sqlite:') === 0) {
+    if (strpos($dsn, 'sqlite:') === 0) {
       $this->connection['options'] = $options;
     }
   }
 
-  public function close(){
+  public function close() {
     $this->connection['pdo'] = null;
   }
 
-  public function connection(){
-    if(empty($this->connection['pdo'])) {
+  public function connection() {
+    if (empty($this->connection['pdo'])) {
       try {
         $this->connection['pdo'] = new PDO(
             $this->connection['dsn'],
@@ -133,26 +133,26 @@ 
             $this->connection['options']
 
         );
-        Event::trigger('core.sql.connect',$this);
-      } catch(Exception $e) {
+        Event::trigger('core.sql.connect', $this);
+      } catch (Exception $e) {
         $this->connection['pdo'] = null;
       }
     }
     return $this->connection['pdo'];
   }
 
-  public function prepare($query){
-    if(!$this->connection()) return false;
+  public function prepare($query) {
+    if (!$this->connection()) return false;
     return isset($this->queries[$query]) ? $this->queries[$query] : ($this->queries[$query] = $this->connection()->prepare($query));
   }
 
-  public function exec($query, $params=[]){
-    if(!$this->connection()) return false;
+  public function exec($query, $params = []) {
+    if (!$this->connection()) return false;
 
-    if (false==is_array($params)) $params = (array)$params;
-    $query = Filter::with('core.sql.query',$query);
-    if($statement = $this->prepare($query)){
-      Event::trigger('core.sql.query',$query,$params,(bool)$statement);
+    if (false == is_array($params)) $params = (array) $params;
+    $query = Filter::with('core.sql.query', $query);
+    if ($statement = $this->prepare($query)) {
+      Event::trigger('core.sql.query', $query, $params, (bool) $statement);
 
       foreach ($params as $key => $val) {
         $type = PDO::PARAM_STR;
@@ -164,10 +164,10 @@ 
           $type = PDO::PARAM_INT;
         }
         // bindValue need a 1-based numeric parameter
-        $statement->bindValue(is_numeric($key)?$key+1:':'.$key, $val, $type);
+        $statement->bindValue(is_numeric($key) ? $key + 1 : ':'.$key, $val, $type);
       }
     } else {
-      Event::trigger('core.sql.error',$query,$params);
+      Event::trigger('core.sql.error', $query, $params);
       return false;
     }
 
@@ -175,18 +175,18 @@ 
     return $statement;
   }
 
-  public function value($query, $params=[], $column=0){
-    if(!$this->connection()) return false;
+  public function value($query, $params = [], $column = 0) {
+    if (!$this->connection()) return false;
 
-    $res = $this->exec($query,$params);
+    $res = $this->exec($query, $params);
     return $res ? $res->fetchColumn($column) : null;
   }
 
-  public function column($query, $params=[], $column=0){
-    if(!$this->connection()) return false;
+  public function column($query, $params = [], $column = 0) {
+    if (!$this->connection()) return false;
 
     $results = [];
-    $res     = $this->exec($query,$params);
+    $res     = $this->exec($query, $params);
 
     if (is_string($column))
       while ($x = $res->fetch(PDO::FETCH_OBJ)) $results[] = $x->$column;
@@ -196,25 +196,25 @@ 
     return $results;
   }
 
-  public function each($query, $params=[], callable $looper = null){
-    if(!$this->connection()) return false;
+  public function each($query, $params = [], callable $looper = null) {
+    if (!$this->connection()) return false;
 
     // ($query,$looper) shorthand
-    if ($looper===null && is_callable($params)) {$looper = $params; $params = [];}
-    if( $res = $this->exec($query,$params) ){
-      if(is_callable($looper))
+    if ($looper === null && is_callable($params)) {$looper = $params;$params = [];}
+    if ($res = $this->exec($query, $params)) {
+      if (is_callable($looper))
         while ($row = $res->fetchObject()) $looper($row);
       else
         return $res->fetchAll(PDO::FETCH_CLASS);
     }
   }
 
-  public function single($query, $params=[], callable $handler = null){
-    if(!$this->connection()) return false;
+  public function single($query, $params = [], callable $handler = null) {
+    if (!$this->connection()) return false;
 
     // ($query,$handler) shorthand
-    if ($handler===null && is_callable($params)) {$handler = $params; $params = [];}
-    if( $res = $this->exec($query,$params) ){
+    if ($handler === null && is_callable($params)) {$handler = $params;$params = [];}
+    if ($res = $this->exec($query, $params)) {
         if (is_callable($handler))
           $handler($res->fetchObject());
         else
@@ -222,76 +222,76 @@ 
     }
   }
 
- public function run($script){
-    if(!$this->connection()) return false;
+ public function run($script) {
+    if (!$this->connection()) return false;
 
-    $sql_path = Options::get('database.sql.path',APP_DIR.'/sql');
-    $sql_sep  = Options::get('database.sql.separator',';');
-    if (is_file($f = "$sql_path/$script.sql")){
+    $sql_path = Options::get('database.sql.path', APP_DIR.'/sql');
+    $sql_sep  = Options::get('database.sql.separator', ';');
+    if (is_file($f = "$sql_path/$script.sql")) {
         $result = true;
-        foreach(explode($sql_sep,file_get_contents($f)) as $statement) {
+        foreach (explode($sql_sep, file_get_contents($f)) as $statement) {
             $result = $this->exec($statement);
         }
         return $result;
     } else return false;
   }
 
-  public function all($query, $params=[], callable $looper = null){
-   if(!$this->connection()) return false;
-   return $this->each($query,$params,$looper);
+  public function all($query, $params = [], callable $looper = null) {
+   if (!$this->connection()) return false;
+   return $this->each($query, $params, $looper);
   }
 
-  public function delete($table, $pks=null, $pk='id', $inclusive=true){
-    if(!$this->connection()) return false;
+  public function delete($table, $pks = null, $pk = 'id', $inclusive = true) {
+    if (!$this->connection()) return false;
 
-    if (null===$pks) {
+    if (null === $pks) {
       return $this->exec("DELETE FROM `$table`");
     } else {
-      return $this->exec("DELETE FROM `$table` WHERE `$pk` ".($inclusive ? "" : "NOT " )."IN (" . implode( ',', array_fill_keys( (array)$pks, '?' ) ) . ")",(array)$pks);
+      return $this->exec("DELETE FROM `$table` WHERE `$pk` ".($inclusive ? "" : "NOT ")."IN (".implode(',', array_fill_keys((array) $pks, '?')).")", (array) $pks);
     }
   }
 
-  public function insert($table, $data){
-    if(!$this->connection()) return false;
+  public function insert($table, $data) {
+    if (!$this->connection()) return false;
 
-    if (false==is_array($data)) $data = (array)$data;
+    if (false == is_array($data)) $data = (array) $data;
     $k = array_keys($data);
     asort($k);
     $pk = $k;
-    array_walk($pk,function(&$e){ $e = ':'.$e;});
-    $q = "INSERT INTO `$table` (`".implode('`,`',$k)."`) VALUES (".implode(',',$pk).")";
-    $this->exec($q,$data);
+    array_walk($pk, function(&$e) { $e = ':'.$e;});
+    $q = "INSERT INTO `$table` (`".implode('`,`', $k)."`) VALUES (".implode(',', $pk).")";
+    $this->exec($q, $data);
     return $this->last_exec_success ? $this->connection()->lastInsertId() : false;
   }
 
-  public function updateWhere($table, $data, $where, $pk='id'){
-    if(!$this->connection()) return false;
+  public function updateWhere($table, $data, $where, $pk = 'id') {
+    if (!$this->connection()) return false;
 
-    if (false==is_array($data)) $data = (array)$data;
+    if (false == is_array($data)) $data = (array) $data;
     if (empty($data)) return false;
     $k = array_keys($data);
     asort($k);
 
     // Remove primary key from SET
-    array_walk($k,function(&$e) use ($pk) {
-      $e = ($e==$pk) ? null : "`$e`=:$e";
+    array_walk($k, function(&$e) use ($pk) {
+      $e = ($e == $pk) ? null : "`$e`=:$e";
     });
 
-    $q = "UPDATE `$table` SET ".implode(', ',array_filter($k))." WHERE $where";
-    $this->exec($q,$data);
+    $q = "UPDATE `$table` SET ".implode(', ', array_filter($k))." WHERE $where";
+    $this->exec($q, $data);
     return $this->last_exec_success;
   }
 
-  public function update($table, $data, $pk='id', $extra_where=''){
+  public function update($table, $data, $pk = 'id', $extra_where = '') {
     return $this->updateWhere($table, $data, "`$pk`=:$pk $extra_where", $pk);
   }
 
-  public function insertOrUpdate($table, $data=[], $pk='id', $extra_where=''){
-    if(!$this->connection()) return false;
+  public function insertOrUpdate($table, $data = [], $pk = 'id', $extra_where = '') {
+    if (!$this->connection()) return false;
 
-    if (false==is_array($data)) $data = (array)$data;
+    if (false == is_array($data)) $data = (array) $data;
     if (empty($data[$pk])) return $this->insert($table, $data);
-    if( (string) $this->value("SELECT `$pk` FROM `$table` WHERE `$pk`=? LIMIT 1", [$data[$pk]]) === (string) $data[$pk] ){
+    if ((string) $this->value("SELECT `$pk` FROM `$table` WHERE `$pk`=? LIMIT 1", [$data[$pk]]) === (string) $data[$pk]) {
         return $this->update($table, $data, $pk, $extra_where);
     } else {
         return $this->insert($table, $data);

Braces +113 added lines, -64 removed lines

@@ -25,7 +25,7 @@ 
    * @param  array  $options  Options to pass to the PDO constructor
    * @return SQLConnection    The datasource resource
    */
-  public static function register($name, $dsn, $username=null, $password=null, $options=[]){
+  public static function register($name, $dsn, $username=null, $password=null, $options=[]) {
     return self::$connections[$name] = new SQLConnection($dsn, $username, $password, $options);
   }
 
@@ -37,7 +37,7 @@ 
    * @param  array  $options  Options to pass to the PDO constructor
    * @return SQLConnection    The datasource resource
    */
-  public static function connect($dsn, $username=null, $password=null, $options=[]){
+  public static function connect($dsn, $username=null, $password=null, $options=[]) {
     return self::register('default', $dsn, $username, $password, $options);
   }
 
@@ -46,11 +46,13 @@ 
    * @param  string $name The datasource name
    * @return bool       `true` if correctly changed
    */
-  public static function defaultTo($name){
-    if (isset(self::$connections[$name])){
+  public static function defaultTo($name) {
+    if (isset(self::$connections[$name])) {
       self::$current = $name;
       return true;
-    } else return false;
+    } else {
+      return false;
+    }
   }
 
   /**
@@ -58,14 +60,16 @@ 
    * @param  string $name The datasource name, omit for close all of them
    * @return bool       `true` if one or more datasource where closed
    */
-  public static function close($name=null){
+  public static function close($name=null) {
     if ($name === null) {
       foreach (self::$connections as $conn) $conn->close();
       return true;
-    } else if (isset(self::$connections[$name])){
+    } else if (isset(self::$connections[$name])) {
       self::$connections[$name]->close();
       return true;
-    } else return false;
+    } else {
+      return false;
+    }
   }
 
   /**
@@ -73,8 +77,10 @@ 
    * @param  strinf $name The datasource name
    * @return SQLConnect   The datasource connection
    */
-  public static function using($name){
-    if (empty(self::$connections[$name])) throw new \Exception("[SQL] Unknown connection named '$name'.");
+  public static function using($name) {
+    if (empty(self::$connections[$name])) {
+      throw new \Exception("[SQL] Unknown connection named '$name'.");
+    }
     return self::$connections[$name];
   }
 
@@ -84,8 +90,10 @@ 
    * @param  array $args    The method arguments
    * @return mixed          The method return value
    */
-  public static function __callStatic($method, $args){
-    if (empty(self::$connections[self::$current])) throw new \Exception("[SQL] No default connection defined.");
+  public static function __callStatic($method, $args) {
+    if (empty(self::$connections[self::$current])) {
+      throw new \Exception("[SQL] No default connection defined.");
+    }
     return call_user_func_array([self::$connections[self::$current],$method],$args);
   }
 
@@ -101,7 +109,7 @@ 
             $queries           = [],
             $last_exec_success = true;
 
-  public function __construct($dsn, $username=null, $password=null, $options=[]){
+  public function __construct($dsn, $username=null, $password=null, $options=[]) {
     $this->connection = [
       'dsn'        => $dsn,
       'pdo'        => null,
@@ -119,11 +127,11 @@ 
     }
   }
 
-  public function close(){
+  public function close() {
     $this->connection['pdo'] = null;
   }
 
-  public function connection(){
+  public function connection() {
     if(empty($this->connection['pdo'])) {
       try {
         $this->connection['pdo'] = new PDO(
@@ -141,17 +149,23 @@ 
     return $this->connection['pdo'];
   }
 
-  public function prepare($query){
-    if(!$this->connection()) return false;
+  public function prepare($query) {
+    if(!$this->connection()) {
+      return false;
+    }
     return isset($this->queries[$query]) ? $this->queries[$query] : ($this->queries[$query] = $this->connection()->prepare($query));
   }
 
-  public function exec($query, $params=[]){
-    if(!$this->connection()) return false;
+  public function exec($query, $params=[]) {
+    if(!$this->connection()) {
+      return false;
+    }
 
-    if (false==is_array($params)) $params = (array)$params;
+    if (false==is_array($params)) {
+      $params = (array)$params;
+    }
     $query = Filter::with('core.sql.query',$query);
-    if($statement = $this->prepare($query)){
+    if($statement = $this->prepare($query)) {
       Event::trigger('core.sql.query',$query,$params,(bool)$statement);
 
       foreach ($params as $key => $val) {
@@ -175,74 +189,93 @@ 
     return $statement;
   }
 
-  public function value($query, $params=[], $column=0){
-    if(!$this->connection()) return false;
+  public function value($query, $params=[], $column=0) {
+    if(!$this->connection()) {
+      return false;
+    }
 
     $res = $this->exec($query,$params);
     return $res ? $res->fetchColumn($column) : null;
   }
 
-  public function column($query, $params=[], $column=0){
-    if(!$this->connection()) return false;
+  public function column($query, $params=[], $column=0) {
+    if(!$this->connection()) {
+      return false;
+    }
 
     $results = [];
     $res     = $this->exec($query,$params);
 
-    if (is_string($column))
-      while ($x = $res->fetch(PDO::FETCH_OBJ)) $results[] = $x->$column;
-    else
-      while ($x = $res->fetchColumn($column)) $results[] = $x;
+    if (is_string($column)) {
+          while ($x = $res->fetch(PDO::FETCH_OBJ)) $results[] = $x->$column;
+    } else {
+          while ($x = $res->fetchColumn($column)) $results[] = $x;
+    }
 
     return $results;
   }
 
-  public function each($query, $params=[], callable $looper = null){
-    if(!$this->connection()) return false;
+  public function each($query, $params=[], callable $looper = null) {
+    if(!$this->connection()) {
+      return false;
+    }
 
     // ($query,$looper) shorthand
     if ($looper===null && is_callable($params)) {$looper = $params; $params = [];}
-    if( $res = $this->exec($query,$params) ){
-      if(is_callable($looper))
-        while ($row = $res->fetchObject()) $looper($row);
-      else
-        return $res->fetchAll(PDO::FETCH_CLASS);
+    if( $res = $this->exec($query,$params) ) {
+      if(is_callable($looper)) {
+              while ($row = $res->fetchObject()) $looper($row);
+      } else {
+              return $res->fetchAll(PDO::FETCH_CLASS);
+      }
     }
   }
 
-  public function single($query, $params=[], callable $handler = null){
-    if(!$this->connection()) return false;
+  public function single($query, $params=[], callable $handler = null) {
+    if(!$this->connection()) {
+      return false;
+    }
 
     // ($query,$handler) shorthand
     if ($handler===null && is_callable($params)) {$handler = $params; $params = [];}
-    if( $res = $this->exec($query,$params) ){
-        if (is_callable($handler))
-          $handler($res->fetchObject());
-        else
-          return $res->fetchObject();
+    if( $res = $this->exec($query,$params) ) {
+        if (is_callable($handler)) {
+                  $handler($res->fetchObject());
+        } else {
+                  return $res->fetchObject();
+        }
     }
   }
 
- public function run($script){
-    if(!$this->connection()) return false;
+ public function run($script) {
+    if(!$this->connection()) {
+      return false;
+    }
 
     $sql_path = Options::get('database.sql.path',APP_DIR.'/sql');
     $sql_sep  = Options::get('database.sql.separator',';');
-    if (is_file($f = "$sql_path/$script.sql")){
+    if (is_file($f = "$sql_path/$script.sql")) {
         $result = true;
         foreach(explode($sql_sep,file_get_contents($f)) as $statement) {
             $result = $this->exec($statement);
         }
         return $result;
-    } else return false;
+    } else {
+      return false;
+    }
   }
 
-  public function all($query, $params=[], callable $looper = null){
-   if(!$this->connection()) return false;
+  public function all($query, $params=[], callable $looper = null) {
+   if(!$this->connection()) {
+     return false;
+   }
    return $this->each($query,$params,$looper);
   }
 
-  public function delete($table, $pks=null, $pk='id', $inclusive=true){
-    if(!$this->connection()) return false;
+  public function delete($table, $pks=null, $pk='id', $inclusive=true) {
+    if(!$this->connection()) {
+      return false;
+    }
 
     if (null===$pks) {
       return $this->exec("DELETE FROM `$table`");
@@ -251,10 +284,14 @@ 
     }
   }
 
-  public function insert($table, $data){
-    if(!$this->connection()) return false;
+  public function insert($table, $data) {
+    if(!$this->connection()) {
+      return false;
+    }
 
-    if (false==is_array($data)) $data = (array)$data;
+    if (false==is_array($data)) {
+      $data = (array)$data;
+    }
     $k = array_keys($data);
     asort($k);
     $pk = $k;
@@ -264,11 +301,17 @@ 
     return $this->last_exec_success ? $this->connection()->lastInsertId() : false;
   }
 
-  public function updateWhere($table, $data, $where, $pk='id'){
-    if(!$this->connection()) return false;
+  public function updateWhere($table, $data, $where, $pk='id') {
+    if(!$this->connection()) {
+      return false;
+    }
 
-    if (false==is_array($data)) $data = (array)$data;
-    if (empty($data)) return false;
+    if (false==is_array($data)) {
+      $data = (array)$data;
+    }
+    if (empty($data)) {
+      return false;
+    }
     $k = array_keys($data);
     asort($k);
 
@@ -282,16 +325,22 @@ 
     return $this->last_exec_success;
   }
 
-  public function update($table, $data, $pk='id', $extra_where=''){
+  public function update($table, $data, $pk='id', $extra_where='') {
     return $this->updateWhere($table, $data, "`$pk`=:$pk $extra_where", $pk);
   }
 
-  public function insertOrUpdate($table, $data=[], $pk='id', $extra_where=''){
-    if(!$this->connection()) return false;
+  public function insertOrUpdate($table, $data=[], $pk='id', $extra_where='') {
+    if(!$this->connection()) {
+      return false;
+    }
 
-    if (false==is_array($data)) $data = (array)$data;
-    if (empty($data[$pk])) return $this->insert($table, $data);
-    if( (string) $this->value("SELECT `$pk` FROM `$table` WHERE `$pk`=? LIMIT 1", [$data[$pk]]) === (string) $data[$pk] ){
+    if (false==is_array($data)) {
+      $data = (array)$data;
+    }
+    if (empty($data[$pk])) {
+      return $this->insert($table, $data);
+    }
+    if( (string) $this->value("SELECT `$pk` FROM `$table` WHERE `$pk`=? LIMIT 1", [$data[$pk]]) === (string) $data[$pk] ) {
         return $this->update($table, $data, $pk, $extra_where);
     } else {
         return $this->insert($table, $data);