summaryrefslogtreecommitdiff
path: root/lib/sqlalchemy/pool.py
diff options
context:
space:
mode:
authorJason Kirtland <jek@discorporate.us>2009-07-10 21:48:45 +0000
committerJason Kirtland <jek@discorporate.us>2009-07-10 21:48:45 +0000
commitca4744c1cb0fcd9888a45f50ecbc5b4549f3a637 (patch)
tree96c50a6024815cedf48859cd0d0d14415a9781d3 /lib/sqlalchemy/pool.py
parent910961fccdf9fe6933c56c595c1126df132a31ff (diff)
downloadsqlalchemy-ca4744c1cb0fcd9888a45f50ecbc5b4549f3a637.tar.gz
Implemented recreate() for StaticPool
Diffstat (limited to 'lib/sqlalchemy/pool.py')
-rw-r--r--lib/sqlalchemy/pool.py16
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