maikees / moc-orm

lib/Connection.php

Braces +9 added lines, -3 removed lines

@@ -96,7 +96,9 @@ 
      */
     public function connection($connectionString, $username, $password)
     {
-        if (is_null($this->getCurrentConnectionName())) throw new \Exception('Conexão não setada.');
+        if (is_null($this->getCurrentConnectionName())) {
+         throw new \Exception('Conexão não setada.');
+        }
 
         try {
             $connectionName = $this->getCurrentConnectionName();
@@ -199,8 +201,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/Config.php

Spacing +1 added lines, -1 removed lines

@@ -134,7 +134,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.");
         }
 

Braces +18 added lines, -6 removed lines

@@ -71,15 +71,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;

lib/Model.php

Spacing +9 added lines, -9 removed lines

@@ -135,8 +135,8 @@ 
         if (!empty($this->_data[$key])) {
             $sql = 'UPDATE ' . $_tableName . ' SET ';
 
-            if (count($this->_newData) <= 0){
-                Error::create('Don\'t have alter data.', 1,'InvalidArgumentException');
+            if (count($this->_newData) <= 0) {
+                Error::create('Don\'t have alter data.', 1, 'InvalidArgumentException');
                 return false;
             }
 
@@ -146,7 +146,7 @@ 
             $this->_newData[] = $this->{$key};
 
             $update = true;
-        } else {
+        }else {
             /**
              * Insert case don't have primary key
              */
@@ -162,8 +162,8 @@ 
         $insert = $this->Connection->getConnection()->prepare($sql);
         $this->burnError($insert);
 
-        $this->_newData = array_map(function ($data){
-            if(is_bool($data) and $data === false)  $data = 0;
+        $this->_newData = array_map(function($data) {
+            if (is_bool($data) and $data === false)  $data = 0;
 
             return $data;
         }, $this->_newData);
@@ -192,7 +192,7 @@ 
         return true;
     }
 
-    private function burnError($statment){
+    private function burnError($statment) {
         if (!is_null($statment->errorInfo()[1])) throw new \Exception($statment->errorInfo()[2], $statment->errorInfo()[1]);
     }
 
@@ -217,7 +217,7 @@ 
 
         $instance = self::$_instance;
 
-        if (is_callable($this->triggerBefore)) ($this->triggerBefore)();;
+        if (is_callable($this->triggerBefore)) ($this->triggerBefore)(); ;
 
         $start = microtime(true);
 
@@ -373,7 +373,7 @@ 
 
         if ($instance->Connection->getConnection()->lastInsertId() == '-1' || $instance->Connection->getConnection()->lastInsertId() == 0) {
             return false;
-        } else {
+        }else {
             return $instance;
         }
     }
@@ -526,7 +526,7 @@ 
 
         if ($match) {
             $this->_data = $objetos = $consulta->fetchAll(\PDO::FETCH_CLASS, get_called_class());
-        } else {
+        }else {
             $objetos = $consulta->rowCount();
         }
 

Braces +87 added lines, -29 removed lines

@@ -55,7 +55,9 @@ 
             $this->cleanNewData();
 
             if (!is_null($object)) {
-                if (!is_array($object)) throw new \InvalidArgumentException('Accept only array from object');
+                if (!is_array($object)) {
+                 throw new \InvalidArgumentException('Accept only array from object');
+                }
 
                 $this->_data = $object;
                 $this->_newData = $object;
@@ -82,9 +84,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];
     }
@@ -156,14 +162,18 @@ 
             $sql .= " ($repeat); ";
         }
 
-        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);
@@ -174,7 +184,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);
@@ -193,7 +205,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]);
+        }
     }
 
     /**
@@ -208,16 +222,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);
 
@@ -228,10 +249,15 @@ 
 
         $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) return true;
-        else return false;
+        if ($insert->rowCount() > 0) {
+         return true;
+        } else {
+         return false;
+        }
     }
 
     /**
@@ -249,7 +275,9 @@ 
      */
     public static function all()
     {
-        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;
 
@@ -286,8 +314,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;
 
@@ -339,7 +371,9 @@ 
         self::$_instance->_data = [];
         self::$_instance->_newData = [];
 
-        if (!is_array($attributes)) throw new \Exception("Invalid parameter type.");
+        if (!is_array($attributes)) {
+         throw new \Exception("Invalid parameter type.");
+        }
 
         $repeat = substr(str_repeat(' ?, ', count($attributes)), 0, -2);
 
@@ -356,7 +390,9 @@ 
             Throw new \Exception($e->getMessage());
         }
 
-        if (is_callable(self::$_instance->triggerBefore)) self::$_instance->triggerBefore();
+        if (is_callable(self::$_instance->triggerBefore)) {
+         self::$_instance->triggerBefore();
+        }
 
         $start = microtime(true);
 
@@ -367,7 +403,9 @@ 
 
         $instance->Connection->setPerformedQuery($insert->queryString, round(($end - $start), 5));
 
-        if (is_callable(self::$_instance->triggerAfter)) self::$_instance->triggerAfter();
+        if (is_callable(self::$_instance->triggerAfter)) {
+         self::$_instance->triggerAfter();
+        }
 
         $instance->_data = $attributes;
         $instance->_data[static::$primary_key] = $instance->Connection->getConnection()->lastInsertId();
@@ -395,13 +433,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() . '.');
+        }
 
         self::$_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.");
+                }
 
                 self::$_instance->_current_custom_query_values[] = $parameters;
                 self::$_instance->_current_custom_query[] = ' WHERE ' . static::$primary_key . ' = ?';
@@ -435,11 +477,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;
     }
@@ -508,7 +554,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);
 
@@ -553,7 +601,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;
 
@@ -592,7 +642,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;
 
@@ -607,7 +659,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;
 
@@ -621,7 +675,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;
@@ -659,6 +715,8 @@ 
 
     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.');
+        }
     }
 }
\ No newline at end of file

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/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;
         $errors['code'] = $code;
@@ -36,7 +38,9 @@ 
 
     public static function instance()
     {
-        if (!self::$_instance) self::$_instance = new self();
+        if (!self::$_instance) {
+         self::$_instance = new self();
+        }
         return self::$_instance;
     }
 

lib/ConnectionManager.php

Spacing +4 added lines, -5 removed lines

@@ -100,8 +100,7 @@ 
             $default = $this->Config->getDefault();
 
             $name = is_null($default) ?
-                @end(array_keys($configs)) :
-                $this->Config->getDefault();
+                @end(array_keys($configs)) : $this->Config->getDefault();
 
             self::open($name);
         }
@@ -132,7 +131,7 @@ 
                 } catch (\Exception $e) {
                     throw $e;
                 }
-            } else {
+            }else {
 
                 throw new \Exception("This connection isn't actived.");
             }
@@ -178,7 +177,7 @@ 
     {
         if (array_key_exists($connectionName, $this->connections)) {
             return true;
-        } else {
+        }else {
             return false;
         }
     }
@@ -201,7 +200,7 @@ 
     {
         if (array_key_exists($connectionName, $this->Config->getConfigs())) {
             return true;
-        } else {
+        }else {
             return false;
         }
     }

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)) 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)) {
+         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->getConfigs();
 
-            if (count($configs) == 0) throw new \Exception('Not have connection');
+            if (count($configs) == 0) {
+             throw new \Exception('Not have connection');
+            }
 
             $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;
     }

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();
                 }