Add query support

1 files changed, 96 insertions, 0 deletions

diff --git a/odb/mysql/query.cxx b/odb/mysql/query.cxx
new file mode 100644
index 0000000..1a2003a
--- /dev/null
+++ b/odb/mysql/query.cxx
@@ -0,0 +1,96 @@
+// file      : odb/mysql/query.cxx
+// author    : Boris Kolpackov <boris@codesynthesis.com>
+// copyright : Copyright (c) 2009-2010 Code Synthesis Tools CC
+// license   : GNU GPL v2; see accompanying LICENSE file
+
+#include <cstddef> // std::size_t
+#include <cstring> // std::memset
+
+#include <odb/mysql/query.hxx>
+
+using namespace std;
+
+namespace odb
+{
+  namespace mysql
+  {
+    // query_param
+    //
+    query_param::
+    ~query_param ()
+    {
+    }
+
+    query::
+    query (const query& q)
+        : clause_ (q.clause_),
+          parameters_ (q.parameters_),
+          binding_ (q.binding_)
+    {
+    }
+
+    query& query::
+    operator= (const query& q)
+    {
+      if (this != &q)
+      {
+        clause_ = q.clause_;
+        parameters_ = q.parameters_;
+        binding_ = q.binding_;
+      }
+
+      return *this;
+    }
+
+    void query::
+    add (shared_ptr<query_param> p)
+    {
+      clause_ += '?';
+
+      parameters_.push_back (p);
+      binding_.push_back (MYSQL_BIND ());
+      MYSQL_BIND* b (&binding_.back ());
+      memset (b, 0, sizeof (MYSQL_BIND));
+
+      if (!p->reference ())
+        p->bind (b);
+    }
+
+    MYSQL_BIND* query::
+    parameters () const
+    {
+      size_t n (parameters_.size ());
+
+      if (n == 0)
+        return 0;
+
+      MYSQL_BIND* b (const_cast<MYSQL_BIND*> (&binding_[0]));
+
+      for (size_t i (0); i < n; ++i)
+      {
+        query_param& p (*parameters_[i]);
+
+        if (p.reference ())
+        {
+          p.init ();
+          p.bind (b + i);
+        }
+      }
+
+      return b;
+    }
+
+    std::string query::
+    clause () const
+    {
+      if (clause_.empty () ||
+          clause_.compare (0, 6, "WHERE ") == 0 ||
+          clause_.compare (0, 9, "ORDER BY ") == 0 ||
+          clause_.compare (0, 9, "GROUP BY ") == 0 ||
+          clause_.compare (0, 7, "HAVING ") == 0)
+        return clause_;
+      else
+        return "WHERE " + clause_;
+    }
+  }
+}