o hC3@sdZddlmZddlmZmZmZmZmZddl m Z GdddZ Gddde Z Gd d d e Z Gd d d e ZGd dde ZGddde ZGdddeZGdddeZdS)z{Result class definitions. .. seealso:: This module is compatible with both the synchronous and asynchronous PyMongo APIs. ) annotations)AnyMappingMutableMappingOptionalcast)InvalidOperationc@s@eZdZdZdZdddZdd d Zdd dZedddZ dS) _WriteResultz$Base class for write result classes.)Z__acknowledged acknowledgedboolreturnNonecCs ||_dSN_WriteResult__acknowledged)selfr rB/var/www/html/venv/lib/python3.10/site-packages/pymongo/results.py__init__s z_WriteResult.__init__strcCs|jjd|jdS)N()) __class____name__rrrrr__repr__"sz_WriteResult.__repr__ property_namecC|js td|ddS)z8Raise an exception on property access if unacknowledged. A value for zi is not available when the write is unacknowledged. Check the acknowledged attribute to avoid this error.N)rrrrrrr_raise_if_unacknowledged%  z%_WriteResult._raise_if_unacknowledgedcC|jS)aCIs this the result of an acknowledged write operation? The :attr:`acknowledged` attribute will be ``False`` when using ``WriteConcern(w=0)``, otherwise ``True``. .. note:: If the :attr:`acknowledged` attribute is ``False`` all other attributes of this class will raise :class:`~pymongo.errors.InvalidOperation` when accessed. Values for other attributes cannot be determined if the write operation was unacknowledged. .. seealso:: :class:`~pymongo.write_concern.WriteConcern` rrrrrr /sz_WriteResult.acknowledgedN)r r r r r rrrr r r r ) r __module__ __qualname____doc__ __slots__rrr propertyr rrrrr s    r c>eZdZdZdZdfd d Zdd d ZedddZZ S)InsertOneResultzThe return type for :meth:`~pymongo.collection.Collection.insert_one` and as part of :meth:`~pymongo.mongo_client.MongoClient.bulk_write`. )Z __inserted_id inserted_idrr r r r c||_t|dSr)_InsertOneResult__inserted_idsuperr)rr-r rrrrJzInsertOneResult.__init__rcC|jjd|jd|jdSNrz, acknowledged=r)rrr/r rrrrrNzInsertOneResult.__repr__cCr")zThe inserted document's _id.)r/rrrrr-SzInsertOneResult.inserted_id)r-rr r r r r#r r) rr&r'r(r)rrr*r- __classcell__rrr1rr,Cs r,cr+)InsertManyResultzGThe return type for :meth:`~pymongo.collection.Collection.insert_many`.)Z__inserted_ids inserted_ids list[Any]r r r r cr.r)_InsertManyResult__inserted_idsr0r)rr:r r1rrr^r2zInsertManyResult.__init__rcCr3r4)rrr<r rrrrrbr5zInsertManyResult.__repr__cCr")a@A list of _ids of the inserted documents, in the order provided. .. note:: If ``False`` is passed for the `ordered` parameter to :meth:`~pymongo.collection.Collection.insert_many` the server may have inserted the documents in a different order than what is presented here. )r<rrrrr:gs zInsertManyResult.inserted_ids)r:r;r r r r r#)r r;) rr&r'r(r)rrr*r:r8rrr1rr9Ys r9cszeZdZdZdZ ddfd d Zdd dZedddZedddZ edddZ ed ddZ ed!ddZ Z S)" UpdateResultaThe return type for :meth:`~pymongo.collection.Collection.update_one`, :meth:`~pymongo.collection.Collection.update_many`, and :meth:`~pymongo.collection.Collection.replace_one`, and as part of :meth:`~pymongo.mongo_client.MongoClient.bulk_write`. ) __raw_resultZ__in_client_bulkF raw_resultOptional[Mapping[str, Any]]r r in_client_bulkcs||_||_t|dSr)_UpdateResult__raw_result_UpdateResult__in_client_bulkr0r)rr?r rAr1rrrszUpdateResult.__init__r rcCr3r4)rrrBr rrrrrzUpdateResult.__repr__cCr"z/The raw result document returned by the server.rBrrrrr?r6zUpdateResult.raw_resultintcCs:|d|jdus J|js|jdurdS|jddS)z0The number of documents matched for this update. matched_countNrn)r rBrC upserted_idgetrrrrrHs zUpdateResult.matched_countcCs*|d|jdus Jtt|jdS)!The number of documents modified.modified_countN nModified)r rBrrGrKrrrrrMs zUpdateResult.modified_countrcCsF|d|jdus J|jr|jdr|jddS|jddS)z^The _id of the inserted document if an upsert took place. Otherwise ``None``. rJNupserted_id)r rBrCrKrrrrrJs zUpdateResult.upserted_idcCs|jdusJd|jvS)zEWhether an upsert took place. .. versionadded:: 4.9 NrOrFrrrr did_upserts zUpdateResult.did_upsert)F)r?r@r r rAr r#)r r@r rGr7r%)rr&r'r(r)rrr*r?rHrMrJrQr8rrr1rr=ss        r=csLeZdZdZdZdfd d Zdd d ZedddZedddZ Z S) DeleteResultzThe return type for :meth:`~pymongo.collection.Collection.delete_one` and :meth:`~pymongo.collection.Collection.delete_many` and as part of :meth:`~pymongo.mongo_client.MongoClient.bulk_write`. )r>r?Mapping[str, Any]r r r r cr.r)_DeleteResult__raw_resultr0r)rr?r r1rrrr2zDeleteResult.__init__rcCr3r4)rrrUr rrrrrrDzDeleteResult.__repr__cCr"rE)rUrrrrr?r6zDeleteResult.raw_resultrGcCs|d|jddS) The number of documents deleted. deleted_countrIr)r rUrKrrrrrWs zDeleteResult.deleted_count)r?rTr r r r r#)r rTrR) rr&r'r(r)rrr*r?rWr8rrr1rrSs  rScseZdZdZdZdfd d Zdd d ZedddZedddZ edddZ edddZ edddZ edddZ ZS)_BulkWriteResultBasez.Private base class for bulk write API results.)Z__bulk_api_resultbulk_api_resultdict[str, Any]r r r r cr.r)%_BulkWriteResultBase__bulk_api_resultr0rrrYr r1rrrr2z_BulkWriteResultBase.__init__rcCr3r4)rrr[r rrrrrrDz_BulkWriteResultBase.__repr__cCr")zThe raw bulk write API result.)r[rrrrrYr6z$_BulkWriteResultBase.bulk_api_resultrGcC|dtt|jdS)z!The number of documents inserted.inserted_countZ nInsertedr rrGr[rKrrrrr^ z#_BulkWriteResultBase.inserted_countcCr])z.The number of documents matched for an update.rHZnMatchedr_rrrrrHr`z"_BulkWriteResultBase.matched_countcCr])rLrMrNr_rrrrrMr`z#_BulkWriteResultBase.modified_countcCs8|dd|jvrtt|jdStt|jdS)rVrWZnRemovedZnDeleted)r r[rrGrKrrrrrWs  z"_BulkWriteResultBase.deleted_countcCr])z!The number of documents upserted.upserted_countZ nUpsertedr_rrrrrar`z#_BulkWriteResultBase.upserted_countrYrZr r r r r#)r rZrR)rr&r'r(r)rrr*rYr^rHrMrWrar8rrr1rrXs"      rXcs>eZdZdZdZdfd d Zdd d ZedddZZ S)BulkWriteResultz>An object wrapper for collection-level bulk write API results.rrYrZr r r r cst||dS)a@Create a BulkWriteResult instance. :param bulk_api_result: A result dict from the collection-level bulk write API :param acknowledged: Was this write result acknowledged? If ``False`` then all properties of this object will raise :exc:`~pymongo.errors.InvalidOperation`. N)r0rr\r1rrr szBulkWriteResult.__init__rcCr3r4)rrrYr rrrrrr5zBulkWriteResult.__repr__Optional[dict[int, Any]]cCs(|d|jrdd|jdDSdS)z=A map of operation index to the _id of the upserted document. upserted_idscSsi|] }|d|dqS)indexrPr).0Zupsertrrr sz0BulkWriteResult.upserted_ids..rON)r rYrrrrres zBulkWriteResult.upserted_idsrbr#)r rd) rr&r'r(r)rrr*rer8rrr1rrcs rccsreZdZdZdZdfd d Zdd dZdddZed ddZ ed!ddZ ed"ddZ ed#ddZ Z S)$ClientBulkWriteResultz:An object wrapper for client-level bulk write API results.)Z__has_verbose_resultsrYMutableMapping[str, Any]r r has_verbose_resultsr r cs||_t||dS)aUCreate a ClientBulkWriteResult instance. :param bulk_api_result: A result dict from the client-level bulk write API :param acknowledged: Was this write result acknowledged? If ``False`` then all properties of this object will raise :exc:`~pymongo.errors.InvalidOperation`. :param has_verbose_results: Should the returned result be verbose? If ``False``, then the ``insert_results``, ``update_results``, and ``delete_results`` properties of this object will raise :exc:`~pymongo.errors.InvalidOperation`. N)+_ClientBulkWriteResult__has_verbose_resultsr0r)rrYr rkr1rrr&s zClientBulkWriteResult.__init__rcCsd|jj|j|j|jS)Nz%{}({!r}, acknowledged={}, verbose={}))formatrrrYr rkrrrrr=s zClientBulkWriteResult.__repr__rcCr)zARaise an exception on property access if verbose results are off.rzv is not available when the results are not set to be verbose. Check the verbose_results attribute to avoid this error.N)rlrrrrr_raise_if_not_verboseEr!z+ClientBulkWriteResult._raise_if_not_verbosecCr")z/Whether the returned results should be verbose.)rlrrrrrkNr6z)ClientBulkWriteResult.has_verbose_resultsMapping[int, InsertOneResult]cC.|d|dttttf|jdS)z:A map of successful insertion operations to their results.insert_resultsZ insertResults)r rnrrrGr,rYrKrrrrrqS    z$ClientBulkWriteResult.insert_resultsMapping[int, UpdateResult]cCrp)z7A map of successful update operations to their results.update_resultsZ updateResults)r rnrrrGr=rYrKrrrrrt]rrz$ClientBulkWriteResult.update_resultsMapping[int, DeleteResult]cCrp)z7A map of successful delete operations to their results.delete_resultsZ deleteResults)r rnrrrGrSrYrKrrrrrvgrrz$ClientBulkWriteResult.delete_results)rYrjr r rkr r r r#r$r%)r ro)r rs)r ru)rr&r'r(r)rrrnr*rkrqrtrvr8rrr1rri!s      riN)r( __future__rtypingrrrrrZpymongo.errorsrr r,r9r=rSrXrcrirrrrs  )C3