summaryrefslogtreecommitdiff
path: root/lib/sqlalchemy/orm/persistence.py
diff options
context:
space:
mode:
authorMike Bayer <mike_mp@zzzcomputing.com>2014-12-07 20:21:20 -0500
committerMike Bayer <mike_mp@zzzcomputing.com>2014-12-07 20:21:20 -0500
commitc42b8f8eb8f4c324e2469bf3baaa316c214abce5 (patch)
treea5cde5ef779ccdb306351f0ad9624451ea873bdd /lib/sqlalchemy/orm/persistence.py
parente257ca6c5268517ec2e9a561372d82dfc10475e8 (diff)
downloadsqlalchemy-c42b8f8eb8f4c324e2469bf3baaa316c214abce5.tar.gz
- fix inheritance persistence
- start writing docs
Diffstat (limited to 'lib/sqlalchemy/orm/persistence.py')
-rw-r--r--lib/sqlalchemy/orm/persistence.py15
1 files changed, 9 insertions, 6 deletions
diff --git a/lib/sqlalchemy/orm/persistence.py b/lib/sqlalchemy/orm/persistence.py
index 81024c41f..d94fbb040 100644
--- a/lib/sqlalchemy/orm/persistence.py
+++ b/lib/sqlalchemy/orm/persistence.py
@@ -49,7 +49,7 @@ def _bulk_insert(
continue
records = (
- (None, state_dict, params, super_mapper,
+ (None, state_dict, params, mapper,
connection, value_params, has_all_pks, has_all_defaults)
for
state, state_dict, params, mp,
@@ -918,7 +918,7 @@ def _finalize_insert_update_commands(base_mapper, uowtransaction, states):
def _postfetch(mapper, uowtransaction, table,
- state, dict_, result, params, value_params):
+ state, dict_, result, params, value_params, bulk=False):
"""Expire attributes in need of newly persisted database state,
after an INSERT or UPDATE statement has proceeded for that
state."""
@@ -954,10 +954,13 @@ def _postfetch(mapper, uowtransaction, table,
# TODO: this still goes a little too often. would be nice to
# have definitive list of "columns that changed" here
for m, equated_pairs in mapper._table_to_equated[table]:
- sync.populate(state, m, state, m,
- equated_pairs,
- uowtransaction,
- mapper.passive_updates)
+ if state is None:
+ sync.bulk_populate_inherit_keys(dict_, m, equated_pairs)
+ else:
+ sync.populate(state, m, state, m,
+ equated_pairs,
+ uowtransaction,
+ mapper.passive_updates)
def _connections_for_states(base_mapper, uowtransaction, states):