force_close...

diff --git a/lib/sqlalchemy/engine/threadlocal.py b/lib/sqlalchemy/engine/threadlocal.py
index 040c6bd9fa1b1f7cfcc7edb3961dc0ac7d644f2b..1d99f9ce88279ab72d1cf78ceb79b91584c9e330 100644 (file)
--- a/lib/sqlalchemy/engine/threadlocal.py
+++ b/lib/sqlalchemy/engine/threadlocal.py
@@ -22,7 +22,7 @@ class TLSession(object):
         self.__tcount += 1
     def reset(self):
         try:
-            self.__transaction.close()
+            self.__transaction._force_close()
             del self.__transaction
             del self.__trans
         except AttributeError:
@@ -71,7 +71,10 @@ class TLConnection(base.Connection):
         if self.__opencount == 1:
             base.Connection.close(self)
         self.__opencount -= 1
-        
+    def _force_close(self):
+        self.__opencount = 0
+        base.Connection.close(self)
+            
 class TLTransaction(base.Transaction):
     def _commit_impl(self):
         base.Transaction.commit(self)