1 files changed, 60 insertions, 0 deletions
diff --git a/mod/database.cxx b/mod/database.cxx
new file mode 100644
index 0000000..0f0b703
--- /dev/null
+++ b/mod/database.cxx
@@ -0,0 +1,60 @@
+// file      : mod/database.cxx -*- C++ -*-
+// copyright : Copyright (c) 2014-2016 Code Synthesis Ltd
+// license   : MIT; see accompanying LICENSE file
+
+#include <mod/database>
+
+#include <map>
+
+#include <odb/pgsql/database.hxx>
+#include <odb/pgsql/connection-factory.hxx>
+
+namespace brep
+{
+  namespace options
+  {
+    bool
+    operator< (const db& x, const db& y)
+    {
+      int r;
+      if ((r = x.db_user ().compare (y.db_user ())) != 0 ||
+          (r = x.db_password ().compare (y.db_password ())) != 0 ||
+          (r = x.db_name ().compare (y.db_name ())) != 0 ||
+          (r = x.db_host ().compare (y.db_host ())))
+        return r < 0;
+
+      return x.db_port () < y.db_port ();
+    }
+  }
+
+  using namespace odb;
+
+  shared_ptr<database>
+  shared_database (const options::db& o)
+  {
+    static std::map<options::db, weak_ptr<database>> databases;
+
+    auto i (databases.find (o));
+    if (i != databases.end ())
+    {
+      if (shared_ptr<database> d = i->second.lock ())
+        return d;
+    }
+
+    unique_ptr<pgsql::connection_factory>
+      f (new pgsql::connection_pool_factory (o.db_max_connections ()));
+
+    shared_ptr<database> d (
+      make_shared<pgsql::database> (
+        o.db_user (),
+        o.db_password (),
+        o.db_name (),
+        o.db_host (),
+        o.db_port (),
+        "options='-c default_transaction_isolation=serializable'",
+        move (f)));
+
+    databases[o] = d;
+    return d;
+  }
+}