summaryrefslogtreecommitdiff
path: root/lib/sqlalchemy/orm/sync.py
diff options
context:
space:
mode:
authorDiana Clarke <diana.joan.clarke@gmail.com>2012-11-19 14:56:11 -0500
committerDiana Clarke <diana.joan.clarke@gmail.com>2012-11-19 14:56:11 -0500
commit655e0b4de28841339a8aae5491225e5473e3ef8a (patch)
tree582ff6715aa4d4b8f3d18fe98ca5a0f56c97b184 /lib/sqlalchemy/orm/sync.py
parent03687b36b78be86c0f2a01eeb658c5b52fbd6c76 (diff)
downloadsqlalchemy-655e0b4de28841339a8aae5491225e5473e3ef8a.tar.gz
just a pep8 pass of lib/sqlalchemy/orm/
Diffstat (limited to 'lib/sqlalchemy/orm/sync.py')
-rw-r--r--lib/sqlalchemy/orm/sync.py23
1 files changed, 16 insertions, 7 deletions
diff --git a/lib/sqlalchemy/orm/sync.py b/lib/sqlalchemy/orm/sync.py
index 2b2f6d092..847bce30e 100644
--- a/lib/sqlalchemy/orm/sync.py
+++ b/lib/sqlalchemy/orm/sync.py
@@ -11,6 +11,7 @@ between instances based on join conditions.
from . import exc, util as orm_util, attributes
+
def populate(source, source_mapper, dest, dest_mapper,
synchronize_pairs, uowcommit, flag_cascaded_pks):
source_dict = source.dict
@@ -42,38 +43,45 @@ def populate(source, source_mapper, dest, dest_mapper,
r.references(l):
uowcommit.attributes[("pk_cascaded", dest, r)] = True
+
def clear(dest, dest_mapper, synchronize_pairs):
for l, r in synchronize_pairs:
if r.primary_key:
raise AssertionError(
- "Dependency rule tried to blank-out primary key "
- "column '%s' on instance '%s'" %
- (r, orm_util.state_str(dest))
- )
+ "Dependency rule tried to blank-out primary key "
+ "column '%s' on instance '%s'" %
+ (r, orm_util.state_str(dest))
+ )
try:
dest_mapper._set_state_attr_by_column(dest, dest.dict, r, None)
except exc.UnmappedColumnError:
_raise_col_to_prop(True, None, l, dest_mapper, r)
+
def update(source, source_mapper, dest, old_prefix, synchronize_pairs):
for l, r in synchronize_pairs:
try:
- oldvalue = source_mapper._get_committed_attr_by_column(source.obj(), l)
- value = source_mapper._get_state_attr_by_column(source, source.dict, l)
+ oldvalue = source_mapper._get_committed_attr_by_column(
+ source.obj(), l)
+ value = source_mapper._get_state_attr_by_column(
+ source, source.dict, l)
except exc.UnmappedColumnError:
_raise_col_to_prop(False, source_mapper, l, None, r)
dest[r.key] = value
dest[old_prefix + r.key] = oldvalue
+
def populate_dict(source, source_mapper, dict_, synchronize_pairs):
for l, r in synchronize_pairs:
try:
- value = source_mapper._get_state_attr_by_column(source, source.dict, l)
+ value = source_mapper._get_state_attr_by_column(
+ source, source.dict, l)
except exc.UnmappedColumnError:
_raise_col_to_prop(False, source_mapper, l, None, r)
dict_[r.key] = value
+
def source_modified(uowcommit, source, source_mapper, synchronize_pairs):
"""return true if the source object has changes from an old to a
new value on the given synchronize pairs
@@ -90,6 +98,7 @@ def source_modified(uowcommit, source, source_mapper, synchronize_pairs):
else:
return False
+
def _raise_col_to_prop(isdest, source_mapper, source_column,
dest_mapper, dest_column):
if isdest: