File: //opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/orm/sync.pyc
�
���ec @ s� d Z d d l m Z d d l m Z d d l m Z d d l m Z d � Z d � Z d � Z d � Z d
� Z
d � Z d � Z d
S( sg private module containing functions used for copying data
between instances based on join conditions.
i ( t
attributes( t exc( t utili c C s; | j } | j } x"| D]\ } }
y6 | j | } | j | j j j | | t j � } Wn/ t j k
r� }
t
t | | | |
|
� n Xy4 | j |
} | j | j j j | | | d � Wn/ t j k
r� }
t
t | | | |
|
� n X| r | j r |
j r |
j | � r t | j d | |
f <q q Wd S( Nt pk_cascaded( t dictt _columntopropertyt managert keyt implt getR t PASSIVE_OFFR t UnmappedColumnErrort _raise_col_to_propt Falset sett Nonet Truet primary_keyt
references( t sourcet
source_mappert destt dest_mappert synchronize_pairst uowcommitt flag_cascaded_pkst source_dictt dest_dictt lt rt propt valuet err( ( sD /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/orm/sync.pyt populate s&
' c C s� x� | D]� \ } } y | j | } | | j } Wn/ t j k
rb } t t | | | | | � n Xy | j | } | | | j <Wq t j k
r� t t | | | | � q Xq Wd S( N( R R R R R R
R ( R R R R R R R R ( ( sD /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/orm/sync.pyt bulk_populate_inherit_keys> s
c C s� x� | D]� \ } } | j r_ | j | | j | � t j k r_ t d | t j | � f � � n y | j | | j | d � Wq t j
k
r� } t t d | | | | � q Xq Wd S( NsK Dependency rule tried to blank-out primary key column '%s' on instance '%s'(
R t _get_state_attr_by_columnR t orm_utilt _none_sett AssertionErrort state_strt _set_state_attr_by_columnR R R R R ( R R R R R R ( ( sD /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/orm/sync.pyt clearN s c
C s� x� | D]� \ } } y= | j | j � | � } | j | | j | d t j �} Wn/ t j k
r� } t t | | d | | � n X| | | j <| | | | j <q Wd S( Nt passive( t _get_committed_attr_by_columnt objR# R R R
R R R R
R R (
R R R t
old_prefixR R R t oldvalueR R ( ( sD /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/orm/sync.pyt update` s
c C s xx | D]p \ } } y% | j | | j | d t j �} Wn/ t j k
ri } t t | | d | | � n X| | | j <q Wd S( NR* (
R# R R R
R R R R
R R ( R R t dict_R R R R R ( ( sD /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/orm/sync.pyt
populate_dicto s c C s� x� | D]} \ } } y | j | } Wn/ t j k
rU } t t | | d | | � n X| j | | j t j � } t
| j � r t Sq Wt Sd S( sp return true if the source object has changes from an old to a
new value on the given synchronize pairs
N(
R R R R R
R t get_attribute_historyR R t PASSIVE_NO_INITIALIZEt boolt deletedR ( R R R R R R R R t history( ( sD /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/orm/sync.pyt source_modified{ s c C s\ | r/ t j t j d | | f � d | �n) t j t j d | | | f � d | �d S( Ns� Can'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).t replace_contexts� Can'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 t raise_R R ( t isdestR t
source_columnR t dest_columnR ( ( sD /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/orm/sync.pyR � s
N(
t __doc__t R R R R$ R! R" R) R/ R1 R7 R ( ( ( sD /opt/alt/python27/lib/python2.7/site-packages/sqlalchemy/orm/sync.pyt <module> s +