@@ -17,11 +17,14 @@ |
||
17 | 17 | * <p>(PECL mongo >= 1.5.0)</p> |
18 | 18 | * @link http://php.net/manual/en/class.mongowriteconcernexception.php#class.mongowriteconcernexception |
19 | 19 | */ |
20 | -class MongoWriteConcernException extends MongoCursorException { |
|
20 | +class MongoWriteConcernException extends MongoCursorException |
|
21 | +{ |
|
21 | 22 | /** |
22 | 23 | * Get the error document |
23 | 24 | * @link http://php.net/manual/en/mongowriteconcernexception.getdocument.php |
24 | 25 | * @return array <p>A MongoDB document, if available, as an array.</p> |
25 | 26 | */ |
26 | - public function getDocument() {} |
|
27 | + public function getDocument() |
|
28 | + { |
|
29 | +} |
|
27 | 30 | } |
@@ -35,7 +35,7 @@ |
||
35 | 35 | * |
36 | 36 | * @link http://php.net/manual/en/mongopool.setsize.php |
37 | 37 | * @param int $size |
38 | - * @return boolean Returns the former value of pool size |
|
38 | + * @return integer Returns the former value of pool size |
|
39 | 39 | */ |
40 | 40 | public static function setSize($size) |
41 | 41 | { |
@@ -119,7 +119,7 @@ |
||
119 | 119 | * <ul> |
120 | 120 | * @return boolean Returns <b>TRUE</b> on success or <b>FALSE</b> on failure. |
121 | 121 | */ |
122 | - public static function setCallback(callable $log_function ) |
|
122 | + public static function setCallback(callable $log_function) |
|
123 | 123 | { |
124 | 124 | self::$callback = $log_function; |
125 | 125 | return true; |
@@ -241,10 +241,10 @@ discard block |
||
241 | 241 | ]; |
242 | 242 | |
243 | 243 | $handle = fopen($filename, 'r'); |
244 | - if (! $handle) { |
|
244 | + if ( ! $handle) { |
|
245 | 245 | throw new MongoGridFSException('could not open file: ' . $filename); |
246 | 246 | } |
247 | - } elseif (! is_resource($filename)) { |
|
247 | + } elseif ( ! is_resource($filename)) { |
|
248 | 248 | throw new \Exception('first argument must be a string or stream resource'); |
249 | 249 | } else { |
250 | 250 | $handle = $filename; |
@@ -266,10 +266,10 @@ discard block |
||
266 | 266 | |
267 | 267 | // Add length and MD5 if they were not present before |
268 | 268 | $update = []; |
269 | - if (! isset($record['length'])) { |
|
269 | + if ( ! isset($record['length'])) { |
|
270 | 270 | $update['length'] = $length; |
271 | 271 | } |
272 | - if (! isset($record['md5'])) { |
|
272 | + if ( ! isset($record['md5'])) { |
|
273 | 273 | try { |
274 | 274 | $update['md5'] = $this->getMd5ForFile($file['_id']); |
275 | 275 | } catch (MongoException $e) { |
@@ -280,7 +280,7 @@ discard block |
||
280 | 280 | if (count($update)) { |
281 | 281 | try { |
282 | 282 | $result = $this->update(['_id' => $file['_id']], ['$set' => $update]); |
283 | - if (! $this->isOKResult($result)) { |
|
283 | + if ( ! $this->isOKResult($result)) { |
|
284 | 284 | throw new MongoGridFSException('Error updating file record'); |
285 | 285 | } |
286 | 286 | } catch (MongoException $e) { |
@@ -304,10 +304,10 @@ discard block |
||
304 | 304 | */ |
305 | 305 | public function storeUpload($name, array $metadata = []) |
306 | 306 | { |
307 | - if (! isset($_FILES[$name]) || $_FILES[$name]['error'] !== UPLOAD_ERR_OK) { |
|
307 | + if ( ! isset($_FILES[$name]) || $_FILES[$name]['error'] !== UPLOAD_ERR_OK) { |
|
308 | 308 | throw new MongoGridFSException("Could not find uploaded file $name"); |
309 | 309 | } |
310 | - if (! isset($_FILES[$name]['tmp_name'])) { |
|
310 | + if ( ! isset($_FILES[$name]['tmp_name'])) { |
|
311 | 311 | throw new MongoGridFSException("Couldn't find tmp_name in the \$_FILES array. Are you sure the upload worked?"); |
312 | 312 | } |
313 | 313 | |
@@ -357,7 +357,7 @@ discard block |
||
357 | 357 | |
358 | 358 | $result = $this->chunks->insert($chunk); |
359 | 359 | |
360 | - if (! $this->isOKResult($result)) { |
|
360 | + if ( ! $this->isOKResult($result)) { |
|
361 | 361 | throw new \MongoException('error inserting chunk'); |
362 | 362 | } |
363 | 363 | |
@@ -399,7 +399,7 @@ discard block |
||
399 | 399 | $chunkSize = $record['chunkSize']; |
400 | 400 | |
401 | 401 | rewind($handle); |
402 | - while (! feof($handle)) { |
|
402 | + while ( ! feof($handle)) { |
|
403 | 403 | $data = stream_get_contents($handle, $chunkSize); |
404 | 404 | $this->insertChunk($fileId, $data, $i++); |
405 | 405 | $written += strlen($data); |
@@ -426,7 +426,7 @@ discard block |
||
426 | 426 | |
427 | 427 | $result = $this->insert($record, $options); |
428 | 428 | |
429 | - if (! $this->isOKResult($result)) { |
|
429 | + if ( ! $this->isOKResult($result)) { |
|
430 | 430 | throw new \MongoException('error inserting file'); |
431 | 431 | } |
432 | 432 |
@@ -106,7 +106,6 @@ |
||
106 | 106 | * @link http://php.net/manual/en/mongogridfs.find.php |
107 | 107 | * @param array $query The query |
108 | 108 | * @param array $fields Fields to return |
109 | - * @param array $options Options for the find command |
|
110 | 109 | * @return MongoGridFSCursor A MongoGridFSCursor |
111 | 110 | */ |
112 | 111 | public function find(array $query = [], array $fields = []) |
@@ -65,6 +65,6 @@ |
||
65 | 65 | public function key() |
66 | 66 | { |
67 | 67 | $file = $this->current(); |
68 | - return ($file !== null) ? (string)$file->file['_id'] : null; |
|
68 | + return ($file !== null) ? (string) $file->file['_id'] : null; |
|
69 | 69 | } |
70 | 70 | } |
@@ -76,7 +76,7 @@ discard block |
||
76 | 76 | public function add($item) |
77 | 77 | { |
78 | 78 | if (is_object($item)) { |
79 | - $item = (array)$item; |
|
79 | + $item = (array) $item; |
|
80 | 80 | } |
81 | 81 | |
82 | 82 | $this->validate($item); |
@@ -95,7 +95,7 @@ discard block |
||
95 | 95 | final public function execute(array $writeOptions = []) |
96 | 96 | { |
97 | 97 | $writeOptions += $this->writeOptions; |
98 | - if (! count($this->items)) { |
|
98 | + if ( ! count($this->items)) { |
|
99 | 99 | return ['ok' => true]; |
100 | 100 | } |
101 | 101 | |
@@ -142,13 +142,13 @@ discard block |
||
142 | 142 | { |
143 | 143 | switch ($this->batchType) { |
144 | 144 | case self::COMMAND_UPDATE: |
145 | - if (! isset($item['q']) || ! isset($item['u'])) { |
|
145 | + if ( ! isset($item['q']) || ! isset($item['u'])) { |
|
146 | 146 | throw new Exception('invalid item'); |
147 | 147 | } |
148 | 148 | break; |
149 | 149 | |
150 | 150 | case self::COMMAND_DELETE: |
151 | - if (! isset($item['q']) || ! isset($item['limit'])) { |
|
151 | + if ( ! isset($item['q']) || ! isset($item['limit'])) { |
|
152 | 152 | throw new Exception('invalid item'); |
153 | 153 | } |
154 | 154 | break; |
@@ -55,7 +55,7 @@ |
||
55 | 55 | */ |
56 | 56 | protected function setWriteConcernFromParameters($wstring, $wtimeout = 0) |
57 | 57 | { |
58 | - if (! is_string($wstring) && ! is_int($wstring)) { |
|
58 | + if ( ! is_string($wstring) && ! is_int($wstring)) { |
|
59 | 59 | trigger_error("w for WriteConcern must be a string or integer", E_WARNING); |
60 | 60 | return false; |
61 | 61 | } |