SQLite是Python3标准库中内置的数据库模块,无需额外安装依赖就能直接使用,非常适合小型应用的数据存储需求,比如本地配置存储、轻量日志记录等场景。

一、SQLite基础连接与游标创建
使用Python3操作SQLite首先需要导入内置的sqlite3模块,然后通过connect方法建立数据库连接,该方法如果传入的文件路径不存在,会自动创建对应的数据库文件。
import sqlite3
# 连接数据库,文件不存在会自动创建
conn = sqlite3.connect('test.db')
# 创建游标对象,所有SQL操作通过游标执行
cursor = conn.cursor()
二、核心数据操作
1. 创建数据表
使用CREATE TABLE语句可以创建数据表,建议添加IF NOT EXISTS避免重复创建报错,同时可以定义主键、非空等约束。
# 创建用户表,id为主键自增,name和age为非空字段
create_table_sql = '''
CREATE TABLE IF NOT EXISTS user (
id INTEGER PRIMARY KEY AUTOINCREMENT,
name TEXT NOT NULL,
age INTEGER NOT NULL
)
'''
cursor.execute(create_table_sql)
# 执行建表操作后提交事务
conn.commit()
2. 数据插入操作
插入数据推荐使用参数化查询,避免SQL注入风险,参数使用?作为占位符,对应的值通过元组传入。
# 单条插入
insert_sql = 'INSERT INTO user (name, age) VALUES (?, ?)'
cursor.execute(insert_sql, ('张三', 25))
# 批量插入
user_list = [('李四', 28), ('王五', 22)]
cursor.executemany(insert_sql, user_list)
# 提交事务保存数据
conn.commit()
3. 数据查询操作
查询操作使用SELECT语句,执行后可以通过fetchone获取单条结果,fetchall获取所有结果,返回的结果是元组形式。
# 查询所有用户
query_sql = 'SELECT id, name, age FROM user'
cursor.execute(query_sql)
# 获取所有结果
all_users = cursor.fetchall()
for user in all_users:
print(f'用户ID:{user[0]},姓名:{user[1]},年龄:{user[2]}')
# 查询单条数据
cursor.execute('SELECT * FROM user WHERE name = ?', ('张三',))
single_user = cursor.fetchone()
print(single_user)
4. 数据更新与删除
更新和删除操作同样使用参数化查询,执行后需要提交事务才能生效,建议操作前先确认条件避免误删全表数据。
# 更新用户年龄 update_sql = 'UPDATE user SET age = ? WHERE name = ?' cursor.execute(update_sql, (26, '张三')) conn.commit() # 删除用户数据 delete_sql = 'DELETE FROM user WHERE age < ?' cursor.execute(delete_sql, (23,)) conn.commit()
三、实用技巧
1. 事务处理
SQLite默认开启自动提交,但执行增删改操作时建议显式提交,也可以手动控制事务,出错时回滚避免数据异常。
try:
cursor.execute('INSERT INTO user (name, age) VALUES (?, ?)', ('赵六', 30))
# 模拟出错场景
raise Exception('操作异常')
conn.commit()
except Exception as e:
print(f'操作失败:{e}')
conn.rollback()
2. 设置查询结果返回字典形式
默认查询结果返回的是元组,不方便通过字段名取值,可以修改row_factory让结果返回字典。
conn = sqlite3.connect('test.db')
# 设置行工厂为字典形式
conn.row_factory = sqlite3.Row
cursor = conn.cursor()
cursor.execute('SELECT id, name, age FROM user')
row = cursor.fetchone()
# 可以通过字段名取值
print(row['name'], row['age'])
3. 关闭连接
操作完成后需要关闭游标和连接,释放资源,避免文件被占用。
cursor.close() conn.close()