o KDi@sddlmZddlZddlmZmZmZddlmZddl m Z ddl m Z ddl mZer:ddlmZdd lmZGd d d ejZGd d d ejZGdddejZdddZdddZdS)) annotationsN) TYPE_CHECKINGAnycast)fields)is_iterable_but_not_string)inspect) NoResultFound)DeclarativeMeta)MapperPropertycseZdZdfdd ZZS) RelatedListNcsttj|j|||dS)N)accessor)superrList get_value)selfobjattrr  __class__V/var/www/Datamplify/venv/lib/python3.10/site-packages/marshmallow_sqlalchemy/fields.pyrszRelatedList.get_valueN)__name__ __module__ __qualname__r __classcell__rrrrr sr cseZdZdZddiZ  ddfd d Zed d dZed!ddZeddZ eddZ eddZ ddZ ddZ ddZZS)"Relateda~Related data represented by a SQLAlchemy `relationship`. Must be attached to a `Schema ` class whose options includes a SQLAlchemy `model`, such as `SQLAlchemySchema `. :param columns: Optional column names on related model. If not provided, the primary key(s) of the related model will be used. invalidzWCould not deserialize related value {value!r}; expected a dictionary with keys {keys!r}Ncolumnslist[str] | str | Nonecolumn str | Nonec sH|durtjdtdd|dur|}tjdi|t|pg|_dS)Nz_`column` parameter is deprecated and will be removed in future releases. Use `columns` instead.) stacklevelr)warningswarnDeprecationWarningr__init__ ensure_listr)rrr!kwargsrrrr('szRelated.__init__returntype[DeclarativeMeta] | NonecCs|jdur td|jjjS)Nz4Cannot access model before field is bound to schema.)root RuntimeErroroptsmodelrrrrr09s  z Related.modeltype[DeclarativeMeta]cCsF|jdur tdt|jtd|jp|j}t|dr|j}|jj j S)NzNz(Related.related_keys..)rrr=get_primary_keysr1rrAr related_keysJs  zRelated.related_keyscC|jjSr)r-sessionr1rrrrHQzRelated.sessioncCrGr)r- transientr1rrrrJUrIzRelated.transientcs4fdd|jD}t|dkr|Stt|S)Ncsi|] }|jt|jdqSr)keyr5r@propvaluerr Zsz&Related._serialize..)rFlennextitervalues)rrOrrretrrNr _serializeYs zRelated._serializecOst|ts$t|jdkrdd|jD}|jd||d|jdj|i}|jr/|jdi|Sz ||j|}W|St yJ|jdi|YSw) aDeserialize a serialized value to a model instance. If the parent schema is transient, create a new (transient) instance. Otherwise, attempt to find an existing instance in the database. :param value: The value to deserialize. rQcSg|]}|jqSrrKrLrrrrCfz(Related._deserialize..rrOkeysrNr) isinstancedictrRrF make_errorrKrJr=_get_existing_instancer )rrOargsr*r\resultrrr _deserialize]s  zRelated._deserializec s|jr|j|jd ifdd|jD}|Sfdd|jD}z |j||}WntyK}zdd|jD}|jd|d|d}~ww|durRt |S) a Retrieve the related object from an existing instance in the DB. :param related_model: The related model to query :param value: The serialized value to mapto an existing instance. :raises NoResultFound: if there is no matching record. csi|] }|j|jqSr)rKgetrLrNrrrP~sz2Related._get_existing_instance..csg|]}|jqSr)rdrKrLrNrrrCsz2Related._get_existing_instance..cSrXrrYrLrrrrCrZrr[Nr) rrHquery filter_byrFonerd TypeErrorr_r )rr=rOrb lookup_valueserrorr\rrNrr`ss( zRelated._get_existing_instance)NN)rr r!r")r+r,)r+r2)rrr__doc__default_error_messagesr(r9r0r=rFrHrJrWrcr`rrrrrrs(      rcs eZdZdZfddZZS)Nestedz7Nested field that inherits the session from its parent.cs6t|jdr|jj|j_|jj|j_tj|i|S)NrH)r8schemar-rHrJrrc)rrar*rrrrcs   zNested._deserialize)rrrrkrcrrrrrrmsrmr0r2r+list[MapperProperty]cs|jfddjDS)zaGet primary key properties for a SQLAlchemy model. :param model: SQLAlchemy model class csg|]}|qSr)get_property_by_columnr?r:rrrCrDz$get_primary_keys..) __mapper__ primary_key)r0rrqrrEsrErOrlistcCst|rt|S|gSr)rrtrNrrrr)sr))r0r2r+ro)rOrr+rt) __future__rr%typingrrr marshmallowrmarshmallow.utilsr sqlalchemyrsqlalchemy.orm.excr sqlalchemy.ext.declarativer sqlalchemy.ormr rr FieldrrmrEr)rrrrs        v