
使用 aiosqlite 时,若未显式调用 commit(),即使执行了 insert 语句,数据也不会真正写入磁盘——这是导致“无报错却无数据”的最常见原因。
使用 aiosqlite 时,若未显式调用 commit(),即使执行了 insert 语句,数据也不会真正写入磁盘——这是导致“无报错却无数据”的最常见原因。
在异步 SQLite 操作中,aiosqlite 遵循与标准 sqlite3 相同的事务机制:所有 DML 操作(如 INSERT、UPDATE、DELETE)默认运行在隐式事务中,但必须显式提交(commit)才能持久化。而你的 add_user 方法中仅执行了 cursor.execute(),却未调用 con.commit(),因此变更始终停留在内存事务中,连接关闭时自动回滚,导致数据“消失”。
✅ 正确写法:确保 commit 执行
修改 add_user 方法如下(关键改动已加注释):
async def add_user(self, uid: int) -> None:
'''The method adds a user into the table'''
await self.start() # 确保表已存在
async with aiosql.connect(self.path) as con:
# 注意:aiosqlite 3.0+ 推荐直接使用 con.execute(),无需显式 cursor
request = 'INSERT INTO users(user_telegram_id, status) VALUES(?, ?)'
await con.execute(request, (uid, 'member'))
await con.commit() # ✅ 必须添加:提交事务,使数据持久化
? 提示:aiosqlite.Connection.execute() 内部已返回可 await 的 Cursor,因此无需手动 await con.cursor();更简洁、更安全。
? 其他潜在问题排查建议
- 避免重复创建连接:self.start() 中也使用了 aiosql.connect(),但该方法仅建表,不涉及写操作,影响较小;不过建议将 start() 改为幂等初始化(如只在首次启动时建表),或复用连接。
-
异常处理缺失:生产环境应包裹 try/except,捕获 aiosqlite.IntegrityError(如主键冲突)等异常:
try: await con.execute("INSERT INTO users ...", (uid, 'member')) await con.commit() except aiosqlite.IntegrityError: # 用户已存在,可选择忽略或更新 await con.rollback() - 连接池与性能:高频写入场景下,频繁 connect() 开销较大,可考虑使用连接池(如 aiosqlite.Pool)或复用连接实例。
✅ 总结
| 问题现象 | 根本原因 | 解决方案 |
|---|---|---|
| /start 后数据库无新增记录,且无报错 | 未调用 await con.commit(),事务未提交 | 在 INSERT 后显式调用 await con.commit() |
牢记:aiosqlite ≠ 自动提交。它严格遵循 SQLite 的 ACID 特性——你负责开启事务,也必须负责提交或回滚。补上这一行,数据即可稳定落库。











