P> d d Z ddlmZ ddlmZ ddlmZ ddlmZ d Zd Zd Zd Z d
Z
d Z d Z d
S )zgprivate module containing functions used for copying data
between instances based on join conditions.
)
attributes)exc)util c
\ | j }|j }|D ]\ } }
|j | } | j | j j | |t j } n0# t j $ r }
t d|| ||
|
Y d }
~
nd }
~
ww xY w |j |
} |j | j j ||| d n0# t j $ r }
t d|| ||
|
Y d }
~
nd }
~
ww xY w|r0| j r)|
j r"|
| r
d|j d||
f< d S )NFT pk_cascaded)dict_columntopropertymanagerkeyimplgetr PASSIVE_OFFr UnmappedColumnError_raise_col_to_propset primary_key
references)source
source_mapperdest dest_mappersynchronize_pairs uowcommitflag_cascaded_pks source_dict dest_dictlrpropvalueerrs g/builddir/build/BUILD/cloudlinux-venv-1.0.10/venv/lib64/python3.11/site-packages/sqlalchemy/orm/sync.pypopulater$ s +K I! B B1 M 215DN48,155 Z%; EE & M M M umQ Q L L L L L L L L M L 03D L " ' + +D)UD I I I I& L L L t]A{As K K K K K K K K L
B
B
B Q B >BI -q!9 :9 B Bs0 AA B +BB
:CC5C00C5c
. |D ]\ }} |j | }| |j }n0# t j $ r }t d||||| Y d }~nd }~ww xY w |j | }|| |j < j# t j $ r t d|||| Y w xY wd S )NFT)r
r r r r )r r r r r r r! r" s r# bulk_populate_inherit_keysr& > s ! I I1 O 215D )EE& O O O umQ
q# N N N N N N N N O I 215D$)K ! !& I I I t]A}a H H H H H I I Is& $AA AA--"BBc
` |D ]\ }}|j rP| | | j | t j vr(t d|dt j | d | | | j |d {# t j $ r }t dd |||| Y d }~d }~ww xY wd S )Nz7Dependency rule 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_columnr r r )r r r r r r" s r# clearr/ N s ! C C1
M 55dDIqII%& & !.23!!X5G5M5M5M5MO
C 1 1$ 1d K K K K& C C C tT1k1c B B B B B B B B CC Cs A>>B+
B&&B+c
H |D ]\ }} | | | }| | | j |t j }n0# t j $ r } t d||d || Y d } ~ nd } ~ ww xY w|||j < ||||j z < d S N)passiveF)
_get_committed_attr_by_columnobjr) r r r r r r r )
r r r
old_prefixr r r oldvaluer! r" s
r# updater7 ` s ! , ,1 F$BB
a H ";; Q
0F < EE & F F F umQa E E E E E E E E FQU #+Z!%
, ,s AAB)BBc
|D ]i\ }} | | | j |t j }n0# t j $ r }t
d||d || Y d }~nd }~ww xY w|||j < jd S r1 )r) r r r r r r r )r r dict_r r r r! r" s r#
populate_dictr: o s ! 1 F!;; Q
0F < EE & F F F umQa E E E E E E E E F ae s (2A AA c
|D ]\ }} |j | }n0# t j $ r }t d||d|| Y d}~nd}~ww xY w| ||j t j }t |j r dS dS )zpreturn true if the source object has changes from an old to a
new value on the given synchronize pairs
FNT)
r
r r r get_attribute_historyr r PASSIVE_NO_INITIALIZEbooldeleted) r r r r r r r r" historys r# source_modifiedrA { s
" 1 F 215DD& F F F umQa E E E E E E E E F11 DHj >
44 us
A?Ac | r1t j t j d|d|d | d S t j t j d|d|d|d | d S )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).)replace_contextz+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).)r raise_r r )isdestr
source_columnr dest_columnr" s r# r r s
# #
1< [[[ J
# # !==--- >
N)
__doc__ r r r r* r$ r& r/ r7 r: rA r rH r# rL s
(B (B (BV
I
I
I C C C$ , , , &
rH