查询期间与MySQL服务器的连接丢失

Question

查询期间与MySQL服务器的连接丢失我有一个巨大的表，我需要处理其中的所有行。我总是得到这个丢失的连接消息，我无法重新连接并将光标恢复到它的最后位置。这基本上就是我在这里的代码：#import MySQLdbclass DB:   conn = None   def connect(self):     self.conn = MySQLdb.connect('hostname', 'user', '*****', 'some_table', cursorclass=MySQLdb.cursors.SSCursor)   def query(self, sql):     try:      cursor = self.conn.cursor()      cursor.execute(sql)    except (AttributeError, MySQLdb.OperationalError):      self.connect()      cursor = self.conn.cursor()      cursor.execute(sql)    return cursor##db = DB()sql = "SELECT bla FROM foo"data = db.query(sql)for row in data:     do_something(row)#但我总是得到这个：#Traceback (most recent call last):   File "teste.py", line 124, in <module>    run()  File "teste.py", line 109, in run   for row in data:  File "/usr/lib64/python2.5/site-packages/MySQLdb/cursors.py", line 417, in next    row = self.fetchone()  File "/usr/lib64/python2.5/site-packages/MySQLdb/cursors.py", line 388, in fetchone    r = self._fetch_row(1)  File "/usr/lib64/python2.5/site-packages/MySQLdb/cursors.py", line 285, in _fetch_row   return self._result.fetch_row(size, self._fetch_type)    _mysql_exceptions.OperationalError: (2013, 'Lost connection to MySQL server during query')     Exception _mysql_exceptions.OperationalError: (2013, 'Lost connection to MySQL server during query') in <bound method SSCursor.__del__ of <MySQLdb.cursors.SSCursor object at 0x7f7e3c8da410>> ignored#你有什么主意吗？

Answer 1

扩展mysql服务器的max_allowed_packet有三种方法：

1. 更改mysql服务器计算机上的max_allowed_packet=64M文件/etc/mysql/my.cnf并重新启动服务器

2. 在mysql服务器上执行sql： set global max_allowed_packet=67108864;

3. Python连接到mysql后执行sql：

connection.execute（'set max_allowed_packet = 67108864'）

Answer 2

确保在连接前关闭光标。我用这个解决了我的问题：

if cur and con:                        
    cur.close() 
    con.close()