attempting to catch OperationalErrors and invalidate the connection

diff --git a/lib/sqlalchemy/engine.py b/lib/sqlalchemy/engine.py
index 482aa4270ea6ff3eada43538d41701418abddda1..d4f01f174cd573b89d89bf17d6798bfcf305af8c 100644 (file)
--- a/lib/sqlalchemy/engine.py
+++ b/lib/sqlalchemy/engine.py
@@ -686,6 +686,9 @@ class SQLEngine(schema.SchemaEngine):
                 parameters = {}
         try:
             c.execute(statement, parameters)
+        except self.dbapi().OperationalError, e:
+            c.parent.invalidate()
+            raise exceptions.SQLError(statement, parameters, e)
         except Exception, e:
             raise exceptions.SQLError(statement, parameters, e)
         self.context.rowcount = c.rowcount