diff options
| author | Jason Kirtland <jek@discorporate.us> | 2009-07-10 21:48:45 +0000 |
|---|---|---|
| committer | Jason Kirtland <jek@discorporate.us> | 2009-07-10 21:48:45 +0000 |
| commit | ca4744c1cb0fcd9888a45f50ecbc5b4549f3a637 (patch) | |
| tree | 96c50a6024815cedf48859cd0d0d14415a9781d3 /lib/sqlalchemy/pool.py | |
| parent | 910961fccdf9fe6933c56c595c1126df132a31ff (diff) | |
| download | sqlalchemy-ca4744c1cb0fcd9888a45f50ecbc5b4549f3a637.tar.gz | |
Implemented recreate() for StaticPool
Diffstat (limited to 'lib/sqlalchemy/pool.py')
| -rw-r--r-- | lib/sqlalchemy/pool.py | 16 |
1 files changed, 13 insertions, 3 deletions
diff --git a/lib/sqlalchemy/pool.py b/lib/sqlalchemy/pool.py index 2eabd8572..c4e1af20c 100644 --- a/lib/sqlalchemy/pool.py +++ b/lib/sqlalchemy/pool.py @@ -706,15 +706,16 @@ class NullPool(Pool): def dispose(self): pass - + + class StaticPool(Pool): """A Pool of exactly one connection, used for all requests. - + Reconnect-related functions such as ``recycle`` and connection invalidation (which is also used to support auto-reconnect) are not currently supported by this Pool implementation but may be implemented in a future release. - + """ def __init__(self, creator, **params): @@ -754,6 +755,15 @@ class StaticPool(Pool): self._conn.close() self._conn = None + def recreate(self): + self.log("Pool recreating") + return self.__class__(creator=self._creator, + recycle=self._recycle, + use_threadlocal=self._use_threadlocal, + reset_on_return=self._reset_on_return, + echo=self.echo, + listeners=self.listeners) + def create_connection(self): return self._conn |
