如何在 aiosqlite 中正确插入数据并持久化到数据库

使用 aiosqlite 如果没有显式调用，时间 commit()，即使执行了 insert 句子，数据不会真正写入磁盘——这是“无报错但无数据”最常见的原因。

使用 aiosqlite 如果没有显式调用，时间 commit()，即使执行了 insert 句子，数据不会真正写入磁盘——这是“无报错但无数据”最常见的原因。

在异步 SQLite 操作中，aiosqlite 遵循与标准 sqlite3 相同的事务机制：所有事务机制： DML 操作（如 INSERT、UPDATE、DELETE）在隐式事务中默认运行，但必须显式提交（commit）可以持久。而你的 add_user 该方法仅执行 cursor.execute()，但没有调用 con.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）或者重用连接实例。

牢记：aiosqlite ≠ 自动提交。严格遵循。 SQLite 的 ACID 特点——你负责开始事务，也必须负责提交或回滚。补上这一行，数据就可以稳定落库了。