aboutsummaryrefslogtreecommitdiff
path: root/odb/mysql/view-result.txx
diff options
context:
space:
mode:
authorBoris Kolpackov <boris@codesynthesis.com>2013-09-10 14:10:45 +0200
committerBoris Kolpackov <boris@codesynthesis.com>2013-09-10 14:10:45 +0200
commit0ed9ceef3abbd9f4ff786f6a02fe8767780e8c2c (patch)
tree0bca6f9e302dd92eb4dc9136ab0b826f8fa61aff /odb/mysql/view-result.txx
parent075f64ca84e4e1be22bad30e4974e9b675d12ec8 (diff)
Schema versioning support
Diffstat (limited to 'odb/mysql/view-result.txx')
-rw-r--r--odb/mysql/view-result.txx12
1 files changed, 7 insertions, 5 deletions
diff --git a/odb/mysql/view-result.txx b/odb/mysql/view-result.txx
index 895f3fe..5d4c2e5 100644
--- a/odb/mysql/view-result.txx
+++ b/odb/mysql/view-result.txx
@@ -36,10 +36,12 @@ namespace odb
view_result_impl<T>::
view_result_impl (const query_base&,
details::shared_ptr<select_statement> statement,
- statements_type& statements)
+ statements_type& statements,
+ const schema_version_migration* svm)
: base_type (statements.connection ()),
statement_ (statement),
statements_ (statements),
+ tc_ (svm),
count_ (0)
{
}
@@ -52,7 +54,7 @@ namespace odb
fetch ();
view_traits::callback (this->db_, view, callback_event::pre_load);
- view_traits::init (view, statements_.image (), &this->db_);
+ tc_.init (view, statements_.image (), &this->db_);
view_traits::callback (this->db_, view, callback_event::post_load);
}
@@ -95,7 +97,7 @@ namespace odb
if (im.version != statements_.image_version ())
{
binding& b (statements_.image_binding ());
- view_traits::bind (b.bind, im);
+ tc_.bind (b.bind, im);
statements_.image_version (im.version);
b.version++;
}
@@ -116,13 +118,13 @@ namespace odb
typename view_traits::image_type& im (statements_.image ());
- if (view_traits::grow (im, statements_.image_truncated ()))
+ if (tc_.grow (im, statements_.image_truncated ()))
im.version++;
if (im.version != statements_.image_version ())
{
binding& b (statements_.image_binding ());
- view_traits::bind (b.bind, im);
+ tc_.bind (b.bind, im);
statements_.image_version (im.version);
b.version++;
statement_->refetch ();