src/ceph/src/brag/server/ceph_brag/model/__init__.py

   1 from sqlalchemy import create_engine
   2 from pecan import conf  # noqa
   3 from .db import Session, Base
   4 import sys
   5
   6 def create_from_conf():
   7     configs = dict(conf.sqlalchemy)
   8     url = configs.pop('url')
   9     return create_engine(url, **configs)
  10
  11 def init_model():
  12     engine = create_from_conf()
  13     conf.sqlalchemy.engine = engine
  14     engine.connect()
  15     #create the tables if not existing
  16     Base.metadata.create_all(engine)
  17
  18 def start():
  19     Session.bind = conf.sqlalchemy.engine
  20
  21 def commit():
  22     Session.commit()
  23
  24 def rollback():
  25     Session.rollback()
  26
  27 def clear():
  28     Session.remove()