o [h@spdZddlmZddlmZddlmZddlmZddZdd Zd d Zd d Z ddZ ddZ ddZ dS)zgprivate module containing functions used for copying data between instances based on join conditions. ) attributes)exc)utilc 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)NFTZ pk_cascaded)dict_columntopropertymanagerkeyimplgetr PASSIVE_OFFrUnmappedColumnError_raise_col_to_propset primary_keyZ references)source source_mapperdest dest_mappersynchronize_pairs uowcommitZflag_cascaded_pks source_dictZ dest_dictlrpropvalueerrrz/home/ubuntu/experiments/live_experiments/Pythonexperiments/Otree/venv/lib/python3.10/site-packages/sqlalchemy/orm/sync.pypopulates<     rc Cs|D]K\}}z |j|}||j}Wntjy.}ztd|||||WYd}~nd}~wwz |j|}|||j<WqtjyMtd||||YqwdS)NFT)rr rr r)rrrrrrrrrrrbulk_populate_inherit_keys>s   r c Cs|D]D\}}|jr|||j|tjvrtd|t|fz |||j|dWqtj yF}zt dd||||WYd}~qd}~wwdS)NzKDependency rule tried to blank-out primary key column '%s' on instance '%s'T) r_get_state_attr_by_columnrorm_utilZ _none_setAssertionErrorZ state_strZ_set_state_attr_by_columnrr r)rrrrrrrrrclearNs$  r$c Cs|D]B\}}z|||}|j||j|tjd}Wntjy7} ztd||d|| WYd} ~ nd} ~ ww|||j <||||j <qdSN)ZpassiveF) Z_get_committed_attr_by_columnobjr!rrr rr rr ) rrrZ old_prefixrrrZoldvaluerrrrrupdate`s    r'c Csp|D]3\}}z |j||j|tjd}Wntjy/}ztd||d||WYd}~nd}~ww|||j<qdSr%)r!rrr rr rr )rrZdict_rrrrrrrr populate_dictos    r(c 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) rrr rZget_attribute_historyr rZPASSIVE_NO_INITIALIZEboolZdeleted) rrrrrrrrhistoryrrrsource_modified{s   r+cCsF|rtjtd||f|ddStjtd|||f|ddS)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).)Zreplace_contextzCan'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).)rZraise_rr )ZisdestrZ source_columnrZ dest_columnrrrrrs"   rN) __doc__rrrr"rr r$r'r(r+rrrrrs    +