_i| .dZddlmZddlZddlmZmZmZmZm Z m Z m Z m Z ddl mZddlmZddlmZddlmZmZdd lmZdd lmZmZmZdd lmZmZmZdd l m!Z!erdd lm"Z"m#Z#e e e e$e e$e e%e$ee$effffee$effZ&e e$e&fZ'Gdde$ejPZ)GddeeZ*GddZ+Gdde+Z,Gdde+Z-GddeeZ.GddZ/Gdde/Z0Gdde/Z1Gd d!Z2Gd"d#Z3y)$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_AgnosticClientBulkceZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZy)_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_CURSORSTESTU/var/www/pod-logistic/pod-api/venv/lib/python3.12/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[rcFeZdZdZdZd d dZd dZd dZddZddZ dd Z y) InsertOnez#Represents an insert_one operation._doc _namespaceNc ||_||_y)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_)selfdocument namespaces r\__init__zInsertOne.__init__]s #r[c:|j|jy)>Add this operation to the _AsyncBulk/_Bulk instance `bulkobj`.N) add_insertr`rcbulkobjs r\ _add_to_bulkzInsertOne._add_to_bulkms499%r[c~|js td|j|j|jy)JAdd this operation to the _AsyncClientBulk/_ClientBulk instance `bulkobj`.SMongoClient.bulk_write requires a namespace to be provided for each write operationN)rarrir`rjs r\_add_to_client_bulkzInsertOne._add_to_client_bulkqs7"e   OO II r[c|jr3|jjd|jd|jdS|jjd|jdS)N(, ))ra __class__r:r`rcs r\__repr__zInsertOne.__repr__|sY ??nn--.a }Bt>QQRS S..))*!DII=::r[ct|t|k(r4|j|jk(xr|j|jk(StSN)typer`raNotImplementedrcothers r\__eq__zInsertOne.__eq__s? ;$t* $::*Ru/?/?4??/R Rr[c||k( SryrZr|s r\__ne__zInsertOne.__ne__5=  r[ry)rdrre Optional[str]returnNonerkrrrrkrrrrstrr}rrbool) r:r;r<__doc__ __slots__rfrlrprwr~rrZr[r\r^r^Us*-I $ &  ;  !r[r^cNeZdZdZdZ d d dZd dZd dZd dZy) _DeleteOpz)Private base class for delete operations.)_filter _collation_hintraNc| td||+t|tstj||_n||_||_||_||_y)Nfilter) r isinstancerr rrrrra)rcr collationhintres r\rfz_DeleteOp.__init__sR   & 1  JtS$9;I;Y;YZ^;_DJDJ ##r[ct|t|k(r]|j|j|j|jf|j|j|j|jfk(St Sry)rzrrrrar{r|s r\r~z_DeleteOp.__eq__sl ;$t* $            r[c||k( SryrZr|s r\rz_DeleteOp.__ne__rr[c<|jrQdj|jj|j|j |j |jS|jjd|jd|j d|j dS)Nz{}({!r}, {!r}, {!r}, {!r})rrrsrt)raformatrur:rrrrvs r\rwz_DeleteOp.__repr__s ??/66''    ..))*!DLL+;2doo=PPRSWS]S]R``abbr[NNN rMapping[str, Any]rOptional[_CollationIn]rOptional[_IndexKeyHint]rerrrrr r:r;r<rrrfr~rrwrZr[r\rrs\3I-1(,#' $!$*$& $ ! $  $$ ! cr[rcReZdZdZdZ d dfd ZddZd dZxZS) DeleteOnez"Represents a delete_one operation.rZc*t|||||y)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. Nsuperrfrcrrrrerus r\rfzDeleteOne.__init__< D)> NN # # LL II LL OO JJ JJ  r[NNNNN)rrrz%Union[_DocumentType, RawBSONDocument]rOptional[bool]rrrrrerrOptional[Mapping[str, Any]]rrrrrr) r:r;r<rrrfrlrpr~rrwrZr[r\rr>s-I"&,0(,#',06$!6$;6$ 6$ * 6$ & 6$!6$*6$ 6$p   *! r[rcTeZdZdZdZ ddZd dZd dZd dZy) _UpdateOpz)Private base class for update operations.)rr`rr_array_filtersrrarc "| td|| td|| td||+t|tst j ||_n||_||_||_ ||_ ||_ ||_ ||_ ||_y)Nrr array_filters)rrrrrr rrrr`rrrrar) rcrdocrrrrrers r\rfz_UpdateOp.__init__s   & 1   Xv .  $ /= 9  JtS$9;I;Y;YZ^;_DJDJ   #+# r[c t|t|r|j|j|j|j |j |j|j|jf|j|j|j|j |j |j|j|jfk(StSry) rrzrr`rrrrrarr{r|s r\r~z_UpdateOp.__eq__s eT$Z (     $$        ##    &r[c||k( SryrZr|s r\rz_UpdateOp.__ne__rr[c |jr}dj|jj|j|j |j |j|j|j|j|j Sdj|jj|j|j |j |j|j|j|jS)Nz2{}({!r}, {!r}, {!r}, {!r}, {!r}, {!r}, {!r}, {!r})r) rarrur:rr`rrrrrrvs r\rwz_UpdateOp.__repr__s ??GNN''   ##    >DD NN # # LL II LL OO    JJ JJ  r[N)rrr#Union[Mapping[str, Any], _Pipeline]rrrrr!Optional[list[Mapping[str, Any]]]rrrerrr)r}objectrrrrrrZr[r\rrsn3 I!1  *  9 &!*:.! r[rcheZdZdZdZ d dfd ZddZd dZxZS) UpdateOnez#Represents an update_one operation.rZc 2t |||||||||y)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) rcrr3rrrrrerrus r\rfzUpdateOne.__init__0s#^ M4QZ\`ar[c |j|j|jdt|jt |j |j|j|jy)rhFrrrrN) add_updaterr`rrrrrrrrjs r\rlzUpdateOne._add_to_bulkasU LL II   0A--  r[c |js td|j|j|j|jd|j t |j|j|j|j y)rnroFrN) rarrrr`rrrrrrrjs r\rpzUpdateOne._add_to_client_bulknsp"e   OO LL II  LL0A--  r[)NNNNNN)rrr3rrrrrrrrrrerrrrrrrrrs@r\rr+s-I "&,0;?(,#',0/b!/b4/b /b * /b 9 /b&/b!/b*/b /bb   r[rcbeZdZdZdZ d dfd ZddZd dZxZS) UpdateManyz$Represents an update_many operation.rZc 2t||||||||dy)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) rcrr3rrrrrerus r\rfzUpdateMany.__init__s#T M4QZ\`ar[c |j|j|jd|jt |j |j |jy)rhTrrrN)rrr`rrrrrrjs r\rlzUpdateMany._add_to_bulksI LL II  LL0A--  r[c |js td|j|j|j|jd|j t |j|j|jy)rnroTrN) rarrrr`rrrrrrjs r\rpzUpdateMany._add_to_client_bulksi"e   OO LL II  LL0A--  r[r)rrr3rrrrrrrrrrerrrrrrrs@r\rrs.I "&,0;?(,#'*b!*b4*b *b * *b 9 *b&*b!*b *bX   r[rc6eZdZdZdZddZeddZd dZy) IndexModelzRepresents an index to create. __documentc t|}|jdt||d<t||d<t |j dd}||_|||j d<yy)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://dochub.mongodb.org/core/index-wildcard/ nameNkeyr)rgetrrrpop_IndexModel__document)rckeyskwargsrs r\rfzIndexModel.__init__soz4  ::f  %,T2F6N'-u .vzz+t/LM    +4DOOK ( !r[c|jS)zUAn index document suitable for passing to the createIndexes command. )rrvs r\rdzIndexModel.documents r[cdj|jj|jddj |jj Dcgc]\}}|dk7s d|d|c}}Scc}}w)Nz{}({}{})rrs=)rrur:rdjoinitemsrcrvalues r\rwzIndexModel.__repr__"sr  NN # # MM% GGDMMrsG#    *"8=+PPBB2B U3c5c7383D)D#EEFF GH'RUWZRZJ[[ c:o& #tyy@2! &2!j7c7ct: : z: : zL 'L ^[ [ |S S lL L ^W W t+ + r[