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/mysqldb.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/mysqldb.py')
| -rw-r--r-- | lib/sqlalchemy/dialects/mysql/mysqldb.py | 11 |
1 files changed, 11 insertions, 0 deletions
diff --git a/lib/sqlalchemy/dialects/mysql/mysqldb.py b/lib/sqlalchemy/dialects/mysql/mysqldb.py index 535c8ec52..7554d244c 100644 --- a/lib/sqlalchemy/dialects/mysql/mysqldb.py +++ b/lib/sqlalchemy/dialects/mysql/mysqldb.py @@ -101,6 +101,17 @@ class MySQLDialect_mysqldb(MySQLDialect): def dbapi(cls): return __import__('MySQLdb') + def do_ping(self, dbapi_connection): + try: + dbapi_connection.ping(False) + except self.dbapi.Error as err: + if self.is_disconnect(err, dbapi_connection, None): + return False + else: + raise + else: + return True + def do_executemany(self, cursor, statement, parameters, context=None): rowcount = cursor.executemany(statement, parameters) if context is not None: |