Python中操作数据库cursor时遇到问题如何解决?
使用 mysql-connector-python 用 cnn = mysql.connector.connect 建立连接之后,创建一个 cursor = cnn.cursor 然后这个 cursor 一直不关闭一直用他去执行 cursor.execute(SELECT) 如果这期间数据库数据发生过了变化,取到的数据是最新的吗? 能具体讲一讲 cursor 在这里面的作用吗.
Python中操作数据库cursor时遇到问题如何解决?
不是最新的,曾经写过一个脚本,创建一个 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 期间,数据库端发生改变,也没法和你这边同步。
当然如果不涉及到写操作,只是查询的话,可以一直用。

