芝麻web文件管理V1.00
编辑当前文件:/home2/sdektunc/public_html/cepali/cache/stores/mongodb/MongoDB/Client.php
'MongoDB\Model\BSONArray', 'document' => 'MongoDB\Model\BSONDocument', 'root' => 'MongoDB\Model\BSONDocument', ]; private static $wireVersionForReadConcern = 4; private static $wireVersionForWritableCommandWriteConcern = 5; private $manager; private $readConcern; private $readPreference; private $uri; private $typeMap; private $writeConcern; /** * Constructs a new Client instance. * * This is the preferred class for connecting to a MongoDB server or * cluster of servers. It serves as a gateway for accessing individual * databases and collections. * * Supported driver-specific options: * * * typeMap (array): Default type map for cursors and BSON documents. * * Other options are documented in MongoDB\Driver\Manager::__construct(). * * @see http://docs.mongodb.org/manual/reference/connection-string/ * @see http://php.net/manual/en/mongodb-driver-manager.construct.php * @see http://php.net/manual/en/mongodb.persistence.php#mongodb.persistence.typemaps * @param string $uri MongoDB connection string * @param array $uriOptions Additional connection string options * @param array $driverOptions Driver-specific options * @throws InvalidArgumentException for parameter/option parsing errors * @throws DriverInvalidArgumentException for parameter/option parsing errors in the driver * @throws DriverRuntimeException for other driver errors (e.g. connection errors) */ public function __construct($uri = 'mongodb://127.0.0.1/', array $uriOptions = [], array $driverOptions = []) { $driverOptions += ['typeMap' => self::$defaultTypeMap]; if (isset($driverOptions['typeMap']) && ! is_array($driverOptions['typeMap'])) { throw InvalidArgumentException::invalidType('"typeMap" driver option', $driverOptions['typeMap'], 'array'); } $this->uri = (string) $uri; $this->typeMap = isset($driverOptions['typeMap']) ? $driverOptions['typeMap'] : null; unset($driverOptions['typeMap']); $this->manager = new Manager($uri, $uriOptions, $driverOptions); $this->readConcern = $this->manager->getReadConcern(); $this->readPreference = $this->manager->getReadPreference(); $this->writeConcern = $this->manager->getWriteConcern(); } /** * Return internal properties for debugging purposes. * * @see http://php.net/manual/en/language.oop5.magic.php#language.oop5.magic.debuginfo * @return array */ public function __debugInfo() { return [ 'manager' => $this->manager, 'uri' => $this->uri, 'typeMap' => $this->typeMap, 'writeConcern' => $this->writeConcern, ]; } /** * Select a database. * * Note: databases whose names contain special characters (e.g. "-") may * be selected with complex syntax (e.g. $client->{"that-database"}) or * {@link selectDatabase()}. * * @see http://php.net/oop5.overloading#object.get * @see http://php.net/types.string#language.types.string.parsing.complex * @param string $databaseName Name of the database to select * @return Database */ public function __get($databaseName) { return $this->selectDatabase($databaseName); } /** * Return the connection string (i.e. URI). * * @return string */ public function __toString() { return $this->uri; } /** * Drop a database. * * @see DropDatabase::__construct() for supported options * @param string $databaseName Database name * @param array $options Additional options * @return array|object Command result document * @throws UnsupportedException if options are unsupported on the selected server * @throws InvalidArgumentException for parameter/option parsing errors * @throws DriverRuntimeException for other driver errors (e.g. connection errors) */ public function dropDatabase($databaseName, array $options = []) { if ( ! isset($options['typeMap'])) { $options['typeMap'] = $this->typeMap; } $server = $this->manager->selectServer(new ReadPreference(ReadPreference::RP_PRIMARY)); if ( ! isset($options['writeConcern']) && \MongoDB\server_supports_feature($server, self::$wireVersionForWritableCommandWriteConcern)) { $options['writeConcern'] = $this->writeConcern; } $operation = new DropDatabase($databaseName, $options); return $operation->execute($server); } /** * Return the Manager. * * @return Manager */ public function getManager() { return $this->manager; } /** * Return the read concern for this client. * * @see http://php.net/manual/en/mongodb-driver-readconcern.isdefault.php * @return ReadConcern */ public function getReadConcern() { return $this->readConcern; } /** * Return the read preference for this client. * * @return ReadPreference */ public function getReadPreference() { return $this->readPreference; } /** * Return the type map for this client. * * @return array */ public function getTypeMap() { return $this->typeMap; } /** * Return the write concern for this client. * * @see http://php.net/manual/en/mongodb-driver-writeconcern.isdefault.php * @return WriteConcern */ public function getWriteConcern() { return $this->writeConcern; } /** * List databases. * * @see ListDatabases::__construct() for supported options * @return DatabaseInfoIterator * @throws UnexpectedValueException if the command response was malformed * @throws InvalidArgumentException for parameter/option parsing errors * @throws DriverRuntimeException for other driver errors (e.g. connection errors) */ public function listDatabases(array $options = []) { $operation = new ListDatabases($options); $server = $this->manager->selectServer(new ReadPreference(ReadPreference::RP_PRIMARY)); return $operation->execute($server); } /** * Select a collection. * * @see Collection::__construct() for supported options * @param string $databaseName Name of the database containing the collection * @param string $collectionName Name of the collection to select * @param array $options Collection constructor options * @return Collection * @throws InvalidArgumentException for parameter/option parsing errors */ public function selectCollection($databaseName, $collectionName, array $options = []) { $options += ['typeMap' => $this->typeMap]; return new Collection($this->manager, $databaseName, $collectionName, $options); } /** * Select a database. * * @see Database::__construct() for supported options * @param string $databaseName Name of the database to select * @param array $options Database constructor options * @return Database * @throws InvalidArgumentException for parameter/option parsing errors */ public function selectDatabase($databaseName, array $options = []) { $options += ['typeMap' => $this->typeMap]; return new Database($this->manager, $databaseName, $options); } /** * Start a new client session. * * @see http://php.net/manual/en/mongodb-driver-manager.startsession.php * @param array $options Session options * @return MongoDB\Driver\Session */ public function startSession(array $options = []) { return $this->manager->startSession($options); } /** * Create a change stream for watching changes to the cluster. * * @see Watch::__construct() for supported options * @param array $pipeline List of pipeline operations * @param array $options Command options * @return ChangeStream * @throws InvalidArgumentException for parameter/option parsing errors */ public function watch(array $pipeline = [], array $options = []) { if ( ! isset($options['readPreference'])) { $options['readPreference'] = $this->readPreference; } $server = $this->manager->selectServer($options['readPreference']); if ( ! isset($options['readConcern']) && \MongoDB\server_supports_feature($server, self::$wireVersionForReadConcern)) { $options['readConcern'] = $this->readConcern; } if ( ! isset($options['typeMap'])) { $options['typeMap'] = $this->typeMap; } $operation = new Watch($this->manager, null, null, $pipeline, $options); return $operation->execute($server); } }