o g@spdZddlmZddlmZddlmZddlmZddZ d d Z d d Z d dZ ddZ ddZddZdS)zgprivate module containing functions used for copying data between instances based on join conditions. ) annotations)exc)util) PassiveFlagc Cs |j}|j}|D]{\} } z|j| } |j| jj||tj} Wntj y<} zt d|| || | WYd} ~ nd} ~ wwz|j| } |j| jj ||| dWntj ym} zt d|| || | WYd} ~ nd} ~ ww|r| j r| j r| | rd|jd|| f<qdS)NFT pk_cascaded)dict_columntopropertymanagerkeyimplgetr PASSIVE_OFFrUnmappedColumnError_raise_col_to_propset primary_key references attributes)source source_mapperdest dest_mappersynchronize_pairs uowcommitflag_cascaded_pks source_dict dest_dictlrpropvalueerrr#O/var/www/html/flaskapp/venv/lib/python3.10/site-packages/sqlalchemy/orm/sync.pypopulates<     r%c Cs|D]U\}}z |j|}||j}Wntjy.}ztd|||||WYd}~nd}~wwz |j|}|||j<WqtjyW}ztd|||||WYd}~qd}~wwdS)NFT)r r rrr)rrrrrr r!r"r#r#r$bulk_populate_inherit_keysAs   r&c Cs|D]J\}}|jr%|||j|tjvr%td|d|dt|dz |||j|dWqtj yL}zt dd||||WYd}~qd}~wwdS)NzDependency rule on column 'z)' tried to blank-out primary key column 'z' on instance ''T) r_get_state_attr_by_columnrorm_util _none_setAssertionError state_str_set_state_attr_by_columnrrr)rrrrrr"r#r#r$clearQs( r.c Cs|D]B\}}z|||}|j||j|tjd}Wntjy7} ztd||d|| WYd} ~ nd} ~ ww|||j <||||j <qdSN)passiveF) _get_committed_attr_by_columnobjr(rrrrrrr ) rrr old_prefixrrroldvaluer!r"r#r#r$updatecs    r5c Csp|D]3\}}z |j||j|tjd}Wntjy/}ztd||d||WYd}~nd}~ww|||j<qdSr/)r(rrrrrrr )rrdict_rrrr!r"r#r#r$ populate_dictrs    r7c Cs||D]9\}}z|j|}Wntjy)}ztd||d||WYd}~nd}~ww|||jtj}t|j r;dSqdS)zpreturn true if the source object has changes from an old to a new value on the given synchronize pairs FNT) r rrrget_attribute_historyr rPASSIVE_NO_INITIALIZEbooldeleted) rrrrrrr r"historyr#r#r$source_modified~s   r=cCs.|r td||f|td|||f|)NzCan't execute sync rule for destination column '%s'; mapper '%s' does not map this column. Try using an explicit `foreign_keys` collection which does not include this column (or use a viewonly=True relation).zCan't execute sync rule for source column '%s'; mapper '%s' does not map this column. Try using an explicit `foreign_keys` collection which does not include destination column '%s' (or use a viewonly=True relation).)rr)isdestr source_columnr dest_columnr"r#r#r$rsrN)__doc__ __future__rrrr)baserr%r&r.r5r7r=rr#r#r#r$s    +