@@ -51,6 +51,7 @@ discard block |
||
51 | 51 | /** |
52 | 52 | * getTableName() |
53 | 53 | * |
54 | + * @param string $connection |
|
54 | 55 | * @return string |
55 | 56 | */ |
56 | 57 | public static function getTableName($connection) |
@@ -62,7 +63,7 @@ discard block |
||
62 | 63 | * getALL() |
63 | 64 | * Get all record from the database |
64 | 65 | * |
65 | - * @return object |
|
66 | + * @return GetData |
|
66 | 67 | */ |
67 | 68 | public function getALL($dbConnection = NULL) |
68 | 69 | { |
@@ -82,7 +83,7 @@ discard block |
||
82 | 83 | * where($data, $condition) |
83 | 84 | * Get data from database where $data = $condition |
84 | 85 | * |
85 | - * @return object |
|
86 | + * @return GetData |
|
86 | 87 | */ |
87 | 88 | public function where($data, $condition = NULL, $dbConnection = NULL) |
88 | 89 | { |
@@ -103,7 +104,7 @@ discard block |
||
103 | 104 | * find($value) |
104 | 105 | * Find data from database where id = $value |
105 | 106 | * |
106 | - * @return array |
|
107 | + * @return Model |
|
107 | 108 | */ |
108 | 109 | public static function find($value, $dbConnection = NULL) |
109 | 110 | { |
@@ -126,7 +127,7 @@ discard block |
||
126 | 127 | * save() |
127 | 128 | * Insert data into database |
128 | 129 | * |
129 | - * @return bool |
|
130 | + * @return string |
|
130 | 131 | */ |
131 | 132 | public function save($dbConnection = NULL) |
132 | 133 | { |
@@ -9,17 +9,12 @@ |
||
9 | 9 | |
10 | 10 | namespace Ibonly\PotatoORM; |
11 | 11 | |
12 | -use PDO; |
|
13 | -use Exception; |
|
14 | -use PDOException; |
|
15 | 12 | use Ibonly\PotatoORM\GetData; |
16 | 13 | use Ibonly\PotatoORM\DatabaseQuery; |
17 | 14 | use Ibonly\PotatoORM\ModelInterface; |
18 | 15 | use Ibonly\PotatoORM\UserNotFoundException; |
19 | 16 | use Ibonly\PotatoORM\EmptyDatabaseException; |
20 | 17 | use Ibonly\PotatoORM\SaveUserExistException; |
21 | -use Ibonly\PotatoORM\ColumnNotExistExeption; |
|
22 | -use Ibonly\PotatoORM\InvalidConnectionException; |
|
23 | 18 | |
24 | 19 | class Model extends DatabaseQuery implements ModelInterface |
25 | 20 | { |
@@ -71,7 +71,7 @@ discard block |
||
71 | 71 | $sqlQuery = DatabaseQuery::selectAllQuery(self::getTableName($connection)); |
72 | 72 | $query = $connection->prepare($sqlQuery); |
73 | 73 | $query->execute(); |
74 | - if ( $query->rowCount() ) |
|
74 | + if ($query->rowCount()) |
|
75 | 75 | { |
76 | 76 | return new GetData($query->fetchAll($connection::FETCH_ASSOC)); |
77 | 77 | } |
@@ -92,7 +92,7 @@ discard block |
||
92 | 92 | $sqlQuery = $databaseQuery->selectQuery(self::getTableName($connection), $data, $condition, $connection); |
93 | 93 | $query = $connection->prepare($sqlQuery); |
94 | 94 | $query->execute(); |
95 | - if ( $query->rowCount() ) |
|
95 | + if ($query->rowCount()) |
|
96 | 96 | { |
97 | 97 | return new GetData($query->fetchAll($connection::FETCH_ASSOC)); |
98 | 98 | } |
@@ -112,7 +112,7 @@ discard block |
||
112 | 112 | $sqlQuery = DatabaseQuery::selectQuery(self::getTableName($connection), ['id' => $value], NULL, $connection); |
113 | 113 | $query = $connection->prepare($sqlQuery); |
114 | 114 | $query->execute(); |
115 | - if ( $query->rowCount() ) |
|
115 | + if ($query->rowCount()) |
|
116 | 116 | { |
117 | 117 | $found = new static; |
118 | 118 | $found->id = $value; |
@@ -155,7 +155,7 @@ discard block |
||
155 | 155 | |
156 | 156 | $updateQuery = $this->updateQuery(self::getTableName($connection)); |
157 | 157 | $statement = $connection->prepare($updateQuery); |
158 | - if( $statement->execute() ) |
|
158 | + if ($statement->execute()) |
|
159 | 159 | { |
160 | 160 | return true; |
161 | 161 | } |
@@ -172,7 +172,7 @@ discard block |
||
172 | 172 | { |
173 | 173 | $connection = DatabaseQuery::checkConnection($dbConnection); |
174 | 174 | |
175 | - $query = $connection->prepare('DELETE FROM ' . self::getTableName($connection) . ' WHERE id = '.$value); |
|
175 | + $query = $connection->prepare('DELETE FROM '.self::getTableName($connection).' WHERE id = '.$value); |
|
176 | 176 | $query->execute(); |
177 | 177 | $check = $query->rowCount(); |
178 | 178 | if ($check) |
@@ -47,7 +47,7 @@ discard block |
||
47 | 47 | { |
48 | 48 | parent::__construct($this->mysqlConnectionString(), $this->user, $this->password); |
49 | 49 | } |
50 | - elseif($this->driver === 'sqlite') |
|
50 | + elseif ($this->driver === 'sqlite') |
|
51 | 51 | { |
52 | 52 | parent::__construct($this->sqlitConnectionString()); |
53 | 53 | } |
@@ -63,7 +63,7 @@ discard block |
||
63 | 63 | */ |
64 | 64 | protected function pgsqlConnectionString() |
65 | 65 | { |
66 | - return $this->driver . ':host=' . $this->host . ';port=' . $this->port . ';dbname=' . $this->dbname . ';user=' . $this->user . ';password=' . $this->password; |
|
66 | + return $this->driver.':host='.$this->host.';port='.$this->port.';dbname='.$this->dbname.';user='.$this->user.';password='.$this->password; |
|
67 | 67 | } |
68 | 68 | |
69 | 69 | /** |
@@ -73,7 +73,7 @@ discard block |
||
73 | 73 | */ |
74 | 74 | protected function mysqlConnectionString() |
75 | 75 | { |
76 | - return $this->driver . ':host=' . $this->host . ';dbname=' . $this->dbname . ';charset=utf8mb4'; |
|
76 | + return $this->driver.':host='.$this->host.';dbname='.$this->dbname.';charset=utf8mb4'; |
|
77 | 77 | } |
78 | 78 | |
79 | 79 | /** |
@@ -83,7 +83,7 @@ discard block |
||
83 | 83 | */ |
84 | 84 | protected function sqlitConnectionString() |
85 | 85 | { |
86 | - return $this->driver . ':' . $this->sqlitePath; |
|
86 | + return $this->driver.':'.$this->sqlitePath; |
|
87 | 87 | } |
88 | 88 | |
89 | 89 | /** |
@@ -91,7 +91,7 @@ discard block |
||
91 | 91 | */ |
92 | 92 | protected function loadEnv() |
93 | 93 | { |
94 | - if( ! getenv("APP_ENV" !== "production")) |
|
94 | + if ( ! getenv("APP_ENV" !== "production")) |
|
95 | 95 | { |
96 | 96 | $dotenv = new Dotenv($_SERVER['DOCUMENT_ROOT']); |
97 | 97 | $dotenv->load(); |