from ..defaults import get_default_db_uri
from .tables import metadata
+from .multilang import MultilangSession, MultilangScopedSession
def connect(uri=None, session_args={}, engine_args={}, engine_prefix=''):
# If we didn't get a uri, fall back to the default
if uri is None:
- uri = engine_args[engine_prefix + 'url']
+ uri = engine_args.get(engine_prefix + 'url', None)
if uri is None:
uri = get_default_db_uri()
all_session_args = dict(autoflush=True, autocommit=False, bind=engine)
all_session_args.update(session_args)
- sm = orm.sessionmaker(**all_session_args)
- session = orm.scoped_session(sm)
+ sm = orm.sessionmaker(class_=MultilangSession, **all_session_args)
+ session = MultilangScopedSession(sm)
return session