我正在用Python和MySQL玩大数据。在
我有一个巨大的表,我需要在获取查询结果时插入新行。在
我有个错误:
Traceback (most recent call last):
File "recsys.py", line 53, in <module>
write_cursor.executemany(add_sim, data_sims)
File "/Library/Python/2.7/site-packages/mysql/connector/cursor.py", line 603, in executemany
self._connection.handle_unread_result()
File "/Library/Python/2.7/site-packages/mysql/connector/connection.py", line 1057, in handle_unread_result
raise errors.InternalError("Unread result found")
mysql.connector.errors.InternalError: Unread result found
代码如下:
^{pr2}$我知道我可以使用到mysql的缓冲连接,但这不是一个好的选择,因为我的表有多大!在
在查询中限制100。在
然后使用fetchall()而不是fetchmany(100)
这是^{} 的记录行为:
^{bq}$要解决此问题,您可以建立一个新的连接供
write_cursor
使用:我在线程时也遇到了类似的问题,只需要在每个线程中分别关闭和打开一个新的连接。。。而不是让连接打开。在
相关问题 更多 >
编程相关推荐