o h@ @spdZddlmZddlmZmZmZmZmZddl m Z m Z ddl m Z er,ddlmZdddZdddZdS)zRConstants, types, and classes shared across Client Bulk Write API implementations.) annotations) TYPE_CHECKINGAnyMappingMutableMappingNoReturn)ClientBulkWriteExceptionOperationFailure) _get_wce_doc) _DocumentOutops#list[tuple[str, Mapping[str, Any]]]offsetint full_resultMutableMapping[str, Any]resultMapping[str, Any]returnNonec Cs|dr |d|d<|d|dd7<|d|dd7<|d|dd7<|d|dd7<|d|dd7<|d}|rp|D]}|}|d |}||d <||d |d <|d|qPt|}|r|d |d Sd S)z?Merge result of a single bulk write batch into the full result.errorZ nInsertedrZnDeletedZnMatchedZ nModifiedZ nUpserted writeErrorsidxopZwriteConcernErrorsN)getcopyappendr ) r rrrZ write_errorsdoc replacementZoriginal_indexZwcer N/var/www/html/venv/lib/python3.10/site-packages/pymongo/_client_bulk_shared.py_merge_commands&    r"r verbose_resultsboolrcCs|dr-|djddd|dd}|d}|d}|dkr-|d r-d }t|||t|d trBsz4_throw_client_bulk_write_exception..)keyrcodeerrmsgzTransaction numberszrThis MongoDB deployment does not support retryable writes. Please add retryWrites=false to your connection string.r)sort startswithr isinstance BaseExceptionr)rr#errr'msgr(r r r!"_throw_client_bulk_write_exception<s   r0N) r r rrrrrrrr)rr r#r$rr)__doc__ __future__rtypingrrrrrZpymongo.errorsrr Zpymongo.helpers_sharedr Zpymongo.typingsr r"r0r r r r!s