后台服务在运行时发现一个问题,运行约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断开重连
免责声明:本站文章均来自网站采集或用户投稿,网站不提供任何软件下载或自行开发的软件! 如有用户或公司发现本站内容信息存在侵权行为,请邮件告知! 858582#qq.com
《魔兽世界》大逃杀!60人新游玩模式《强袭风暴》3月21日上线
暴雪近日发布了《魔兽世界》10.2.6 更新内容,新游玩模式《强袭风暴》即将于3月21 日在亚服上线,届时玩家将前往阿拉希高地展开一场 60 人大逃杀对战。
艾泽拉斯的冒险者已经征服了艾泽拉斯的大地及遥远的彼岸。他们在对抗世界上最致命的敌人时展现出过人的手腕,并且成功阻止终结宇宙等级的威胁。当他们在为即将于《魔兽世界》资料片《地心之战》中来袭的萨拉塔斯势力做战斗准备时,他们还需要在熟悉的阿拉希高地面对一个全新的敌人──那就是彼此。在《巨龙崛起》10.2.6 更新的《强袭风暴》中,玩家将会进入一个全新的海盗主题大逃杀式限时活动,其中包含极高的风险和史诗级的奖励。
《强袭风暴》不是普通的战场,作为一个独立于主游戏之外的活动,玩家可以用大逃杀的风格来体验《魔兽世界》,不分职业、不分装备(除了你在赛局中捡到的),光是技巧和战略的强弱之分就能决定出谁才是能坚持到最后的赢家。本次活动将会开放单人和双人模式,玩家在加入海盗主题的预赛大厅区域前,可以从强袭风暴角色画面新增好友。游玩游戏将可以累计名望轨迹,《巨龙崛起》和《魔兽世界:巫妖王之怒 经典版》的玩家都可以获得奖励。
更新日志
- 小骆驼-《草原狼2(蓝光CD)》[原抓WAV+CUE]
- 群星《欢迎来到我身边 电影原声专辑》[320K/MP3][105.02MB]
- 群星《欢迎来到我身边 电影原声专辑》[FLAC/分轨][480.9MB]
- 雷婷《梦里蓝天HQⅡ》 2023头版限量编号低速原抓[WAV+CUE][463M]
- 群星《2024好听新歌42》AI调整音效【WAV分轨】
- 王思雨-《思念陪着鸿雁飞》WAV
- 王思雨《喜马拉雅HQ》头版限量编号[WAV+CUE]
- 李健《无时无刻》[WAV+CUE][590M]
- 陈奕迅《酝酿》[WAV分轨][502M]
- 卓依婷《化蝶》2CD[WAV+CUE][1.1G]
- 群星《吉他王(黑胶CD)》[WAV+CUE]
- 齐秦《穿乐(穿越)》[WAV+CUE]
- 发烧珍品《数位CD音响测试-动向效果(九)》【WAV+CUE】
- 邝美云《邝美云精装歌集》[DSF][1.6G]
- 吕方《爱一回伤一回》[WAV+CUE][454M]





