python MySQL连接

2024-03-29 10:08:44 发布

您现在位置:Python中文网/ 问答频道 /正文

我正在用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的缓冲连接,但这不是一个好的选择,因为我的表有多大!在


Tags: inpyconnectorpackageslinelibrarymysqlsite
3条回答

在查询中限制100。在

query = ("..."),  //limit 100 here

然后使用fetchall()而不是fetchmany(100)

这是^{}的记录行为:

^{bq}$

要解决此问题,您可以建立一个新的连接供write_cursor使用:

cnx_write = mysql.connector.connect(...)
write_cursor = cnx_write.cursor()

我在线程时也遇到了类似的问题,只需要在每个线程中分别关闭和打开一个新的连接。。。而不是让连接打开。在

相关问题 更多 >