diff options
| author | Maxim Bublis <satori@dropbox.com> | 2018-07-02 12:34:32 -0400 |
|---|---|---|
| committer | Mike Bayer <mike_mp@zzzcomputing.com> | 2018-07-09 17:59:20 -0400 |
| commit | bd3255760b24bf9f3772415afd2e87c7a12a91e6 (patch) | |
| tree | f580e7f25400b6909d71e94058d6a1c9ac20200f /lib/sqlalchemy/dialects/mysql/pymysql.py | |
| parent | 284009683d9e48e19cc09e740e7b928c2c02997c (diff) | |
| download | sqlalchemy-bd3255760b24bf9f3772415afd2e87c7a12a91e6.tar.gz | |
Use MySQL protocol-level ping.
Utilizes MySQL protocol-level pings for disconnection detection.
This is just a 5-byte packet followed by a 7-byte response.
Affects MySQLdb, MySQL Connector and PyMySQL dialects.
Change-Id: I672f75e3746878d88987a31750444dde0cf8eb9b
Pull-request: https://github.com/zzzeek/sqlalchemy/pull/460
Diffstat (limited to 'lib/sqlalchemy/dialects/mysql/pymysql.py')
| -rw-r--r-- | lib/sqlalchemy/dialects/mysql/pymysql.py | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/lib/sqlalchemy/dialects/mysql/pymysql.py b/lib/sqlalchemy/dialects/mysql/pymysql.py index 4f1c792f9..5f176cef2 100644 --- a/lib/sqlalchemy/dialects/mysql/pymysql.py +++ b/lib/sqlalchemy/dialects/mysql/pymysql.py @@ -61,6 +61,14 @@ class MySQLDialect_pymysql(MySQLDialect_mysqldb): def dbapi(cls): return __import__('pymysql') + def is_disconnect(self, e, connection, cursor): + if super(MySQLDialect_pymysql, self).is_disconnect(e, connection, cursor): + return True + elif isinstance(e, self.dbapi.Error): + return "Already closed" in str(e) + else: + return False + if py3k: def _extract_error_code(self, exception): if isinstance(exception.args[0], Exception): |