gbdZddlmZddlmZddlmZddlmZdZ dZ d Z d Z d Z d Zd Zy)zgprivate module containing functions used for copying data between instances based on join conditions. ) annotations)exc)util) PassiveFlagc |j}|j}|D]\} } |j| } |j| jjj ||t j} |j| } |j| jjj|| d|s| js| js| j| sd|jd|| f<y#tj$r} td|| || | Yd} ~ d} ~ wwxYw#tj$r} td|| || | Yd} ~ d} ~ wwxYw)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_dictlrpropvalueerrs D/opt/hc_python/lib64/python3.12/site-packages/sqlalchemy/orm/sync.pypopulater&s9++K I!1 M 2215DNN488,1155 [%<%<E  L003D LL " ' ' + +D)UD I    Q=AI -q!9 :9"&& M umQ Q L L M&& L t]A{As K K Ls1AC<4AD,<D)D$$D),E?EEc T|D]C\}} |j|}||j} |j|}||j<Ey#tj$r}t d|||||Yd}~Jd}~wwxYw#tj$r}t d|||||Yd}~d}~wwxYw)NFT)r r rrr)rrrr r!r"r#r$s r%bulk_populate_inherit_keysr(As!1 O 2215D)E N 2215D$)K !"&& O umQ q# N N O && N t]A}a M M Ns.A A: A7A22A7:B' B""B'c x|D]\}}|jrU|j||j|tjvr(t d|d|dtj |d |j||j|dy#tj$r}tdd||||Yd}~d}~wwxYw)NzDependency rule on column 'z)' tried to blank-out primary key column 'z' on instance ''T) r_get_state_attr_by_columnr orm_util _none_setAssertionError state_str_set_state_attr_by_columnrrr)rrrr r!r$s r%clearr1Qs!1 MM55dDIIqI%%&!-aS1#_X-?-?-E,FaI   C  1 1$ 1d K"&& C tT1k1c B B Cs+B  B9B44B9c V|D]t\}} |j|j|}|j||j|tj }||j<|||jz<vy#t j$r} td||d|| Yd} ~ Ld} ~ wwxYwN)passiveF) _get_committed_attr_by_columnobjr+r rrrrrr ) rrr old_prefixrr r!oldvaluer#r$s r%updater9cs!1 F$BB aH";; Q 0G0G<E QUU #+Z!%%  "&& F umQa E E FsA A;;B(B##B(c |D]B\}} |j||j|tj}||j<Dy#tj $r}t d||d||Yd}~:d}~wwxYwr3)r+r rrrrrr )rrdict_rr r!r#r$s r% populate_dictr<rs|!1 F!;; Q 0G0G<E aee " && F umQa E E Fs-A  A6A11A6c |D]W\}} |j|}|j |j t j}t|jsWyy#tj$r}td||d||Yd}~md}~wwxYw)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) rrrrr r!r"r$historys r%source_modifiedrC~s "1 F 2215D11 DHHk??   "&& F umQa E E FsAB 1BB c |rtjd|d|d|tjd|d|d|d|)Nz0Can't execute sync rule for destination column 'z '; mapper 'z' does not map this column. Try using an explicit `foreign_keys` collection which does not include this column (or use a viewonly=True relation).z+Can't execute sync rule for source column 'zx' does not map this column. Try using an explicit `foreign_keys` collection which does not include destination column 'z$' (or use a viewonly=True relation).)rr)isdestr source_columnr dest_columnr$s r%rrsT%% -8  F   %% m[  :  N)__doc__ __future__rrrr,baserr&r(r1r9r<rCrrHr%rNs? #(BV N C$ , &rH