Iiv 8SrSSKJr SSKrSSKJrJrJrJrJ r J r J r J r SSK Jr SSKJr SSKJr SSKJrJr SS KJr SS KJrJrJr SS KJrJrJr SS K J!r! \(aSS KJ"r"J#r# \ \ \ \$\ \$\ \%\$\\$\4444\\$\44r&\ \$\&4r'"SS\$\RP5r)"SS\\5r*"SS5r+"SS\+5r,"SS\+5r-"SS\\5r."SS5r/"SS\/5r0"SS\/5r1"S S!5r2"S"S#5r3g)$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\rSrSrSrSrSrSrSrSr Sr S r S r S r S rS rSrSrSrSrSrSrSrSrSrSrSrSrSrSrSrSrSr Sr!g )!_Op5abortTransaction aggregate bulkWritecommitTransactioncountcreate createIndexescreateSearchIndexesdeletedistinctdrop dropDatabase dropIndexesdropSearchIndexes endSessions findAndModifyfindinsertlistCollections listIndexeslistSearchIndexes listDatabasesupdate updateIndexupdateSearchIndexrenamegetMore killCursors testOperationN)"__name__ __module__ __qualname____firstlineno__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_CURSORSTEST__static_attributes__r;8/venv/lib/python3.13/site-packages/pymongo/operations.pyrr5s EIJ F E F$N1 FH D"M L- L%O D F( L+$N F L- FG L Dr^rc\\rSrSrSrSrS S SjjrS SjrSSjrSSjr SS jr SS jr Sr g) InsertOneUz#Represents an insert_one operation._doc _namespaceNcXlX lg)a6Create 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`. Nrc)selfdocument namespaces r___init__InsertOne.__init__]s #r^c:URUR5 g)>Add this operation to the _AsyncBulk/_Bulk instance `bulkobj`.N) add_insertrdrgbulkobjs r_ _add_to_bulkInsertOne._add_to_bulkms499%r^cUR(d [S5eURURUR5 g)JAdd this operation to the _AsyncClientBulk/_ClientBulk instance `bulkobj`.SMongoClient.bulk_write requires a namespace to be provided for each write operationN)rerrnrdros r__add_to_client_bulkInsertOne._add_to_client_bulkqs7"e   OO II r^cUR(a5URRSUR<SUR<S3$URRSUR<S3$)N(, ))re __class__r<rdrgs r___repr__InsertOne.__repr__|sY ??nn--.a }Bt>QQRS S..))*!DII=::r^c[U5[U5:Xa9URUR:H=(a URUR:H$[$N)typerdreNotImplementedrgothers r___eq__InsertOne.__eq__s? ;$t* $::*Ru/?/?4??/R Rr^c X:X+$rr;rs r___ne__InsertOne.__ne__   r^r)rhrri Optional[str]returnNonerprrrrprrrrstrrrrbool) r<r=r>r?__doc__ __slots__rjrqrvr~rrr]r;r^r_raraUs*-I $ &  ;  !r^rac`\rSrSrSrSrS S SjjrS SjrS SjrS Sjr S r g) _DeleteOpz)Private base class for delete operations.)_filter _collation_hintreNcUb [SU5 Ub1[U[5(d[R"U5UlOX0lXlX lX@lg)Nfilter) r isinstancerr rrrrre)rgr collationhintris r_rj_DeleteOp.__init__sM   & 1  JtS$9$9;I;Y;YZ^;_DJJ ##r^c[U5[U5:Xa]URURURUR4URURURUR4:H$[ $r)rrrrrerrs r_r_DeleteOp.__eq__sl ;$t* $            r^c X:X+$rr;rs r_r_DeleteOp.__ne__rr^cLUR(aQSRURRURUR UR UR5$URRSUR<SUR <SUR <S3$)Nz{}({!r}, {!r}, {!r}, {!r})ryrzr{)reformatr|r<rrrr}s r_r~_DeleteOp.__repr__s ??/66''    ..))*!DLL+;2doo=PPRSWS]S]R``abbr^)rrrreNNN rMapping[str, Any]rOptional[_CollationIn]rOptional[_IndexKeyHint]rirrrrr r<r=r>r?rrrjrrr~r]r;r^r_rrs\3I-1(,#' $!$*$& $ ! $  $$ ! cr^rcd^\rSrSrSrSrSSU4SjjjrS SjrS SjrSr U=r $) DeleteOnez"Represents a delete_one operation.r;c&>[TU]XX45 g)a5Create 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. Nsuperrjrgrrrrir|s r_rjDeleteOne.__init__< Dr?rrrjrqrvr] __classcell__r|s@r_rrs`,I -1(,#' =!=*=& = ! =  ==@    r^rcd^\rSrSrSrSrSSU4SjjjrS SjrS SjrSr U=r $) DeleteManyiz#Represents a delete_many operation.r;c&>[TU]XX45 g)a6Create 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. Nrrs r_rjDeleteMany.__init__rr^cvURURS[UR5URS9 g)rmrrNrros r_rqDeleteMany._add_to_bulk&rr^cUR(d [S5eURURURS[ UR 5UR S9 g)rtruTrNrros r_rvDeleteMany._add_to_client_bulk/sR"e   OO LL0A  r^rrrrrrs@r_rrs`-I -1(,#' =!=*=& = ! =  ==@    r^rc~\rSrSrSrSrS S SjjrSSjrSSjrSSjr SS jr SS jr S r g) ReplaceOnei>z#Represents a replace_one operation.)rrd_upsertrrreNcUb [SU5 Ub [SU5 Ub1[U[5(d[R "U5UlOXPlXlX lX0l X@l X`l g)aCreate 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 namespace: (optional) The namespace in which to replace 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. Nrupsert) rrrrr rrrrdrrre)rgr replacementrrrris r_rjReplaceOne.__init__JshF   & 1   Xv .  JtS$9$9;I;Y;YZ^;_DJJ   ##r^cURURURUR[ UR 5UR S9 g)rmrN) add_replacerrdrrrrros r_rqReplaceOne._add_to_bulk|s= LL II LL0A  r^c UR(d [S5eURURURURUR [ UR5URS9 g)rtrurN) rerrrrdrrrrros r_rvReplaceOne._add_to_client_bulks]"e   OO LL II LL0A  r^cP[U5[U5:XaURURURURUR UR 4URURURURUR UR 4:H$[$r)rrrdrrrrerrs r_rReplaceOne.__eq__s ;$t* $              r^c X:X+$rr;rs r_rReplaceOne.__ne__rr^c UR(agSRURRURUR UR URURUR5$SRURRURUR UR URUR5$)N&{}({!r}, {!r}, {!r}, {!r}, {!r}, {!r})z {}({!r}, {!r}, {!r}, {!r}, {!r})) rerr|r<rrdrrrr}s r_r~ReplaceOne.__repr__s ??;BB''     288 NN # # LL II LL OO JJ   r^)rrdrrrer)FNNN)rrrz%Union[_DocumentType, RawBSONDocument]rrrrrrrirrrrrrr) r<r=r>r?rrrjrqrvrrr~r]r;r^r_rr>s}-I,0(,#'0$!0$;0$ 0$ * 0$ & 0$!0$ 0$d   &! r^rc`\rSrSrSrSrS SjrS SjrS SjrS Sjr Sr g ) _UpdateOpiz)Private base class for update operations.)rrdrr_array_filtersrrecUb [SU5 Ub [SU5 Ub [SU5 Ub1[U[5(d[ R "U5UlOX`lXlX l X0l X@l XPl Xpl g)Nrr array_filters)rrrrrr rrrrdrrrre)rgrdocrrrrris r_rj_UpdateOp.__init__s}   & 1   Xv .  $ /= 9  JtS$9$9;I;Y;YZ^;_DJJ   #+#r^c[U[U55(aURURURUR UR URUR4URURURUR UR URUR4:H$[$r) rrrrdrrrrrerrs r_r_UpdateOp.__eq__s eT$Z ( (     $$      ##  "r^c X:X+$rr;rs r_r_UpdateOp.__ne__rr^c UR(arSRURRURUR UR URURURUR5$SRURRURUR UR URURUR5$)Nz,{}({!r}, {!r}, {!r}, {!r}, {!r}, {!r}, {!r})r) rerr|r<rrdrrrrr}s r_r~_UpdateOp.__repr__s ??AHH''   ##   8>> NN # # LL II LL OO    JJ  r^)rrrdrrrerN)rrr#Union[Mapping[str, Any], _Pipeline]rOptional[bool]rrr!Optional[list[Mapping[str, Any]]]rrrir)robjectrrrrrr;r^r_rrsd3I$!$1$ $ * $ 9 $&$!$8*! r^rct^\rSrSrSrSrSSU4SjjjrS SjrS SjrSr U=r $) UpdateOneiz#Represents an update_one operation.r;c *>[TU]XX4XVU5 g)aRepresents 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: (optional) The namespace in which to update a document. .. 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 rgrr4rrrrrir|s r_rjUpdateOne.__init__T MQZ[r^c URURURS[UR5[ UR 5URURS9 g)rmFrrrN add_updaterrdrrrrrrros r_rqUpdateOne._add_to_bulkIsN LL II   0A--  r^c UR(d [S5eURURURURSUR [ UR5URURS9 g)rtruFrN rerrrrdrrrrrros r_rvUpdateOne._add_to_client_bulkUsi"e   OO LL II  LL0A--  r^NNNNNrrr4rrrrrrrrrrirrrrrrrs@r_rrs-I "&,0;?(,#'*\!*\4*\ *\ * *\ 9 *\&*\!*\ *\*\X    r^rct^\rSrSrSrSrSSU4SjjjrS SjrS SjrSr U=r $) UpdateManyigz$Represents an update_many operation.r;c *>[TU]XX4XVU5 g)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. Nrrs r_rjUpdateMany.__init__lrr^c URURURS[UR5[ UR 5URURS9 g)rmTrNrros r_rqUpdateMany._add_to_bulksN LL II   0A--  r^c UR(d [S5eURURURURSUR [ UR5URURS9 g)rtruTrNrros r_rvUpdateMany._add_to_client_bulksi"e   OO LL II  LL0A--  r^rrrrrrs@r_rrgs.I "&,0;?(,#'*\!*\4*\ *\ * *\ 9 *\&*\!*\ *\*\X    r^rc:\rSrSrSrSrSSjr\SSj5rSr g) IndexModelizRepresents an index to create. __documentc [U5nURS5c[U5US'[U5US'[ UR SS55nX lUbX0R S'gg)a8 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)rgetrrrpop_IndexModel__document)rgkeyskwargsrs r_rjIndexModel.__init__skz4  ::f  %,T2F6N'-u .vzz+t/LM    +4OOK ( !r^cUR$)zEAn index document suitable for passing to the createIndexes command. )rr}s r_rhIndexModel.documents r^N)r _IndexKeyHintrrrr)rzdict[str, Any] r<r=r>r?rrrjpropertyrhr]r;r^r_r r s%(ID5Lr^r cT\rSrSrSrSrSSSjjr\S Sj5rSr g) SearchIndexModeli z$Represents a search index to create.rNc 0UlUbX RS'XRS'UbX0RS'URRU5 g)anCreate 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. Nr definitionr)_SearchIndexModel__documentr4)rgr!rrrs r_rjSearchIndexModel.__init__sM*+-  &*OOF #(2 %  &*OOF # v&r^cUR$)zThe document for this index.)r"r}s r_rhSearchIndexModel.document+sr^)NN) r!rrrrrrrrr)rrrr;r^r_rr s[.I #" '%'' '  '  ':r^r)4r __future__renumtypingrrrrrr r r bson.raw_bsonr pymongor pymongo.collationrpymongo.commonrrpymongo.errorsrpymongo.helpers_sharedrrrpymongo.typingsrrrpymongo.write_concernrrrrint _IndexListrEnumrrarrrrrrrr rr;r^r_r4sG#    *"8=+PPBB2B U3c5c7383D)D#EEFF GH'RUWZRZJ[[ c:o& #tyy@2! &2!j7c7ct: : z: : z ' DU U pL L ^L L ^PPf%%r^