Remove terminated connections from the pool.

In pymssql, if you terminate a long running query manually
it will give you a connection reset by peer message, but this
connection remains in the pool and will be re-used.

diff --git a/lib/sqlalchemy/dialects/mssql/pymssql.py b/lib/sqlalchemy/dialects/mssql/pymssql.py
index b916612fbe1926d4bf17638f9f5e2bc9c9df3c10..471d54f8413b52c09facda7707a0546ddffee94c 100644 (file)
--- a/lib/sqlalchemy/dialects/mssql/pymssql.py
+++ b/lib/sqlalchemy/dialects/mssql/pymssql.py
@@ -86,6 +86,7 @@ class MSDialect_pymssql(MSDialect):
     def is_disconnect(self, e, connection, cursor):
         for msg in (
             "Adaptive Server connection timed out",
+            "Net-Lib error during Connection reset by peer",
             "message 20003",  # connection timeout
             "Error 10054",
             "Not connected to any MS SQL server",

diff --git a/test/dialect/mssql/test_engine.py b/test/dialect/mssql/test_engine.py
index 2834f35ecb1e0ba7542f0c9ad45790c094bbd595..c07f30040515941e21cfd3cf0b26db827722b085 100644 (file)
--- a/test/dialect/mssql/test_engine.py
+++ b/test/dialect/mssql/test_engine.py
@@ -131,10 +131,11 @@ class ParseConnectTest(fixtures.TestBase):
 
         for error in [
                 'Adaptive Server connection timed out',
+                'Net-Lib error during Connection reset by peer',
                 'message 20003',
-                "Error 10054",
-                "Not connected to any MS SQL server",
-                "Connection is closed"
+                'Error 10054',
+                'Not connected to any MS SQL server',
+                'Connection is closed'
                 ]:
             eq_(dialect.is_disconnect(error, None, None), True)