aboutsummaryrefslogtreecommitdiff
path: root/odb/pgsql
diff options
context:
space:
mode:
authorBoris Kolpackov <boris@codesynthesis.com>2013-01-09 14:50:26 +0200
committerBoris Kolpackov <boris@codesynthesis.com>2013-01-16 07:42:55 +0200
commit424b08e7e843498923b3c55e576c11cdf4f2e158 (patch)
treee9bebcfa3765f13d81f76af3b71715e49572a2c9 /odb/pgsql
parent8f95d4f75660b58b84f6a3b8ffe9a9900498b002 (diff)
Implement two-phase session insertion
On the first step an uninitialized object is inserted into the cache as before (this is necessary to handle recursive loading). The second step is to notify the session that the object has been initialized. On this second step the session can perform change tracking preparations, such as make a copy of the object or reset the modification flag. New test: common/session/custom (implements a custom session that uses copies to track changes).
Diffstat (limited to 'odb/pgsql')
-rw-r--r--odb/pgsql/polymorphic-object-result.txx1
-rw-r--r--odb/pgsql/simple-object-statements.txx11
2 files changed, 5 insertions, 7 deletions
diff --git a/odb/pgsql/polymorphic-object-result.txx b/odb/pgsql/polymorphic-object-result.txx
index daea20e..e968b82 100644
--- a/odb/pgsql/polymorphic-object-result.txx
+++ b/odb/pgsql/polymorphic-object-result.txx
@@ -153,6 +153,7 @@ namespace odb
ce = callback_event::post_load;
pi.dispatch (info_type::call_callback, this->db_, pobj, &ce);
+ object_traits::pointer_cache_traits::initialize (ig.position ());
ig.release ();
}
diff --git a/odb/pgsql/simple-object-statements.txx b/odb/pgsql/simple-object-statements.txx
index fe9fe9b..c9eda09 100644
--- a/odb/pgsql/simple-object-statements.txx
+++ b/odb/pgsql/simple-object-statements.txx
@@ -108,7 +108,7 @@ namespace odb
while (!dls.empty ())
{
delayed_load l (dls.back ());
- typename pointer_cache_traits::insert_guard g (l.pos);
+ typename pointer_cache_traits::insert_guard ig (l.pos);
dls.pop_back ();
if (l.loader == 0)
@@ -144,7 +144,8 @@ namespace odb
else
l.loader (db, l.id, *l.obj);
- g.release ();
+ pointer_cache_traits::initialize (ig.position ());
+ ig.release ();
}
}
@@ -152,11 +153,7 @@ namespace odb
void object_statements<T>::
clear_delayed_ ()
{
- // Remove the objects from the session cache. This is not the most
- // efficient way to do this (cache_traits::erase() will check for
- // a session on every iteration), but the delay vector won't be
- // empty only if something goes wrong (i.e., we are throwing an
- // exception).
+ // Remove the objects from the session cache.
//
for (typename delayed_loads::iterator i (delayed_.begin ()),
e (delayed_.end ()); i != e; ++i)