我有一个很大的表,需要处理其中的所有行。我总是收到丢失连接的消息,并且我无法重新连接并将光标恢复到上次的位置。这基本上就是我这里的代码:
#
import MySQLdb
class 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
#
你有什么想法吗?
发布于 2012-03-07 22:51:24
确保在连接前关闭游标。我已经解决了我的问题:
if cur and con:
cur.close()
con.close()
发布于 2009-12-11 07:40:51
您需要增加连接的超时时间。如果你因为某些原因不能或不想这样做,你可以试着调用:
data = db.query(sql).store_result()
这将立即获取所有结果,这样您的连接就不会在迭代它们的过程中超时。
发布于 2014-02-24 06:23:30
这发生在我的mariadb上,因为我把一个varchar(255)
专栏变成了一个unique key
。我猜这对于唯一的来说太重了,因为插入超时了。
https://stackoverflow.com/questions/1884859
复制相似问题