本文主要是介绍python连接sqlite3简单用法完整例子,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!
《python连接sqlite3简单用法完整例子》SQLite3是一个内置的Python模块,可以通过Python的标准库轻松地使用,无需进行额外安装和配置,:本文主要介绍python连接sqli...
1. 连接到数据库
在 python 中使用 SQLite3.connect()
方法连接到 SQLite 数据库。如果数据库文件不存在,会自动创建。
import sqlite3 # 连接到数据库文件(如果不存在则自动创建) conn = sqlite3.connect('example.db')
- 解释:
connect('example.db')
:创建或打开名为example.db
的数据库文件。- 返回的
conn
是数据库连接对象,后续操作都需要通过它进行。
2. 创建游标对象
通过连接对象创建游标(Cursor),用于执行 SQL 语句。
cursor = conn.cursor()
- 解释:
- 游标对象
cursor
用于执行create table
、insert into
、select
等 SQL 语句。
- 游标对象
3. 创建表
使用 create table
语句创建表,推荐使用 if not exists
避免重复创建。
cursor.execute(''' CREATE TABLE IF NOT EXISTS users ( id INTEGER PRIMARY KEY AUTOINCREMENT, name TEXT NOT NULL, age INTEGER, email TEXT UNIQUE ) ''') conn.commit()
- 解释:
create table if not exists users
:如果表users
不存在则创建。id integer primary key autoincrement
:id
是主键,自动递增。name text not null
:name
字段为文本类型且不能为空。email text unique
:email
字段必须唯一。conn.commit()
:提交事务(必须执行,否则表不会被创建)。
4. 插入数据
使用 insert编程 into
插入数据,推荐使用参数化查询防止 SQL 注入。
# 单条插入 cursor.execute("INSERT INTO users (name, age, email) VALUES (?, ?, ?)", ('Alice', 25, 'alice@example.com')) # 多条插入 users_data = [ ('Bob', 30, 'bob@example.com'), ('Charlie', 35, 'charlie@example.com') ] cursor.executemany("INSERT INTO users (name, age, email) VALUES (?, ?, ?)", users_data) conn.commit()
- 解释:
values (?, ?, ?)
:?
是占位符,Python 会自动替换参数(防止 SQL 注入)。executemany
可一次插入多条数据。conn.commit()
提交事务(插入操作必须提交)。
5. 查询数据
使用 select
查询数据,结果通过 fetchone()
或 fetchall()
获取。
# 查询所有用户 cursor.execute("SELECT * FROM users") rows = cursor.fetchall() for row in rows: print(row) # 条件查询 cursor.execute("SELECT name, age FROM users WHERE age > ?", (30,)) result = cursor.fetchone() print(result)
- 解释:
select * from users
:查询users
表的所有字段。fetchall()
:获取所有查询结果(返回列表)。fetchone()
:获取单条结果(返回元组)。where age > ?
:筛选age
大于指定值的记录。
6. 更新数据
使用 update
修改已有数据。
cursor.execute("UPDATE users SET age = ? WHERE name = ?", (26, 'Alice')) conn.commit()
- 解释:
set age = ?
:将age
字段更新为新值。where name = ?
:仅更新name
为'Alice'
的记录。conn.commit()
提交事务。
7. 删除数据
使用 delete from
删除数据。
cursor.execute("DELETE FROM users WHERE name = 'Bob'") conn.commit()
- 解释:
delete from users
:删除users
表中的记录。where name = 'Bob'
:仅删除name
为'Bob'
的记录。conn.commit()
提交事务。
8. 创建索引(可选)
索引可以加速查询,但会降低插入/更新速度。
cursor.execute("CREATE INDEX idx_name ON users (name)") conn.commit()
- 解释:
create index idx_name on usersfpLiv (name)
:为users
表的name
字段创建索引。
9. 事务处理
SQLite 支持事务(begin
, commit
, rollback
),确保操作的原子性。
try: # 开始事务 conn.execute("BEGIN") # 执行多条操作 cursor.execute("INSERT INTO users (name, age) VALUES (?, ?)", ('David', 28)) cursor.execute("UPDATE users SET age = ? WHERE name = ?", (29, 'David')) # 提交事务 conn.commit() except Exception as e: print("事务失败,回滚:", e) conn.rollback() # 回滚事务
- 解释:
begin
:显式开始事务(默认情况下,每条语句都是独立事务)。conn.commit()
:提交事务(所有操作生效)。conn.rollback()
:回滚事务(撤销所有未提交的操作)。
10. 关闭连接
操作完成后,关闭游标和数据库连接。
cursor.close() conn.close()
- 解释:
- 关闭游标和连接释放资源,避免内存泄漏。
完整示例代码
import sqlite3 # 1. 连接数据库 conn = sqlite3.connect('example.db') cursor = conn.cursojsr() # 2. 创建表 cursor.execute(''' CREATE TABLE IF NOT EXISTS users ( id INTEGER PRIMARY KEY AUTOINCREMENT, name TEXT NOT NULL, age INTEGER, email TEXT UNIQUE ) ''') conn.commit() # 3. 插入数据 cursor.execute("INSERT INTO users (name, age, email) VALUES (?, ?, ?)", ('Alice', 25, 'alice@example.com')) conn.commit() # 4. 查询数据 cursor.execute("SELECT * FROM users") rows = cursor.fetchall() for row in rows: print(row) # 5. 更新数据 cursor.execute("UPDATE users SET age = ? WHERE name = ?", (26, 'Alice')) conn.commit() # js6. 删除数据 cursor.execute("DELETE FROM users WHERE name = 'Alice'") conn.commit() # 7. 关闭连接 cursor.close() conn.close()
常见错误与避坑指南
忘记提交China编程事务
- 错误:插入/更新/删除后未调用
conn.commit()
。 - 修正:每次修改数据后必须调用
conn.commit()
。
- 错误:插入/更新/删除后未调用
SQL 注入风险
- 错误:直接拼接 SQL 语句(如
f"INSERT INTO users VALUES ({name})"
)。 - 修正:使用参数化查询(如
VALUES (?, ?)
)。
- 错误:直接拼接 SQL 语句(如
字段名与保留字冲突
- 错误:使用
order
,group
等保留字作为字段名。 - 修正:避免使用保留字,或用引号包裹字段名(如
"order"
)。
- 错误:使用
未关闭连接
- 错误:程序结束时未关闭
cursor
和conn
。 - 修正:使用
with
上下文管理器自动关闭资源:with sqlite3.connect('example.db') as conn: cursor = conn.cursor() # 执行操作...
- 错误:程序结束时未关闭
总结
到此这篇关于python连接sqlite3简单用法的文章就介绍到这了,更多相关python连接sqlite3用法内容请搜索China编程(www.chinasem.cn)以前的文章或继续浏览下面的相关文章希望大家以后多多支持编程China编程(www.chinasem.cn)!
这篇关于python连接sqlite3简单用法完整例子的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!