maikees / moc-orm

lib/Query.php

Spacing +1 added lines, -1 removed lines

@@ -202,7 +202,7 @@
         if (substr_count($last, 'ORDER BY') > 0) {
             $sql .= isset($this->_group) ? $this->_group : '';
             $sql .= $last;
-        } else {
+        }else {
             $sql .= $last;
             $sql .= isset($this->_group) ? $this->_group : '';
         }

Braces +36 added lines, -12 removed lines

@@ -48,8 +48,12 @@ 
      */
     final public function where($parameter = null, $value = null)
     {
-        if (!is_string($parameter)) throw new \Exception('Invalid parameter type.');
-        if (!isset($value)) throw new \Exception('This value not set.');
+        if (!is_string($parameter)) {
+         throw new \Exception('Invalid parameter type.');
+        }
+        if (!isset($value)) {
+         throw new \Exception('This value not set.');
+        }
 
         $this->_current_custom_query[] = " WHERE $parameter = ? ";
         $this->_current_custom_query_values[] = $value;
@@ -66,8 +70,12 @@ 
      */
     final public function and ($parameter = null, $value = null)
     {
-        if (!is_string($parameter)) throw new \Exception('Invalid parameter type.');
-        if (!isset($value)) throw new \Exception('This value not set.');
+        if (!is_string($parameter)) {
+         throw new \Exception('Invalid parameter type.');
+        }
+        if (!isset($value)) {
+         throw new \Exception('This value not set.');
+        }
 
         $this->_current_custom_query[] = " AND $parameter = ? ";
         $this->_current_custom_query_values[] = $value;
@@ -84,8 +92,12 @@ 
      */
     final public function or ($parameter = null, $value = null)
     {
-        if (!is_string($parameter)) throw new \Exception('Invalid parameter type.');
-        if (!isset($value)) throw new \Exception('This value not set.');
+        if (!is_string($parameter)) {
+         throw new \Exception('Invalid parameter type.');
+        }
+        if (!isset($value)) {
+         throw new \Exception('This value not set.');
+        }
 
         $this->_current_custom_query[] = " OR $parameter = ? ";
         $this->_current_custom_query_values[] = $value;
@@ -102,10 +114,18 @@ 
      */
     final public function orderBy($parameter = null, $value = null)
     {
-        if (!is_string($parameter)) throw new \Exception('Invalid parameter type.');
-        if (!isset($value)) throw new \Exception('This value not set.');
-        if (!is_string($value)) throw new \Exception('Don\'t accepted this type on value.');
-        if ($value != 'ASC' AND $value != 'DESC') throw new \Exception('This value not found.');
+        if (!is_string($parameter)) {
+         throw new \Exception('Invalid parameter type.');
+        }
+        if (!isset($value)) {
+         throw new \Exception('This value not set.');
+        }
+        if (!is_string($value)) {
+         throw new \Exception('Don\'t accepted this type on value.');
+        }
+        if ($value != 'ASC' AND $value != 'DESC') {
+         throw new \Exception('This value not found.');
+        }
 
         $this->_current_custom_query[] = " ORDER BY $parameter $value";
 
@@ -119,7 +139,9 @@ 
      */
     final public function custom($partialQuery)
     {
-        if (!is_string($partialQuery)) throw new \Exception('Invalid parameter type.');
+        if (!is_string($partialQuery)) {
+         throw new \Exception('Invalid parameter type.');
+        }
 
         $this->_current_custom_query[] = $partialQuery;
 
@@ -178,7 +200,9 @@ 
      */
     final public function groupBy($colunm)
     {
-        if (!is_string($colunm)) throw new \Exception('The colunm isn\'t an string.');
+        if (!is_string($colunm)) {
+         throw new \Exception('The colunm isn\'t an string.');
+        }
 
         $this->_group = " GROUP BY $colunm ";
 

lib/support/Transaction.php

Spacing +2 added lines, -2 removed lines

@@ -38,7 +38,7 @@ 
         if (!is_callable($closure)) {
             throw new \Exception("Transaction must have a callable as parameter.");
 
-        } else {
+        }else {
             $connection = $this->getConnection();
 
             try {
@@ -48,7 +48,7 @@ 
 
                 if ($this->results === false) {
                     $connection->rollbackTransaction();
-                } else {
+                }else {
                     $connection->commitTransaction();
                 }
 

lib/ConnectionManager.php

Braces +24 added lines, -8 removed lines

@@ -41,7 +41,9 @@ 
      */
     public static function initialize($config = null)
     {
-        if (!self::$_instance) self::$_instance = new ConnectionManager();
+        if (!self::$_instance) {
+         self::$_instance = new ConnectionManager();
+        }
 
         if (is_callable($config)) {
 
@@ -63,9 +65,15 @@ 
     {
         $instance = self::$_instance;
 
-        if (!is_string($connectionName) || empty($connectionName)) throw new \Exception("Invalid connection name.");
-        if (!$instance->hasConnection($connectionName)) throw new \Exception("The connection name $connectionName is not set.");
-        if ($instance->hasOpen($connectionName)) throw new \Exception('This connection is actived.');
+        if (!is_string($connectionName) || empty($connectionName)) {
+         throw new \Exception("Invalid connection name.");
+        }
+        if (!$instance->hasConnection($connectionName)) {
+         throw new \Exception("The connection name $connectionName is not set.");
+        }
+        if ($instance->hasOpen($connectionName)) {
+         throw new \Exception('This connection is actived.');
+        }
 
         $instance->_currentConnectionName = $connectionName;
 
@@ -95,7 +103,9 @@ 
         if (empty($this->currentConnection)) {
             $configs = ($this->Config) ? $this->Config->getConfigs() : null;
 
-            if (count($configs) == 0) throw new \Exception('No connections are available.');
+            if (count($configs) == 0) {
+             throw new \Exception('No connections are available.');
+            }
 
             $default = $this->Config->getDefault();
 
@@ -121,9 +131,13 @@ 
     {
         $instance = self::initialize();
 
-        if (!is_string($connectionName)) throw new \Exception("Invalid connection name.");
+        if (!is_string($connectionName)) {
+         throw new \Exception("Invalid connection name.");
+        }
 
-        if (!$instance->hasConnection($connectionName)) throw new \Exception("The connection name $connectionName is not set.");
+        if (!$instance->hasConnection($connectionName)) {
+         throw new \Exception("The connection name $connectionName is not set.");
+        }
 
         if (!$instance->hasOpen($connectionName)) {
             if ($open) {
@@ -154,7 +168,9 @@ 
      */
     public function getAllActive()
     {
-        if (!$this->hasInstance()) throw new \Exception('This instance isnt\'t initialized');
+        if (!$this->hasInstance()) {
+         throw new \Exception('This instance isnt\'t initialized');
+        }
 
         return $this->connections;
     }

Spacing +2 added lines, -3 removed lines

@@ -101,8 +101,7 @@ 
             $default = $this->Config->getDefault();
 
             $name = is_null($default) ?
-                @end(array_keys($configs ?: [])) :
-                $default;
+                @end(array_keys($configs ?: [])) : $default;
 
             $this->open($name);
         }
@@ -133,7 +132,7 @@ 
                 } catch (\Exception $e) {
                     throw $e;
                 }
-            } else {
+            }else {
 
                 throw new \Exception("This connection isn't actived.");
             }

lib/Config.php

Spacing +2 added lines, -2 removed lines

@@ -149,7 +149,7 @@ 
                 'password' => $this->_password[$connectionName],
                 'charset' => $this->_charset[$connectionName],
                 'schema' => $this->_schema[$connectionName]];
-        } else {
+        }else {
             throw new \Exception("The connection name $connectionName is not set.");
         }
 
@@ -183,7 +183,7 @@ 
 
         $connectionSettings = (object)$connectionSettings;
 
-        $this->_connectionString[$connectionName] = $this->_driver[$connectionName].":host=$connectionSettings->host;dbname=$connectionSettings->database;port=$connectionSettings->port;";
+        $this->_connectionString[$connectionName] = $this->_driver[$connectionName] . ":host=$connectionSettings->host;dbname=$connectionSettings->database;port=$connectionSettings->port;";
 
         return $this;
     }

Braces +24 added lines, -8 removed lines

@@ -79,15 +79,27 @@ 
         $defaultSchema = null)
     {
         #Begin: Verify if all parameters send is valid.
-        if (!is_string($driver) || !in_array($driver, self::DRIVERS)) throw new \Exception("The driver $driver don't supported.");
-        if (!is_string($username) || empty($username)) throw new \Exception("Invalid username.");
-        if (!is_string($password) || empty($password)) throw new \Exception("Invalid password.");
-        if (!is_string($host) || empty($host)) throw new \Exception("Invalid host.");
-        if (!is_string($database) || empty($database)) throw new \Exception("Invalid database name.");
+        if (!is_string($driver) || !in_array($driver, self::DRIVERS)) {
+         throw new \Exception("The driver $driver don't supported.");
+        }
+        if (!is_string($username) || empty($username)) {
+         throw new \Exception("Invalid username.");
+        }
+        if (!is_string($password) || empty($password)) {
+         throw new \Exception("Invalid password.");
+        }
+        if (!is_string($host) || empty($host)) {
+         throw new \Exception("Invalid host.");
+        }
+        if (!is_string($database) || empty($database)) {
+         throw new \Exception("Invalid database name.");
+        }
         $this->validatesConnectionName($connectionName);
 
         $port = is_null($port) ? '' : (int)$port;
-        if (!is_null($port) && !is_int($port)) throw new \Exception("Invalid port format.");
+        if (!is_null($port) && !is_int($port)) {
+         throw new \Exception("Invalid port format.");
+        }
         #Constructor of the connection string
         $this->_connectionString[$connectionName] = "$driver:host=$host;dbname=$database;port=$port;";
         $this->_username[$connectionName] = $username;
@@ -176,8 +188,12 @@ 
      */
     public function setSettings($connectionName, $connectionSettings)
     {
-        if (!is_array($connectionSettings)) throw new \Exception('Invalid format connectionSettings');
-        if (empty($this->_driver[$connectionName])) throw new \Exception('Driver not set.');
+        if (!is_array($connectionSettings)) {
+         throw new \Exception('Invalid format connectionSettings');
+        }
+        if (empty($this->_driver[$connectionName])) {
+         throw new \Exception('Driver not set.');
+        }
 
         $this->validatesConnectionName($connectionName);
 

lib/Model.php

Spacing +7 added lines, -7 removed lines

@@ -74,7 +74,7 @@ 
 
             $this->Result = new Result();
 
-            if($this->Result && !$this->Result->getResults()) {
+            if ($this->Result && !$this->Result->getResults()) {
                 $clone = clone $this;
                 $this->Result->setResults($clone);
             }
@@ -188,7 +188,7 @@ 
             $this->_newData[] = $this->{$key};
 
             $update = true;
-        } else {
+        }else {
             $logger = [
                 'function' => 'Save',
                 'next' => $this->_data,
@@ -212,7 +212,7 @@ 
         $insert = $this->Connection->getConnection()->prepare($sql);
         $this->burnError($insert);
 
-        $this->_newData = array_map(function ($data) {
+        $this->_newData = array_map(function($data) {
             if (is_bool($data) and $data === false) $data = 0;
 
             return $data;
@@ -287,7 +287,7 @@ 
 
         $instance = self::$_instance;
 
-        if (is_callable($this->triggerBefore)) ($this->triggerBefore)();;
+        if (is_callable($this->triggerBefore)) ($this->triggerBefore)(); ;
 
         $start = microtime(true);
 
@@ -310,7 +310,7 @@ 
 
             return true;
         }
-        else{ return false; };
+        else { return false; };
     }
 
     /**
@@ -455,7 +455,7 @@ 
 
         $done = $instance->done();
 
-        if(count($done) > 0) {
+        if (count($done) > 0) {
             $done = $done[0];
 
             $clone = clone $done;
@@ -557,7 +557,7 @@ 
 
         if ($match) {
             $this->_data = $objetos = $consulta->fetchAll(\PDO::FETCH_CLASS, get_called_class());
-        } else {
+        }else {
             $objetos = $consulta->rowCount();
         }
 

Braces +75 added lines, -27 removed lines

@@ -68,7 +68,9 @@ 
             }
 
             if (!is_null($array)) {
-                if (!is_array($array)) throw new \InvalidArgumentException('Accept only array from object');
+                if (!is_array($array)) {
+                 throw new \InvalidArgumentException('Accept only array from object');
+                }
 
                 $this->_data = $array;
                 $this->_newData = $array;
@@ -102,9 +104,13 @@ 
      */
     public function __get($name)
     {
-        if (strtolower($name) == 'errors') return Error::instance();
+        if (strtolower($name) == 'errors') {
+         return Error::instance();
+        }
 
-        if (!key_exists($name, $this->_data)) throw new \Exception("The attribute $name not found.");
+        if (!key_exists($name, $this->_data)) {
+         throw new \Exception("The attribute $name not found.");
+        }
 
         return $this->_data[$name];
     }
@@ -208,14 +214,18 @@ 
         }
 
 
-        if (is_callable($this->triggerBefore)) ($this->triggerBefore)();
+        if (is_callable($this->triggerBefore)) {
+         ($this->triggerBefore)();
+        }
 
         $start = microtime(true);
         $insert = $this->Connection->getConnection()->prepare($sql);
         $this->burnError($insert);
 
         $this->_newData = array_map(function ($data) {
-            if (is_bool($data) and $data === false) $data = 0;
+            if (is_bool($data) and $data === false) {
+             $data = 0;
+            }
 
             return $data;
         }, $this->_newData);
@@ -226,7 +236,9 @@ 
 
         $this->Connection->setPerformedQuery($insert->queryString, round(($end - $start), 5));
 
-        if (is_callable($this->triggerAfter)) ($this->triggerAfter)();
+        if (is_callable($this->triggerAfter)) {
+         ($this->triggerAfter)();
+        }
 
         if ($update) {
             $this->burnError($insert);
@@ -265,7 +277,9 @@ 
 
     private function burnError($statment)
     {
-        if (!is_null($statment->errorInfo()[1])) throw new \Exception($statment->errorInfo()[2], $statment->errorInfo()[1]);
+        if (!is_null($statment->errorInfo()[1])) {
+         throw new \Exception($statment->errorInfo()[2], $statment->errorInfo()[1]);
+        }
     }
 
     /**
@@ -280,16 +294,23 @@ 
             throw new \Exception($e->getMessage());
         }
 
-        if (!isset(static::$primary_key)) throw new \Exception('Primary key don\'t set');
+        if (!isset(static::$primary_key)) {
+         throw new \Exception('Primary key don\'t set');
+        }
 
-        if (!is_numeric($this->{static::$primary_key})) throw new \Exception('Primary key value don\'t is valid');
+        if (!is_numeric($this->{static::$primary_key})) {
+         throw new \Exception('Primary key value don\'t is valid');
+        }
 
         $sql = ' DELETE FROM ' . static::$table_name;
         $sql .= ' WHERE ' . static::$primary_key . ' = ? ';
 
         $instance = self::$_instance;
 
-        if (is_callable($this->triggerBefore)) ($this->triggerBefore)();;
+        if (is_callable($this->triggerBefore)) {
+         ($this->triggerBefore)();
+        }
+        ;
 
         $start = microtime(true);
 
@@ -300,7 +321,9 @@ 
 
         $instance->Connection->setPerformedQuery($insert->queryString, round(($end - $start), 5));
 
-        if (is_callable($this->triggerAfter)) ($this->triggerAfter)();
+        if (is_callable($this->triggerAfter)) {
+         ($this->triggerAfter)();
+        }
 
         if ($insert->rowCount() > 0) {
             $logger = [
@@ -311,8 +334,7 @@ 
             $this->saveLogger($logger);
 
             return true;
-        }
-        else{ return false; };
+        } else{ return false; };
     }
 
     /**
@@ -332,7 +354,9 @@ 
     {
         self::instance();
 
-        if (!isset(static::$table_name)) throw new \Exception('Don\'t set table name in model.');
+        if (!isset(static::$table_name)) {
+         throw new \Exception('Don\'t set table name in model.');
+        }
 
         $currentTable = static::$table_name;
 
@@ -360,8 +384,12 @@ 
     {
         self::instance();
 
-        if (!is_string($procedureName)) throw new \Exception("Procedure name is invalid.");
-        if (!is_array($param)) throw new \Exception("Tipo de parâmetros inválidos.");
+        if (!is_string($procedureName)) {
+         throw new \Exception("Procedure name is invalid.");
+        }
+        if (!is_array($param)) {
+         throw new \Exception("Tipo de parâmetros inválidos.");
+        }
 
         $currentTable = static::$table_name;
 
@@ -436,13 +464,17 @@ 
             throw new \Exception($e->getMessage());
         }
 
-        if (!is_array($parameters) and !is_numeric($parameters)) throw new \Exception('Invalid parameter type on model ' . get_called_class() . '.');
+        if (!is_array($parameters) and !is_numeric($parameters)) {
+         throw new \Exception('Invalid parameter type on model ' . get_called_class() . '.');
+        }
 
         $instance->_current_custom_query[] = 'SELECT * FROM ' . static::$table_name . ' ';
 
         switch ($parameters) {
             case is_numeric($parameters):
-                if (!isset(static::$primary_key)) throw new \Exception("Invalid parameter type.");
+                if (!isset(static::$primary_key)) {
+                 throw new \Exception("Invalid parameter type.");
+                }
 
                 $instance->_current_custom_query_values[] = $parameters;
                 $instance->_current_custom_query[] = ' WHERE ' . static::$primary_key . ' = ?';
@@ -465,7 +497,7 @@ 
             $done->Result->setResults($clone);
 
             return $done;
-        }else {
+        } else {
             return null;
         }
     }
@@ -486,11 +518,15 @@ 
             throw new \Exception($e->getMessage());
         }
 
-        if (!is_string($colunm)) throw new \Exception("Invalid parameter type.");
+        if (!is_string($colunm)) {
+         throw new \Exception("Invalid parameter type.");
+        }
 
         self::$_instance->_current_custom_query[] = "SELECT $colunm FROM " . static::$table_name . ' ';
 
-        if (!isset(static::$primary_key)) throw new \Exception("Invalid parameter type.");
+        if (!isset(static::$primary_key)) {
+         throw new \Exception("Invalid parameter type.");
+        }
 
         return self::$_instance;
     }
@@ -540,7 +576,9 @@ 
             throw new \Exception($e->getMessage());
         }
 
-        if (!is_array($param)) throw new \Exception('Tipo de parâmetro inválido.');
+        if (!is_array($param)) {
+         throw new \Exception('Tipo de parâmetro inválido.');
+        }
 
         $start = microtime(true);
 
@@ -585,7 +623,9 @@ 
             throw new \Exception($e->getMessage());
         }
 
-        if (!is_array($param)) throw new \Exception('Invalid parameter type.');
+        if (!is_array($param)) {
+         throw new \Exception('Invalid parameter type.');
+        }
 
         self::$_instance->_current_custom_query_values = $param;
 
@@ -624,7 +664,9 @@ 
      */
     final protected function setTriggerAfter($closure = null)
     {
-        if (!is_callable($closure)) throw new \Exception('The parameter don\'t is an closure.');
+        if (!is_callable($closure)) {
+         throw new \Exception('The parameter don\'t is an closure.');
+        }
 
         $this->triggerAfter = $closure;
 
@@ -639,7 +681,9 @@ 
      */
     final protected function setTriggerBefore($closure = null)
     {
-        if (!is_callable($closure)) throw new \Exception('The parameter don\'t is an closure.');
+        if (!is_callable($closure)) {
+         throw new \Exception('The parameter don\'t is an closure.');
+        }
 
         $this->triggerBefore = $closure;
 
@@ -653,7 +697,9 @@ 
      */
     final protected function changeSchema($schema)
     {
-        if (!is_string($schema)) throw new \Exception('The parameter don\'t is an String.');
+        if (!is_string($schema)) {
+         throw new \Exception('The parameter don\'t is an String.');
+        }
 
         $this->Connection->changeSchema($schema);
         return $this;
@@ -692,7 +738,9 @@ 
      */
     final private function verifyConnection()
     {
-        if (is_null($this->Connection->getCurrentConnectionString())) throw new \Exception('Not set connection.');
+        if (is_null($this->Connection->getCurrentConnectionString())) {
+         throw new \Exception('Not set connection.');
+        }
     }
 
     /**

lib/support/Model.php

Spacing +2 added lines, -2 removed lines

@@ -27,7 +27,7 @@ 
     {
         if (!($data instanceof self)) throw new \Exception(" It's not a model.");
 
-        $data = array_map(function ($object) { return $object->toArray(); }, $data);
+        $data = array_map(function($object) { return $object->toArray(); }, $data);
 
         return $data;
     }
@@ -65,7 +65,7 @@ 
 
         if (is_null($offset)) {
             $data[] = $value;
-        } else {
+        }else {
             $data[$offset] = $value;
         }
     }

Braces +3 added lines, -1 removed lines

@@ -25,7 +25,9 @@
      */
     public static function toList($data)
     {
-        if (!($data instanceof self)) throw new \Exception(" It's not a model.");
+        if (!($data instanceof self)) {
+         throw new \Exception(" It's not a model.");
+        }
 
         $data = array_map(function ($object) { return $object->toArray(); }, $data);
 

lib/Connection.php

Braces +6 added lines, -2 removed lines

@@ -175,8 +175,12 @@
      */
     final public function changeSchema($schema = null)
     {
-        if (!is_string($schema)) throw new \InvalidArgumentException('The parameter don\'t is an String.');
-        if ($this->driver == 'mysql') throw new \InvalidArgumentException('This driver not supported schemas.');
+        if (!is_string($schema)) {
+         throw new \InvalidArgumentException('The parameter don\'t is an String.');
+        }
+        if ($this->driver == 'mysql') {
+         throw new \InvalidArgumentException('This driver not supported schemas.');
+        }
 
         $this->getConnection()->exec("SET search_path TO '$schema';");
         return $this;

lib/Error.php

Braces +6 added lines, -2 removed lines

@@ -23,7 +23,9 @@ 
     {
         $instance = self::instance();
 
-        if ($instance->burst) $instance->burst($message, $code, $type);
+        if ($instance->burst) {
+         $instance->burst($message, $code, $type);
+        }
 
         $errors = [
             'message' => $message,
@@ -38,7 +40,9 @@ 
 
     public static function instance()
     {
-        if (!self::$_instance) self::$_instance = new self();
+        if (!self::$_instance) {
+         self::$_instance = new self();
+        }
         return self::$_instance;
     }