diff options
Diffstat (limited to 'lib/sqlalchemy')
-rw-r--r-- | lib/sqlalchemy/engine/default.py | 7 | ||||
-rw-r--r-- | lib/sqlalchemy/exceptions.py | 4 |
2 files changed, 9 insertions, 2 deletions
diff --git a/lib/sqlalchemy/engine/default.py b/lib/sqlalchemy/engine/default.py index bf023e319..f0ffd7797 100644 --- a/lib/sqlalchemy/engine/default.py +++ b/lib/sqlalchemy/engine/default.py @@ -24,7 +24,12 @@ class PoolConnectionProvider(base.ConnectionProvider): dbapi = dialect.dbapi() if dbapi is None: raise exceptions.InvalidRequestError("Cant get DBAPI module for dialect '%s'" % dialect) - self._pool = poolclass(lambda: dbapi.connect(*cargs, **cparams), **kwargs) + def connect(): + try: + return dbapi.connect(*cargs, **cparams) + except Exception, e: + raise exceptions.DBAPIError("Connection failed", e) + self._pool = poolclass(connect, **kwargs) else: if isinstance(pool, sqlalchemy.pool.DBProxy): self._pool = pool.get_pool(*cargs, **cparams) diff --git a/lib/sqlalchemy/exceptions.py b/lib/sqlalchemy/exceptions.py index 6aeca3efc..c803a06c3 100644 --- a/lib/sqlalchemy/exceptions.py +++ b/lib/sqlalchemy/exceptions.py @@ -49,4 +49,6 @@ class AssertionError(SQLAlchemyError): class DBAPIError(SQLAlchemyError): """something weird happened with a particular DBAPI version""" - pass + def __init__(self, message, orig): + SQLAlchemyError.__init__(self, "(%s) (%s) %s"% (message, orig.__class__.__name__, str(orig))) + self.orig = orig |