Python中怎样使用sqlite3模块？-Python教程-PHP中文网

Python中怎样使用sqlite3模块？

穿越時空

发布： 2025-05-30 21:51:01

原创

512人浏览过

在python中使用sqlite3模块处理数据库操作非常方便，因为它是标准库的一部分，无需额外安装。具体步骤包括：1. 连接数据库并创建游标；2. 创建表；3. 插入数据并提交事务；4. 查询数据；5. 关闭连接。此外，使用事务处理可以确保数据一致性，注意锁定问题和性能优化，使用上下文管理器和错误处理是重要的最佳实践。

Python中怎样使用sqlite3模块？

在Python中使用sqlite3模块来处理数据库操作是件相当酷的事情。SQLite是一种轻量级的数据库，非常适合嵌入式应用和小型项目。让我们深入探讨一下如何在Python中使用sqlite3模块吧。

首先要说的是，sqlite3模块是Python标准库的一部分，这意味着你不需要额外安装任何东西，直接就能开始使用。这对于快速原型设计或小型应用来说非常方便。相比于其他数据库，SQLite不需要独立的服务器进程，这让它在开发和部署上都更加简便。

关于如何使用sqlite3模块，我可以分享一些实际操作的经验和一些注意事项。

立即学习“Python免费学习笔记（深入）”；

让我们从最基本的操作开始：

import sqlite3

# 连接到数据库（如果不存在，将会创建一个新的数据库文件）
conn = sqlite3.connect('example.db')

# 创建一个游标对象
cursor = conn.cursor()

# 创建表
cursor.execute('''
    CREATE TABLE IF NOT EXISTS users (
        id INTEGER PRIMARY KEY,
        name TEXT NOT NULL,
        email TEXT UNIQUE
    )
''')

# 插入数据
cursor.execute('''
    INSERT INTO users (name, email) VALUES (?, ?)
''', ('Alice', 'alice@example.com'))

# 提交事务
conn.commit()

# 查询数据
cursor.execute('SELECT * FROM users')
rows = cursor.fetchall()
for row in rows:
    print(row)

# 关闭连接
cursor.close()
conn.close()

登录后复制

这段代码展示了如何连接数据库、创建表、插入数据、查询数据和关闭连接。这里有几个关键点值得注意：

使用connect方法连接数据库时，如果指定的数据库文件不存在，SQLite会自动创建一个新的文件。
CREATE TABLE IF NOT EXISTS语句可以确保表只在不存在时被创建，避免了重复创建表的错误。
使用?作为占位符进行参数化查询，这可以防止SQL注入攻击。
记得调用commit方法来保存更改，否则数据不会被持久化到数据库中。

现在，让我们谈谈一些更高级的用法和可能遇到的问题。

假设你需要执行一系列的数据库操作，并且希望这些操作要么全部成功，要么全部失败（即事务处理），你可以这样做：

import sqlite3

conn = sqlite3.connect('example.db')
cursor = conn.cursor()

try:
    cursor.execute('BEGIN TRANSACTION')

    cursor.execute('''
        INSERT INTO users (name, email) VALUES (?, ?)
    ''', ('Bob', 'bob@example.com'))

    cursor.execute('''
        INSERT INTO users (name, email) VALUES (?, ?)
    ''', ('Charlie', 'charlie@example.com'))

    cursor.execute('COMMIT')
except sqlite3.Error as e:
    cursor.execute('ROLLBACK')
    print(f"An error occurred: {e}")
finally:
    cursor.close()
    conn.close()

登录后复制

这里使用了事务处理来确保数据的一致性。如果在插入过程中发生错误，所有的更改都会被回滚。

在使用sqlite3时，还有一些常见的问题和调试技巧值得分享：

锁定问题：SQLite在默认情况下是文件锁定的，这可能会导致在多线程或多进程环境下出现问题。你可以通过设置timeout参数来解决这个问题，例如conn = sqlite3.connect('example.db', timeout=10)。
性能优化：如果你需要执行大量的插入操作，可以使用executemany方法来提高效率。例如：

import sqlite3

conn = sqlite3.connect('example.db')
cursor = conn.cursor()

users = [
    ('David', 'david@example.com'),
    ('Eva', 'eva@example.com'),
    ('Frank', 'frank@example.com')
]

cursor.executemany('''
    INSERT INTO users (name, email) VALUES (?, ?)
''', users)

conn.commit()
cursor.close()
conn.close()

登录后复制

数据类型：SQLite是弱类型的，这意味着你需要在应用层面确保数据类型的一致性。例如，如果你希望id字段是整数类型，你需要在插入数据时确保传递的是整数。

最后，我想分享一些最佳实践：

使用上下文管理器：可以使用with语句来确保连接和游标在使用后被正确关闭，例如：

import sqlite3

with sqlite3.connect('example.db') as conn:
    with conn.cursor() as cursor:
        cursor.execute('SELECT * FROM users')
        rows = cursor.fetchall()
        for row in rows:
            print(row)

登录后复制