added invalidate() method to connectionfairy, allows the connection to be removed...

diff --git a/lib/sqlalchemy/pool.py b/lib/sqlalchemy/pool.py
index 5ab8ba57888cf19b17a92129aa6e9143ba0853e2..eb3073a5f4bcf6bde03b00731457a1ca8b6f4024 100644 (file)
--- a/lib/sqlalchemy/pool.py
+++ b/lib/sqlalchemy/pool.py
@@ -134,6 +134,9 @@ class ConnectionFairy(object):
                 self.connection = None
                 self.pool.return_invalid()
                 raise
+    def invalidate(self):
+        self.connection = None
+        self.pool.return_invalid()
     def cursor(self):
         return CursorFairy(self, self.connection.cursor())
     def __getattr__(self, key):