@@ -200,7 +200,7 @@ |
||
| 200 | 200 | } |
| 201 | 201 | |
| 202 | 202 | /** |
| 203 | - * @param $id |
|
| 203 | + * @param string|null $id |
|
| 204 | 204 | * @throws MongoException |
| 205 | 205 | */ |
| 206 | 206 | private function createObjectID($id) |
@@ -23,13 +23,13 @@ discard block |
||
| 23 | 23 | class MongoClient |
| 24 | 24 | { |
| 25 | 25 | const VERSION = '1.6.12'; |
| 26 | - const DEFAULT_HOST = "localhost" ; |
|
| 27 | - const DEFAULT_PORT = 27017 ; |
|
| 28 | - const RP_PRIMARY = "primary" ; |
|
| 29 | - const RP_PRIMARY_PREFERRED = "primaryPreferred" ; |
|
| 30 | - const RP_SECONDARY = "secondary" ; |
|
| 31 | - const RP_SECONDARY_PREFERRED = "secondaryPreferred" ; |
|
| 32 | - const RP_NEAREST = "nearest" ; |
|
| 26 | + const DEFAULT_HOST = "localhost"; |
|
| 27 | + const DEFAULT_PORT = 27017; |
|
| 28 | + const RP_PRIMARY = "primary"; |
|
| 29 | + const RP_PRIMARY_PREFERRED = "primaryPreferred"; |
|
| 30 | + const RP_SECONDARY = "secondary"; |
|
| 31 | + const RP_SECONDARY_PREFERRED = "secondaryPreferred"; |
|
| 32 | + const RP_NEAREST = "nearest"; |
|
| 33 | 33 | |
| 34 | 34 | /** |
| 35 | 35 | * @var bool |
@@ -198,7 +198,7 @@ discard block |
||
| 198 | 198 | * {@link http://www.php.net/manual/en/class.mongoint64.php MongoInt64} class. The latter is necessary on 32 |
| 199 | 199 | * bit platforms (and Windows). |
| 200 | 200 | */ |
| 201 | - public function killCursor($server_hash , $id) |
|
| 201 | + public function killCursor($server_hash, $id) |
|
| 202 | 202 | { |
| 203 | 203 | |
| 204 | 204 | } |
@@ -216,7 +216,7 @@ |
||
| 216 | 216 | * @link http://www.php.net/manual/en/mongoclient.killcursor.php |
| 217 | 217 | * @param string $server_hash The server hash that has the cursor. |
| 218 | 218 | * @param int|MongoInt64 $id The ID of the cursor to kill. |
| 219 | - * @return bool |
|
| 219 | + * @return boolean|null |
|
| 220 | 220 | */ |
| 221 | 221 | public function killCursor($server_hash , $id) |
| 222 | 222 | { |
@@ -25,7 +25,7 @@ |
||
| 25 | 25 | * http://php.net/manual/en/mongoresultexception.getdocument.php |
| 26 | 26 | * @return array <p>The full result document as an array, including partial data if available and additional keys.</p> |
| 27 | 27 | */ |
| 28 | - public function getDocument () {} |
|
| 28 | + public function getDocument() {} |
|
| 29 | 29 | |
| 30 | 30 | public $document; |
| 31 | 31 | |
@@ -18,13 +18,16 @@ |
||
| 18 | 18 | * @link http://php.net/manual/en/class.mongoresultexception.php#mongoresultexception.props.document |
| 19 | 19 | * |
| 20 | 20 | */ |
| 21 | -class MongoResultException extends MongoException { |
|
| 21 | +class MongoResultException extends MongoException |
|
| 22 | +{ |
|
| 22 | 23 | /** |
| 23 | 24 | * Retrieve the full result document |
| 24 | 25 | * http://php.net/manual/en/mongoresultexception.getdocument.php |
| 25 | 26 | * @return array <p>The full result document as an array, including partial data if available and additional keys.</p> |
| 26 | 27 | */ |
| 27 | - public function getDocument () {} |
|
| 28 | + public function getDocument () |
|
| 29 | + { |
|
| 30 | +} |
|
| 28 | 31 | |
| 29 | 32 | public $document; |
| 30 | 33 | |
@@ -15,7 +15,6 @@ |
||
| 15 | 15 | |
| 16 | 16 | use Alcaeus\MongoDbAdapter\TypeInterface; |
| 17 | 17 | use MongoDB\BSON\Binary; |
| 18 | -use MongoDB\BSON\Type; |
|
| 19 | 18 | |
| 20 | 19 | class MongoBinData implements TypeInterface |
| 21 | 20 | { |
@@ -72,7 +72,7 @@ |
||
| 72 | 72 | protected $readPreference = []; |
| 73 | 73 | |
| 74 | 74 | /** |
| 75 | - * @return Cursor |
|
| 75 | + * @return \Traversable |
|
| 76 | 76 | */ |
| 77 | 77 | abstract protected function ensureCursor(); |
| 78 | 78 | |
@@ -201,7 +201,7 @@ |
||
| 201 | 201 | * @link http://www.php.net/manual/en/mongocursor.hasnext.php |
| 202 | 202 | * @throws MongoConnectionException |
| 203 | 203 | * @throws MongoCursorTimeoutException |
| 204 | - * @return bool Returns true if there is another element |
|
| 204 | + * @return boolean|null Returns true if there is another element |
|
| 205 | 205 | */ |
| 206 | 206 | public function hasNext() |
| 207 | 207 | { |
@@ -15,7 +15,6 @@ |
||
| 15 | 15 | |
| 16 | 16 | use Alcaeus\MongoDbAdapter\AbstractCursor; |
| 17 | 17 | use MongoDB\Driver\Cursor; |
| 18 | -use MongoDB\Driver\ReadPreference; |
|
| 19 | 18 | use MongoDB\Operation\Find; |
| 20 | 19 | |
| 21 | 20 | /** |
@@ -380,7 +380,7 @@ |
||
| 380 | 380 | */ |
| 381 | 381 | protected function convertCursorType() |
| 382 | 382 | { |
| 383 | - if (! $this->tailable) { |
|
| 383 | + if ( ! $this->tailable) { |
|
| 384 | 384 | return null; |
| 385 | 385 | } |
| 386 | 386 | |
@@ -126,6 +126,9 @@ |
||
| 126 | 126 | ); |
| 127 | 127 | } |
| 128 | 128 | |
| 129 | + /** |
|
| 130 | + * @param resource $handle |
|
| 131 | + */ |
|
| 129 | 132 | private function writeFromRessource($handle) |
| 130 | 133 | { |
| 131 | 134 | |
@@ -75,7 +75,7 @@ |
||
| 75 | 75 | $filename = 'file'; |
| 76 | 76 | } |
| 77 | 77 | |
| 78 | - if (! $handle = fopen($filename, 'w')) { |
|
| 78 | + if ( ! $handle = fopen($filename, 'w')) { |
|
| 79 | 79 | trigger_error(E_ERROR, 'Can not open the destination file'); |
| 80 | 80 | return 0; |
| 81 | 81 | } |
@@ -48,7 +48,7 @@ discard block |
||
| 48 | 48 | * Returns the address being used by this for slaveOkay reads |
| 49 | 49 | * |
| 50 | 50 | * @link http://php.net/manual/en/mongo.getslave.php |
| 51 | - * @return bool The address of the secondary this connection is using for |
|
| 51 | + * @return boolean|null The address of the secondary this connection is using for |
|
| 52 | 52 | * reads. This returns NULL if this is not connected to a replica set or not yet |
| 53 | 53 | * initialized. |
| 54 | 54 | */ |
@@ -61,7 +61,7 @@ discard block |
||
| 61 | 61 | * Get slaveOkay setting for this connection |
| 62 | 62 | * |
| 63 | 63 | * @link http://php.net/manual/en/mongo.getslaveokay.php |
| 64 | - * @return bool Returns the value of slaveOkay for this instance. |
|
| 64 | + * @return boolean|null Returns the value of slaveOkay for this instance. |
|
| 65 | 65 | */ |
| 66 | 66 | public function getSlaveOkay() |
| 67 | 67 | { |
@@ -73,7 +73,7 @@ discard block |
||
| 73 | 73 | * |
| 74 | 74 | * @link http://www.php.net/manual/en/mongo.pairconnect.php |
| 75 | 75 | * @throws MongoConnectionException |
| 76 | - * @return boolean |
|
| 76 | + * @return boolean|null |
|
| 77 | 77 | * |
| 78 | 78 | * @deprecated Pass a string of the form "mongodb://server1,server2" to the constructor instead of using this method. |
| 79 | 79 | */ |
@@ -99,7 +99,7 @@ discard block |
||
| 99 | 99 | * |
| 100 | 100 | * @link http://php.net/manual/en/mongo.setslaveokay.php |
| 101 | 101 | * @param bool $ok |
| 102 | - * @return bool returns the former value of slaveOkay for this instance. |
|
| 102 | + * @return boolean|null returns the former value of slaveOkay for this instance. |
|
| 103 | 103 | */ |
| 104 | 104 | public function setSlaveOkay ($ok) |
| 105 | 105 | { |
@@ -111,7 +111,7 @@ discard block |
||
| 111 | 111 | * |
| 112 | 112 | * @link http://php.net/manual/en/mongo.setpoolsize.php |
| 113 | 113 | * @param $size <p>The max number of connections future pools will be able to create. Negative numbers mean that the pool will spawn an infinite number of connections.</p> |
| 114 | - * @return bool Returns the former value of pool size. |
|
| 114 | + * @return boolean|null Returns the former value of pool size. |
|
| 115 | 115 | * @deprecated Relying on this feature is highly discouraged. Please use MongoPool::setSize() instead. |
| 116 | 116 | */ |
| 117 | 117 | public function setPoolSize($size) |
@@ -126,7 +126,7 @@ discard block |
||
| 126 | 126 | * @param string $username A username used to identify the connection. |
| 127 | 127 | * @param string $password A password used to identify the connection. |
| 128 | 128 | * @throws MongoConnectionException |
| 129 | - * @return boolean If the connection was successful. |
|
| 129 | + * @return boolean|null If the connection was successful. |
|
| 130 | 130 | * @deprecated Pass array("persist" => $id) to the constructor instead of using this method. |
| 131 | 131 | */ |
| 132 | 132 | public function persistConnect($username = "", $password = "") |
@@ -141,7 +141,7 @@ discard block |
||
| 141 | 141 | * @param string $username A username used to identify the connection. |
| 142 | 142 | * @param string $password A password used to identify the connection. |
| 143 | 143 | * @throws MongoConnectionException |
| 144 | - * @return boolean If the connection was successful. |
|
| 144 | + * @return boolean|null If the connection was successful. |
|
| 145 | 145 | * @deprecated Pass "mongodb://server1,server2" and array("persist" => $id) to the constructor instead of using this method. |
| 146 | 146 | */ |
| 147 | 147 | public function pairPersistConnect($username = "", $password = "") |
@@ -154,7 +154,7 @@ discard block |
||
| 154 | 154 | * |
| 155 | 155 | * @link http://www.php.net/manual/en/mongo.connectutil.php |
| 156 | 156 | * @throws MongoConnectionException |
| 157 | - * @return boolean If the connection was successful. |
|
| 157 | + * @return boolean|null If the connection was successful. |
|
| 158 | 158 | */ |
| 159 | 159 | protected function connectUtil() |
| 160 | 160 | { |
@@ -201,7 +201,7 @@ discard block |
||
| 201 | 201 | * Creates a database error on the database. |
| 202 | 202 | * |
| 203 | 203 | * @link http://www.php.net/manual/en/mongo.forceerror.php |
| 204 | - * @return boolean The database response. |
|
| 204 | + * @return boolean|null The database response. |
|
| 205 | 205 | * @deprecated Use MongoDB::forceError() instead. |
| 206 | 206 | */ |
| 207 | 207 | public function forceError() |
@@ -101,7 +101,7 @@ |
||
| 101 | 101 | * @param bool $ok |
| 102 | 102 | * @return bool returns the former value of slaveOkay for this instance. |
| 103 | 103 | */ |
| 104 | - public function setSlaveOkay ($ok) |
|
| 104 | + public function setSlaveOkay($ok) |
|
| 105 | 105 | { |
| 106 | 106 | $this->notImplemented(); |
| 107 | 107 | } |
@@ -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 | } |