B .`@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}x|D]\} } y(|j| } |j| jj||tj} Wn6tj k rz} zt d|| || | Wdd} ~ XYnXy(|j| } |j| jj ||| dWn6tj k r} zt d|| || | Wdd} ~ XYnX|r| j r| j r| | rd|jd|| f<qWdS)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_dictlrpropvalueerrrB/home/dcms/DCMS/lib/python3.7/site-packages/sqlalchemy/orm/sync.pypopulates&  $ $ rc Csx|D]\}}y|j|}||j}Wn6tjk r\}ztd|||||Wdd}~XYnXy|j|}|||j<Wqtjk rtd||||YqXqWdS)NFT)rr rr r)rrrrrrrrrrrbulk_populate_inherit_keys>s $ r c Csx|D]\}}|jr@|||j|tjkr@td|t|fy|||j|dWqtj k r}zt dd||||Wdd}~XYqXqWdS)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)rrrrrrrrrclearNsr$c Csx|D]\}}y*|||}|j||j|tjd}Wn6tjk rn} ztd||d|| Wdd} ~ XYnX|||j <||||j <qWdS)N)passiveF) Z_get_committed_attr_by_columnobjr!rrr rr rr ) rrrZ old_prefixrrrZoldvaluerrrrrupdate`s $ r'c Csrxl|D]d\}}y|j||j|tjd}Wn6tjk r^}ztd||d||Wdd}~XYnX|||j<qWdS)N)r%F)r!rrr rr rr )rrZdict_rrrrrrrr populate_dictos$r(c Csxz|D]n\}}y|j|}Wn6tjk rR}ztd||d||Wdd}~XYnX|||jtj}t|j rdSqWdSdS)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+cCsD|r"tjtd||f|dntjtd|||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+rrrrr s    +