@@ -48,13 +48,13 @@ discard block |
||
| 48 | 48 | * mapped to queries without using sql |
| 49 | 49 | * @since 7.0.0 |
| 50 | 50 | */ |
| 51 | - public function __construct(IDBConnection $db, $tableName, $entityClass=null){ |
|
| 51 | + public function __construct(IDBConnection $db, $tableName, $entityClass = null) { |
|
| 52 | 52 | $this->db = $db; |
| 53 | - $this->tableName = '*PREFIX*' . $tableName; |
|
| 53 | + $this->tableName = '*PREFIX*'.$tableName; |
|
| 54 | 54 | |
| 55 | 55 | // if not given set the entity name to the class without the mapper part |
| 56 | 56 | // cache it here for later use since reflection is slow |
| 57 | - if($entityClass === null) { |
|
| 57 | + if ($entityClass === null) { |
|
| 58 | 58 | $this->entityClass = str_replace('Mapper', '', get_class($this)); |
| 59 | 59 | } else { |
| 60 | 60 | $this->entityClass = $entityClass; |
@@ -66,7 +66,7 @@ discard block |
||
| 66 | 66 | * @return string the table name |
| 67 | 67 | * @since 7.0.0 |
| 68 | 68 | */ |
| 69 | - public function getTableName(){ |
|
| 69 | + public function getTableName() { |
|
| 70 | 70 | return $this->tableName; |
| 71 | 71 | } |
| 72 | 72 | |
@@ -77,8 +77,8 @@ discard block |
||
| 77 | 77 | * @return Entity the deleted entity |
| 78 | 78 | * @since 7.0.0 - return value added in 8.1.0 |
| 79 | 79 | */ |
| 80 | - public function delete(Entity $entity){ |
|
| 81 | - $sql = 'DELETE FROM `' . $this->tableName . '` WHERE `id` = ?'; |
|
| 80 | + public function delete(Entity $entity) { |
|
| 81 | + $sql = 'DELETE FROM `'.$this->tableName.'` WHERE `id` = ?'; |
|
| 82 | 82 | $stmt = $this->execute($sql, [$entity->getId()]); |
| 83 | 83 | $stmt->closeCursor(); |
| 84 | 84 | return $entity; |
@@ -91,7 +91,7 @@ discard block |
||
| 91 | 91 | * @return Entity the saved entity with the set id |
| 92 | 92 | * @since 7.0.0 |
| 93 | 93 | */ |
| 94 | - public function insert(Entity $entity){ |
|
| 94 | + public function insert(Entity $entity) { |
|
| 95 | 95 | // get updated fields to save, fields have to be set using a setter to |
| 96 | 96 | // be saved |
| 97 | 97 | $properties = $entity->getUpdatedFields(); |
@@ -101,15 +101,15 @@ discard block |
||
| 101 | 101 | |
| 102 | 102 | // build the fields |
| 103 | 103 | $i = 0; |
| 104 | - foreach($properties as $property => $updated) { |
|
| 104 | + foreach ($properties as $property => $updated) { |
|
| 105 | 105 | $column = $entity->propertyToColumn($property); |
| 106 | - $getter = 'get' . ucfirst($property); |
|
| 106 | + $getter = 'get'.ucfirst($property); |
|
| 107 | 107 | |
| 108 | - $columns .= '`' . $column . '`'; |
|
| 108 | + $columns .= '`'.$column.'`'; |
|
| 109 | 109 | $values .= '?'; |
| 110 | 110 | |
| 111 | 111 | // only append colon if there are more entries |
| 112 | - if($i < count($properties)-1){ |
|
| 112 | + if ($i < count($properties) - 1) { |
|
| 113 | 113 | $columns .= ','; |
| 114 | 114 | $values .= ','; |
| 115 | 115 | } |
@@ -119,8 +119,8 @@ discard block |
||
| 119 | 119 | |
| 120 | 120 | } |
| 121 | 121 | |
| 122 | - $sql = 'INSERT INTO `' . $this->tableName . '`(' . |
|
| 123 | - $columns . ') VALUES(' . $values . ')'; |
|
| 122 | + $sql = 'INSERT INTO `'.$this->tableName.'`('. |
|
| 123 | + $columns.') VALUES('.$values.')'; |
|
| 124 | 124 | |
| 125 | 125 | $stmt = $this->execute($sql, $params); |
| 126 | 126 | |
@@ -140,16 +140,16 @@ discard block |
||
| 140 | 140 | * @return Entity the saved entity with the set id |
| 141 | 141 | * @since 7.0.0 - return value was added in 8.0.0 |
| 142 | 142 | */ |
| 143 | - public function update(Entity $entity){ |
|
| 143 | + public function update(Entity $entity) { |
|
| 144 | 144 | // if entity wasn't changed it makes no sense to run a db query |
| 145 | 145 | $properties = $entity->getUpdatedFields(); |
| 146 | - if(count($properties) === 0) { |
|
| 146 | + if (count($properties) === 0) { |
|
| 147 | 147 | return $entity; |
| 148 | 148 | } |
| 149 | 149 | |
| 150 | 150 | // entity needs an id |
| 151 | 151 | $id = $entity->getId(); |
| 152 | - if($id === null){ |
|
| 152 | + if ($id === null) { |
|
| 153 | 153 | throw new \InvalidArgumentException( |
| 154 | 154 | 'Entity which should be updated has no id'); |
| 155 | 155 | } |
@@ -164,15 +164,15 @@ discard block |
||
| 164 | 164 | |
| 165 | 165 | // build the fields |
| 166 | 166 | $i = 0; |
| 167 | - foreach($properties as $property => $updated) { |
|
| 167 | + foreach ($properties as $property => $updated) { |
|
| 168 | 168 | |
| 169 | 169 | $column = $entity->propertyToColumn($property); |
| 170 | - $getter = 'get' . ucfirst($property); |
|
| 170 | + $getter = 'get'.ucfirst($property); |
|
| 171 | 171 | |
| 172 | - $columns .= '`' . $column . '` = ?'; |
|
| 172 | + $columns .= '`'.$column.'` = ?'; |
|
| 173 | 173 | |
| 174 | 174 | // only append colon if there are more entries |
| 175 | - if($i < count($properties)-1){ |
|
| 175 | + if ($i < count($properties) - 1) { |
|
| 176 | 176 | $columns .= ','; |
| 177 | 177 | } |
| 178 | 178 | |
@@ -180,8 +180,8 @@ discard block |
||
| 180 | 180 | $i++; |
| 181 | 181 | } |
| 182 | 182 | |
| 183 | - $sql = 'UPDATE `' . $this->tableName . '` SET ' . |
|
| 184 | - $columns . ' WHERE `id` = ?'; |
|
| 183 | + $sql = 'UPDATE `'.$this->tableName.'` SET '. |
|
| 184 | + $columns.' WHERE `id` = ?'; |
|
| 185 | 185 | $params[] = $id; |
| 186 | 186 | |
| 187 | 187 | $stmt = $this->execute($sql, $params); |
@@ -227,7 +227,7 @@ discard block |
||
| 227 | 227 | * @return \PDOStatement the database query result |
| 228 | 228 | * @since 7.0.0 |
| 229 | 229 | */ |
| 230 | - protected function execute($sql, array $params=[], $limit=null, $offset=null){ |
|
| 230 | + protected function execute($sql, array $params = [], $limit = null, $offset = null) { |
|
| 231 | 231 | $query = $this->db->prepare($sql, $limit, $offset); |
| 232 | 232 | |
| 233 | 233 | if ($this->isAssocArray($params)) { |
@@ -236,7 +236,7 @@ discard block |
||
| 236 | 236 | $query->bindValue($key, $param, $pdoConstant); |
| 237 | 237 | } |
| 238 | 238 | } else { |
| 239 | - $index = 1; // bindParam is 1 indexed |
|
| 239 | + $index = 1; // bindParam is 1 indexed |
|
| 240 | 240 | foreach ($params as $param) { |
| 241 | 241 | $pdoConstant = $this->getPDOType($param); |
| 242 | 242 | $query->bindValue($index, $param, $pdoConstant); |
@@ -263,11 +263,11 @@ discard block |
||
| 263 | 263 | * @return array the result as row |
| 264 | 264 | * @since 7.0.0 |
| 265 | 265 | */ |
| 266 | - protected function findOneQuery($sql, array $params=[], $limit=null, $offset=null){ |
|
| 266 | + protected function findOneQuery($sql, array $params = [], $limit = null, $offset = null) { |
|
| 267 | 267 | $stmt = $this->execute($sql, $params, $limit, $offset); |
| 268 | 268 | $row = $stmt->fetch(); |
| 269 | 269 | |
| 270 | - if($row === false || $row === null){ |
|
| 270 | + if ($row === false || $row === null) { |
|
| 271 | 271 | $stmt->closeCursor(); |
| 272 | 272 | $msg = $this->buildDebugMessage( |
| 273 | 273 | 'Did expect one result but found none when executing', $sql, $params, $limit, $offset |
@@ -277,7 +277,7 @@ discard block |
||
| 277 | 277 | $row2 = $stmt->fetch(); |
| 278 | 278 | $stmt->closeCursor(); |
| 279 | 279 | //MDB2 returns null, PDO and doctrine false when no row is available |
| 280 | - if( ! ($row2 === false || $row2 === null )) { |
|
| 280 | + if (!($row2 === false || $row2 === null)) { |
|
| 281 | 281 | $msg = $this->buildDebugMessage( |
| 282 | 282 | 'Did not expect more than one result when executing', $sql, $params, $limit, $offset |
| 283 | 283 | ); |
@@ -298,12 +298,12 @@ discard block |
||
| 298 | 298 | * @return string formatted error message string |
| 299 | 299 | * @since 9.1.0 |
| 300 | 300 | */ |
| 301 | - private function buildDebugMessage($msg, $sql, array $params=[], $limit=null, $offset=null) { |
|
| 302 | - return $msg . |
|
| 303 | - ': query "' . $sql . '"; ' . |
|
| 304 | - 'parameters ' . print_r($params, true) . '; ' . |
|
| 305 | - 'limit "' . $limit . '"; '. |
|
| 306 | - 'offset "' . $offset . '"'; |
|
| 301 | + private function buildDebugMessage($msg, $sql, array $params = [], $limit = null, $offset = null) { |
|
| 302 | + return $msg. |
|
| 303 | + ': query "'.$sql.'"; '. |
|
| 304 | + 'parameters '.print_r($params, true).'; '. |
|
| 305 | + 'limit "'.$limit.'"; '. |
|
| 306 | + 'offset "'.$offset.'"'; |
|
| 307 | 307 | } |
| 308 | 308 | |
| 309 | 309 | |
@@ -315,7 +315,7 @@ discard block |
||
| 315 | 315 | * @since 7.0.0 |
| 316 | 316 | */ |
| 317 | 317 | protected function mapRowToEntity($row) { |
| 318 | - return call_user_func($this->entityClass .'::fromRow', $row); |
|
| 318 | + return call_user_func($this->entityClass.'::fromRow', $row); |
|
| 319 | 319 | } |
| 320 | 320 | |
| 321 | 321 | |
@@ -328,12 +328,12 @@ discard block |
||
| 328 | 328 | * @return array all fetched entities |
| 329 | 329 | * @since 7.0.0 |
| 330 | 330 | */ |
| 331 | - protected function findEntities($sql, array $params=[], $limit=null, $offset=null) { |
|
| 331 | + protected function findEntities($sql, array $params = [], $limit = null, $offset = null) { |
|
| 332 | 332 | $stmt = $this->execute($sql, $params, $limit, $offset); |
| 333 | 333 | |
| 334 | 334 | $entities = []; |
| 335 | 335 | |
| 336 | - while($row = $stmt->fetch()){ |
|
| 336 | + while ($row = $stmt->fetch()) { |
|
| 337 | 337 | $entities[] = $this->mapRowToEntity($row); |
| 338 | 338 | } |
| 339 | 339 | |
@@ -355,7 +355,7 @@ discard block |
||
| 355 | 355 | * @return Entity the entity |
| 356 | 356 | * @since 7.0.0 |
| 357 | 357 | */ |
| 358 | - protected function findEntity($sql, array $params=[], $limit=null, $offset=null){ |
|
| 358 | + protected function findEntity($sql, array $params = [], $limit = null, $offset = null) { |
|
| 359 | 359 | return $this->mapRowToEntity($this->findOneQuery($sql, $params, $limit, $offset)); |
| 360 | 360 | } |
| 361 | 361 | |
@@ -37,327 +37,327 @@ |
||
| 37 | 37 | */ |
| 38 | 38 | abstract class Mapper { |
| 39 | 39 | |
| 40 | - protected $tableName; |
|
| 41 | - protected $entityClass; |
|
| 42 | - protected $db; |
|
| 43 | - |
|
| 44 | - /** |
|
| 45 | - * @param IDBConnection $db Instance of the Db abstraction layer |
|
| 46 | - * @param string $tableName the name of the table. set this to allow entity |
|
| 47 | - * @param string $entityClass the name of the entity that the sql should be |
|
| 48 | - * mapped to queries without using sql |
|
| 49 | - * @since 7.0.0 |
|
| 50 | - */ |
|
| 51 | - public function __construct(IDBConnection $db, $tableName, $entityClass=null){ |
|
| 52 | - $this->db = $db; |
|
| 53 | - $this->tableName = '*PREFIX*' . $tableName; |
|
| 54 | - |
|
| 55 | - // if not given set the entity name to the class without the mapper part |
|
| 56 | - // cache it here for later use since reflection is slow |
|
| 57 | - if($entityClass === null) { |
|
| 58 | - $this->entityClass = str_replace('Mapper', '', get_class($this)); |
|
| 59 | - } else { |
|
| 60 | - $this->entityClass = $entityClass; |
|
| 61 | - } |
|
| 62 | - } |
|
| 63 | - |
|
| 64 | - |
|
| 65 | - /** |
|
| 66 | - * @return string the table name |
|
| 67 | - * @since 7.0.0 |
|
| 68 | - */ |
|
| 69 | - public function getTableName(){ |
|
| 70 | - return $this->tableName; |
|
| 71 | - } |
|
| 72 | - |
|
| 73 | - |
|
| 74 | - /** |
|
| 75 | - * Deletes an entity from the table |
|
| 76 | - * @param Entity $entity the entity that should be deleted |
|
| 77 | - * @return Entity the deleted entity |
|
| 78 | - * @since 7.0.0 - return value added in 8.1.0 |
|
| 79 | - */ |
|
| 80 | - public function delete(Entity $entity){ |
|
| 81 | - $sql = 'DELETE FROM `' . $this->tableName . '` WHERE `id` = ?'; |
|
| 82 | - $stmt = $this->execute($sql, [$entity->getId()]); |
|
| 83 | - $stmt->closeCursor(); |
|
| 84 | - return $entity; |
|
| 85 | - } |
|
| 86 | - |
|
| 87 | - |
|
| 88 | - /** |
|
| 89 | - * Creates a new entry in the db from an entity |
|
| 90 | - * @param Entity $entity the entity that should be created |
|
| 91 | - * @return Entity the saved entity with the set id |
|
| 92 | - * @since 7.0.0 |
|
| 93 | - */ |
|
| 94 | - public function insert(Entity $entity){ |
|
| 95 | - // get updated fields to save, fields have to be set using a setter to |
|
| 96 | - // be saved |
|
| 97 | - $properties = $entity->getUpdatedFields(); |
|
| 98 | - $values = ''; |
|
| 99 | - $columns = ''; |
|
| 100 | - $params = []; |
|
| 101 | - |
|
| 102 | - // build the fields |
|
| 103 | - $i = 0; |
|
| 104 | - foreach($properties as $property => $updated) { |
|
| 105 | - $column = $entity->propertyToColumn($property); |
|
| 106 | - $getter = 'get' . ucfirst($property); |
|
| 107 | - |
|
| 108 | - $columns .= '`' . $column . '`'; |
|
| 109 | - $values .= '?'; |
|
| 110 | - |
|
| 111 | - // only append colon if there are more entries |
|
| 112 | - if($i < count($properties)-1){ |
|
| 113 | - $columns .= ','; |
|
| 114 | - $values .= ','; |
|
| 115 | - } |
|
| 116 | - |
|
| 117 | - $params[] = $entity->$getter(); |
|
| 118 | - $i++; |
|
| 119 | - |
|
| 120 | - } |
|
| 121 | - |
|
| 122 | - $sql = 'INSERT INTO `' . $this->tableName . '`(' . |
|
| 123 | - $columns . ') VALUES(' . $values . ')'; |
|
| 124 | - |
|
| 125 | - $stmt = $this->execute($sql, $params); |
|
| 126 | - |
|
| 127 | - $entity->setId((int) $this->db->lastInsertId($this->tableName)); |
|
| 128 | - |
|
| 129 | - $stmt->closeCursor(); |
|
| 130 | - |
|
| 131 | - return $entity; |
|
| 132 | - } |
|
| 133 | - |
|
| 134 | - |
|
| 135 | - |
|
| 136 | - /** |
|
| 137 | - * Updates an entry in the db from an entity |
|
| 138 | - * @throws \InvalidArgumentException if entity has no id |
|
| 139 | - * @param Entity $entity the entity that should be created |
|
| 140 | - * @return Entity the saved entity with the set id |
|
| 141 | - * @since 7.0.0 - return value was added in 8.0.0 |
|
| 142 | - */ |
|
| 143 | - public function update(Entity $entity){ |
|
| 144 | - // if entity wasn't changed it makes no sense to run a db query |
|
| 145 | - $properties = $entity->getUpdatedFields(); |
|
| 146 | - if(count($properties) === 0) { |
|
| 147 | - return $entity; |
|
| 148 | - } |
|
| 149 | - |
|
| 150 | - // entity needs an id |
|
| 151 | - $id = $entity->getId(); |
|
| 152 | - if($id === null){ |
|
| 153 | - throw new \InvalidArgumentException( |
|
| 154 | - 'Entity which should be updated has no id'); |
|
| 155 | - } |
|
| 156 | - |
|
| 157 | - // get updated fields to save, fields have to be set using a setter to |
|
| 158 | - // be saved |
|
| 159 | - // do not update the id field |
|
| 160 | - unset($properties['id']); |
|
| 161 | - |
|
| 162 | - $columns = ''; |
|
| 163 | - $params = []; |
|
| 164 | - |
|
| 165 | - // build the fields |
|
| 166 | - $i = 0; |
|
| 167 | - foreach($properties as $property => $updated) { |
|
| 168 | - |
|
| 169 | - $column = $entity->propertyToColumn($property); |
|
| 170 | - $getter = 'get' . ucfirst($property); |
|
| 171 | - |
|
| 172 | - $columns .= '`' . $column . '` = ?'; |
|
| 173 | - |
|
| 174 | - // only append colon if there are more entries |
|
| 175 | - if($i < count($properties)-1){ |
|
| 176 | - $columns .= ','; |
|
| 177 | - } |
|
| 178 | - |
|
| 179 | - $params[] = $entity->$getter(); |
|
| 180 | - $i++; |
|
| 181 | - } |
|
| 182 | - |
|
| 183 | - $sql = 'UPDATE `' . $this->tableName . '` SET ' . |
|
| 184 | - $columns . ' WHERE `id` = ?'; |
|
| 185 | - $params[] = $id; |
|
| 186 | - |
|
| 187 | - $stmt = $this->execute($sql, $params); |
|
| 188 | - $stmt->closeCursor(); |
|
| 189 | - |
|
| 190 | - return $entity; |
|
| 191 | - } |
|
| 192 | - |
|
| 193 | - /** |
|
| 194 | - * Checks if an array is associative |
|
| 195 | - * @param array $array |
|
| 196 | - * @return bool true if associative |
|
| 197 | - * @since 8.1.0 |
|
| 198 | - */ |
|
| 199 | - private function isAssocArray(array $array) { |
|
| 200 | - return array_values($array) !== $array; |
|
| 201 | - } |
|
| 202 | - |
|
| 203 | - /** |
|
| 204 | - * Returns the correct PDO constant based on the value type |
|
| 205 | - * @param $value |
|
| 206 | - * @return int PDO constant |
|
| 207 | - * @since 8.1.0 |
|
| 208 | - */ |
|
| 209 | - private function getPDOType($value) { |
|
| 210 | - switch (gettype($value)) { |
|
| 211 | - case 'integer': |
|
| 212 | - return \PDO::PARAM_INT; |
|
| 213 | - case 'boolean': |
|
| 214 | - return \PDO::PARAM_BOOL; |
|
| 215 | - default: |
|
| 216 | - return \PDO::PARAM_STR; |
|
| 217 | - } |
|
| 218 | - } |
|
| 219 | - |
|
| 220 | - |
|
| 221 | - /** |
|
| 222 | - * Runs an sql query |
|
| 223 | - * @param string $sql the prepare string |
|
| 224 | - * @param array $params the params which should replace the ? in the sql query |
|
| 225 | - * @param int $limit the maximum number of rows |
|
| 226 | - * @param int $offset from which row we want to start |
|
| 227 | - * @return \PDOStatement the database query result |
|
| 228 | - * @since 7.0.0 |
|
| 229 | - */ |
|
| 230 | - protected function execute($sql, array $params=[], $limit=null, $offset=null){ |
|
| 231 | - $query = $this->db->prepare($sql, $limit, $offset); |
|
| 232 | - |
|
| 233 | - if ($this->isAssocArray($params)) { |
|
| 234 | - foreach ($params as $key => $param) { |
|
| 235 | - $pdoConstant = $this->getPDOType($param); |
|
| 236 | - $query->bindValue($key, $param, $pdoConstant); |
|
| 237 | - } |
|
| 238 | - } else { |
|
| 239 | - $index = 1; // bindParam is 1 indexed |
|
| 240 | - foreach ($params as $param) { |
|
| 241 | - $pdoConstant = $this->getPDOType($param); |
|
| 242 | - $query->bindValue($index, $param, $pdoConstant); |
|
| 243 | - $index++; |
|
| 244 | - } |
|
| 245 | - } |
|
| 246 | - |
|
| 247 | - $query->execute(); |
|
| 248 | - |
|
| 249 | - return $query; |
|
| 250 | - } |
|
| 251 | - |
|
| 252 | - |
|
| 253 | - /** |
|
| 254 | - * Returns an db result and throws exceptions when there are more or less |
|
| 255 | - * results |
|
| 256 | - * @see findEntity |
|
| 257 | - * @param string $sql the sql query |
|
| 258 | - * @param array $params the parameters of the sql query |
|
| 259 | - * @param int $limit the maximum number of rows |
|
| 260 | - * @param int $offset from which row we want to start |
|
| 261 | - * @throws DoesNotExistException if the item does not exist |
|
| 262 | - * @throws MultipleObjectsReturnedException if more than one item exist |
|
| 263 | - * @return array the result as row |
|
| 264 | - * @since 7.0.0 |
|
| 265 | - */ |
|
| 266 | - protected function findOneQuery($sql, array $params=[], $limit=null, $offset=null){ |
|
| 267 | - $stmt = $this->execute($sql, $params, $limit, $offset); |
|
| 268 | - $row = $stmt->fetch(); |
|
| 269 | - |
|
| 270 | - if($row === false || $row === null){ |
|
| 271 | - $stmt->closeCursor(); |
|
| 272 | - $msg = $this->buildDebugMessage( |
|
| 273 | - 'Did expect one result but found none when executing', $sql, $params, $limit, $offset |
|
| 274 | - ); |
|
| 275 | - throw new DoesNotExistException($msg); |
|
| 276 | - } |
|
| 277 | - $row2 = $stmt->fetch(); |
|
| 278 | - $stmt->closeCursor(); |
|
| 279 | - //MDB2 returns null, PDO and doctrine false when no row is available |
|
| 280 | - if( ! ($row2 === false || $row2 === null )) { |
|
| 281 | - $msg = $this->buildDebugMessage( |
|
| 282 | - 'Did not expect more than one result when executing', $sql, $params, $limit, $offset |
|
| 283 | - ); |
|
| 284 | - throw new MultipleObjectsReturnedException($msg); |
|
| 285 | - } else { |
|
| 286 | - return $row; |
|
| 287 | - } |
|
| 288 | - } |
|
| 289 | - |
|
| 290 | - /** |
|
| 291 | - * Builds an error message by prepending the $msg to an error message which |
|
| 292 | - * has the parameters |
|
| 293 | - * @see findEntity |
|
| 294 | - * @param string $sql the sql query |
|
| 295 | - * @param array $params the parameters of the sql query |
|
| 296 | - * @param int $limit the maximum number of rows |
|
| 297 | - * @param int $offset from which row we want to start |
|
| 298 | - * @return string formatted error message string |
|
| 299 | - * @since 9.1.0 |
|
| 300 | - */ |
|
| 301 | - private function buildDebugMessage($msg, $sql, array $params=[], $limit=null, $offset=null) { |
|
| 302 | - return $msg . |
|
| 303 | - ': query "' . $sql . '"; ' . |
|
| 304 | - 'parameters ' . print_r($params, true) . '; ' . |
|
| 305 | - 'limit "' . $limit . '"; '. |
|
| 306 | - 'offset "' . $offset . '"'; |
|
| 307 | - } |
|
| 308 | - |
|
| 309 | - |
|
| 310 | - /** |
|
| 311 | - * Creates an entity from a row. Automatically determines the entity class |
|
| 312 | - * from the current mapper name (MyEntityMapper -> MyEntity) |
|
| 313 | - * @param array $row the row which should be converted to an entity |
|
| 314 | - * @return Entity the entity |
|
| 315 | - * @since 7.0.0 |
|
| 316 | - */ |
|
| 317 | - protected function mapRowToEntity($row) { |
|
| 318 | - return call_user_func($this->entityClass .'::fromRow', $row); |
|
| 319 | - } |
|
| 320 | - |
|
| 321 | - |
|
| 322 | - /** |
|
| 323 | - * Runs a sql query and returns an array of entities |
|
| 324 | - * @param string $sql the prepare string |
|
| 325 | - * @param array $params the params which should replace the ? in the sql query |
|
| 326 | - * @param int $limit the maximum number of rows |
|
| 327 | - * @param int $offset from which row we want to start |
|
| 328 | - * @return array all fetched entities |
|
| 329 | - * @since 7.0.0 |
|
| 330 | - */ |
|
| 331 | - protected function findEntities($sql, array $params=[], $limit=null, $offset=null) { |
|
| 332 | - $stmt = $this->execute($sql, $params, $limit, $offset); |
|
| 333 | - |
|
| 334 | - $entities = []; |
|
| 335 | - |
|
| 336 | - while($row = $stmt->fetch()){ |
|
| 337 | - $entities[] = $this->mapRowToEntity($row); |
|
| 338 | - } |
|
| 339 | - |
|
| 340 | - $stmt->closeCursor(); |
|
| 341 | - |
|
| 342 | - return $entities; |
|
| 343 | - } |
|
| 344 | - |
|
| 345 | - |
|
| 346 | - /** |
|
| 347 | - * Returns an db result and throws exceptions when there are more or less |
|
| 348 | - * results |
|
| 349 | - * @param string $sql the sql query |
|
| 350 | - * @param array $params the parameters of the sql query |
|
| 351 | - * @param int $limit the maximum number of rows |
|
| 352 | - * @param int $offset from which row we want to start |
|
| 353 | - * @throws DoesNotExistException if the item does not exist |
|
| 354 | - * @throws MultipleObjectsReturnedException if more than one item exist |
|
| 355 | - * @return Entity the entity |
|
| 356 | - * @since 7.0.0 |
|
| 357 | - */ |
|
| 358 | - protected function findEntity($sql, array $params=[], $limit=null, $offset=null){ |
|
| 359 | - return $this->mapRowToEntity($this->findOneQuery($sql, $params, $limit, $offset)); |
|
| 360 | - } |
|
| 40 | + protected $tableName; |
|
| 41 | + protected $entityClass; |
|
| 42 | + protected $db; |
|
| 43 | + |
|
| 44 | + /** |
|
| 45 | + * @param IDBConnection $db Instance of the Db abstraction layer |
|
| 46 | + * @param string $tableName the name of the table. set this to allow entity |
|
| 47 | + * @param string $entityClass the name of the entity that the sql should be |
|
| 48 | + * mapped to queries without using sql |
|
| 49 | + * @since 7.0.0 |
|
| 50 | + */ |
|
| 51 | + public function __construct(IDBConnection $db, $tableName, $entityClass=null){ |
|
| 52 | + $this->db = $db; |
|
| 53 | + $this->tableName = '*PREFIX*' . $tableName; |
|
| 54 | + |
|
| 55 | + // if not given set the entity name to the class without the mapper part |
|
| 56 | + // cache it here for later use since reflection is slow |
|
| 57 | + if($entityClass === null) { |
|
| 58 | + $this->entityClass = str_replace('Mapper', '', get_class($this)); |
|
| 59 | + } else { |
|
| 60 | + $this->entityClass = $entityClass; |
|
| 61 | + } |
|
| 62 | + } |
|
| 63 | + |
|
| 64 | + |
|
| 65 | + /** |
|
| 66 | + * @return string the table name |
|
| 67 | + * @since 7.0.0 |
|
| 68 | + */ |
|
| 69 | + public function getTableName(){ |
|
| 70 | + return $this->tableName; |
|
| 71 | + } |
|
| 72 | + |
|
| 73 | + |
|
| 74 | + /** |
|
| 75 | + * Deletes an entity from the table |
|
| 76 | + * @param Entity $entity the entity that should be deleted |
|
| 77 | + * @return Entity the deleted entity |
|
| 78 | + * @since 7.0.0 - return value added in 8.1.0 |
|
| 79 | + */ |
|
| 80 | + public function delete(Entity $entity){ |
|
| 81 | + $sql = 'DELETE FROM `' . $this->tableName . '` WHERE `id` = ?'; |
|
| 82 | + $stmt = $this->execute($sql, [$entity->getId()]); |
|
| 83 | + $stmt->closeCursor(); |
|
| 84 | + return $entity; |
|
| 85 | + } |
|
| 86 | + |
|
| 87 | + |
|
| 88 | + /** |
|
| 89 | + * Creates a new entry in the db from an entity |
|
| 90 | + * @param Entity $entity the entity that should be created |
|
| 91 | + * @return Entity the saved entity with the set id |
|
| 92 | + * @since 7.0.0 |
|
| 93 | + */ |
|
| 94 | + public function insert(Entity $entity){ |
|
| 95 | + // get updated fields to save, fields have to be set using a setter to |
|
| 96 | + // be saved |
|
| 97 | + $properties = $entity->getUpdatedFields(); |
|
| 98 | + $values = ''; |
|
| 99 | + $columns = ''; |
|
| 100 | + $params = []; |
|
| 101 | + |
|
| 102 | + // build the fields |
|
| 103 | + $i = 0; |
|
| 104 | + foreach($properties as $property => $updated) { |
|
| 105 | + $column = $entity->propertyToColumn($property); |
|
| 106 | + $getter = 'get' . ucfirst($property); |
|
| 107 | + |
|
| 108 | + $columns .= '`' . $column . '`'; |
|
| 109 | + $values .= '?'; |
|
| 110 | + |
|
| 111 | + // only append colon if there are more entries |
|
| 112 | + if($i < count($properties)-1){ |
|
| 113 | + $columns .= ','; |
|
| 114 | + $values .= ','; |
|
| 115 | + } |
|
| 116 | + |
|
| 117 | + $params[] = $entity->$getter(); |
|
| 118 | + $i++; |
|
| 119 | + |
|
| 120 | + } |
|
| 121 | + |
|
| 122 | + $sql = 'INSERT INTO `' . $this->tableName . '`(' . |
|
| 123 | + $columns . ') VALUES(' . $values . ')'; |
|
| 124 | + |
|
| 125 | + $stmt = $this->execute($sql, $params); |
|
| 126 | + |
|
| 127 | + $entity->setId((int) $this->db->lastInsertId($this->tableName)); |
|
| 128 | + |
|
| 129 | + $stmt->closeCursor(); |
|
| 130 | + |
|
| 131 | + return $entity; |
|
| 132 | + } |
|
| 133 | + |
|
| 134 | + |
|
| 135 | + |
|
| 136 | + /** |
|
| 137 | + * Updates an entry in the db from an entity |
|
| 138 | + * @throws \InvalidArgumentException if entity has no id |
|
| 139 | + * @param Entity $entity the entity that should be created |
|
| 140 | + * @return Entity the saved entity with the set id |
|
| 141 | + * @since 7.0.0 - return value was added in 8.0.0 |
|
| 142 | + */ |
|
| 143 | + public function update(Entity $entity){ |
|
| 144 | + // if entity wasn't changed it makes no sense to run a db query |
|
| 145 | + $properties = $entity->getUpdatedFields(); |
|
| 146 | + if(count($properties) === 0) { |
|
| 147 | + return $entity; |
|
| 148 | + } |
|
| 149 | + |
|
| 150 | + // entity needs an id |
|
| 151 | + $id = $entity->getId(); |
|
| 152 | + if($id === null){ |
|
| 153 | + throw new \InvalidArgumentException( |
|
| 154 | + 'Entity which should be updated has no id'); |
|
| 155 | + } |
|
| 156 | + |
|
| 157 | + // get updated fields to save, fields have to be set using a setter to |
|
| 158 | + // be saved |
|
| 159 | + // do not update the id field |
|
| 160 | + unset($properties['id']); |
|
| 161 | + |
|
| 162 | + $columns = ''; |
|
| 163 | + $params = []; |
|
| 164 | + |
|
| 165 | + // build the fields |
|
| 166 | + $i = 0; |
|
| 167 | + foreach($properties as $property => $updated) { |
|
| 168 | + |
|
| 169 | + $column = $entity->propertyToColumn($property); |
|
| 170 | + $getter = 'get' . ucfirst($property); |
|
| 171 | + |
|
| 172 | + $columns .= '`' . $column . '` = ?'; |
|
| 173 | + |
|
| 174 | + // only append colon if there are more entries |
|
| 175 | + if($i < count($properties)-1){ |
|
| 176 | + $columns .= ','; |
|
| 177 | + } |
|
| 178 | + |
|
| 179 | + $params[] = $entity->$getter(); |
|
| 180 | + $i++; |
|
| 181 | + } |
|
| 182 | + |
|
| 183 | + $sql = 'UPDATE `' . $this->tableName . '` SET ' . |
|
| 184 | + $columns . ' WHERE `id` = ?'; |
|
| 185 | + $params[] = $id; |
|
| 186 | + |
|
| 187 | + $stmt = $this->execute($sql, $params); |
|
| 188 | + $stmt->closeCursor(); |
|
| 189 | + |
|
| 190 | + return $entity; |
|
| 191 | + } |
|
| 192 | + |
|
| 193 | + /** |
|
| 194 | + * Checks if an array is associative |
|
| 195 | + * @param array $array |
|
| 196 | + * @return bool true if associative |
|
| 197 | + * @since 8.1.0 |
|
| 198 | + */ |
|
| 199 | + private function isAssocArray(array $array) { |
|
| 200 | + return array_values($array) !== $array; |
|
| 201 | + } |
|
| 202 | + |
|
| 203 | + /** |
|
| 204 | + * Returns the correct PDO constant based on the value type |
|
| 205 | + * @param $value |
|
| 206 | + * @return int PDO constant |
|
| 207 | + * @since 8.1.0 |
|
| 208 | + */ |
|
| 209 | + private function getPDOType($value) { |
|
| 210 | + switch (gettype($value)) { |
|
| 211 | + case 'integer': |
|
| 212 | + return \PDO::PARAM_INT; |
|
| 213 | + case 'boolean': |
|
| 214 | + return \PDO::PARAM_BOOL; |
|
| 215 | + default: |
|
| 216 | + return \PDO::PARAM_STR; |
|
| 217 | + } |
|
| 218 | + } |
|
| 219 | + |
|
| 220 | + |
|
| 221 | + /** |
|
| 222 | + * Runs an sql query |
|
| 223 | + * @param string $sql the prepare string |
|
| 224 | + * @param array $params the params which should replace the ? in the sql query |
|
| 225 | + * @param int $limit the maximum number of rows |
|
| 226 | + * @param int $offset from which row we want to start |
|
| 227 | + * @return \PDOStatement the database query result |
|
| 228 | + * @since 7.0.0 |
|
| 229 | + */ |
|
| 230 | + protected function execute($sql, array $params=[], $limit=null, $offset=null){ |
|
| 231 | + $query = $this->db->prepare($sql, $limit, $offset); |
|
| 232 | + |
|
| 233 | + if ($this->isAssocArray($params)) { |
|
| 234 | + foreach ($params as $key => $param) { |
|
| 235 | + $pdoConstant = $this->getPDOType($param); |
|
| 236 | + $query->bindValue($key, $param, $pdoConstant); |
|
| 237 | + } |
|
| 238 | + } else { |
|
| 239 | + $index = 1; // bindParam is 1 indexed |
|
| 240 | + foreach ($params as $param) { |
|
| 241 | + $pdoConstant = $this->getPDOType($param); |
|
| 242 | + $query->bindValue($index, $param, $pdoConstant); |
|
| 243 | + $index++; |
|
| 244 | + } |
|
| 245 | + } |
|
| 246 | + |
|
| 247 | + $query->execute(); |
|
| 248 | + |
|
| 249 | + return $query; |
|
| 250 | + } |
|
| 251 | + |
|
| 252 | + |
|
| 253 | + /** |
|
| 254 | + * Returns an db result and throws exceptions when there are more or less |
|
| 255 | + * results |
|
| 256 | + * @see findEntity |
|
| 257 | + * @param string $sql the sql query |
|
| 258 | + * @param array $params the parameters of the sql query |
|
| 259 | + * @param int $limit the maximum number of rows |
|
| 260 | + * @param int $offset from which row we want to start |
|
| 261 | + * @throws DoesNotExistException if the item does not exist |
|
| 262 | + * @throws MultipleObjectsReturnedException if more than one item exist |
|
| 263 | + * @return array the result as row |
|
| 264 | + * @since 7.0.0 |
|
| 265 | + */ |
|
| 266 | + protected function findOneQuery($sql, array $params=[], $limit=null, $offset=null){ |
|
| 267 | + $stmt = $this->execute($sql, $params, $limit, $offset); |
|
| 268 | + $row = $stmt->fetch(); |
|
| 269 | + |
|
| 270 | + if($row === false || $row === null){ |
|
| 271 | + $stmt->closeCursor(); |
|
| 272 | + $msg = $this->buildDebugMessage( |
|
| 273 | + 'Did expect one result but found none when executing', $sql, $params, $limit, $offset |
|
| 274 | + ); |
|
| 275 | + throw new DoesNotExistException($msg); |
|
| 276 | + } |
|
| 277 | + $row2 = $stmt->fetch(); |
|
| 278 | + $stmt->closeCursor(); |
|
| 279 | + //MDB2 returns null, PDO and doctrine false when no row is available |
|
| 280 | + if( ! ($row2 === false || $row2 === null )) { |
|
| 281 | + $msg = $this->buildDebugMessage( |
|
| 282 | + 'Did not expect more than one result when executing', $sql, $params, $limit, $offset |
|
| 283 | + ); |
|
| 284 | + throw new MultipleObjectsReturnedException($msg); |
|
| 285 | + } else { |
|
| 286 | + return $row; |
|
| 287 | + } |
|
| 288 | + } |
|
| 289 | + |
|
| 290 | + /** |
|
| 291 | + * Builds an error message by prepending the $msg to an error message which |
|
| 292 | + * has the parameters |
|
| 293 | + * @see findEntity |
|
| 294 | + * @param string $sql the sql query |
|
| 295 | + * @param array $params the parameters of the sql query |
|
| 296 | + * @param int $limit the maximum number of rows |
|
| 297 | + * @param int $offset from which row we want to start |
|
| 298 | + * @return string formatted error message string |
|
| 299 | + * @since 9.1.0 |
|
| 300 | + */ |
|
| 301 | + private function buildDebugMessage($msg, $sql, array $params=[], $limit=null, $offset=null) { |
|
| 302 | + return $msg . |
|
| 303 | + ': query "' . $sql . '"; ' . |
|
| 304 | + 'parameters ' . print_r($params, true) . '; ' . |
|
| 305 | + 'limit "' . $limit . '"; '. |
|
| 306 | + 'offset "' . $offset . '"'; |
|
| 307 | + } |
|
| 308 | + |
|
| 309 | + |
|
| 310 | + /** |
|
| 311 | + * Creates an entity from a row. Automatically determines the entity class |
|
| 312 | + * from the current mapper name (MyEntityMapper -> MyEntity) |
|
| 313 | + * @param array $row the row which should be converted to an entity |
|
| 314 | + * @return Entity the entity |
|
| 315 | + * @since 7.0.0 |
|
| 316 | + */ |
|
| 317 | + protected function mapRowToEntity($row) { |
|
| 318 | + return call_user_func($this->entityClass .'::fromRow', $row); |
|
| 319 | + } |
|
| 320 | + |
|
| 321 | + |
|
| 322 | + /** |
|
| 323 | + * Runs a sql query and returns an array of entities |
|
| 324 | + * @param string $sql the prepare string |
|
| 325 | + * @param array $params the params which should replace the ? in the sql query |
|
| 326 | + * @param int $limit the maximum number of rows |
|
| 327 | + * @param int $offset from which row we want to start |
|
| 328 | + * @return array all fetched entities |
|
| 329 | + * @since 7.0.0 |
|
| 330 | + */ |
|
| 331 | + protected function findEntities($sql, array $params=[], $limit=null, $offset=null) { |
|
| 332 | + $stmt = $this->execute($sql, $params, $limit, $offset); |
|
| 333 | + |
|
| 334 | + $entities = []; |
|
| 335 | + |
|
| 336 | + while($row = $stmt->fetch()){ |
|
| 337 | + $entities[] = $this->mapRowToEntity($row); |
|
| 338 | + } |
|
| 339 | + |
|
| 340 | + $stmt->closeCursor(); |
|
| 341 | + |
|
| 342 | + return $entities; |
|
| 343 | + } |
|
| 344 | + |
|
| 345 | + |
|
| 346 | + /** |
|
| 347 | + * Returns an db result and throws exceptions when there are more or less |
|
| 348 | + * results |
|
| 349 | + * @param string $sql the sql query |
|
| 350 | + * @param array $params the parameters of the sql query |
|
| 351 | + * @param int $limit the maximum number of rows |
|
| 352 | + * @param int $offset from which row we want to start |
|
| 353 | + * @throws DoesNotExistException if the item does not exist |
|
| 354 | + * @throws MultipleObjectsReturnedException if more than one item exist |
|
| 355 | + * @return Entity the entity |
|
| 356 | + * @since 7.0.0 |
|
| 357 | + */ |
|
| 358 | + protected function findEntity($sql, array $params=[], $limit=null, $offset=null){ |
|
| 359 | + return $this->mapRowToEntity($this->findOneQuery($sql, $params, $limit, $offset)); |
|
| 360 | + } |
|
| 361 | 361 | |
| 362 | 362 | |
| 363 | 363 | } |
@@ -32,13 +32,13 @@ |
||
| 32 | 32 | */ |
| 33 | 33 | class DoesNotExistException extends \Exception { |
| 34 | 34 | |
| 35 | - /** |
|
| 36 | - * Constructor |
|
| 37 | - * @param string $msg the error message |
|
| 38 | - * @since 7.0.0 |
|
| 39 | - */ |
|
| 40 | - public function __construct($msg){ |
|
| 41 | - parent::__construct($msg); |
|
| 42 | - } |
|
| 35 | + /** |
|
| 36 | + * Constructor |
|
| 37 | + * @param string $msg the error message |
|
| 38 | + * @since 7.0.0 |
|
| 39 | + */ |
|
| 40 | + public function __construct($msg){ |
|
| 41 | + parent::__construct($msg); |
|
| 42 | + } |
|
| 43 | 43 | |
| 44 | 44 | } |
@@ -37,7 +37,7 @@ |
||
| 37 | 37 | * @param string $msg the error message |
| 38 | 38 | * @since 7.0.0 |
| 39 | 39 | */ |
| 40 | - public function __construct($msg){ |
|
| 40 | + public function __construct($msg) { |
|
| 41 | 41 | parent::__construct($msg); |
| 42 | 42 | } |
| 43 | 43 | |
@@ -31,224 +31,224 @@ |
||
| 31 | 31 | */ |
| 32 | 32 | abstract class Entity { |
| 33 | 33 | |
| 34 | - public $id; |
|
| 34 | + public $id; |
|
| 35 | 35 | |
| 36 | - private $_updatedFields = array(); |
|
| 37 | - private $_fieldTypes = array('id' => 'integer'); |
|
| 36 | + private $_updatedFields = array(); |
|
| 37 | + private $_fieldTypes = array('id' => 'integer'); |
|
| 38 | 38 | |
| 39 | 39 | |
| 40 | - /** |
|
| 41 | - * Simple alternative constructor for building entities from a request |
|
| 42 | - * @param array $params the array which was obtained via $this->params('key') |
|
| 43 | - * in the controller |
|
| 44 | - * @return Entity |
|
| 45 | - * @since 7.0.0 |
|
| 46 | - */ |
|
| 47 | - public static function fromParams(array $params) { |
|
| 48 | - $instance = new static(); |
|
| 40 | + /** |
|
| 41 | + * Simple alternative constructor for building entities from a request |
|
| 42 | + * @param array $params the array which was obtained via $this->params('key') |
|
| 43 | + * in the controller |
|
| 44 | + * @return Entity |
|
| 45 | + * @since 7.0.0 |
|
| 46 | + */ |
|
| 47 | + public static function fromParams(array $params) { |
|
| 48 | + $instance = new static(); |
|
| 49 | 49 | |
| 50 | - foreach($params as $key => $value) { |
|
| 51 | - $method = 'set' . ucfirst($key); |
|
| 52 | - $instance->$method($value); |
|
| 53 | - } |
|
| 50 | + foreach($params as $key => $value) { |
|
| 51 | + $method = 'set' . ucfirst($key); |
|
| 52 | + $instance->$method($value); |
|
| 53 | + } |
|
| 54 | 54 | |
| 55 | - return $instance; |
|
| 56 | - } |
|
| 55 | + return $instance; |
|
| 56 | + } |
|
| 57 | 57 | |
| 58 | 58 | |
| 59 | - /** |
|
| 60 | - * Maps the keys of the row array to the attributes |
|
| 61 | - * @param array $row the row to map onto the entity |
|
| 62 | - * @since 7.0.0 |
|
| 63 | - */ |
|
| 64 | - public static function fromRow(array $row){ |
|
| 65 | - $instance = new static(); |
|
| 59 | + /** |
|
| 60 | + * Maps the keys of the row array to the attributes |
|
| 61 | + * @param array $row the row to map onto the entity |
|
| 62 | + * @since 7.0.0 |
|
| 63 | + */ |
|
| 64 | + public static function fromRow(array $row){ |
|
| 65 | + $instance = new static(); |
|
| 66 | 66 | |
| 67 | - foreach($row as $key => $value){ |
|
| 68 | - $prop = ucfirst($instance->columnToProperty($key)); |
|
| 69 | - $setter = 'set' . $prop; |
|
| 70 | - $instance->$setter($value); |
|
| 71 | - } |
|
| 67 | + foreach($row as $key => $value){ |
|
| 68 | + $prop = ucfirst($instance->columnToProperty($key)); |
|
| 69 | + $setter = 'set' . $prop; |
|
| 70 | + $instance->$setter($value); |
|
| 71 | + } |
|
| 72 | 72 | |
| 73 | - $instance->resetUpdatedFields(); |
|
| 73 | + $instance->resetUpdatedFields(); |
|
| 74 | 74 | |
| 75 | - return $instance; |
|
| 76 | - } |
|
| 75 | + return $instance; |
|
| 76 | + } |
|
| 77 | 77 | |
| 78 | 78 | |
| 79 | - /** |
|
| 80 | - * @return array with attribute and type |
|
| 81 | - * @since 7.0.0 |
|
| 82 | - */ |
|
| 83 | - public function getFieldTypes() { |
|
| 84 | - return $this->_fieldTypes; |
|
| 85 | - } |
|
| 79 | + /** |
|
| 80 | + * @return array with attribute and type |
|
| 81 | + * @since 7.0.0 |
|
| 82 | + */ |
|
| 83 | + public function getFieldTypes() { |
|
| 84 | + return $this->_fieldTypes; |
|
| 85 | + } |
|
| 86 | 86 | |
| 87 | 87 | |
| 88 | - /** |
|
| 89 | - * Marks the entity as clean needed for setting the id after the insertion |
|
| 90 | - * @since 7.0.0 |
|
| 91 | - */ |
|
| 92 | - public function resetUpdatedFields(){ |
|
| 93 | - $this->_updatedFields = array(); |
|
| 94 | - } |
|
| 95 | - |
|
| 96 | - /** |
|
| 97 | - * Generic setter for properties |
|
| 98 | - * @since 7.0.0 |
|
| 99 | - */ |
|
| 100 | - protected function setter($name, $args) { |
|
| 101 | - // setters should only work for existing attributes |
|
| 102 | - if(property_exists($this, $name)){ |
|
| 103 | - if($this->$name === $args[0]) { |
|
| 104 | - return; |
|
| 105 | - } |
|
| 106 | - $this->markFieldUpdated($name); |
|
| 107 | - |
|
| 108 | - // if type definition exists, cast to correct type |
|
| 109 | - if($args[0] !== null && array_key_exists($name, $this->_fieldTypes)) { |
|
| 110 | - settype($args[0], $this->_fieldTypes[$name]); |
|
| 111 | - } |
|
| 112 | - $this->$name = $args[0]; |
|
| 113 | - |
|
| 114 | - } else { |
|
| 115 | - throw new \BadFunctionCallException($name . |
|
| 116 | - ' is not a valid attribute'); |
|
| 117 | - } |
|
| 118 | - } |
|
| 119 | - |
|
| 120 | - /** |
|
| 121 | - * Generic getter for properties |
|
| 122 | - * @since 7.0.0 |
|
| 123 | - */ |
|
| 124 | - protected function getter($name) { |
|
| 125 | - // getters should only work for existing attributes |
|
| 126 | - if(property_exists($this, $name)){ |
|
| 127 | - return $this->$name; |
|
| 128 | - } else { |
|
| 129 | - throw new \BadFunctionCallException($name . |
|
| 130 | - ' is not a valid attribute'); |
|
| 131 | - } |
|
| 132 | - } |
|
| 133 | - |
|
| 134 | - |
|
| 135 | - /** |
|
| 136 | - * Each time a setter is called, push the part after set |
|
| 137 | - * into an array: for instance setId will save Id in the |
|
| 138 | - * updated fields array so it can be easily used to create the |
|
| 139 | - * getter method |
|
| 140 | - * @since 7.0.0 |
|
| 141 | - */ |
|
| 142 | - public function __call($methodName, $args){ |
|
| 143 | - $attr = lcfirst( substr($methodName, 3) ); |
|
| 144 | - |
|
| 145 | - if(strpos($methodName, 'set') === 0){ |
|
| 146 | - $this->setter($attr, $args); |
|
| 147 | - } elseif(strpos($methodName, 'get') === 0) { |
|
| 148 | - return $this->getter($attr); |
|
| 149 | - } else { |
|
| 150 | - throw new \BadFunctionCallException($methodName . |
|
| 151 | - ' does not exist'); |
|
| 152 | - } |
|
| 153 | - |
|
| 154 | - } |
|
| 155 | - |
|
| 156 | - |
|
| 157 | - /** |
|
| 158 | - * Mark am attribute as updated |
|
| 159 | - * @param string $attribute the name of the attribute |
|
| 160 | - * @since 7.0.0 |
|
| 161 | - */ |
|
| 162 | - protected function markFieldUpdated($attribute){ |
|
| 163 | - $this->_updatedFields[$attribute] = true; |
|
| 164 | - } |
|
| 165 | - |
|
| 166 | - |
|
| 167 | - /** |
|
| 168 | - * Transform a database columnname to a property |
|
| 169 | - * @param string $columnName the name of the column |
|
| 170 | - * @return string the property name |
|
| 171 | - * @since 7.0.0 |
|
| 172 | - */ |
|
| 173 | - public function columnToProperty($columnName){ |
|
| 174 | - $parts = explode('_', $columnName); |
|
| 175 | - $property = null; |
|
| 176 | - |
|
| 177 | - foreach($parts as $part){ |
|
| 178 | - if($property === null){ |
|
| 179 | - $property = $part; |
|
| 180 | - } else { |
|
| 181 | - $property .= ucfirst($part); |
|
| 182 | - } |
|
| 183 | - } |
|
| 184 | - |
|
| 185 | - return $property; |
|
| 186 | - } |
|
| 187 | - |
|
| 188 | - |
|
| 189 | - /** |
|
| 190 | - * Transform a property to a database column name |
|
| 191 | - * @param string $property the name of the property |
|
| 192 | - * @return string the column name |
|
| 193 | - * @since 7.0.0 |
|
| 194 | - */ |
|
| 195 | - public function propertyToColumn($property){ |
|
| 196 | - $parts = preg_split('/(?=[A-Z])/', $property); |
|
| 197 | - $column = null; |
|
| 198 | - |
|
| 199 | - foreach($parts as $part){ |
|
| 200 | - if($column === null){ |
|
| 201 | - $column = $part; |
|
| 202 | - } else { |
|
| 203 | - $column .= '_' . lcfirst($part); |
|
| 204 | - } |
|
| 205 | - } |
|
| 206 | - |
|
| 207 | - return $column; |
|
| 208 | - } |
|
| 209 | - |
|
| 210 | - |
|
| 211 | - /** |
|
| 212 | - * @return array array of updated fields for update query |
|
| 213 | - * @since 7.0.0 |
|
| 214 | - */ |
|
| 215 | - public function getUpdatedFields(){ |
|
| 216 | - return $this->_updatedFields; |
|
| 217 | - } |
|
| 218 | - |
|
| 219 | - |
|
| 220 | - /** |
|
| 221 | - * Adds type information for a field so that its automatically casted to |
|
| 222 | - * that value once its being returned from the database |
|
| 223 | - * @param string $fieldName the name of the attribute |
|
| 224 | - * @param string $type the type which will be used to call settype() |
|
| 225 | - * @since 7.0.0 |
|
| 226 | - */ |
|
| 227 | - protected function addType($fieldName, $type){ |
|
| 228 | - $this->_fieldTypes[$fieldName] = $type; |
|
| 229 | - } |
|
| 230 | - |
|
| 231 | - |
|
| 232 | - /** |
|
| 233 | - * Slugify the value of a given attribute |
|
| 234 | - * Warning: This doesn't result in a unique value |
|
| 235 | - * @param string $attributeName the name of the attribute, which value should be slugified |
|
| 236 | - * @return string slugified value |
|
| 237 | - * @since 7.0.0 |
|
| 238 | - */ |
|
| 239 | - public function slugify($attributeName){ |
|
| 240 | - // toSlug should only work for existing attributes |
|
| 241 | - if(property_exists($this, $attributeName)){ |
|
| 242 | - $value = $this->$attributeName; |
|
| 243 | - // replace everything except alphanumeric with a single '-' |
|
| 244 | - $value = preg_replace('/[^A-Za-z0-9]+/', '-', $value); |
|
| 245 | - $value = strtolower($value); |
|
| 246 | - // trim '-' |
|
| 247 | - return trim($value, '-'); |
|
| 248 | - } else { |
|
| 249 | - throw new \BadFunctionCallException($attributeName . |
|
| 250 | - ' is not a valid attribute'); |
|
| 251 | - } |
|
| 252 | - } |
|
| 88 | + /** |
|
| 89 | + * Marks the entity as clean needed for setting the id after the insertion |
|
| 90 | + * @since 7.0.0 |
|
| 91 | + */ |
|
| 92 | + public function resetUpdatedFields(){ |
|
| 93 | + $this->_updatedFields = array(); |
|
| 94 | + } |
|
| 95 | + |
|
| 96 | + /** |
|
| 97 | + * Generic setter for properties |
|
| 98 | + * @since 7.0.0 |
|
| 99 | + */ |
|
| 100 | + protected function setter($name, $args) { |
|
| 101 | + // setters should only work for existing attributes |
|
| 102 | + if(property_exists($this, $name)){ |
|
| 103 | + if($this->$name === $args[0]) { |
|
| 104 | + return; |
|
| 105 | + } |
|
| 106 | + $this->markFieldUpdated($name); |
|
| 107 | + |
|
| 108 | + // if type definition exists, cast to correct type |
|
| 109 | + if($args[0] !== null && array_key_exists($name, $this->_fieldTypes)) { |
|
| 110 | + settype($args[0], $this->_fieldTypes[$name]); |
|
| 111 | + } |
|
| 112 | + $this->$name = $args[0]; |
|
| 113 | + |
|
| 114 | + } else { |
|
| 115 | + throw new \BadFunctionCallException($name . |
|
| 116 | + ' is not a valid attribute'); |
|
| 117 | + } |
|
| 118 | + } |
|
| 119 | + |
|
| 120 | + /** |
|
| 121 | + * Generic getter for properties |
|
| 122 | + * @since 7.0.0 |
|
| 123 | + */ |
|
| 124 | + protected function getter($name) { |
|
| 125 | + // getters should only work for existing attributes |
|
| 126 | + if(property_exists($this, $name)){ |
|
| 127 | + return $this->$name; |
|
| 128 | + } else { |
|
| 129 | + throw new \BadFunctionCallException($name . |
|
| 130 | + ' is not a valid attribute'); |
|
| 131 | + } |
|
| 132 | + } |
|
| 133 | + |
|
| 134 | + |
|
| 135 | + /** |
|
| 136 | + * Each time a setter is called, push the part after set |
|
| 137 | + * into an array: for instance setId will save Id in the |
|
| 138 | + * updated fields array so it can be easily used to create the |
|
| 139 | + * getter method |
|
| 140 | + * @since 7.0.0 |
|
| 141 | + */ |
|
| 142 | + public function __call($methodName, $args){ |
|
| 143 | + $attr = lcfirst( substr($methodName, 3) ); |
|
| 144 | + |
|
| 145 | + if(strpos($methodName, 'set') === 0){ |
|
| 146 | + $this->setter($attr, $args); |
|
| 147 | + } elseif(strpos($methodName, 'get') === 0) { |
|
| 148 | + return $this->getter($attr); |
|
| 149 | + } else { |
|
| 150 | + throw new \BadFunctionCallException($methodName . |
|
| 151 | + ' does not exist'); |
|
| 152 | + } |
|
| 153 | + |
|
| 154 | + } |
|
| 155 | + |
|
| 156 | + |
|
| 157 | + /** |
|
| 158 | + * Mark am attribute as updated |
|
| 159 | + * @param string $attribute the name of the attribute |
|
| 160 | + * @since 7.0.0 |
|
| 161 | + */ |
|
| 162 | + protected function markFieldUpdated($attribute){ |
|
| 163 | + $this->_updatedFields[$attribute] = true; |
|
| 164 | + } |
|
| 165 | + |
|
| 166 | + |
|
| 167 | + /** |
|
| 168 | + * Transform a database columnname to a property |
|
| 169 | + * @param string $columnName the name of the column |
|
| 170 | + * @return string the property name |
|
| 171 | + * @since 7.0.0 |
|
| 172 | + */ |
|
| 173 | + public function columnToProperty($columnName){ |
|
| 174 | + $parts = explode('_', $columnName); |
|
| 175 | + $property = null; |
|
| 176 | + |
|
| 177 | + foreach($parts as $part){ |
|
| 178 | + if($property === null){ |
|
| 179 | + $property = $part; |
|
| 180 | + } else { |
|
| 181 | + $property .= ucfirst($part); |
|
| 182 | + } |
|
| 183 | + } |
|
| 184 | + |
|
| 185 | + return $property; |
|
| 186 | + } |
|
| 187 | + |
|
| 188 | + |
|
| 189 | + /** |
|
| 190 | + * Transform a property to a database column name |
|
| 191 | + * @param string $property the name of the property |
|
| 192 | + * @return string the column name |
|
| 193 | + * @since 7.0.0 |
|
| 194 | + */ |
|
| 195 | + public function propertyToColumn($property){ |
|
| 196 | + $parts = preg_split('/(?=[A-Z])/', $property); |
|
| 197 | + $column = null; |
|
| 198 | + |
|
| 199 | + foreach($parts as $part){ |
|
| 200 | + if($column === null){ |
|
| 201 | + $column = $part; |
|
| 202 | + } else { |
|
| 203 | + $column .= '_' . lcfirst($part); |
|
| 204 | + } |
|
| 205 | + } |
|
| 206 | + |
|
| 207 | + return $column; |
|
| 208 | + } |
|
| 209 | + |
|
| 210 | + |
|
| 211 | + /** |
|
| 212 | + * @return array array of updated fields for update query |
|
| 213 | + * @since 7.0.0 |
|
| 214 | + */ |
|
| 215 | + public function getUpdatedFields(){ |
|
| 216 | + return $this->_updatedFields; |
|
| 217 | + } |
|
| 218 | + |
|
| 219 | + |
|
| 220 | + /** |
|
| 221 | + * Adds type information for a field so that its automatically casted to |
|
| 222 | + * that value once its being returned from the database |
|
| 223 | + * @param string $fieldName the name of the attribute |
|
| 224 | + * @param string $type the type which will be used to call settype() |
|
| 225 | + * @since 7.0.0 |
|
| 226 | + */ |
|
| 227 | + protected function addType($fieldName, $type){ |
|
| 228 | + $this->_fieldTypes[$fieldName] = $type; |
|
| 229 | + } |
|
| 230 | + |
|
| 231 | + |
|
| 232 | + /** |
|
| 233 | + * Slugify the value of a given attribute |
|
| 234 | + * Warning: This doesn't result in a unique value |
|
| 235 | + * @param string $attributeName the name of the attribute, which value should be slugified |
|
| 236 | + * @return string slugified value |
|
| 237 | + * @since 7.0.0 |
|
| 238 | + */ |
|
| 239 | + public function slugify($attributeName){ |
|
| 240 | + // toSlug should only work for existing attributes |
|
| 241 | + if(property_exists($this, $attributeName)){ |
|
| 242 | + $value = $this->$attributeName; |
|
| 243 | + // replace everything except alphanumeric with a single '-' |
|
| 244 | + $value = preg_replace('/[^A-Za-z0-9]+/', '-', $value); |
|
| 245 | + $value = strtolower($value); |
|
| 246 | + // trim '-' |
|
| 247 | + return trim($value, '-'); |
|
| 248 | + } else { |
|
| 249 | + throw new \BadFunctionCallException($attributeName . |
|
| 250 | + ' is not a valid attribute'); |
|
| 251 | + } |
|
| 252 | + } |
|
| 253 | 253 | |
| 254 | 254 | } |
@@ -47,8 +47,8 @@ discard block |
||
| 47 | 47 | public static function fromParams(array $params) { |
| 48 | 48 | $instance = new static(); |
| 49 | 49 | |
| 50 | - foreach($params as $key => $value) { |
|
| 51 | - $method = 'set' . ucfirst($key); |
|
| 50 | + foreach ($params as $key => $value) { |
|
| 51 | + $method = 'set'.ucfirst($key); |
|
| 52 | 52 | $instance->$method($value); |
| 53 | 53 | } |
| 54 | 54 | |
@@ -61,12 +61,12 @@ discard block |
||
| 61 | 61 | * @param array $row the row to map onto the entity |
| 62 | 62 | * @since 7.0.0 |
| 63 | 63 | */ |
| 64 | - public static function fromRow(array $row){ |
|
| 64 | + public static function fromRow(array $row) { |
|
| 65 | 65 | $instance = new static(); |
| 66 | 66 | |
| 67 | - foreach($row as $key => $value){ |
|
| 67 | + foreach ($row as $key => $value) { |
|
| 68 | 68 | $prop = ucfirst($instance->columnToProperty($key)); |
| 69 | - $setter = 'set' . $prop; |
|
| 69 | + $setter = 'set'.$prop; |
|
| 70 | 70 | $instance->$setter($value); |
| 71 | 71 | } |
| 72 | 72 | |
@@ -89,7 +89,7 @@ discard block |
||
| 89 | 89 | * Marks the entity as clean needed for setting the id after the insertion |
| 90 | 90 | * @since 7.0.0 |
| 91 | 91 | */ |
| 92 | - public function resetUpdatedFields(){ |
|
| 92 | + public function resetUpdatedFields() { |
|
| 93 | 93 | $this->_updatedFields = array(); |
| 94 | 94 | } |
| 95 | 95 | |
@@ -99,20 +99,20 @@ discard block |
||
| 99 | 99 | */ |
| 100 | 100 | protected function setter($name, $args) { |
| 101 | 101 | // setters should only work for existing attributes |
| 102 | - if(property_exists($this, $name)){ |
|
| 103 | - if($this->$name === $args[0]) { |
|
| 102 | + if (property_exists($this, $name)) { |
|
| 103 | + if ($this->$name === $args[0]) { |
|
| 104 | 104 | return; |
| 105 | 105 | } |
| 106 | 106 | $this->markFieldUpdated($name); |
| 107 | 107 | |
| 108 | 108 | // if type definition exists, cast to correct type |
| 109 | - if($args[0] !== null && array_key_exists($name, $this->_fieldTypes)) { |
|
| 109 | + if ($args[0] !== null && array_key_exists($name, $this->_fieldTypes)) { |
|
| 110 | 110 | settype($args[0], $this->_fieldTypes[$name]); |
| 111 | 111 | } |
| 112 | 112 | $this->$name = $args[0]; |
| 113 | 113 | |
| 114 | 114 | } else { |
| 115 | - throw new \BadFunctionCallException($name . |
|
| 115 | + throw new \BadFunctionCallException($name. |
|
| 116 | 116 | ' is not a valid attribute'); |
| 117 | 117 | } |
| 118 | 118 | } |
@@ -123,10 +123,10 @@ discard block |
||
| 123 | 123 | */ |
| 124 | 124 | protected function getter($name) { |
| 125 | 125 | // getters should only work for existing attributes |
| 126 | - if(property_exists($this, $name)){ |
|
| 126 | + if (property_exists($this, $name)) { |
|
| 127 | 127 | return $this->$name; |
| 128 | 128 | } else { |
| 129 | - throw new \BadFunctionCallException($name . |
|
| 129 | + throw new \BadFunctionCallException($name. |
|
| 130 | 130 | ' is not a valid attribute'); |
| 131 | 131 | } |
| 132 | 132 | } |
@@ -139,15 +139,15 @@ discard block |
||
| 139 | 139 | * getter method |
| 140 | 140 | * @since 7.0.0 |
| 141 | 141 | */ |
| 142 | - public function __call($methodName, $args){ |
|
| 143 | - $attr = lcfirst( substr($methodName, 3) ); |
|
| 142 | + public function __call($methodName, $args) { |
|
| 143 | + $attr = lcfirst(substr($methodName, 3)); |
|
| 144 | 144 | |
| 145 | - if(strpos($methodName, 'set') === 0){ |
|
| 145 | + if (strpos($methodName, 'set') === 0) { |
|
| 146 | 146 | $this->setter($attr, $args); |
| 147 | - } elseif(strpos($methodName, 'get') === 0) { |
|
| 147 | + } elseif (strpos($methodName, 'get') === 0) { |
|
| 148 | 148 | return $this->getter($attr); |
| 149 | 149 | } else { |
| 150 | - throw new \BadFunctionCallException($methodName . |
|
| 150 | + throw new \BadFunctionCallException($methodName. |
|
| 151 | 151 | ' does not exist'); |
| 152 | 152 | } |
| 153 | 153 | |
@@ -159,7 +159,7 @@ discard block |
||
| 159 | 159 | * @param string $attribute the name of the attribute |
| 160 | 160 | * @since 7.0.0 |
| 161 | 161 | */ |
| 162 | - protected function markFieldUpdated($attribute){ |
|
| 162 | + protected function markFieldUpdated($attribute) { |
|
| 163 | 163 | $this->_updatedFields[$attribute] = true; |
| 164 | 164 | } |
| 165 | 165 | |
@@ -170,12 +170,12 @@ discard block |
||
| 170 | 170 | * @return string the property name |
| 171 | 171 | * @since 7.0.0 |
| 172 | 172 | */ |
| 173 | - public function columnToProperty($columnName){ |
|
| 173 | + public function columnToProperty($columnName) { |
|
| 174 | 174 | $parts = explode('_', $columnName); |
| 175 | 175 | $property = null; |
| 176 | 176 | |
| 177 | - foreach($parts as $part){ |
|
| 178 | - if($property === null){ |
|
| 177 | + foreach ($parts as $part) { |
|
| 178 | + if ($property === null) { |
|
| 179 | 179 | $property = $part; |
| 180 | 180 | } else { |
| 181 | 181 | $property .= ucfirst($part); |
@@ -192,15 +192,15 @@ discard block |
||
| 192 | 192 | * @return string the column name |
| 193 | 193 | * @since 7.0.0 |
| 194 | 194 | */ |
| 195 | - public function propertyToColumn($property){ |
|
| 195 | + public function propertyToColumn($property) { |
|
| 196 | 196 | $parts = preg_split('/(?=[A-Z])/', $property); |
| 197 | 197 | $column = null; |
| 198 | 198 | |
| 199 | - foreach($parts as $part){ |
|
| 200 | - if($column === null){ |
|
| 199 | + foreach ($parts as $part) { |
|
| 200 | + if ($column === null) { |
|
| 201 | 201 | $column = $part; |
| 202 | 202 | } else { |
| 203 | - $column .= '_' . lcfirst($part); |
|
| 203 | + $column .= '_'.lcfirst($part); |
|
| 204 | 204 | } |
| 205 | 205 | } |
| 206 | 206 | |
@@ -212,7 +212,7 @@ discard block |
||
| 212 | 212 | * @return array array of updated fields for update query |
| 213 | 213 | * @since 7.0.0 |
| 214 | 214 | */ |
| 215 | - public function getUpdatedFields(){ |
|
| 215 | + public function getUpdatedFields() { |
|
| 216 | 216 | return $this->_updatedFields; |
| 217 | 217 | } |
| 218 | 218 | |
@@ -224,7 +224,7 @@ discard block |
||
| 224 | 224 | * @param string $type the type which will be used to call settype() |
| 225 | 225 | * @since 7.0.0 |
| 226 | 226 | */ |
| 227 | - protected function addType($fieldName, $type){ |
|
| 227 | + protected function addType($fieldName, $type) { |
|
| 228 | 228 | $this->_fieldTypes[$fieldName] = $type; |
| 229 | 229 | } |
| 230 | 230 | |
@@ -236,9 +236,9 @@ discard block |
||
| 236 | 236 | * @return string slugified value |
| 237 | 237 | * @since 7.0.0 |
| 238 | 238 | */ |
| 239 | - public function slugify($attributeName){ |
|
| 239 | + public function slugify($attributeName) { |
|
| 240 | 240 | // toSlug should only work for existing attributes |
| 241 | - if(property_exists($this, $attributeName)){ |
|
| 241 | + if (property_exists($this, $attributeName)) { |
|
| 242 | 242 | $value = $this->$attributeName; |
| 243 | 243 | // replace everything except alphanumeric with a single '-' |
| 244 | 244 | $value = preg_replace('/[^A-Za-z0-9]+/', '-', $value); |
@@ -246,7 +246,7 @@ discard block |
||
| 246 | 246 | // trim '-' |
| 247 | 247 | return trim($value, '-'); |
| 248 | 248 | } else { |
| 249 | - throw new \BadFunctionCallException($attributeName . |
|
| 249 | + throw new \BadFunctionCallException($attributeName. |
|
| 250 | 250 | ' is not a valid attribute'); |
| 251 | 251 | } |
| 252 | 252 | } |
@@ -33,32 +33,32 @@ |
||
| 33 | 33 | */ |
| 34 | 34 | interface IProviderFactory { |
| 35 | 35 | |
| 36 | - /** |
|
| 37 | - * IProviderFactory constructor. |
|
| 38 | - * @param IServerContainer $serverContainer |
|
| 39 | - * @since 9.0.0 |
|
| 40 | - */ |
|
| 41 | - public function __construct(IServerContainer $serverContainer); |
|
| 36 | + /** |
|
| 37 | + * IProviderFactory constructor. |
|
| 38 | + * @param IServerContainer $serverContainer |
|
| 39 | + * @since 9.0.0 |
|
| 40 | + */ |
|
| 41 | + public function __construct(IServerContainer $serverContainer); |
|
| 42 | 42 | |
| 43 | - /** |
|
| 44 | - * @param string $id |
|
| 45 | - * @return IShareProvider |
|
| 46 | - * @throws ProviderException |
|
| 47 | - * @since 9.0.0 |
|
| 48 | - */ |
|
| 49 | - public function getProvider($id); |
|
| 43 | + /** |
|
| 44 | + * @param string $id |
|
| 45 | + * @return IShareProvider |
|
| 46 | + * @throws ProviderException |
|
| 47 | + * @since 9.0.0 |
|
| 48 | + */ |
|
| 49 | + public function getProvider($id); |
|
| 50 | 50 | |
| 51 | - /** |
|
| 52 | - * @param int $shareType |
|
| 53 | - * @return IShareProvider |
|
| 54 | - * @throws ProviderException |
|
| 55 | - * @since 9.0.0 |
|
| 56 | - */ |
|
| 57 | - public function getProviderForType($shareType); |
|
| 51 | + /** |
|
| 52 | + * @param int $shareType |
|
| 53 | + * @return IShareProvider |
|
| 54 | + * @throws ProviderException |
|
| 55 | + * @since 9.0.0 |
|
| 56 | + */ |
|
| 57 | + public function getProviderForType($shareType); |
|
| 58 | 58 | |
| 59 | - /** |
|
| 60 | - * @return IShareProvider[] |
|
| 61 | - * @since 11.0.0 |
|
| 62 | - */ |
|
| 63 | - public function getAllProviders(); |
|
| 59 | + /** |
|
| 60 | + * @return IShareProvider[] |
|
| 61 | + * @since 11.0.0 |
|
| 62 | + */ |
|
| 63 | + public function getAllProviders(); |
|
| 64 | 64 | } |
@@ -33,65 +33,65 @@ |
||
| 33 | 33 | */ |
| 34 | 34 | class SabrePluginEvent extends Event { |
| 35 | 35 | |
| 36 | - /** @var int */ |
|
| 37 | - protected $statusCode; |
|
| 36 | + /** @var int */ |
|
| 37 | + protected $statusCode; |
|
| 38 | 38 | |
| 39 | - /** @var string */ |
|
| 40 | - protected $message; |
|
| 39 | + /** @var string */ |
|
| 40 | + protected $message; |
|
| 41 | 41 | |
| 42 | - /** @var Server */ |
|
| 43 | - protected $server; |
|
| 42 | + /** @var Server */ |
|
| 43 | + protected $server; |
|
| 44 | 44 | |
| 45 | - /** |
|
| 46 | - * @since 8.2.0 |
|
| 47 | - */ |
|
| 48 | - public function __construct($server = null) { |
|
| 49 | - $this->message = ''; |
|
| 50 | - $this->statusCode = Http::STATUS_OK; |
|
| 51 | - $this->server = $server; |
|
| 52 | - } |
|
| 45 | + /** |
|
| 46 | + * @since 8.2.0 |
|
| 47 | + */ |
|
| 48 | + public function __construct($server = null) { |
|
| 49 | + $this->message = ''; |
|
| 50 | + $this->statusCode = Http::STATUS_OK; |
|
| 51 | + $this->server = $server; |
|
| 52 | + } |
|
| 53 | 53 | |
| 54 | - /** |
|
| 55 | - * @param int $statusCode |
|
| 56 | - * @return self |
|
| 57 | - * @since 8.2.0 |
|
| 58 | - */ |
|
| 59 | - public function setStatusCode($statusCode) { |
|
| 60 | - $this->statusCode = (int) $statusCode; |
|
| 61 | - return $this; |
|
| 62 | - } |
|
| 54 | + /** |
|
| 55 | + * @param int $statusCode |
|
| 56 | + * @return self |
|
| 57 | + * @since 8.2.0 |
|
| 58 | + */ |
|
| 59 | + public function setStatusCode($statusCode) { |
|
| 60 | + $this->statusCode = (int) $statusCode; |
|
| 61 | + return $this; |
|
| 62 | + } |
|
| 63 | 63 | |
| 64 | - /** |
|
| 65 | - * @param string $message |
|
| 66 | - * @return self |
|
| 67 | - * @since 8.2.0 |
|
| 68 | - */ |
|
| 69 | - public function setMessage($message) { |
|
| 70 | - $this->message = (string) $message; |
|
| 71 | - return $this; |
|
| 72 | - } |
|
| 64 | + /** |
|
| 65 | + * @param string $message |
|
| 66 | + * @return self |
|
| 67 | + * @since 8.2.0 |
|
| 68 | + */ |
|
| 69 | + public function setMessage($message) { |
|
| 70 | + $this->message = (string) $message; |
|
| 71 | + return $this; |
|
| 72 | + } |
|
| 73 | 73 | |
| 74 | - /** |
|
| 75 | - * @return int |
|
| 76 | - * @since 8.2.0 |
|
| 77 | - */ |
|
| 78 | - public function getStatusCode() { |
|
| 79 | - return $this->statusCode; |
|
| 80 | - } |
|
| 74 | + /** |
|
| 75 | + * @return int |
|
| 76 | + * @since 8.2.0 |
|
| 77 | + */ |
|
| 78 | + public function getStatusCode() { |
|
| 79 | + return $this->statusCode; |
|
| 80 | + } |
|
| 81 | 81 | |
| 82 | - /** |
|
| 83 | - * @return string |
|
| 84 | - * @since 8.2.0 |
|
| 85 | - */ |
|
| 86 | - public function getMessage() { |
|
| 87 | - return $this->message; |
|
| 88 | - } |
|
| 82 | + /** |
|
| 83 | + * @return string |
|
| 84 | + * @since 8.2.0 |
|
| 85 | + */ |
|
| 86 | + public function getMessage() { |
|
| 87 | + return $this->message; |
|
| 88 | + } |
|
| 89 | 89 | |
| 90 | - /** |
|
| 91 | - * @return null|Server |
|
| 92 | - * @since 9.0.0 |
|
| 93 | - */ |
|
| 94 | - public function getServer() { |
|
| 95 | - return $this->server; |
|
| 96 | - } |
|
| 90 | + /** |
|
| 91 | + * @return null|Server |
|
| 92 | + * @since 9.0.0 |
|
| 93 | + */ |
|
| 94 | + public function getServer() { |
|
| 95 | + return $this->server; |
|
| 96 | + } |
|
| 97 | 97 | } |
@@ -29,11 +29,11 @@ |
||
| 29 | 29 | */ |
| 30 | 30 | interface IValidator { |
| 31 | 31 | |
| 32 | - /** |
|
| 33 | - * @param string $subject |
|
| 34 | - * @param array[] $parameters |
|
| 35 | - * @throws InvalidObjectExeption |
|
| 36 | - * @since 11.0.0 |
|
| 37 | - */ |
|
| 38 | - public function validate($subject, array $parameters); |
|
| 32 | + /** |
|
| 33 | + * @param string $subject |
|
| 34 | + * @param array[] $parameters |
|
| 35 | + * @throws InvalidObjectExeption |
|
| 36 | + * @since 11.0.0 |
|
| 37 | + */ |
|
| 38 | + public function validate($subject, array $parameters); |
|
| 39 | 39 | } |
@@ -26,9 +26,9 @@ |
||
| 26 | 26 | * @since 8.2.0 |
| 27 | 27 | */ |
| 28 | 28 | interface IQueryFunction { |
| 29 | - /** |
|
| 30 | - * @return string |
|
| 31 | - * @since 8.2.0 |
|
| 32 | - */ |
|
| 33 | - public function __toString(); |
|
| 29 | + /** |
|
| 30 | + * @return string |
|
| 31 | + * @since 8.2.0 |
|
| 32 | + */ |
|
| 33 | + public function __toString(); |
|
| 34 | 34 | } |
@@ -26,9 +26,9 @@ |
||
| 26 | 26 | * @since 8.2.0 |
| 27 | 27 | */ |
| 28 | 28 | interface ILiteral { |
| 29 | - /** |
|
| 30 | - * @return string |
|
| 31 | - * @since 8.2.0 |
|
| 32 | - */ |
|
| 33 | - public function __toString(); |
|
| 29 | + /** |
|
| 30 | + * @return string |
|
| 31 | + * @since 8.2.0 |
|
| 32 | + */ |
|
| 33 | + public function __toString(); |
|
| 34 | 34 | } |
@@ -28,39 +28,39 @@ |
||
| 28 | 28 | * @since 8.2.0 |
| 29 | 29 | */ |
| 30 | 30 | interface ICompositeExpression { |
| 31 | - /** |
|
| 32 | - * Adds multiple parts to composite expression. |
|
| 33 | - * |
|
| 34 | - * @param array $parts |
|
| 35 | - * |
|
| 36 | - * @return ICompositeExpression |
|
| 37 | - * @since 8.2.0 |
|
| 38 | - */ |
|
| 39 | - public function addMultiple(array $parts = array()); |
|
| 31 | + /** |
|
| 32 | + * Adds multiple parts to composite expression. |
|
| 33 | + * |
|
| 34 | + * @param array $parts |
|
| 35 | + * |
|
| 36 | + * @return ICompositeExpression |
|
| 37 | + * @since 8.2.0 |
|
| 38 | + */ |
|
| 39 | + public function addMultiple(array $parts = array()); |
|
| 40 | 40 | |
| 41 | - /** |
|
| 42 | - * Adds an expression to composite expression. |
|
| 43 | - * |
|
| 44 | - * @param mixed $part |
|
| 45 | - * |
|
| 46 | - * @return ICompositeExpression |
|
| 47 | - * @since 8.2.0 |
|
| 48 | - */ |
|
| 49 | - public function add($part); |
|
| 41 | + /** |
|
| 42 | + * Adds an expression to composite expression. |
|
| 43 | + * |
|
| 44 | + * @param mixed $part |
|
| 45 | + * |
|
| 46 | + * @return ICompositeExpression |
|
| 47 | + * @since 8.2.0 |
|
| 48 | + */ |
|
| 49 | + public function add($part); |
|
| 50 | 50 | |
| 51 | - /** |
|
| 52 | - * Retrieves the amount of expressions on composite expression. |
|
| 53 | - * |
|
| 54 | - * @return integer |
|
| 55 | - * @since 8.2.0 |
|
| 56 | - */ |
|
| 57 | - public function count(); |
|
| 51 | + /** |
|
| 52 | + * Retrieves the amount of expressions on composite expression. |
|
| 53 | + * |
|
| 54 | + * @return integer |
|
| 55 | + * @since 8.2.0 |
|
| 56 | + */ |
|
| 57 | + public function count(); |
|
| 58 | 58 | |
| 59 | - /** |
|
| 60 | - * Returns the type of this composite expression (AND/OR). |
|
| 61 | - * |
|
| 62 | - * @return string |
|
| 63 | - * @since 8.2.0 |
|
| 64 | - */ |
|
| 65 | - public function getType(); |
|
| 59 | + /** |
|
| 60 | + * Returns the type of this composite expression (AND/OR). |
|
| 61 | + * |
|
| 62 | + * @return string |
|
| 63 | + * @since 8.2.0 |
|
| 64 | + */ |
|
| 65 | + public function getType(); |
|
| 66 | 66 | } |