&g 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;WC:\Suresh\moveshuttle\MDcreated\moveengine\venv\Lib\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_upsertrrre_sortNcUb [SU5 Ub [SU5 Ub1[U[5(d[R "U5UlOXPlXplXlX l X0l 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 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. Nrupsert) rrrrr rrrrrdrrre)rgr replacementrrrrisorts r_rjReplaceOne.__init__KsmP   & 1   Xv .  JtS$9$9;I;Y;YZ^;_DJJ    ##r^c URURURUR[ UR 5UR URS9 g)rmrrrN) add_replacerrdrrrrrros r_rqReplaceOne._add_to_bulksD LL II LL0A  r^c UR(d [S5eURURURURUR [ UR5URURS9 g)rtrurN) rerrrrdrrrrrros r_rvReplaceOne._add_to_client_bulksd"e   OO LL II LL0A  r^c|[U5[U5:XaURURURURUR UR UR4URURURURUR UR UR4:H$[$r) rrrdrrrrerrrs r_rReplaceOne.__eq__s ;$t* $               "r^c X:X+$rr;rs r_rReplaceOne.__ne__rr^c UR(arSRURRURUR UR URURURUR5$SRURRURUR UR URURUR5$)N,{}({!r}, {!r}, {!r}, {!r}, {!r}, {!r}, {!r})z&{}({!r}, {!r}, {!r}, {!r}, {!r}, {!r})) rerr|r<rrdrrrrr}s r_r~ReplaceOne.__repr__s ??AHH''       8>> NN # # LL II LL OO JJ JJ  r^)rrdrrrerrNNNNN)rrrz%Union[_DocumentType, RawBSONDocument]rOptional[bool]rrrrrirrOptional[Mapping[str, Any]]rrrrrr) r<r=r>r?rrrjrqrvrrr~r]r;r^r_rr>s-I"&,0(,#',06$!6$;6$ 6$ * 6$ & 6$!6$*6$ 6$p   *! r^rcd\rSrSrSrSrS SjrS SjrS SjrS Sjr Sr g ) _UpdateOpiz)Private base class for update operations.)rrdrr_array_filtersrrerc &Ub [SU5 Ub [SU5 Ub [SU5 Ub1[U[5(d[ R "U5UlOX`lXlX l X0l X@l XPl Xpl Xlg)Nrr array_filters)rrrrrr rrrrdrrrrer) rgrdocrrrrrirs r_rj_UpdateOp.__init__s   & 1   Xv .  $ /= 9  JtS$9$9;I;Y;YZ^;_DJJ   #+# r^c [U[U55(aURURURUR UR URURUR4URURURUR UR URURUR4:H$[$r) rrrrdrrrrrerrrs r_r_UpdateOp.__eq__s eT$Z ( (     $$        ##    &r^c X:X+$rr;rs r_r_UpdateOp.__ne__rr^c UR(a}SRURRURUR UR URURURURUR5 $SRURRURUR UR URURURUR5$)Nz2{}({!r}, {!r}, {!r}, {!r}, {!r}, {!r}, {!r}, {!r})r) rerr|r<rrdrrrrrr}s r_r~_UpdateOp.__repr__s ??GNN''   ##    >DD NN # # LL II LL OO    JJ JJ  r^)rrrdrrrerrN)rrr#Union[Mapping[str, Any], _Pipeline]rrrrr!Optional[list[Mapping[str, Any]]]rrrirrr)robjectrrrrrr;r^r_rrsn3 I!1  *  9 &!*:.! r^rcz^\rSrSrSrSrSSU4SjjjrS SjrS SjrSr U=r $) UpdateOnei+z#Represents an update_one operation.r;c *>[T U]XX4XVXx5 g)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) rgrr4rrrrrirr|s r_rjUpdateOne.__init__0s^ MQZar^c URURURS[UR5[ UR 5URURURS9 g)rmFrrrrN) add_updaterrdrrrrrrrros r_rqUpdateOne._add_to_bulkasU LL II   0A--  r^c UR(d [S5eURURURURSUR [ UR5URURURS9 g)rtruFrN) rerrrrdrrrrrrros r_rvUpdateOne._add_to_client_bulknsp"e   OO LL II  LL0A--  r^)NNNNNN)rrr4rrrrrrrrrrirrrrrrrrrs@r_rr+s-I "&,0;?(,#',0/b!/b4/b /b * /b 9 /b&/b!/b*/b /b/bb    r^rct^\rSrSrSrSrSSU4SjjjrS SjrS SjrSr U=r $) UpdateManyiz$Represents an update_many operation.r;c ,>[TU]XX4XVUS5 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. Nr) rgrr4rrrrrir|s r_rjUpdateMany.__init__sT MQZ\`ar^c URURURSUR[ UR 5UR URS9 g)rmTrrrN)rrrdrrrrrros r_rqUpdateMany._add_to_bulksI LL II  LL0A--  r^c UR(d [S5eURURURURSUR [ UR5URURS9 g)rtruTrN) rerrrrdrrrrrros r_rvUpdateMany._add_to_client_bulksi"e   OO LL II  LL0A--  r^r)rrr4rrrrrrrrrrirrrrrrrs@r_rrs.I "&,0;?(,#'*b!*b4*b *b * *b 9 *b&*b!*b *b*bX    r^rcD\rSrSrSrSrSSjr\S Sj5rS Sjr Sr 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^c SRURRURSSR URR 5VVs/sHupUS:wdM SUSU<3PM snn55$s snnf)Nz{}({}{})rrz=)rr|r<rhjoinitemsrgrvalues r_r~IndexModel.__repr__"sy  NN # # MM% GGDMMr?rrrjpropertyrhr~r]r;r^r_r r s*(ID5L  r^r c^\rSrSrSrSrSS Sjjr\S Sj5rS Sjr Sr 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.documentLsr^c SRURRSRURR 5VVs/sH upUSU<3PM snn55$s snnf)Nz{}({})rzr)rr|r<rrhrr s r_r~SearchIndexModel.__repr__QsZ NN # # IIDMMr>sG#    *"8=+PPBB2B U3c5c7383D)D#EEFF GH'RUWZRZJ[[ c:o& #tyy@2! &2!j7c7ct: : z: : zL 'L ^[ [ |S S lL L ^W W t+ + r^