圆月山庄资源网 Design By www.vgjia.com
后台服务在运行时发现一个问题,运行约15分钟后,接口请求报错
pymysql.err.InterfaceError: (0, '')
这个错误提示一般发生在将None赋给多个值,定位问题时发现
pymysql.err.OperationalError: (2013, 'Lost connection to MySQL server during query')
如何解决这个问题呢
出现问题的代码
class MysqlConnection(object): """ mysql操作类,对mysql数据库进行增删改查 """ def __init__(self, config): # Connect to the database self.connection = pymysql.connect(**config) self.cursor = self.connection.cursor() def Query(self, sql): """ 查询数据 :param sql: :return: """ self.cursor.execute(sql) return self.cursor.fetchall()
在分析问题前,先看看Python 数据库的Connection、Cursor两大对象
Python 数据库图解流程
Connection、Cursor形象比喻
Connection()的参数列表
- host,连接的数据库服务器主机名,默认为本地主机(localhost)
- user,连接数据库的用户名,默认为当前用户
- passwd,连接密码,没有默认值
- db,连接的数据库名,没有默认值
- conv,将文字映射到Python类型的字典
- cursorclass,cursor()使用的种类,默认值为MySQLdb.cursors.Cursor
- compress,启用协议压缩功能
- named_pipe,在windows中,与一个命名管道相连接
- init_command,一旦连接建立,就为数据库服务器指定一条语句来运行
- read_default_file,使用指定的MySQL配置文件
- read_default_group,读取的默认组
- unix_socket,在unix中,连接使用的套接字,默认使用TCP
- port,指定数据库服务器的连接端口,默认是3306
connection对象支持的方法
Cursor对象支持的方法
用于执行查询和获取结果
execute方法:执行SQL,将结果从数据库获取到客户端
调试代码,将超时时间设置较长
self.connection._write_timeout = 10000
发现并没有生效
使用try...except...
方法捕获失败后重新连接数据库
try: self.cursor.execute(sql) except: self.connection() self.cursor.execute(sql)
直接抛出异常,并没有执行except代码段
打印self.connection
,输出如下:
<pymysql.connections.Connection object at 0x0000000003E2CCC0>
抛出异常重新connect是不行的,因为connections
仍存在未失效
找到一种方法可以解决问题,在每次连接之前,判断该链接是否有效,pymysql提供的接口是 Connection.ping()
这个该方法的源码
def ping(self, reconnect=True): """Check if the server is alive""" if self._sock is None: if reconnect: self.connect() reconnect = False else: raise err.Error("Already closed") try: self._execute_command(COMMAND.COM_PING, "") return self._read_ok_packet() except Exception: if reconnect: self.connect() return self.ping(False) else: raise
在每次请求数据库前执行如下代码
def reConnect(self): try: self.connection.ping() except: self.connection()
不过这样的方式虽然能解决问题,但是感觉相对较low,希望有更好的处理方法
目前已实现的数据库查询这部分的代码
import pymysql class DBManager(object): def __init__(self,config): self.connection = pymysql.connect(**config) # config为数据库登录验证配置信息 self.cursor = self.connection.cursor() def query(self, sql, params): try: with self.connection.cursor() as cursor: cursor.execute(sql, params) result = cursor.fetchall() self.connection.commit() return result # self.connection.close() except Exception as e: traceback.print_exc()
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。
标签:
python,mysql断开重连
圆月山庄资源网 Design By www.vgjia.com
广告合作:本站广告合作请联系QQ:858582 申请时备注:广告合作(否则不回)
免责声明:本站文章均来自网站采集或用户投稿,网站不提供任何软件下载或自行开发的软件! 如有用户或公司发现本站内容信息存在侵权行为,请邮件告知! 858582#qq.com
免责声明:本站文章均来自网站采集或用户投稿,网站不提供任何软件下载或自行开发的软件! 如有用户或公司发现本站内容信息存在侵权行为,请邮件告知! 858582#qq.com
圆月山庄资源网 Design By www.vgjia.com
暂无评论...
更新日志
2024年11月15日
2024年11月15日
- 群星-时尚慢摇DJ舞曲《发烧车载中文天碟-调情》非卖品[WAV]
- 潘美辰.2008-全新重声大碟(出道20年精选纪念版)【倍特音乐】【WAV+CUE】
- 罗时丰.2002-唱歌的人(2011再生版)【贝特音乐】【WAV+CUE】
- 罗时丰.2003-唱歌的人台语精选+新歌【贝特音乐】【WAV+CUE】
- 999PUNKSTA《情绪数码故障》[Hi-Res][24bit 48kHz][FLAC/分轨][301.83MB]
- HOYO-MiX《原神-珍珠之歌4 游戏音乐》[320K/MP3][289.48MB]
- 陈崎凡《CHEN》[320K/MP3][81.13MB]
- skt都在哪一年夺冠 英雄联盟skt夺冠赛季介绍
- 炉石传说抢先体验乱斗什么时候结束 深暗领域体验乱斗结束时间
- 炉石传说抢先乱斗卡组有什么 深暗领域抢先体验乱斗卡组推荐
- 荣耀手机腕上最佳搭档 荣耀手表5首销开启
- 雷克沙ARES 6000 C28战神之翼 AMD 9800X3D超强搭档
- 咪咕快游感恩同游,超值回馈尽在咪咕咪粉节!
- 陈崎凡《CHEN》[FLAC/分轨][326.32MB]
- 群星《我们的歌第六季 第2期》[320K/MP3][74.05MB]