#
# Copyright (c) 2006-2013, Prometheus Research, LLC
#

from ...core.context import context
from ...core.connect import Connect
from ...core.adapter import rank

class SQLAlchemyConnect(Connect):
    """ override normal connection with one from SQLAlchemy """

    rank(2.0) # ensure connections here are not pooled

    def open(self):
        sqlalchemy_engine = context.app.tweak.sqlalchemy.engine
        if sqlalchemy_engine:
            wrapper = sqlalchemy_engine.connect() \
                      .execution_options(autocommit=self.with_autocommit)
            # wrapper.connection is a proxied DBAPI connection
            # that is in the SQLAlchemy connection pool.
            return wrapper.connection
        return super(SQLAlchemyConnect, self).open()



#
# Copyright (c) 2006-2013, Prometheus Research, LLC
#

from ...core.context import context
from ...core.connect import Connect
from ...core.adapter import rank

class SQLAlchemyConnect(Connect):
    """ override normal connection with one from SQLAlchemy """

    rank(2.0) # ensure connections here are not pooled

    def open(self):
        sqlalchemy_engine = context.app.tweak.sqlalchemy.engine
        if sqlalchemy_engine:
            wrapper = sqlalchemy_engine.connect() \
                      .execution_options(autocommit=self.with_autocommit)
            # wrapper.connection is a proxied DBAPI connection
            # that is in the SQLAlchemy connection pool.
            return wrapper.connection
        return super(SQLAlchemyConnect, self).open()



# # Copyright (c) 2006-2013, Prometheus Research, LLC # override normal connection with one from SQLAlchemy # ensure connections here are not pooled # wrapper.connection is a proxied DBAPI connection # that is in the SQLAlchemy connection pool.