1 files changed, 83 insertions, 0 deletions
diff --git a/libodb/odb/database.cxx b/libodb/odb/database.cxx
new file mode 100644
index 0000000..9e098c7
--- /dev/null
+++ b/libodb/odb/database.cxx
@@ -0,0 +1,83 @@
+// file      : odb/database.cxx
+// license   : GNU GPL v2; see accompanying LICENSE file
+
+#include <odb/database.hxx>
+
+#include <odb/details/lock.hxx>
+
+using namespace std;
+
+namespace odb
+{
+  using details::lock;
+
+  database::
+  ~database ()
+  {
+  }
+
+  unsigned long long database::
+  execute (const char* st, std::size_t n)
+  {
+    connection_type& c (transaction::current ().connection (*this));
+    return c.execute (st, n);
+  }
+
+  const database::schema_version_migration_type& database::
+  schema_version_migration (const string& name) const
+  {
+    lock l (*mutex_); // Prevents concurrent loading.
+
+    schema_version_map::const_iterator i (schema_version_map_.find (name));
+    return i != schema_version_map_.end () && i->second.version != 0
+      ? i->second
+      : load_schema_version (name);
+  }
+
+  void database::
+  schema_version_migration (const schema_version_migration_type& svm,
+                            const string& name)
+  {
+    // Note: no lock, not thread-safe.
+
+    schema_version_info& svi (schema_version_map_[name]);
+    if (svi.version != svm.version || svi.migration != svm.migration)
+    {
+      svi.version = svm.version;
+      svi.migration = svm.migration;
+      schema_version_seq_++;
+    }
+  }
+
+  bool database::
+  call_query_factory (const char* name, connection_type& c) const
+  {
+    query_factory_map::const_iterator i (query_factory_map_.find (name));
+
+    if (i == query_factory_map_.end ())
+      i = query_factory_map_.find (""); // Wildcard factory.
+
+    if (i == query_factory_map_.end ())
+      return false;
+
+    const query_factory_wrapper& fw (i->second);
+    if (fw.std_function == 0)
+      fw.function (name, c);
+    else
+    {
+      typedef void (*caller) (const void*, const char*, connection_type&);
+      fw.cast<caller> () (fw.std_function, name, c);
+    }
+
+    return true;
+  }
+
+  void database::
+  query_factory (const char* name, query_factory_wrapper w)
+  {
+    if (w)
+      query_factory_map_[name] = w; // Destructive copy assignment (move).
+    else
+      query_factory_map_.erase (name);
+  }
+}