Python中操作数据库cursor时遇到问题如何解决?

使用 mysql-connector-python 用 cnn = mysql.connector.connect 建立连接之后,创建一个 cursor = cnn.cursor 然后这个 cursor 一直不关闭一直用他去执行 cursor.execute(SELECT) 如果这期间数据库数据发生过了变化,取到的数据是最新的吗? 能具体讲一讲 cursor 在这里面的作用吗.


Python中操作数据库cursor时遇到问题如何解决?
5 回复

不是最新的,曾经写过一个脚本,创建一个 cursor 后一直 for 循环,按序号写入数据库,同时跑了多个进程,跑完后发现数据库出现了大量重复序号。。


帖子回复:

遇到 cursor 问题,先看报错信息。常见问题就几个,我直接给代码例子。

1. 连接没关或游标没关导致资源泄露

import sqlite3

conn = sqlite3.connect('test.db')
cursor = conn.cursor()
try:
    cursor.execute("SELECT * FROM users")
    # ... 处理数据
finally:
    cursor.close()  # 必须关游标
    conn.close()    # 必须关连接

或者用 with 语句自动关:

with sqlite3.connect('test.db') as conn:
    with conn.cursor() as cursor:
        cursor.execute("SELECT * FROM users")
        results = cursor.fetchall()
# 这里自动关闭了

2. 执行查询后忘记取数据

cursor.execute("SELECT * FROM users WHERE id = ?", (user_id,))
row = cursor.fetchone()  # 记得取数据!
if row:
    print(f"用户: {row[1]}")

3. 参数绑定错误

# 错误:直接拼接SQL(有SQL注入风险)
cursor.execute(f"SELECT * FROM users WHERE name = '{name}'")

# 正确:使用参数化查询
cursor.execute("SELECT * FROM users WHERE name = ?", (name,))
# 或者用命名参数
cursor.execute("SELECT * FROM users WHERE name = :name", {'name': name})

4. 事务没提交

cursor.execute("INSERT INTO users (name) VALUES (?)", ('张三',))
conn.commit()  # 增删改操作后必须提交!

5. 游标状态问题

cursor.execute("SELECT * FROM users")
rows = cursor.fetchall()
# 再次使用前如果需要新查询,最好重新获取游标或确保状态正确

调试建议:

  • 打印 cursor.description 看返回字段
  • 检查 cursor.rowcount 看影响行数
  • try-except 捕获具体异常

总结: 大部分游标问题都是资源管理或状态处理不当,用 with 语句能避免很多坑。

这和 Python 没什么关系

游标的作用一是复用链接 类似 mq 在 connect 之上还有一层 channel

还有一个作用是大量数据查询只返回一部分

一直用一个游标查数据是可以的

创建了一个 cursor 以后,建议是以完成一个事务就 commit 一下,不要一直用它,这样一直使用,并不会和数据库完成数据同步,如果操作太多,提交的时候会超时,造成部分数据更新,部分数据丢失,数据不一致,很麻烦,效率也低。

并且你握着 cursor 期间,数据库端发生改变,也没法和你这边同步。

当然如果不涉及到写操作,只是查询的话,可以一直用。

回到顶部