如何正确关闭 Python SQLite 数据库连接-Python教程-PHP中文网

如何正确关闭 Python SQLite 数据库连接

聖光之護

发布： 2025-10-17 08:44:10

原创

383人浏览过

如何正确关闭 python sqlite 数据库连接

本文档旨在指导开发者如何在 Python 中正确关闭 SQLite 数据库连接，尤其是在使用类和上下文管理器的情况下。我们将探讨如何利用 with 语句和自定义类来确保数据库连接在使用完毕后得到妥善关闭，并处理潜在的异常情况，保证数据的一致性。

在 Python 中操作 SQLite 数据库时，正确关闭数据库连接至关重要。这可以避免资源泄露，确保数据写入磁盘，并防止数据库文件损坏。本文将介绍一种使用上下文管理器和装饰器模式来优雅地管理和关闭数据库连接的方法。

使用上下文管理器 (with 语句)

Python 的 with 语句提供了一种简洁的方式来管理资源，它会在代码块执行完毕后自动释放资源。我们可以创建一个自定义类，实现 __enter__ 和 __exit__ 方法，使其能够作为上下文管理器使用。

import sqlite3

class DBConnection:
    def __enter__(self):
        self.conn = sqlite3.connect('main.db')
        self.cursor = self.conn.cursor()
        return self.cursor

    def __exit__(self, exc_type, exc_val, exc_tb):
        if self.cursor:
            self.cursor.close()
        if self.conn:
            if exc_type is None:
                self.conn.commit()  # 如果没有异常，则提交更改
            self.conn.close()
        return False  # 允许异常继续传播

登录后复制

代码解释：

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

__enter__(self)：在进入 with 块时被调用，负责建立数据库连接和创建游标对象。
__exit__(self, exc_type, exc_val, exc_tb)：在退出 with 块时被调用，负责关闭游标和数据库连接。exc_type、exc_val 和 exc_tb 分别表示异常类型、异常值和回溯信息。如果 exc_type 为 None，表示没有发生异常，此时应该提交事务 (conn.commit())。return False 允许异常继续传播，如果希望阻止异常传播，可以返回 True。

使用装饰器

为了简化数据库操作，我们可以创建一个装饰器，它会自动处理数据库连接的建立和关闭。

来画数字人直播

来画数字人自动化直播，无需请真人主播，即可实现24小时直播，无缝衔接各大直播平台。

查看详情

def db_connection(func):
    def wrapper(*args, **kwargs):
        with DBConnection() as cursor:
            return func(cursor, *args, **kwargs)
    return wrapper

登录后复制

代码解释：

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

db_connection(func)：接受一个函数作为参数，并返回一个新的函数 wrapper。
wrapper(*args, **kwargs)：在 wrapper 函数内部，使用 DBConnection 作为上下文管理器，获取游标对象，并调用原始函数 func，将游标对象作为第一个参数传递给它。

示例用法

class Database:
    @db_connection
    def some_query(self, cursor, *args):
        query = "SELECT * FROM mytable;"
        cursor.execute(query)
        results = cursor.fetchall()
        return results

登录后复制

代码解释：

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

@db_connection：将 db_connection 装饰器应用到 some_query 方法上。
some_query(self, cursor, *args)：some_query 方法接收一个游标对象作为第一个参数，然后执行 SQL 查询。

使用示例：

db = Database()
results = db.some_query()
print(results)

登录后复制

注意事项

异常处理： 在 __exit__ 方法中，我们检查 exc_type 是否为 None，如果是，则提交事务。这意味着只有在没有发生异常的情况下，才会提交更改。如果发生异常，则不会提交更改，从而保证数据的一致性。
事务提交： 确保在适当的时候调用 conn.commit()，以将更改写入数据库。如果忘记提交事务，则所做的更改将不会被保存。
资源释放： 务必在 __exit__ 方法中关闭游标和数据库连接，以释放资源。
错误传播： __exit__ 方法返回 False，允许异常继续传播。如果希望阻止异常传播，可以返回 True，但这通常不是一个好的做法，因为它会隐藏错误。
SQL 注入： 始终使用参数化查询来防止 SQL 注入攻击。不要直接将用户输入拼接到 SQL 语句中。