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)_OpZabortTransactionZ aggregateZ bulkWriteZcommitTransactioncountcreateZ createIndexesZcreateSearchIndexesdeleteZdistinctZdropZ dropDatabaseZ dropIndexesZdropSearchIndexesZ endSessionsZ findAndModifyfindinsertZlistCollectionsZ listIndexesZlistSearchIndexesZ listDatabasesupdateZ updateIndexZupdateSearchIndexrenameZgetMoreZ killCursorsZ testOperationN) __name__ __module__ __qualname__ZABORTZ AGGREGATEZ BULK_WRITEZCOMMITZCOUNTZCREATEZCREATE_INDEXESZCREATE_SEARCH_INDEXESDELETEZDISTINCTZDROPZ DROP_DATABASEZ DROP_INDEXESZDROP_SEARCH_INDEXESZ END_SESSIONSZFIND_AND_MODIFYZFINDZINSERTZLIST_COLLECTIONSZ LIST_INDEXESZLIST_SEARCH_INDEXZLIST_DATABASESZUPDATEZ UPDATE_INDEXZUPDATE_SEARCH_INDEXZRENAMEZGETMOREZ KILL_CURSORSTESTr'r'E/var/www/html/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.r'r'r(__init__]s zInsertOne.__init__bulkobjrcCs||jdS)>Add this operation to the _AsyncBulk/_Bulk instance `bulkobj`.N) add_insertr+r2r4r'r'r( _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,rr6r+r7r'r'r(_add_to_client_bulkqszInsertOne._add_to_client_bulkstrcCs:|jr|jjd|jd|jdS|jjd|jdS)N(, ))r, __class__r"r+r2r'r'r(__repr__|szInsertOne.__repr__otherrboolcCs,t|t|kr|j|jko|j|jkStSN)typer+r,NotImplementedr2rCr'r'r(__eq__szInsertOne.__eq__cC ||k SrEr'rHr'r'r(__ne__ zInsertOne.__ne__rE)r-rr.r/r0r1r4rr0r1r4rr0r1r0r<rCrr0rD) r"r#r$__doc__ __slots__r3r8r;rBrIrKr'r'r'r(r)Us    r)c@sDeZdZdZdZ   ddddZdddZdddZdddZdS) _DeleteOpz)Private base class for delete operations.)_filter _collation_hintr,NfilterMapping[str, Any] collationOptional[_CollationIn]hintOptional[_IndexKeyHint]r.r/r0r1cCsN|dur td||durt|tst||_n||_||_||_||_dS)NrW) r isinstancer<r rrVrTrUr,r2rWrYr[r.r'r'r(r3s  z_DeleteOp.__init__rCrrDcCs<t|t|kr|j|j|j|jf|j|j|j|jfkStSrE)rFrTrUrVr,rGrHr'r'r(rIs z_DeleteOp.__eq__cCrJrEr'rHr'r'r(rKrLz_DeleteOp.__ne__r<cCsJ|jrd|jj|j|j|j|jS|jjd|jd|jd|jdS)Nz{}({!r}, {!r}, {!r}, {!r})r=r>r?)r,formatr@r"rTrUrVrAr'r'r(rBs&z_DeleteOp.__repr__NNN rWrXrYrZr[r\r.r/r0r1rPrO r"r#r$rQrRr3rIrKrBr'r'r'r(rSs   rScBeZdZdZdZ   ddfdd ZdddZdddZZS) DeleteOnez"Represents a delete_one operation.r'NrWrXrYrZr[r\r.r/r0r1ct||||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. Nsuperr3r^r@r'r(r3zDeleteOne.__init__r4rcC |j|jdt|j|jddS)r5rYr[N add_deleterTr rUrVr7r'r'r(r8  zDeleteOne._add_to_bulkrcC2|jstd|j|j|jdt|j|jddS)r9r:FmultirYr[Nr,rrnrTr rUrVr7r'r'r(r; zDeleteOne._add_to_client_bulkr`rarMrN r"r#r$rQrRr3r8r; __classcell__r'r'rhr(rd  rdcrc) DeleteManyz#Represents a delete_many operation.r'NrWrXrYrZr[r\r.r/r0r1cre)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. Nrfr^rhr'r(r3rizDeleteMany.__init__r4rcCrj)r5rrlNrmr7r'r'r(r8&rozDeleteMany._add_to_bulkrcCrp)r9r:TrqNrsr7r'r'r(r;/rtzDeleteMany._add_to_client_bulkr`rarMrNrur'r'rhr(rxrwrxc@s\eZdZdZdZ     d'd(ddZd)ddZd*ddZd+d d!Zd+d"d#Z d,d%d&Z dS)- ReplaceOnez#Represents a replace_one operation.)rTr+_upsertrUrVr,_sortNrWrX replacement%Union[_DocumentType, RawBSONDocument]upsertOptional[bool]rYrZr[r\r.r/sortOptional[Mapping[str, Any]]r0r1cCsr|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. NrWr~) rrr]r<r rrVr{rTr+rzrUr,)r2rWr|r~rYr[r.rr'r'r(r3Ks(   zReplaceOne.__init__r4rcCs*|j|j|j|jt|j|j|jddS)r5rYr[rN) add_replacerTr+rzr rUrVr{r7r'r'r(r8s zReplaceOne._add_to_bulkrc Cs<|jstd|j|j|j|j|jt|j|j|j ddS)r9r:rN) r,rrrTr+rzr rUrVr{r7r'r'r(r;s zReplaceOne._add_to_client_bulkrCrrDcCsTt|t|kr(|j|j|j|j|j|j|jf|j|j|j|j|j|j|jfkStSrE) rFrTr+rzrUrVr,r{rGrHr'r'r(rIs& zReplaceOne.__eq__cCrJrEr'rHr'r'r(rKrLzReplaceOne.__ne__r<c 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,r_r@r"rTr+rzrUrVr{rAr'r'r(rBs( zReplaceOne.__repr__NNNNN)rWrXr|r}r~rrYrZr[r\r.r/rrr0r1rMrNrPrO) r"r#r$rQrRr3r8r;rIrKrBr'r'r'r(ry>s 8  ryc@s<eZdZdZdZd"ddZd#ddZd$ddZd%dd Zd!S)& _UpdateOpz)Private base class for update operations.)rTr+rzrU_array_filtersrVr,r{rWrXdoc#Union[Mapping[str, Any], _Pipeline]r~rrYrZ array_filters!Optional[list[Mapping[str, Any]]]r[r\r.r/rrc Cs|dur td||durtd||durtd||dur+t|ts+t||_n||_||_||_ ||_ ||_ ||_ ||_ ||_dS)NrWr~r)rrrr]r<r rrVrTr+rzrUrr,r{) r2rWrr~rYrr[r.rr'r'r(r3s     z_UpdateOp.__init__rCobjectr0rDc CsZt|t|r+|j|j|j|j|j|j|j|j f|j|j|j|j|j|j|j|j fkSt SrE) r]rFrTr+rzrUrrVr,r{rGrHr'r'r(rIs* z_UpdateOp.__eq__rcCrJrEr'rHr'r'r(rKrLz_UpdateOp.__ne__r<c 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,r_r@r"rTr+rzrUrrVr{rAr'r'r(rBs, z_UpdateOp.__repr__N)rWrXrrr~rrYrZrrr[r\r.r/rr)rCrr0rDrPrOrbr'r'r'r(rs  rcsHeZdZdZdZ      dd fdd Zd!ddZd"ddZZS)# UpdateOnez#Represents an update_one operation.r'NrWrXr rr~rrYrZrrr[r\r.r/rrr0r1c 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. Nrf) r2rWr r~rYrr[r.rrhr'r(r30s/zUpdateOne.__init__r4rc Cs4|j|j|jdt|jt|j|j|j|j ddS)r5FrYrr[rN) add_updaterTr+rDrzr rUrrVr{r7r'r'r(r8as zUpdateOne._add_to_bulkrc CsB|jstd|j|j|j|jd|jt|j|j|j |j d dS)r9r:FrN) r,rrrTr+rzr rUrrVr{r7r'r'r(r;ns zUpdateOne._add_to_client_bulk)NNNNNN)rWrXr rr~rrYrZrrr[r\r.r/rrr0r1rMrNrur'r'rhr(r+s 1 rcsFeZdZdZdZ     ddfdd ZdddZd ddZZS)! UpdateManyz$Represents an update_many operation.r'NrWrXr rr~rrYrZrrr[r\r.r/r0r1c 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. Nrf)r2rWr r~rYrr[r.rhr'r(r3s*zUpdateMany.__init__r4rc Cs,|j|j|jd|jt|j|j|jddS)r5TrYrr[N)rrTr+rzr rUrrVr7r'r'r(r8s zUpdateMany._add_to_bulkrc Cs>|jstd|j|j|j|jd|jt|j|j|j ddS)r9r:TrN) r,rrrTr+rzr rUrrVr7r'r'r(r;s zUpdateMany._add_to_client_bulkr)rWrXr rr~rrYrZrrr[r\r.r/r0r1rMrNrur'r'rhr(rs , rc@s6eZdZdZdZdd d Zedd d ZdddZdS) IndexModelzRepresents an index to create.Z __documentkeys _IndexKeyHintkwargsrr0r1cKs^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/ nameNkeyrY)rgetrrr pop_IndexModel__document)r2rrrYr'r'r(r3s=  zIndexModel.__init__dict[str, Any]cC|jS)zUAn index document suitable for passing to the createIndexes command. )rrAr'r'r(r-szIndexModel.documentr<c Cs.d|jj|jdddd|jDS)Nz{}({}{})rcSs(g|]\}}|dkrd|d|qS)rr>=r'.0rvaluer'r'r( &s(z'IndexModel.__repr__..)r_r@r"r-joinitemsrAr'r'r(rB"s zIndexModel.__repr__N)rrrrr0r1)r0rrO r"r#r$rQrRr3propertyr-rBr'r'r'r(rs F rc@s<eZdZdZdZ  ddd dZedddZdddZdS)SearchIndexModelz$Represents a search index to create.rN definitionrXrr/rFrrr0r1cKsDi|_|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. NrrrF)_SearchIndexModel__documentr )r2rrrFrr'r'r(r3/s   zSearchIndexModel.__init__cCr)zThe document for this index.)rrAr'r'r(r-LszSearchIndexModel.documentr<cCs&d|jjddd|jDS)Nz{}({})r>cSsg|] \}}|d|qS)rr'rr'r'r(rTsz-SearchIndexModel.__repr__..)r_r@r"rr-rrAr'r'r(rBQszSearchIndexModel.__repr__)NN) rrXrr/rFr/rrr0r1)r0rXrOrr'r'r'r(r*s  r)4rQ __future__renumtypingrrrrrrr r Z bson.raw_bsonr Zpymongor Zpymongo.collationr Zpymongo.commonrrZpymongo.errorsrZpymongo.helpers_sharedrrrZpymongo.typingsrrrZpymongo.write_concernrrrr<intZ _IndexListrEnumrr)rSrdrxryrrrrrr'r'r'r(s< (    4  5:==^VOZ