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.)__acknowledged acknowledgedboolreturnNonecCs ||_dSN_WriteResult__acknowledged)selfr rK/var/www/html/olx_land/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 rr rrrr rr 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`. ) __inserted_id inserted_idrr r r rc||_t|dSr)_InsertOneResult__inserted_idsuperr)rr/r rrrrJzInsertOneResult.__init__rcC|jjd|jd|jdSNrz, acknowledged=r)rrr1r rrrrrNzInsertOneResult.__repr__cCr#)zThe inserted document's _id.)r1rrrrr/SzInsertOneResult.inserted_id)r/rr r r rr$r r) rr'r(r)r*rrr+r/ __classcell__rrr3rr-Cs r-cr,)InsertManyResultzGThe return type for :meth:`~pymongo.collection.Collection.insert_many`.)__inserted_ids inserted_ids list[Any]r r r rcr0r)_InsertManyResult__inserted_idsr2r)rr=r r3rrr^r4zInsertManyResult.__init__rcCr5r6)rrr?r rrrrrbr7zInsertManyResult.__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 rr$)r r>) rr'r(r)r*rrr+r=r:rrr3rr;Ys r;cszeZdZdZdZ 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_result__in_client_bulkF raw_resultOptional[Mapping[str, Any]]r r in_client_bulkcs||_||_t|dSr)_UpdateResult__raw_result_UpdateResult__in_client_bulkr2r)rrCr rEr3rrrszUpdateResult.__init__r rcCr5r6)rrrFr rrrrrzUpdateResult.__repr__cCr#z/The raw result document returned by the server.rFrrrrrCr8zUpdateResult.raw_resultintcCs:|d|jdus J|js|jdurdS|jddS)z0The number of documents matched for this update. matched_countNrn)r!rFrG upserted_idgetrrrrrLs zUpdateResult.matched_countcCs*|d|jdus Jtt|jdS)!The number of documents modified.modified_countN nModified)r!rFrrKrOrrrrrQs zUpdateResult.modified_countrcCsF|d|jdus J|jr|jdr|jddS|jddS)z^The _id of the inserted document if an upsert took place. Otherwise ``None``. rNNupserted_id)r!rFrGrOrrrrrNs zUpdateResult.upserted_idcCs|jdusJd|jvS)zEWhether an upsert took place. .. versionadded:: 4.9 NrSrJrrrr did_upserts zUpdateResult.did_upsert)F)rCrDr r rEr r$)r rDr rKr9r&)rr'r(r)r*rrr+rCrLrQrNrUr:rrr3rr@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`. )rArCMapping[str, Any]r r r rcr0r)_DeleteResult__raw_resultr2r)rrCr r3rrrr4zDeleteResult.__init__rcCr5r6)rrrYr rrrrrrHzDeleteResult.__repr__cCr#rI)rYrrrrrCr8zDeleteResult.raw_resultrKcCs|d|jddS) The number of documents deleted. deleted_countrMr)r!rYrOrrrrr[s zDeleteResult.deleted_count)rCrXr r r rr$)r rXrV) rr'r(r)r*rrr+rCr[r:rrr3rrWs  rWcseZdZdZdZdfd d Zdd d ZedddZedddZ edddZ edddZ edddZ edddZ ZS)_BulkWriteResultBasez.Private base class for bulk write API results.)__bulk_api_resultbulk_api_resultdict[str, Any]r r r rcr0r)%_BulkWriteResultBase__bulk_api_resultr2rrr^r r3rrrr4z_BulkWriteResultBase.__init__rcCr5r6)rrr`r rrrrrrHz_BulkWriteResultBase.__repr__cCr#)zThe raw bulk write API result.)r`rrrrr^r8z$_BulkWriteResultBase.bulk_api_resultrKcC|dtt|jdS)z!The number of documents inserted.inserted_count nInsertedr!rrKr`rOrrrrrc z#_BulkWriteResultBase.inserted_countcCrb)z.The number of documents matched for an update.rLnMatchedrerrrrrLrfz"_BulkWriteResultBase.matched_countcCrb)rPrQrRrerrrrrQrfz#_BulkWriteResultBase.modified_countcCs8|dd|jvrtt|jdStt|jdS)rZr[nRemovednDeleted)r!r`rrKrOrrrrr[s  z"_BulkWriteResultBase.deleted_countcCrb)z!The number of documents upserted.upserted_count nUpsertedrerrrrrjrfz#_BulkWriteResultBase.upserted_countr^r_r r r rr$)r r_rV)rr'r(r)r*rrr+r^rcrLrQr[rjr:rrr3rr\s"      r\cs>eZdZdZdZdfd d Zdd d ZedddZZ S)BulkWriteResultz>An object wrapper for collection-level bulk write API results.rr^r_r r r rcst||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)r2rrar3rrr szBulkWriteResult.__init__rcCr5r6)rrr^r rrrrrr7zBulkWriteResult.__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)indexrTr).0upsertrrr sz0BulkWriteResult.upserted_ids..rSN)r!r^rrrrros zBulkWriteResult.upserted_idsrlr$)r rn) rr'r(r)r*rrr+ror:rrr3rrms rmcsreZdZdZdZdfd d Zdd dZdddZed ddZ ed!ddZ ed"ddZ ed#ddZ Z S)$ClientBulkWriteResultz:An object wrapper for client-level bulk write API results.)__has_verbose_resultsr^MutableMapping[str, Any]r r has_verbose_resultsr rcs||_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_resultsr2r)rr^r rwr3rrr&s zClientBulkWriteResult.__init__rcCsd|jj|j|j|jS)Nz%{}({!r}, acknowledged={}, verbose={}))formatrrr^r rwrrrrr=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)rxrr rrr_raise_if_not_verboseEr"z+ClientBulkWriteResult._raise_if_not_verbosecCr#)z/Whether the returned results should be verbose.)rxrrrrrwNr8z)ClientBulkWriteResult.has_verbose_resultsMapping[int, InsertOneResult]cC.|d|dttttf|jdS)z:A map of successful insertion operations to their results.insert_results insertResults)r!rzrrrKr-r^rOrrrrr}S    z$ClientBulkWriteResult.insert_resultsMapping[int, UpdateResult]cCr|)z7A map of successful update operations to their results.update_results updateResults)r!rzrrrKr@r^rOrrrrr]rz$ClientBulkWriteResult.update_resultsMapping[int, DeleteResult]cCr|)z7A map of successful delete operations to their results.delete_results deleteResults)r!rzrrrKrWr^rOrrrrrgrz$ClientBulkWriteResult.delete_results)r^rvr r rwr r rr$r%r&)r r{)r r)r r)rr'r(r)r*rrrzr+rwr}rrr:rrr3rrt!s      rtN)r) __future__rtypingrrrrrpymongo.errorsrr r-r;r@rWr\rmrtrrrrs  )C3