目标
内容
示例代码
import sqlite3
conn = sqlite3.connect('test.db')
cursor = conn.cursor()
# 创建表
cursor.execute('create table if not exists user (id int primary key, name text)')
# 插入一条记录
cursor.execute('insert into user (id, name) values (?, ?)', (1, 'Alice'))
try:
# 开始事务
conn.execute('BEGIN')
# 删除数据
cursor.execute('delete from user where id=?', (1,))
# 假设这里发生错误，事务将回滚
raise Exception("模拟错误")
except Exception as e:
print(e)
# 回滚事务
conn.rollback()
else:
# 提交事务
conn.commit()
cursor.close()
conn.close()
