o ]6@sdZddlmZmZmZddlmZddlmZm Z m Z Gddde Z Gddde Z Gd d d e ZGd d d e ZGd dde ZGdddeZGdddeZGddde ZdS)zOperation class definitions.)validate_booleanvalidate_is_mapping validate_list)validate_collation_or_none)_gen_index_name_index_document _index_listc@s<eZdZdZdZddZddZddZd d Zd d Z d S) InsertOnez#Represents an insert_one operation._doccCs ||_dS)zCreate an InsertOne instance. For use with :meth:`~pymongo.collection.Collection.bulk_write`. :Parameters: - `document`: The document to insert. If the document is missing an _id field one will be added. Nr )selfdocumentrD/var/www/html/env/lib/python3.10/site-packages/pymongo/operations.py__init__s zInsertOne.__init__cCs||jdS)3Add this operation to the _Bulk instance `bulkobj`.N) add_insertr r bulkobjrrr _add_to_bulk&szInsertOne._add_to_bulkcCs d|jfS)Nz InsertOne(%r)r r rrr__repr__*s zInsertOne.__repr__cCs t|t|kr|j|jkStSN)typer NotImplementedr otherrrr__eq__-s zInsertOne.__eq__cC ||k Srrrrrr__ne__2 zInsertOne.__ne__N __name__ __module__ __qualname____doc__ __slots__rrrrrrrrrr s  r c@>eZdZdZdZdddZddZdd Zd d Zd d Z dS) DeleteOnez"Represents a delete_one operation._filter _collationNcC"|dur td|||_||_dS)aCreate a DeleteOne instance. For use with :meth:`~pymongo.collection.Collection.bulk_write`. :Parameters: - `filter`: A query that matches the document to delete. - `collation` (optional): An instance of :class:`~pymongo.collation.Collation`. This option is only supported on MongoDB 3.4 and above. .. versionchanged:: 3.5 Added the `collation` option. Nfilterrr*r+r r- collationrrrr;  zDeleteOne.__init__cC|j|jd|jddS)rr0N add_deleter*r+rrrrrNzDeleteOne._add_to_bulkcCd|j|jfS)NzDeleteOne(%r, %r)r)rrrrrRzDeleteOne.__repr__cC,t|t|kr|j|jf|j|jfkStSrrr*r+rrrrrrU   zDeleteOne.__eq__cCrrrrrrrr[r zDeleteOne.__ne__rr!rrrrr(6  r(c@r') DeleteManyz#Represents a delete_many operation.r)NcCr,)aCreate a DeleteMany instance. For use with :meth:`~pymongo.collection.Collection.bulk_write`. :Parameters: - `filter`: A query that matches the documents to delete. - `collation` (optional): An instance of :class:`~pymongo.collation.Collation`. This option is only supported on MongoDB 3.4 and above. .. versionchanged:: 3.5 Added the `collation` option. Nr-r.r/rrrrdr1zDeleteMany.__init__cCr2)rrr4Nr5rrrrrwr7zDeleteMany._add_to_bulkcCr8)NzDeleteMany(%r, %r)r)rrrrr{r9zDeleteMany.__repr__cCr:rr;rrrrr~r<zDeleteMany.__eq__cCrrrrrrrrr zDeleteMany.__ne__rr!rrrrr>_r=r>c@s>eZdZdZdZdddZddZd d Zd d Zd dZ dS) ReplaceOnez#Represents a replace_one operation.)r*r _upsertr+FNcCs@|dur td||durtd|||_||_||_||_dS)aXCreate a ReplaceOne instance. For use with :meth:`~pymongo.collection.Collection.bulk_write`. :Parameters: - `filter`: A query that matches the document to replace. - `replacement`: The new document. - `upsert` (optional): If ``True``, perform an insert if no documents match the filter. - `collation` (optional): An instance of :class:`~pymongo.collation.Collation`. This option is only supported on MongoDB 3.4 and above. .. versionchanged:: 3.5 Added the `collation` option. Nr-upsert)rrr*r r@r+)r r- replacementrAr0rrrrs   zReplaceOne.__init__cCs|j|j|j|j|jddS)rr4N) add_replacer*r r@r+rrrrrs zReplaceOne._add_to_bulkcCs<t|t|kr|j|j|j|jf|j|j|j|jfkStSr)rr*r r@r+rrrrrrs zReplaceOne.__eq__cCrrrrrrrrr zReplaceOne.__ne__cCsd|jj|j|j|j|jfS)Nz%s(%r, %r, %r, %r)) __class__r"r*r r@r+rrrrrszReplaceOne.__repr__)FN) r"r#r$r%r&rrrrrrrrrr?s  r?c@s4eZdZdZdZddZddZddZd d Zd S) _UpdateOpz)Private base class for update operations.)r*r r@r+_array_filterscCsX|dur td||durtd||durtd|||_||_||_||_||_dS)Nr-rA array_filters)rrrr*r r@r+rF)r r-docrAr0rGrrrrs    z_UpdateOp.__init__cCsDt|t|kr |j|j|j|j|jf|j|j|j|j|jfkStSr)rr*r r@r+rFrrrrrrsz_UpdateOp.__eq__cCrrrrrrrrr z_UpdateOp.__ne__cCs"d|jj|j|j|j|j|jfS)Nz%s(%r, %r, %r, %r, %r))rDr"r*r r@r+rFrrrrrsz_UpdateOp.__repr__N) r"r#r$r%r&rrrrrrrrrEs  rEc2eZdZdZdZ  d fdd ZddZZS) UpdateOnez#Represents an update_one operation.rFNctt||||||dS)aRepresents an update_one operation. For use with :meth:`~pymongo.collection.Collection.bulk_write`. :Parameters: - `filter`: A query that matches the document to update. - `update`: The modifications to apply. - `upsert` (optional): If ``True``, perform an insert if no documents match the filter. - `collation` (optional): An instance of :class:`~pymongo.collation.Collation`. This option is only supported on MongoDB 3.4 and above. - `array_filters` (optional): A list of filters specifying which array elements an update should apply. Requires MongoDB 3.6+. .. 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. N)superrJrr r-updaterAr0rGrDrrrzUpdateOne.__init__cC$|j|j|jd|j|j|jddS)rFr0rGN add_updater*r r@r+rFrrrrr zUpdateOne._add_to_bulkFNNr"r#r$r%r&rr __classcell__rrrOrrJrJcrI) UpdateManyz$Represents an update_many operation.rFNcrK)aCreate an UpdateMany instance. For use with :meth:`~pymongo.collection.Collection.bulk_write`. :Parameters: - `filter`: A query that matches the documents to update. - `update`: The modifications to apply. - `upsert` (optional): If ``True``, perform an insert if no documents match the filter. - `collation` (optional): An instance of :class:`~pymongo.collation.Collation`. This option is only supported on MongoDB 3.4 and above. - `array_filters` (optional): A list of filters specifying which array elements an update should apply. Requires MongoDB 3.6+. .. 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. N)rLrZrrMrOrrr rPzUpdateMany.__init__cCrQ)rTrRNrSrrrrr'rUzUpdateMany._add_to_bulkrVrWrrrOrrZrYrZc@s(eZdZdZdZddZeddZdS) IndexModelzRepresents an index to create.) __documentcKsXt|}d|vrt||d<t||d<t|dd}||_|dur*||jd<dSdS)a Create an Index instance. For use with :meth:`~pymongo.collection.Collection.create_indexes`. Takes either a single key or a list of (key, direction) pairs. The key(s) must be an instance of :class:`basestring` (:class:`str` in python 3), and the direction(s) must be one of (:data:`~pymongo.ASCENDING`, :data:`~pymongo.DESCENDING`, :data:`~pymongo.GEO2D`, :data:`~pymongo.GEOHAYSTACK`, :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. Requires server version >= 3.2. - `collation`: An instance of :class:`~pymongo.collation.Collation` that specifies the collation to use in MongoDB >= 3.4. - `wildcardProjection`: Allows users to include or exclude specific field paths from a `wildcard index`_ using the { "$**" : 1} key pattern. Requires server version >= 4.2. See the MongoDB documentation for a full list of supported options by server version. :Parameters: - `keys`: a single key or a list of (key, direction) pairs specifying the index to create - `**kwargs` (optional): any additional index creation options (see the above list) should be passed as keyword arguments .. versionchanged:: 3.2 Added partialFilterExpression to support partial indexes. .. _wildcard index: https://docs.mongodb.com/master/core/index-wildcard/#wildcard-index-core namekeyr0N)rrrrpop_IndexModel__document)r keyskwargsr0rrrr3s8  zIndexModel.__init__cCs|jS)zUAn index document suitable for passing to the createIndexes command. )r`rrrrr tszIndexModel.documentN)r"r#r$r%r&rpropertyr rrrrr[.s Ar[N)r%pymongo.commonrrrpymongo.collationrpymongo.helpersrrrobjectr r(r>r?rErJrZr[rrrrs  ))4$''