a [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} Wn8tj yx} zt d|| || | WYd} ~ n d} ~ 00z(|j| } |j| jj ||| dWn8tj y} zt d|| || | WYd} ~ n d} ~ 00|r| j r| j r| | rd|jd|| f<qdS)NFTZ pk_cascaded)dict_columntopropertymanagerkeyimplgetr PASSIVE_OFFrUnmappedColumnError_raise_col_to_propset primary_keyZ references attributes)source source_mapperdest dest_mappersynchronize_pairs uowcommitZflag_cascaded_pks source_dictZ dest_dictlrpropvalueerrra/var/www/html/cobodadashboardai.evdpl.com/venv/lib/python3.9/site-packages/sqlalchemy/orm/sync.pypopulates0   ( (r!c Cs|D]\}}z|j|}||j}Wn8tjy\}ztd|||||WYd}~n d}~00z|j|}|||j<Wqtjy}ztd|||||WYd}~qd}~00qdS)NFT)rr rrr)rrrrrrrrrrr bulk_populate_inherit_keysAs  ( r"c Cs|D]\}}|jrJ|||j|tjvrJtd|d|dt|dz|||j|dWqtj y}zt dd||||WYd}~qd}~00qdS)NzDependency rule on column 'z)' tried to blank-out primary key column 'z' on instance ''T) r_get_state_attr_by_columnrorm_utilZ _none_setAssertionError state_strZ_set_state_attr_by_columnrrr)rrrrrrrrr clearQs$ r(c Cs|D]\}}z*|||}|j||j|tjd}Wn8tjyn} ztd||d|| WYd} ~ n d} ~ 00|||j <||||j <qdSN)ZpassiveF) Z_get_committed_attr_by_columnobjr$rrr rrrr ) rrrZ old_prefixrrrZoldvaluerrrrr updatecs  ( r+c Csp|D]f\}}z|j||j|tjd}Wn8tjy^}ztd||d||WYd}~n d}~00|||j<qdSr))r$rrr rrrr )rrZdict_rrrrrrrr populate_dictrs  (r,c Cs||D]r\}}z|j|}Wn8tjyR}ztd||d||WYd}~n d}~00|||jtj}t|j rdSqdS)zpreturn true if the source object has changes from an old to a new value on the given synchronize pairs FNT) rrrrZget_attribute_historyr rZPASSIVE_NO_INITIALIZEboolZdeleted) rrrrrrrrhistoryrrr source_modified~s (  r/cCs4|rtd||f|ntd|||f|dS)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)ZisdestrZ source_columnrZ dest_columnrrrr rsrN)__doc__ __future__rrrr%baserr!r"r(r+r,r/rrrrr  s    +