maikees / moc-orm

lib/Config.php

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

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