@@ -6,7 +6,7 @@ |
||
| 6 | 6 | * @license <https://opensource.org/license/MIT> MIT |
| 7 | 7 | */ |
| 8 | 8 | |
| 9 | -namespace Laztopaz\potatoORM ; |
|
| 9 | +namespace Laztopaz\potatoORM; |
|
| 10 | 10 | |
| 11 | 11 | use Exception; |
| 12 | 12 | |
@@ -35,7 +35,7 @@ |
||
| 35 | 35 | } |
| 36 | 36 | |
| 37 | 37 | $sql = 'CREATE TABLE IF NOT EXISTS '.$tableName.'('; |
| 38 | - $sql.= ' id INT( 11 ) AUTO_INCREMENT PRIMARY KEY, name VARCHAR( 100 ), gender VARCHAR( 10 ), alias VARCHAR( 150 ) NOT NULL, class VARCHAR( 150 ), stack VARCHAR( 50 ) )'; |
|
| 38 | + $sql .= ' id INT( 11 ) AUTO_INCREMENT PRIMARY KEY, name VARCHAR( 100 ), gender VARCHAR( 10 ), alias VARCHAR( 150 ) NOT NULL, class VARCHAR( 150 ), stack VARCHAR( 50 ) )'; |
|
| 39 | 39 | |
| 40 | 40 | return $conn->exec($sql); |
| 41 | 41 | throw TableNotCreatedException::tableNotCreatedException("Check your database connection"); |
@@ -23,11 +23,11 @@ discard block |
||
| 23 | 23 | public function __construct() |
| 24 | 24 | { |
| 25 | 25 | $this->loadEnv(); // load the environment variables |
| 26 | - $this->databaseName = getenv('databaseName'); |
|
| 27 | - $this->databaseHost = getenv('databaseHost'); |
|
| 28 | - $this->databaseDriver = getenv('databaseDriver'); |
|
| 29 | - $this->databaseUsername = getenv('databaseUsername'); |
|
| 30 | - $this->databasePassword = getenv('databasePassword'); |
|
| 26 | + $this->databaseName = getenv('databaseName'); |
|
| 27 | + $this->databaseHost = getenv('databaseHost'); |
|
| 28 | + $this->databaseDriver = getenv('databaseDriver'); |
|
| 29 | + $this->databaseUsername = getenv('databaseUsername'); |
|
| 30 | + $this->databasePassword = getenv('databasePassword'); |
|
| 31 | 31 | |
| 32 | 32 | try { |
| 33 | 33 | $options = [ |
@@ -36,7 +36,7 @@ discard block |
||
| 36 | 36 | ]; |
| 37 | 37 | parent::__construct($this->getDatabaseDriver(), $this->databaseUsername, $this->databasePassword, $options); |
| 38 | 38 | |
| 39 | - } catch(PDOException $e) { |
|
| 39 | + } catch (PDOException $e) { |
|
| 40 | 40 | return $e->getMessage(); |
| 41 | 41 | } |
| 42 | 42 | |
@@ -55,19 +55,19 @@ discard block |
||
| 55 | 55 | { |
| 56 | 56 | case 'mysql': |
| 57 | 57 | // Set DSN |
| 58 | - $dsn = 'mysql:host='.$this->databaseHost.';dbname='. $this->databaseName; |
|
| 58 | + $dsn = 'mysql:host='.$this->databaseHost.';dbname='.$this->databaseName; |
|
| 59 | 59 | break; |
| 60 | 60 | case 'sqlite': |
| 61 | 61 | // Set DSN |
| 62 | - $dsn = 'sqlite:host='.$this->databaseHost.';dbname='. $this->databaseName; |
|
| 62 | + $dsn = 'sqlite:host='.$this->databaseHost.';dbname='.$this->databaseName; |
|
| 63 | 63 | break; |
| 64 | 64 | case 'pgsql': |
| 65 | 65 | // Set DSN |
| 66 | - $dsn = 'pgsqlsql:host='.$this->databaseHost.';dbname='. $this->databaseName; |
|
| 66 | + $dsn = 'pgsqlsql:host='.$this->databaseHost.';dbname='.$this->databaseName; |
|
| 67 | 67 | break; |
| 68 | 68 | default: |
| 69 | 69 | // Set DSN |
| 70 | - $dsn = 'mysql:host='.$this->databaseHost.';dbname='. $this->databaseName; |
|
| 70 | + $dsn = 'mysql:host='.$this->databaseHost.';dbname='.$this->databaseName; |
|
| 71 | 71 | } |
| 72 | 72 | return $dsn; |
| 73 | 73 | } |
@@ -99,7 +99,7 @@ discard block |
||
| 99 | 99 | /** |
| 100 | 100 | * This method find a record by id |
| 101 | 101 | * @params int id |
| 102 | - * @return Object |
|
| 102 | + * @return BaseClass |
|
| 103 | 103 | * @throws NoArgumentPassedToFunctionException |
| 104 | 104 | */ |
| 105 | 105 | public static function find($id) |
@@ -142,7 +142,7 @@ discard block |
||
| 142 | 142 | /** |
| 143 | 143 | * This method return the current class name |
| 144 | 144 | * $params void |
| 145 | - * @return classname |
|
| 145 | + * @return string|false |
|
| 146 | 146 | */ |
| 147 | 147 | public static function getClassName() |
| 148 | 148 | { |
@@ -21,6 +21,7 @@ discard block |
||
| 21 | 21 | |
| 22 | 22 | /** |
| 23 | 23 | * This is a constructor; a default method that will be called automatically during class instantiation |
| 24 | + * @param string|false $modelClassName |
|
| 24 | 25 | */ |
| 25 | 26 | public function __construct($modelClassName, $dbConn = Null) |
| 26 | 27 | { |
@@ -35,6 +36,7 @@ discard block |
||
| 35 | 36 | /** |
| 36 | 37 | * This method create a record and store it in a table row |
| 37 | 38 | * @params associative array, string tablename |
| 39 | + * @param string|false $tableName |
|
| 38 | 40 | * @return boolean true or false |
| 39 | 41 | */ |
| 40 | 42 | public function create($associative1DArray, $tableName, $dbConn = Null) |
@@ -69,6 +71,7 @@ discard block |
||
| 69 | 71 | /** |
| 70 | 72 | * This method updates any table by supplying 3 parameter |
| 71 | 73 | * @params: $updateParams, $tableName, $associative1DArray |
| 74 | + * @param string|false $tableName |
|
| 72 | 75 | * @return boolean true or false |
| 73 | 76 | */ |
| 74 | 77 | public function update(array $updateParams, $tableName, $associative1DArray, $dbConn = Null) |
@@ -101,6 +104,7 @@ discard block |
||
| 101 | 104 | /** |
| 102 | 105 | * This method retrieves record from a table |
| 103 | 106 | * @params int id, string tableName |
| 107 | + * @param string|false $tableName |
|
| 104 | 108 | * @return array |
| 105 | 109 | */ |
| 106 | 110 | public static function read($id, $tableName, $dbConn = Null) |
@@ -131,6 +135,7 @@ discard block |
||
| 131 | 135 | /** |
| 132 | 136 | * This method deletes a record from a table row |
| 133 | 137 | * @params int id, string tableName |
| 138 | + * @param string|false $tableName |
|
| 134 | 139 | * @return boolean true or false |
| 135 | 140 | */ |
| 136 | 141 | public static function delete($id, $tableName, $dbConn = Null) |
@@ -163,7 +168,7 @@ discard block |
||
| 163 | 168 | |
| 164 | 169 | /** |
| 165 | 170 | * This method returns sql query |
| 166 | - * @param $sql |
|
| 171 | + * @param string $sql |
|
| 167 | 172 | * @return string |
| 168 | 173 | */ |
| 169 | 174 | public function prepareUpdateQuery($sql) |
@@ -204,6 +209,7 @@ discard block |
||
| 204 | 209 | * This method returns column fields of a particular table |
| 205 | 210 | * @param $table |
| 206 | 211 | * @param $conn |
| 212 | + * @param DatabaseConnection $dbConn |
|
| 207 | 213 | * @return array |
| 208 | 214 | */ |
| 209 | 215 | public function getColumnNames($table, $dbConn = Null) { |
@@ -42,9 +42,9 @@ discard block |
||
| 42 | 42 | */ |
| 43 | 43 | public function create($associative1DArray, $tableName, $dbConn = Null) { |
| 44 | 44 | $tableFields = $this->getColumnNames($this->model, $this->dbConnection); |
| 45 | - $unexpectedFields = self::checkIfMagicSetterContainsIsSameAsClassModel($tableFields,$associative1DArray); |
|
| 45 | + $unexpectedFields = self::checkIfMagicSetterContainsIsSameAsClassModel($tableFields, $associative1DArray); |
|
| 46 | 46 | if (count($unexpectedFields) > 0) { |
| 47 | - throw TableFieldUndefinedException::reportUnknownTableField($unexpectedFields,"needs to be created as table field"); |
|
| 47 | + throw TableFieldUndefinedException::reportUnknownTableField($unexpectedFields, "needs to be created as table field"); |
|
| 48 | 48 | } |
| 49 | 49 | unset($associative1DArray[0]); |
| 50 | 50 | if (is_null($dbConn)) { |
@@ -55,13 +55,13 @@ discard block |
||
| 55 | 55 | |
| 56 | 56 | private function insertRecord($dbConn, $tableName, $associative1DArray) { |
| 57 | 57 | $insertQuery = 'INSERT INTO '.$tableName; |
| 58 | - $TableValues = implode(',',array_keys($associative1DArray)); |
|
| 58 | + $TableValues = implode(',', array_keys($associative1DArray)); |
|
| 59 | 59 | foreach ($associative1DArray as $field => $value) { |
| 60 | 60 | $FormValues[] = "'".trim(addslashes($value))."'"; |
| 61 | 61 | } |
| 62 | 62 | $splittedTableValues = implode(',', $FormValues); |
| 63 | - $insertQuery.= ' ('.$TableValues.')'; |
|
| 64 | - $insertQuery.= ' VALUES ('.$splittedTableValues.')'; |
|
| 63 | + $insertQuery .= ' ('.$TableValues.')'; |
|
| 64 | + $insertQuery .= ' VALUES ('.$splittedTableValues.')'; |
|
| 65 | 65 | $executeQuery = $dbConn->exec($insertQuery); |
| 66 | 66 | |
| 67 | 67 | if ($executeQuery) { |
@@ -85,12 +85,12 @@ discard block |
||
| 85 | 85 | } |
| 86 | 86 | $updateSql = "UPDATE `$tableName` SET "; |
| 87 | 87 | unset($associative1DArray['id']); |
| 88 | - $unexpectedFields = self::checkIfMagicSetterContainsIsSameAsClassModel($this->getColumnNames($this->model, $this->dbConnection),$associative1DArray); |
|
| 88 | + $unexpectedFields = self::checkIfMagicSetterContainsIsSameAsClassModel($this->getColumnNames($this->model, $this->dbConnection), $associative1DArray); |
|
| 89 | 89 | |
| 90 | 90 | if (count($unexpectedFields) > 0) { |
| 91 | 91 | throw TableFieldUndefinedException::reportUnknownTableField($unexpectedFields, "needs to be created as table field"); |
| 92 | 92 | } |
| 93 | - foreach($associative1DArray as $field => $value) { |
|
| 93 | + foreach ($associative1DArray as $field => $value) { |
|
| 94 | 94 | $sql .= "`$field` = '$value'".","; |
| 95 | 95 | } |
| 96 | 96 | |
@@ -123,7 +123,7 @@ discard block |
||
| 123 | 123 | if (is_null($dbConn)) { |
| 124 | 124 | $dbConn = new DatabaseConnection(); |
| 125 | 125 | } |
| 126 | - $sql = $id ? 'SELECT * FROM '.$tableName.' WHERE id = '.$id : 'SELECT * FROM '.$tableName; |
|
| 126 | + $sql = $id ? 'SELECT * FROM '.$tableName.' WHERE id = '.$id : 'SELECT * FROM '.$tableName; |
|
| 127 | 127 | |
| 128 | 128 | try { |
| 129 | 129 | $stmt = $dbConn->prepare($sql); |
@@ -135,7 +135,7 @@ discard block |
||
| 135 | 135 | } |
| 136 | 136 | $results = $stmt->fetchAll(PDO::FETCH_ASSOC); |
| 137 | 137 | |
| 138 | - foreach($results as $result) { |
|
| 138 | + foreach ($results as $result) { |
|
| 139 | 139 | array_push($tableData, $result); |
| 140 | 140 | } |
| 141 | 141 | return $tableData; |
@@ -174,7 +174,7 @@ discard block |
||
| 174 | 174 | { |
| 175 | 175 | $unexpectedFields = []; |
| 176 | 176 | foreach ($userSetterArray as $key => $val) { |
| 177 | - if (!in_array($key,$tableColumn)) { |
|
| 177 | + if (!in_array($key, $tableColumn)) { |
|
| 178 | 178 | $unexpectedFields[] = $key; |
| 179 | 179 | } |
| 180 | 180 | } |
@@ -188,9 +188,9 @@ discard block |
||
| 188 | 188 | */ |
| 189 | 189 | public function prepareUpdateQuery($sql) |
| 190 | 190 | { |
| 191 | - $splittedQuery = explode(",",$sql); |
|
| 191 | + $splittedQuery = explode(",", $sql); |
|
| 192 | 192 | array_pop($splittedQuery); |
| 193 | - $mergeData = implode(",",$splittedQuery); |
|
| 193 | + $mergeData = implode(",", $splittedQuery); |
|
| 194 | 194 | return $mergeData; |
| 195 | 195 | } |
| 196 | 196 | |
@@ -215,7 +215,7 @@ discard block |
||
| 215 | 215 | $statement->execute(); |
| 216 | 216 | $returnedRowNumbers = $statement->rowCount(); |
| 217 | 217 | |
| 218 | - return $returnedRowNumbers ? true : false; |
|
| 218 | + return $returnedRowNumbers ? true : false; |
|
| 219 | 219 | } |
| 220 | 220 | throw EmptyArrayException::checkEmptyArrayException("Array Expected: parameter passed to this function is not an array"); |
| 221 | 221 | } |
@@ -239,7 +239,7 @@ discard block |
||
| 239 | 239 | $stmt->execute(); |
| 240 | 240 | $results = $stmt->fetchAll(PDO::FETCH_ASSOC); |
| 241 | 241 | |
| 242 | - foreach($results as $result) { |
|
| 242 | + foreach ($results as $result) { |
|
| 243 | 243 | array_push($tableFields, $result['Field']); |
| 244 | 244 | } |
| 245 | 245 | return $tableFields; |
@@ -14,7 +14,7 @@ |
||
| 14 | 14 | |
| 15 | 15 | public static function reportUnknownTableField($unExpectedFields, $message) |
| 16 | 16 | { |
| 17 | - $fields = implode(", ",$unExpectedFields); |
|
| 17 | + $fields = implode(", ", $unExpectedFields); |
|
| 18 | 18 | |
| 19 | 19 | //var_dump($fields); |
| 20 | 20 | |
@@ -74,14 +74,14 @@ |
||
| 74 | 74 | 'sex' => 'sexes', |
| 75 | 75 | 'move' => 'moves'); |
| 76 | 76 | $lowercased_word = strtolower($word); |
| 77 | - foreach ($uncountable as $_uncountable){ |
|
| 78 | - if(substr($lowercased_word,(-1*strlen($_uncountable))) == $_uncountable){ |
|
| 77 | + foreach ($uncountable as $_uncountable) { |
|
| 78 | + if (substr($lowercased_word, (-1*strlen($_uncountable))) == $_uncountable) { |
|
| 79 | 79 | return $word; |
| 80 | 80 | } |
| 81 | 81 | } |
| 82 | - foreach ($irregular as $_plural=> $_singular){ |
|
| 82 | + foreach ($irregular as $_plural=> $_singular) { |
|
| 83 | 83 | if (preg_match('/('.$_plural.')$/i', $word, $arr)) { |
| 84 | - return preg_replace('/('.$_plural.')$/i', substr($arr[0],0,1).substr($_singular,1), $word); |
|
| 84 | + return preg_replace('/('.$_plural.')$/i', substr($arr[0], 0, 1).substr($_singular, 1), $word); |
|
| 85 | 85 | } |
| 86 | 86 | } |
| 87 | 87 | foreach ($plural as $rule => $replacement) { |