Add query support

1 files changed, 14 insertions, 0 deletions

diff --git a/odb/mysql/connection.hxx b/odb/mysql/connection.hxx
index ea94cd0..513abc5 100644
--- a/odb/mysql/connection.hxx
+++ b/odb/mysql/connection.hxx
@@ -41,6 +41,19 @@ namespace odb
         return statement_cache_;
       }
 
+    public:
+      statement*
+      active ()
+      {
+        return active_;
+      }
+
+      void
+      active (statement* s)
+      {
+        active_ = s;
+      }
+
     private:
       connection (const connection&);
       connection& operator= (const connection&);
@@ -48,6 +61,7 @@ namespace odb
     private:
       MYSQL mysql_;
       MYSQL* handle_;
+      statement* active_;
       statement_cache_type statement_cache_;
     };
   }