【python】mysql断开重连
2017-11-01 11:06
429 查看
后台服务在运行时发现一个问题,运行约15分钟后,接口请求报错
这个错误提示一般发生在将None赋给多个值,定位问题时发现
如何解决这个问题呢
在分析问题前,先看看Python 数据库的Connection、Cursor两大对象
Connection、Cursor形象比喻
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
execute方法:执行SQL,将结果从数据库获取到客户端
调试代码,将超时时间设置较长
发现并没有生效
使用
直接抛出异常,并没有执行except代码段
打印
抛出异常重新connect是不行的,因为
找到一种方法可以解决问题,在每次连接之前,判断该链接是否有效,pymysql提供的接口是
这个该方法的源码
在每次请求数据库前执行如下代码
不过这样的方式虽然能解决问题,但是感觉相对较low,希望有更好的处理方法
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,希望有更好的处理方法
相关文章推荐
- hibernate dbcp mysql 断开重连
- dbcp基本配置和重连配置 -- mysql 8小时自动断开连接的问题
- python 多线程服务器验证,实现断开重连,信号量解决主线程Ctrl+C不退出问题,多线程打印错行问题
- Mysql网络断开重连问题
- Python Mysql 连接断开错误代码2006
- MySQL之—— 使用Hibernate连接MySQL数据库,MySQL连接超时断开的问题
- python --- mysql启动与基本用法
- mac安装mysql-python和采用MVC的方式操作数据库
- 最新linux下安装mysql-python(转载+部分补充)
- Python中操作MySQL中timestamp时间属性
- 在SAE的Python工程上使用MySQL
- 解决MySQL每隔8小时自动断开连接的问题
- ubuntu安装easy_install命令方法,mysql-python安装时EnvironmentError: mysql_config not found
- Python 連接 MySQL
- mac python 安装mysql(pip install mysql-python)
- python操作mysql
- 【Raspberry pi+python+mysql】红外传感器-发邮件-存数据库
- python访问mysql
- ubuntu python mysql
- python安装MySQL和驱动