在Python中使用sqlite3库进行数据库事务处理

SQLite是一种关系型数据库管理系统，提供了一个轻量级的嵌入式数据库引擎，支持在Python中进行数据库事务处理。使用Python的sqlite3库可以方便地连接、创建、查询和更新SQLite数据库。

以下是一个使用sqlite3库进行数据库事务处理的示例：

1. 连接到SQLite数据库

要使用sqlite3库，首先需要导入该库，并使用connect()函数连接到SQLite数据库。如果数据库不存在，connect()函数会自动创建一个新的数据库文件。

import sqlite3

conn = sqlite3.connect('example.db')  # 连接到SQLite数据库文件example.db

2. 创建数据库表

在SQLite中，可以使用execute()函数执行SQL语句。以下是一个创建名为"employees"的表的示例：

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

c.execute('''CREATE TABLE employees
             (id INT PRIMARY KEY     NOT NULL,
             name           TEXT    NOT NULL,
             age            INT     NOT NULL,
             address        CHAR(50),
             salary         REAL);''')  # 创建表

3. 插入数据

使用execute()函数执行插入语句，将数据插入到表中。

c.execute("INSERT INTO employees (id, name, age, address, salary) \
          VALUES (1, 'John Doe', 25, '123 Main St', 5000.00)")  # 插入一条数据

conn.commit()  # 提交事务

4. 查询数据

使用execute()函数执行查询语句，获取表中的数据。

c.execute("SELECT * FROM employees")  # 查询所有数据

rows = c.fetchall()  # 获取所有行

for row in rows:
    print(row)

5. 更新数据

使用execute()函数执行更新语句，更新表中的数据。

c.execute("UPDATE employees SET salary = 6000.00 WHERE id = 1")  # 更新工资

conn.commit()  # 提交事务

6. 删除数据

使用execute()函数执行删除语句，从表中删除数据。

c.execute("DELETE FROM employees WHERE id = 1")  # 删除数据

conn.commit()  # 提交事务

7. 关闭数据库连接

使用close()函数关闭数据库连接。

conn.close()  # 关闭数据库连接

以上是一个使用Python的sqlite3库进行数据库事务处理的示例。在实际应用中，可以根据具体需求执行更复杂的数据库操作，并使用事务来确保数据的完整性和一致性。