o
    g                     @  sp   d Z ddlmZ ddlmZ ddlmZ ddlmZ dd Z	d	d
 Z
dd Zdd Zdd Zdd Zdd ZdS )zgprivate module containing functions used for copying data
between instances based on join conditions.

    )annotations   )exc)util)PassiveFlagc                 C  s  | j }|j }|D ]{\}	}
z|j|	 }| j|j j| |tj}W n tj	y< } zt
d||	||
| W Y d }~nd }~ww z|j|
 }|j|j j|||d  W n tj	ym } zt
d||	||
| W Y d }~nd }~ww |r|	jr|
jr|
|	rd|jd||
f< qd S )NFTpk_cascaded)dict_columntopropertymanagerkeyimplgetr   PASSIVE_OFFr   UnmappedColumnError_raise_col_to_propsetprimary_key
references
attributes)sourcesource_mapperdestdest_mappersynchronize_pairs	uowcommitflag_cascaded_pkssource_dict	dest_dictlrpropvalueerr r#   U/var/www/html/ecg_monitoring/venv/lib/python3.10/site-packages/sqlalchemy/orm/sync.pypopulate   s<   	

	r%   c                 C  s   |D ]U\}}z|j | }| |j }W n tjy. } ztd||||| W Y d }~nd }~ww z|j | }|| |j< W q tjyW } ztd||||| W Y d }~qd }~ww d S )NFT)r	   r   r   r   r   )r   r   r   r   r   r    r!   r"   r#   r#   r$   bulk_populate_inherit_keysA   s    

r&   c                 C  s   |D ]J\}}|j r%|| | j|tjvr%td| d| dt|  dz|| | j|d  W q tj	yL } zt
dd |||| W Y d }~qd }~ww d S )NzDependency rule on column 'z)' 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"   r#   r#   r$   clearQ   s(   r.   c           
      C  s   |D ]B\}}z| |  |}|j| | j|tjd}W n tjy7 }	 ztd||d ||	 W Y d }	~	nd }	~	ww |||j	< ||||j	 < q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"   r#   r#   r$   updatec   s   

r5   c                 C  sp   |D ]3\}}z|j | | j|tjd}W n tjy/ } ztd||d || W Y d }~nd }~ww |||j< qd S r/   )r(   r   r   r   r   r   r   r   )r   r   dict_r   r   r   r!   r"   r#   r#   r$   populate_dictr   s   
r7   c           	      C  s|   |D ]9\}}z|j | }W n tjy) } ztd||d|| W Y d}~nd}~ww | ||jtj}t|j	r; dS qdS )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"   historyr#   r#   r$   source_modified~   s   

r=   c                 C  s.   | rt d||f |t d|||f |)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).zCan'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).)r   r   )isdestr   source_columnr   dest_columnr"   r#   r#   r$   r      s   r   N)__doc__
__future__r    r   r   r)   baser   r%   r&   r.   r5   r7   r=   r   r#   r#   r#   r$   <module>   s   	+