From 932cd7a53b3996468fee5cfa63c2b2998dbe971a Mon Sep 17 00:00:00 2001
From: Boris Kolpackov <boris@codesynthesis.com>
Date: Mon, 4 Jul 2011 17:53:47 +0200
Subject: Implement support for database operations callbacks

New object pragma: callback. New test: common/callback. New manual
section: 10.1.4, "callback".
---
 odb/relational/header.hxx | 11 ++++++
 odb/relational/inline.hxx | 90 +++++++++++++++++++++++++++++++++++++++++++++++
 odb/relational/source.hxx |  6 ++--
 3 files changed, 105 insertions(+), 2 deletions(-)

(limited to 'odb/relational')

diff --git a/odb/relational/header.hxx b/odb/relational/header.hxx
index 16c7855..62c2e92 100644
--- a/odb/relational/header.hxx
+++ b/odb/relational/header.hxx
@@ -940,6 +940,16 @@ namespace relational
         // Functions (concrete).
         //
 
+        // callback ()
+        //
+        os << "static void" << endl
+           << "callback (database&, object_type&, callback_event);"
+           <<  endl;
+
+        os << "static void" << endl
+           << "callback (database&, const object_type&, callback_event);"
+           <<  endl;
+
         // persist ()
         //
         os << "static void" << endl
@@ -1090,6 +1100,7 @@ namespace relational
       generate ()
       {
         os << "#include <odb/details/buffer.hxx>" << endl
+           << "#include <odb/details/unused.hxx>" << endl
            << endl;
 
         os << "#include <odb/" << db << "/version.hxx>" << endl
diff --git a/odb/relational/inline.hxx b/odb/relational/inline.hxx
index 856965c..89fc720 100644
--- a/odb/relational/inline.hxx
+++ b/odb/relational/inline.hxx
@@ -13,6 +13,67 @@ namespace relational
 {
   namespace inline_
   {
+    //
+    //
+    struct callback_calls: traversal::class_, virtual context
+    {
+      typedef callback_calls base;
+
+      callback_calls ()
+      {
+        *this >> inherits_ >> *this;
+      }
+
+      callback_calls (callback_calls const&)
+          : root_context (), //@@ -Wextra
+            context ()
+      {
+        *this >> inherits_ >> *this;
+      }
+
+      virtual void
+      traverse (type& c, bool constant)
+      {
+        const_ = constant;
+        traverse (c);
+      }
+
+      virtual void
+      traverse (type& c)
+      {
+        // Ignore transient bases.
+        //
+        if (!c.count ("object"))
+          return;
+
+        if (c.count ("callback"))
+        {
+          string name (c.get<string> ("callback"));
+
+          // In case of the const object, we only generate the call if
+          // there is a const callback.
+          //
+          if (const_)
+          {
+            if (c.count ("callback-const"))
+              os << "static_cast< const " << c.fq_name () << "& > (obj)." <<
+                name << " (e, db);";
+          }
+          else
+            os << "static_cast< " << c.fq_name () << "& > (obj)." <<
+              name << " (e, db);";
+        }
+        else
+          inherits (c);
+      }
+
+    protected:
+      bool const_;
+      traversal::inherits inherits_;
+    };
+
+    //
+    //
     struct class_: traversal::class_, virtual context
     {
       typedef class_ base;
@@ -113,6 +174,32 @@ namespace relational
         if (abst)
           return;
 
+        // callback ()
+        //
+        os << "inline" << endl
+           << "void " << traits << "::" << endl
+           << "callback (database& db, object_type& obj, callback_event e)"
+           <<  endl
+           << "{"
+           << "ODB_POTENTIALLY_UNUSED (db);"
+           << "ODB_POTENTIALLY_UNUSED (obj);"
+           << "ODB_POTENTIALLY_UNUSED (e);"
+           << endl;
+        callback_calls_->traverse (c, false);
+        os << "}";
+
+        os << "inline" << endl
+           << "void " << traits << "::" << endl
+           << "callback (database& db, const object_type& obj, " <<
+          "callback_event e)"
+           << "{"
+           << "ODB_POTENTIALLY_UNUSED (db);"
+           << "ODB_POTENTIALLY_UNUSED (obj);"
+           << "ODB_POTENTIALLY_UNUSED (e);"
+           << endl;
+        callback_calls_->traverse (c, true);
+        os << "}";
+
         // query_type
         //
         if (options.generate_query ())
@@ -164,6 +251,9 @@ namespace relational
 
         */
       }
+
+    private:
+      instance<callback_calls> callback_calls_;
     };
   }
 }
diff --git a/odb/relational/source.hxx b/odb/relational/source.hxx
index 4d2f10a..42d0f9b 100644
--- a/odb/relational/source.hxx
+++ b/odb/relational/source.hxx
@@ -2331,9 +2331,11 @@ namespace relational
              << endl
              << "if (l.locked ())"
              << "{"
+             << "callback (db, obj, callback_event::pre_load);"
              << "init (obj, sts.image (), db);"
              << "load_ (sts, obj);"
              << "sts.load_delayed ();"
+             << "callback (db, obj, callback_event::post_load);"
              << "l.unlock ();"
              << "}"
              << "else" << endl
@@ -2367,9 +2369,11 @@ namespace relational
            << endl
            << "if (l.locked ())"
            << "{"
+           << "callback (db, obj, callback_event::pre_load);"
            << "init (obj, sts.image (), db);"
            << "load_ (sts, obj);"
            << "sts.load_delayed ();"
+           << "callback (db, obj, callback_event::post_load);"
            << "l.unlock ();"
            << "}"
            << "else" << endl
@@ -2689,8 +2693,6 @@ namespace relational
         if (embedded_schema)
           os << "#include <odb/schema-catalog-impl.hxx>" << endl;
 
-        os << "#include <odb/details/unused.hxx>" << endl;
-
         if (options.generate_query ())
           os << "#include <odb/details/shared-ptr.hxx>" << endl;
 
-- 
cgit v1.1