X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fceph%2Fsrc%2Fbrag%2Fserver%2Fceph_brag%2Fmodel%2F__init__.py;fp=src%2Fceph%2Fsrc%2Fbrag%2Fserver%2Fceph_brag%2Fmodel%2F__init__.py;h=ad1a942245f0fe4480c59aadbb7a01d0c978815a;hb=812ff6ca9fcd3e629e49d4328905f33eee8ca3f5;hp=0000000000000000000000000000000000000000;hpb=15280273faafb77777eab341909a3f495cf248d9;p=stor4nfv.git

diff --git a/src/ceph/src/brag/server/ceph_brag/model/__init__.py b/src/ceph/src/brag/server/ceph_brag/model/__init__.py
new file mode 100644
index 0000000..ad1a942
--- /dev/null
+++ b/src/ceph/src/brag/server/ceph_brag/model/__init__.py
@@ -0,0 +1,28 @@
+from sqlalchemy import create_engine
+from pecan import conf  # noqa
+from .db import Session, Base
+import sys
+
+def create_from_conf():
+    configs = dict(conf.sqlalchemy)
+    url = configs.pop('url')
+    return create_engine(url, **configs)
+
+def init_model():
+    engine = create_from_conf()
+    conf.sqlalchemy.engine = engine
+    engine.connect()
+    #create the tables if not existing
+    Base.metadata.create_all(engine)
+
+def start():
+    Session.bind = conf.sqlalchemy.engine
+
+def commit():
+    Session.commit()
+
+def rollback():
+    Session.rollback()
+
+def clear():
+    Session.remove()