File: //opt/cloudlinux/venv/lib/python3.11/site-packages/sqlalchemy/orm/__pycache__/sync.cpython-311.pyc
�
� h� � �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�_columntoproperty�manager�key�impl�getr � PASSIVE_OFFr �UnmappedColumnError�_raise_col_to_prop�set� primary_key�
references)�source�
source_mapper�dest� dest_mapper�synchronize_pairs� uowcommit�flag_cascaded_pks� source_dict� dest_dict�l�r�prop�value�errs �H/opt/cloudlinux/venv/lib/python3.11/site-packages/sqlalchemy/orm/sync.py�populater$ s� � � �+�K�� �I�!� B� B���1� M� �2�1�5�D��N�4�8�,�1�5�5�� �Z�%;�� �E�E�� �&� M� M� M� �u�m�Q� �Q�� L� L� L� L� L� L� L� L����� M���� L� �0��3�D� �L��� "� '� +� +�D�)�U�D� I� I� I� I���&� L� L� L� �t�]�A�{�A�s� K� K� K� K� K� K� K� K����� L����
� B��
� B� �
� B� � � �Q��� B� >B�I� �-��q�!9� :��9 B� Bs0 �AA � B �+B�B �
:C�C5�C0�0C5c
�. � |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� I���1� O� �2�1�5�D� ���)�E�E���&� O� O� O� �u�m�Q�
�q�#� N� N� N� N� N� N� N� N����� O���� I� �2�1�5�D�$)�K��� !� !���&� I� I� I� �t�]�A�}�a� H� H� H� H� H� I���� I� Is& �$�A�A � A�A-�-"B�Bc
�` � |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_set�AssertionError� state_str�_set_state_attr_by_columnr r r )r r r r r r" s r# �clearr/ N s� � �!� C� C���1�
�M� ��5�5�d�D�I�q�I�I��%�&� &� !�.�23�!�!�X�5G��5M�5M�5M�5M�O�� �
� C� � 1� 1�$�� �1�d� K� K� K� K���&� C� C� C� �t�T�1�k�1�c� B� B� B� B� B� B� B� B����� C����C� 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_column�objr) r r r r r r r )
r r r �
old_prefixr r r �oldvaluer! r" s
r# �updater7 ` s� � �!� ,� ,���1� F�$�B�B��
�
� � �a�� �H� "�;�;��� �Q�
�0F� <� � �E�E�� �&� F� F� F� �u�m�Q��a�� E� E� E� E� E� E� E� E����� F������Q�U� �#+��Z�!�%�
� � � ,� ,s �AA�B�)B�Bc
�� � |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� <� � �E�E�� �&� F� F� F� �u�m�Q��a�� E� E� E� E� E� E� E� E����� F���� ��a�e� � � � s �(2�A �A�A 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_INITIALIZE�bool�deleted) r r r r r r r r" �historys r# �source_modifiedrA { s� � �
"� � ���1� F� �2�1�5�D�D���&� F� F� F� �u�m�Q��a�� E� E� E� E� E� E� E� E����� F�����1�1� �D�H�j� >�
�
�� ��� � � ��4�4� � �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# �<module>rL s� ��� �
� � � � � � � � � � � � � � � � � � � � � � � �(B� (B� (B�V
I�
I�
I� C� C� C�$ ,� ,� ,� � � �� � �&
�
�
�
�
rH