o 'h| @sdZddlmZddlZddlmZmZmZmZm Z m Z m Z m Z ddl mZddlmZddlmZddlmZmZdd lmZdd lmZmZmZdd lmZmZmZdd l m!Z!erddd lm"Z"m#Z#e e e e$e e$e e%e$ee$effffee$effZ&e e$e&fZ'Gddde$ej(Z)GdddeeZ*GdddZ+Gddde+Z,Gddde+Z-GdddeeZ.GdddZ/Gddde/Z0Gddde/Z1Gd d!d!Z2Gd"d#d#Z3dS)$z~Operation class definitions. .. seealso:: This module is compatible with both the synchronous and asynchronous PyMongo APIs. ) annotationsN) TYPE_CHECKINGAnyGenericMappingOptionalSequenceTupleUnion)RawBSONDocument)helpers_shared)validate_collation_or_none)validate_is_mapping validate_list)InvalidOperation)_gen_index_name_index_document _index_list) _CollationIn _DocumentType _Pipeline)validate_boolean) _AgnosticBulk_AgnosticClientBulkc@seZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdS)_OpabortTransaction aggregate bulkWritecommitTransactioncountcreate createIndexescreateSearchIndexesdeletedistinctdrop dropDatabase dropIndexesdropSearchIndexes endSessions findAndModifyfindinsertlistCollections listIndexeslistSearchIndexes listDatabasesupdate updateIndexupdateSearchIndexrenamegetMore killCursors testOperationN) __name__ __module__ __qualname__ABORT AGGREGATE BULK_WRITECOMMITCOUNTCREATECREATE_INDEXESCREATE_SEARCH_INDEXESDELETEDISTINCTDROP DROP_DATABASE DROP_INDEXESDROP_SEARCH_INDEXES END_SESSIONSFIND_AND_MODIFYFINDINSERTLIST_COLLECTIONS LIST_INDEXESLIST_SEARCH_INDEXLIST_DATABASESUPDATE UPDATE_INDEXUPDATE_SEARCH_INDEXRENAMEGETMORE KILL_CURSORSTESTrXrXN/var/www/html/olx_land/venv/lib/python3.10/site-packages/pymongo/operations.pyr5s<rc@sReZdZdZdZddd d ZdddZd ddZd!ddZd"ddZ d"ddZ dS)# InsertOnez#Represents an insert_one operation._doc _namespaceNdocumentr namespace Optional[str]returnNonecCs||_||_dS)avCreate an InsertOne instance. For use with :meth:`~pymongo.asynchronous.collection.AsyncCollection.bulk_write`, :meth:`~pymongo.collection.Collection.bulk_write`, :meth:`~pymongo.asynchronous.mongo_client.AsyncMongoClient.bulk_write` and :meth:`~pymongo.mongo_client.MongoClient.bulk_write`. :param document: The document to insert. If the document is missing an _id field one will be added. :param namespace: (optional) The namespace in which to insert a document. .. versionchanged:: 4.9 Added the `namespace` option to support `MongoClient.bulk_write`. Nr[)selfr^r_rXrXrY__init__]s zInsertOne.__init__bulkobjrcCs||jdS)>Add this operation to the _AsyncBulk/_Bulk instance `bulkobj`.N) add_insertr\rcrerXrXrY _add_to_bulkmszInsertOne._add_to_bulkrcCs"|jstd||j|jdS)JAdd this operation to the _AsyncClientBulk/_ClientBulk instance `bulkobj`.SMongoClient.bulk_write requires a namespace to be provided for each write operationN)r]rrgr\rhrXrXrY_add_to_client_bulkqszInsertOne._add_to_client_bulkstrcCs:|jr|jjd|jd|jdS|jjd|jdS)N(, ))r] __class__r8r\rcrXrXrY__repr__|szInsertOne.__repr__otherrboolcCs,t|t|kr|j|jko|j|jkStSN)typer\r]NotImplementedrcrtrXrXrY__eq__szInsertOne.__eq__cC ||k SrvrXryrXrXrY__ne__ zInsertOne.__ne__rv)r^rr_r`rarbrerrarbrerrarbrarmrtrraru) r8r9r:__doc__ __slots__rdrirlrsrzr|rXrXrXrYrZUs    rZc@sDeZdZdZdZ   ddddZdddZdddZdddZdS) _DeleteOpz)Private base class for delete operations.)_filter _collation_hintr]NfilterMapping[str, Any] collationOptional[_CollationIn]hintOptional[_IndexKeyHint]r_r`rarbcCsN|dur td||durt|tst||_n||_||_||_||_dS)Nr) r isinstancermr rrrrr]rcrrrr_rXrXrYrds  z_DeleteOp.__init__rtrrucCs<t|t|kr|j|j|j|jf|j|j|j|jfkStSrv)rwrrrr]rxryrXrXrYrzs z_DeleteOp.__eq__cCr{rvrXryrXrXrYr|r}z_DeleteOp.__ne__rmcCsJ|jrd|jj|j|j|j|jS|jjd|jd|jd|jdS)Nz{}({!r}, {!r}, {!r}, {!r})rnrorp)r]formatrqr8rrrrrrXrXrYrss&z_DeleteOp.__repr__NNN rrrrrrr_r`rarbrr r8r9r:rrrdrzr|rsrXrXrXrYrs   rcBeZdZdZdZ   ddfdd ZdddZdddZZS) DeleteOnez"Represents a delete_one operation.rXNrrrrrrr_r`rarbct||||dS)aCreate a DeleteOne instance. For use with :meth:`~pymongo.asynchronous.collection.AsyncCollection.bulk_write`, :meth:`~pymongo.collection.Collection.bulk_write`, :meth:`~pymongo.asynchronous.mongo_client.AsyncMongoClient.bulk_write` and :meth:`~pymongo.mongo_client.MongoClient.bulk_write`. :param filter: A query that matches the document to delete. :param collation: An instance of :class:`~pymongo.collation.Collation`. :param hint: An index to use to support the query predicate specified either by its string name, or in the same format as passed to :meth:`~pymongo.asynchronous.collection.AsyncCollection.create_index` or :meth:`~pymongo.collection.Collection.create_index` (e.g. ``[('field', ASCENDING)]``). This option is only supported on MongoDB 4.4 and above. :param namespace: (optional) The namespace in which to delete a document. .. versionchanged:: 4.9 Added the `namespace` option to support `MongoClient.bulk_write`. .. versionchanged:: 3.11 Added the ``hint`` option. .. versionchanged:: 3.5 Added the `collation` option. NsuperrdrrqrXrYrdzDeleteOne.__init__rercC |j|jdt|j|jddS)rfrrN add_deleterr rrrhrXrXrYri  zDeleteOne._add_to_bulkrcC2|jstd|j|j|jdt|j|jddS)rjrkFmultirrNr]rrrr rrrhrXrXrYrl zDeleteOne._add_to_client_bulkrrr~r r8r9r:rrrdrirl __classcell__rXrXrrYr  rcr) DeleteManyz#Represents a delete_many operation.rXNrrrrrrr_r`rarbcr)aCreate a DeleteMany instance. For use with :meth:`~pymongo.asynchronous.collection.AsyncCollection.bulk_write`, :meth:`~pymongo.collection.Collection.bulk_write`, :meth:`~pymongo.asynchronous.mongo_client.AsyncMongoClient.bulk_write` and :meth:`~pymongo.mongo_client.MongoClient.bulk_write`. :param filter: A query that matches the documents to delete. :param collation: An instance of :class:`~pymongo.collation.Collation`. :param hint: An index to use to support the query predicate specified either by its string name, or in the same format as passed to :meth:`~pymongo.asynchronous.collection.AsyncCollection.create_index` or :meth:`~pymongo.collection.Collection.create_index` (e.g. ``[('field', ASCENDING)]``). This option is only supported on MongoDB 4.4 and above. :param namespace: (optional) The namespace in which to delete documents. .. versionchanged:: 4.9 Added the `namespace` option to support `MongoClient.bulk_write`. .. versionchanged:: 3.11 Added the ``hint`` option. .. versionchanged:: 3.5 Added the `collation` option. NrrrrXrYrdrzDeleteMany.__init__rercCr)rfrrNrrhrXrXrYri&rzDeleteMany._add_to_bulkrcCr)rjrkTrNrrhrXrXrYrl/rzDeleteMany._add_to_client_bulkrrr~rrrXrXrrYrrrc@s\eZdZdZdZ     d'd(ddZd)ddZd*ddZd+d d!Zd+d"d#Z d,d%d&Z dS)- ReplaceOnez#Represents a replace_one operation.)rr\_upsertrrr]_sortNrr replacement%Union[_DocumentType, RawBSONDocument]upsertOptional[bool]rrrrr_r`sortOptional[Mapping[str, Any]]rarbcCsr|dur td||durtd||dur"t|ts"t||_n||_||_||_||_ ||_ ||_ ||_ dS)a]Create a ReplaceOne instance. For use with :meth:`~pymongo.asynchronous.collection.AsyncCollection.bulk_write`, :meth:`~pymongo.collection.Collection.bulk_write`, :meth:`~pymongo.asynchronous.mongo_client.AsyncMongoClient.bulk_write` and :meth:`~pymongo.mongo_client.MongoClient.bulk_write`. :param filter: A query that matches the document to replace. :param replacement: The new document. :param upsert: If ``True``, perform an insert if no documents match the filter. :param collation: An instance of :class:`~pymongo.collation.Collation`. :param hint: An index to use to support the query predicate specified either by its string name, or in the same format as passed to :meth:`~pymongo.asynchronous.collection.AsyncCollection.create_index` or :meth:`~pymongo.collection.Collection.create_index` (e.g. ``[('field', ASCENDING)]``). This option is only supported on MongoDB 4.2 and above. :param sort: Specify which document the operation updates if the query matches multiple documents. The first document matched by the sort order will be updated. :param namespace: (optional) The namespace in which to replace a document. .. versionchanged:: 4.10 Added ``sort`` option. .. versionchanged:: 4.9 Added the `namespace` option to support `MongoClient.bulk_write`. .. versionchanged:: 3.11 Added the ``hint`` option. .. versionchanged:: 3.5 Added the ``collation`` option. Nrr) rrrrmr rrrrr\rrr])rcrrrrrr_rrXrXrYrdKs(   zReplaceOne.__init__rercCs*|j|j|j|jt|j|j|jddS)rfrrrN) add_replacerr\rr rrrrhrXrXrYris zReplaceOne._add_to_bulkrc Cs<|jstd|j|j|j|j|jt|j|j|j ddS)rjrkrN) r]rrrr\rr rrrrhrXrXrYrls zReplaceOne._add_to_client_bulkrtrrucCsTt|t|kr(|j|j|j|j|j|j|jf|j|j|j|j|j|j|jfkStSrv) rwrr\rrrr]rrxryrXrXrYrzs& zReplaceOne.__eq__cCr{rvrXryrXrXrYr|r}zReplaceOne.__ne__rmc CsV|jrd|jj|j|j|j|j|j|j|j Sd|jj|j|j|j|j|j|j S)N,{}({!r}, {!r}, {!r}, {!r}, {!r}, {!r}, {!r})z&{}({!r}, {!r}, {!r}, {!r}, {!r}, {!r})) r]rrqr8rr\rrrrrrrXrXrYrss( zReplaceOne.__repr__NNNNN)rrrrrrrrrrr_r`rrrarbr~rrr) r8r9r:rrrdrirlrzr|rsrXrXrXrYr>s 8  rc@s<eZdZdZdZd"ddZd#ddZd$ddZd%dd Zd!S)& _UpdateOpz)Private base class for update operations.)rr\rr_array_filtersrr]rrrdoc#Union[Mapping[str, Any], _Pipeline]rrrr array_filters!Optional[list[Mapping[str, Any]]]rrr_r`rrc Cs|dur td||durtd||durtd||dur+t|ts+t||_n||_||_||_ ||_ ||_ ||_ ||_ ||_dS)Nrrr)rrrrrmr rrrr\rrrr]r) rcrrrrrrr_rrXrXrYrds     z_UpdateOp.__init__rtobjectraruc CsZt|t|r+|j|j|j|j|j|j|j|j f|j|j|j|j|j|j|j|j fkSt Srv) rrwrr\rrrrr]rrxryrXrXrYrzs* z_UpdateOp.__eq__rcCr{rvrXryrXrXrYr|r}z_UpdateOp.__ne__rmc Cs^|jrd|jj|j|j|j|j|j|j |j|j Sd|jj|j|j|j|j|j|j |j S)Nz2{}({!r}, {!r}, {!r}, {!r}, {!r}, {!r}, {!r}, {!r})r) r]rrqr8rr\rrrrrrrrXrXrYrss, z_UpdateOp.__repr__N)rrrrrrrrrrrrr_r`rr)rtrrarurrrrXrXrXrYrs  rcsHeZdZdZdZ      dd fdd Zd!ddZd"ddZZS)# UpdateOnez#Represents an update_one operation.rXNrrr1rrrrrrrrrr_r`rrrarbc st||||||||dS)a{Represents an update_one operation. For use with :meth:`~pymongo.asynchronous.collection.AsyncCollection.bulk_write`, :meth:`~pymongo.collection.Collection.bulk_write`, :meth:`~pymongo.asynchronous.mongo_client.AsyncMongoClient.bulk_write` and :meth:`~pymongo.mongo_client.MongoClient.bulk_write`. :param filter: A query that matches the document to update. :param update: The modifications to apply. :param upsert: If ``True``, perform an insert if no documents match the filter. :param collation: An instance of :class:`~pymongo.collation.Collation`. :param array_filters: A list of filters specifying which array elements an update should apply. :param hint: An index to use to support the query predicate specified either by its string name, or in the same format as passed to :meth:`~pymongo.asynchronous.collection.AsyncCollection.create_index` or :meth:`~pymongo.collection.Collection.create_index` (e.g. ``[('field', ASCENDING)]``). This option is only supported on MongoDB 4.2 and above. :param namespace: The namespace in which to update a document. :param sort: Specify which document the operation updates if the query matches multiple documents. The first document matched by the sort order will be updated. .. versionchanged:: 4.10 Added ``sort`` option. .. versionchanged:: 4.9 Added the `namespace` option to support `MongoClient.bulk_write`. .. versionchanged:: 3.11 Added the `hint` option. .. versionchanged:: 3.9 Added the ability to accept a pipeline as the `update`. .. versionchanged:: 3.6 Added the `array_filters` option. .. versionchanged:: 3.5 Added the `collation` option. Nr) rcrr1rrrrr_rrrXrYrd0s/zUpdateOne.__init__rerc Cs4|j|j|jdt|jt|j|j|j|j ddS)rfFrrrrN) add_updaterr\rurr rrrrrhrXrXrYrias zUpdateOne._add_to_bulkrc CsB|jstd|j|j|j|jd|jt|j|j|j |j d dS)rjrkFrN) r]rrrr\rr rrrrrhrXrXrYrlns zUpdateOne._add_to_client_bulk)NNNNNN)rrr1rrrrrrrrrr_r`rrrarbr~rrrXrXrrYr+s 1 rcsFeZdZdZdZ     ddfdd ZdddZd ddZZS)! UpdateManyz$Represents an update_many operation.rXNrrr1rrrrrrrrrr_r`rarbc st|||||||ddS)aCreate an UpdateMany instance. For use with :meth:`~pymongo.asynchronous.collection.AsyncCollection.bulk_write`, :meth:`~pymongo.collection.Collection.bulk_write`, :meth:`~pymongo.asynchronous.mongo_client.AsyncMongoClient.bulk_write` and :meth:`~pymongo.mongo_client.MongoClient.bulk_write`. :param filter: A query that matches the documents to update. :param update: The modifications to apply. :param upsert: If ``True``, perform an insert if no documents match the filter. :param collation: An instance of :class:`~pymongo.collation.Collation`. :param array_filters: A list of filters specifying which array elements an update should apply. :param hint: An index to use to support the query predicate specified either by its string name, or in the same format as passed to :meth:`~pymongo.asynchronous.collection.AsyncCollection.create_index` or :meth:`~pymongo.collection.Collection.create_index` (e.g. ``[('field', ASCENDING)]``). This option is only supported on MongoDB 4.2 and above. :param namespace: (optional) The namespace in which to update documents. .. versionchanged:: 4.9 Added the `namespace` option to support `MongoClient.bulk_write`. .. versionchanged:: 3.11 Added the `hint` option. .. versionchanged:: 3.9 Added the ability to accept a pipeline as the `update`. .. versionchanged:: 3.6 Added the `array_filters` option. .. versionchanged:: 3.5 Added the `collation` option. Nr)rcrr1rrrrr_rrXrYrds*zUpdateMany.__init__rerc Cs,|j|j|jd|jt|j|j|jddS)rfTrrrN)rrr\rr rrrrhrXrXrYris zUpdateMany._add_to_bulkrc Cs>|jstd|j|j|j|jd|jt|j|j|j ddS)rjrkTrN) r]rrrr\rr rrrrhrXrXrYrls zUpdateMany._add_to_client_bulkr)rrr1rrrrrrrrrr_r`rarbr~rrrXrXrrYrs , rc@s6eZdZdZdZdd d Zedd d ZdddZdS) IndexModelzRepresents an index to create. __documentkeys _IndexKeyHintkwargsrrarbcKs^t|}|ddurt||d<t||d<t|dd}||_|dur-||jd<dSdS)a Create an Index instance. For use with :meth:`~pymongo.asynchronous.collection.AsyncCollection.create_indexes` and :meth:`~pymongo.collection.Collection.create_indexes`. Takes either a single key or a list containing (key, direction) pairs or keys. If no direction is given, :data:`~pymongo.ASCENDING` will be assumed. The key(s) must be an instance of :class:`str`, and the direction(s) must be one of (:data:`~pymongo.ASCENDING`, :data:`~pymongo.DESCENDING`, :data:`~pymongo.GEO2D`, :data:`~pymongo.GEOSPHERE`, :data:`~pymongo.HASHED`, :data:`~pymongo.TEXT`). Valid options include, but are not limited to: - `name`: custom name to use for this index - if none is given, a name will be generated. - `unique`: if ``True``, creates a uniqueness constraint on the index. - `background`: if ``True``, this index should be created in the background. - `sparse`: if ``True``, omit from the index any documents that lack the indexed field. - `bucketSize`: for use with geoHaystack indexes. Number of documents to group together within a certain proximity to a given longitude and latitude. - `min`: minimum value for keys in a :data:`~pymongo.GEO2D` index. - `max`: maximum value for keys in a :data:`~pymongo.GEO2D` index. - `expireAfterSeconds`: Used to create an expiring (TTL) collection. MongoDB will automatically delete documents from this collection after seconds. The indexed field must be a UTC datetime or the data will not expire. - `partialFilterExpression`: A document that specifies a filter for a partial index. - `collation`: An instance of :class:`~pymongo.collation.Collation` that specifies the collation to use. - `wildcardProjection`: Allows users to include or exclude specific field paths from a `wildcard index`_ using the { "$**" : 1} key pattern. Requires MongoDB >= 4.2. - `hidden`: if ``True``, this index will be hidden from the query planner and will not be evaluated as part of query plan selection. Requires MongoDB >= 4.4. See the MongoDB documentation for a full list of supported options by server version. :param keys: a single key or a list containing (key, direction) pairs or keys specifying the index to create. :param kwargs: any additional index creation options (see the above list) should be passed as keyword arguments. .. versionchanged:: 3.11 Added the ``hidden`` option. .. versionchanged:: 3.2 Added the ``partialFilterExpression`` option to support partial indexes. .. _wildcard index: https://mongodb.com/docs/master/core/index-wildcard/ nameNkeyr)rgetrrr pop_IndexModel__document)rcrrrrXrXrYrds=  zIndexModel.__init__dict[str, Any]cC|jS)zUAn index document suitable for passing to the createIndexes command. )rrrrXrXrYr^szIndexModel.documentrmc Cs.d|jj|jdddd|jDS)Nz{}({}{})rcSs(g|]\}}|dkrd|d|qS)rro=rX.0rvaluerXrXrY &s(z'IndexModel.__repr__..)rrqr8r^joinitemsrrrXrXrYrs"s zIndexModel.__repr__N)rrrrrarb)rarr r8r9r:rrrdpropertyr^rsrXrXrXrYrs F rc@s<eZdZdZdZ  ddd dZedddZdddZdS)SearchIndexModelz$Represents a search index to create.rN definitionrrr`rwrrrarbcKsDi|_|dur ||jd<||jd<|dur||jd<|j|dS)aCreate a Search Index instance. For use with :meth:`~pymongo.collection.AsyncCollection.create_search_index` and :meth:`~pymongo.collection.AsyncCollection.create_search_indexes`. :param definition: The definition for this index. :param name: The name for this index, if present. :param type: The type for this index which defaults to "search". Alternative values include "vectorSearch". :param kwargs: Keyword arguments supplying any additional options. .. note:: Search indexes require a MongoDB server version 7.0+ Atlas cluster. .. versionadded:: 4.5 .. versionchanged:: 4.7 Added the type and kwargs arguments. Nrrrw)_SearchIndexModel__documentr1)rcrrrwrrXrXrYrd/s   zSearchIndexModel.__init__cCr)zThe document for this index.)rrrrXrXrYr^LszSearchIndexModel.documentrmcCs&d|jjddd|jDS)Nz{}({})rocSsg|] \}}|d|qS)rrXrrXrXrYrTsz-SearchIndexModel.__repr__..)rrqr8rr^rrrrXrXrYrsQszSearchIndexModel.__repr__)NN) rrrr`rwr`rrrarb)rarrrrXrXrXrYr*s  r)4r __future__renumtypingrrrrrrr r bson.raw_bsonr pymongor pymongo.collationr pymongo.commonrrpymongo.errorsrpymongo.helpers_sharedrrrpymongo.typingsrrrpymongo.write_concernrrrrmint _IndexListrEnumrrZrrrrrrrrrrXrXrXrYs< (    4  5:==^VOZ