SQLite 中的并发访问

SQLite 中的并发访问：保障数据一致性与性能

python
import sqlite3
import threading
# 连接数据库
conn = sqlite3.connect('example.db')
cursor = conn.cursor()
# 创建表
cursor.execute('CREATE TABLE IF NOT EXISTS users (id INTEGER PRIMARY KEY, name TEXT)')
# 插入初始数据
cursor.execute('INSERT INTO users (name) VALUES (?)', ('User1',))
conn.commit()
# 定义更新函数
def update_user():
    cursor.execute('UPDATE users SET name = ? WHERE id = ?', ('UpdatedUser', 1))
    conn.commit()
# 启动两个线程同时更新数据
thread1 = threading.Thread(target=update_user)
thread2 = threading.Thread(target=update_user)
thread1.start()
thread2.start()
thread1.join()
thread2.join()
# 查询更新后的数据
cursor.execute('SELECT * FROM users WHERE id = 1')
result = cursor.fetchone()
print('Updated User:', result[1])
# 关闭连接
conn.close()