数据库事务

12002

本课介绍

本课将深入探讨MySQL事务处理的基本概念，特别是在应用开发中事务的使用。我们将通过jianghuknex事务处理账单的案例，理解事务在应用开发中的使用场景，并且通过读文档，熟悉事务的提交和回滚操作。

1.事务处理的基本概念

什么是事务处理

事务处理是数据库管理系统中的一个关键组成部分，用于管理数据库中的操作序列。当我们需要执行一系列数据库操作时，比如插入、更新或删除数据，我们把这些操作看作是一个整体，事务确保这些操作要么全部成功执行，要么全部不执行，以保证数据的完整性和一致性。

比如你去银行取款，你需要从一个账户中取出一定金额的钱。在这个过程中，如果银行系统出现问题或者你输入了错误的金额，你可能需要取消这次取款并重新操作。取款过程就可以看作是一个事务，事务处理就像是确保你的取款操作要么全部成功，要么全部失败，以保证账户金额的准确性和一致性。

MySQL事务处理

根据不同的数据库类型，事务处理的方式可能会有所不同。在关系型数据库中，MySQL事务处理是一项关键功能。

MySQL事务处理是确保数据操作一致性和完整性的关键功能。通过使用事务，可以将一系列数据库操作作为一个原子操作来执行，要么全部成功提交，要么全部回滚，从而避免数据不一致的情况发生。MySQL事务遵循ACID属性（原子性、一致性、隔离性和持久性），这确保了数据在并发操作中的正确性和可靠性。在应用开发中，合理利用MySQL事务处理功能可以确保数据的安全性，尤其在涉及复杂操作或多表操作时更为重要。

2.事务处理在应用开发中的使用

了解事务处理在应用开发中的常见应用场景和重要性

在企业级应用中，事务处理的重要性不言而喻，特别是在需要保证数据完整性和一致性的场景下。以下是几个常见的应用场景，展示了事务处理在应用开发中的关键作用：

转账操作：

在转账过程中，需要保证从一个账户扣款和向另一个账户存款的操作是原子的，要么全部成功，要么全部失败，避免出现数据丢失或重复扣款的情况。

订单处理：

在处理订单的过程中，可能涉及到多个操作，如减少库存、生成发货单等。使用事务可以保证这些操作的一致性，避免出现库存不足或生成发货单失败的问题。

数据库备份：

在进行数据库备份时，需要保证备份的数据是一个一致性的状态。使用事务可以确保备份操作的原子性，防止备份过程中的数据变动对备份结果产生影响。

批量操作：

当需要执行一系列操作时，使用事务可以保证这些操作的原子性和一致性。如果其中任何一步操作失败，可以回滚整个事务，避免产生不一致的状态。

通过事务处理，开发人员可以确保数据操作的安全性和一致性，提高系统的可靠性。事务处理能够有效地处理数据操作中的问题，确保数据操作的正确性，让应用程序在各种情况下都能够稳定运行。

案例：jianghuknex事务处理账单

在江湖JS中，我们使用jianghuknex来处理数据事务。jianghuKnex是在Knex的基础上添加了数据历史特性的封装，用于简化开发者与常见数据库的交互。在事务处理方面，jianghuKnex借助Knex的事务特性，使得处理数据库事务更为便捷。相比原生的 Knex，jianghuKnex 在事务处理上提供了更加简洁的方式，省去了显式的提交和回滚操作。

在使用jianghuKnex进行事务处理时，开发者可以利用其封装的方法来执行一系列数据库操作，并通过COMMIT提交事务，确保所有更改永久生效；或者通过ROLLBACK回滚事务，撤销所有的更改，以维护数据库的一致性。

我们以处理账单为例，理解jianghuknex事务

    // 事务处理
    await jianghuKnex.transaction(async trx => {
      //写入账单
      if(dataArray.length > 0){
      // 检查是否有账单数据
        await trx(tableEnum.payment_record, ctx).jhInsert(dataArray);
         // 将 dataArray 数组中的数据插入 payment_record 表中
      }
      
      //更新账单
      for(const item of updateArray){
       // 遍历要更新的账单数组
        await trx(tableEnum.bill, ctx).where({ billId: item.billId }).jhUpdate(item);
        // 根据账单 ID 更新相应的账单数据
      }

这段示例使用了 jianghuKnex.transaction 方法进行事务处理，包括写入账单和更新账单两个操作：

await jianghuKnex.transaction(async trx => { ... });: 这里通过jianghuKnex.transaction方法创建了一个事务对象trx，在这个事务中执行一系列数据库操作。所有操作要么全部成功提交，要么全部回滚。
if(dataArray.length > 0){ await trx(tableEnum.payment_record, ctx).jhInsert(dataArray); }: 这部分代码是在事务中写入账单数据。首先检查dataArray数组是否有数据，如果有数据，则通过trx对象在payment_record表中执行批量插入操作，使用jhInsert方法将dataArray数组中的数据插入数据库中。
for(const item of updateArray){ await trx(tableEnum.bill, ctx).where({ billId: item.billId }).jhUpdate(item); }: 这部分代码是在事务中更新账单数据。遍历billUpdateData数组中的每个元素item，然后通过trx对象在bill表中根据billId字段匹配当前元素item的billId值，使用jhUpdate方法更新相应的账单数据。

通过将这些操作放在同一个事务中，可以确保写入账单和更新账单这两个操作要么全部成功执行并提交，要么发生错误时全部回滚，从而保持数据库操作的一致性和完整性。这种事务处理方式在处理复杂的数据库操作时特别有用，可以有效地管理数据的变更过程。

3.读文档，学习MySQL事务的提交和回滚

在了解了事务处理的概念及其在开发中的应用场景之后，通过阅读文档，我们可以进一步探索MySQL事务的用法，特别是提交和回滚操作。

BEGIN语句的作用

BEGIN语句用于显式地开始一个事务。在MySQL中，当执行BEGIN语句时，将标记事务的开始点。所有在BEGIN和COMMIT（或ROLLBACK）之间的操作将被视为一个事务，直到显式地提交或回滚这个事务。

BEGIN; 
-- 在这里执行一系列数据库操作
COMMIT;

事务的提交：COMMIT语句

COMMIT语句用于将事务中的所有操作永久地保存到数据库中。当执行COMMIT语句时，事务中的所有操作将被提交，即使数据库发生故障，也不会丢失已提交的更改。一旦提交了事务，就无法回滚到事务开始之前的状态。

BEGIN;
-- 在这里执行一系列数据库操作，例如插入数据
INSERT INTO student (studentId, studentName, gender) VALUES (101, '小草', '女');
COMMIT;

在这个示例中，我们开始一个事务（BEGIN），然后向名为student 的表中插入一条记录，其中包括studentId为101、姓名为小草、性别为女。当我们执行COMMIT时，这个插入操作将被永久保存到数据库中。

事务的回滚：ROLLBACK语句

ROLLBACK语句用于撤销事务中的所有操作，将数据库恢复到事务开始之前的状态。当执行ROLLBACK语句时，事务中的所有操作都将被撤销，数据库不会保存任何在该事务中的更改。

BEGIN;
-- 在这里执行一系列数据库操作，例如插入数据
INSERT INTO student (studentId, studentName, gender) VALUES (101, '小花', '女');
ROLLBACK;

在这个示例中，我们开始一个事务（BEGIN），然后向名为student的表中插入一条记录，其中包括studentId为101、姓名为小花、性别为女。但如果ID为1的记录已经存在，插入操作将失败。通过执行ROLLBACK，我们可以撤销这次插入操作，数据库将恢复到事务开始之前的状态，确保数据的完整性。

通过使用BEGIN、COMMIT和ROLLBACK语句，可以有效地管理MySQL中的事务，确保数据操作的一致性和完整性。

参考资料：MySQL 事务

## 本课介绍

本课将深入探讨MySQL事务处理的基本概念，特别是在应用开发中事务的使用。我们将通过jianghuknex事务处理账单的案例，理解事务在应用开发中的使用场景，并且通过读文档，熟悉事务的提交和回滚操作。

## 1.事务处理的基本概念

### 什么是事务处理

事务处理是数据库管理系统中的一个关键组成部分，用于管理数据库中的操作序列。当我们需要执行一系列数据库操作时，比如插入、更新或删除数据，我们把这些操作看作是一个整体，事务确保这些操作要么全部成功执行，要么全部不执行，以保证数据的完整性和一致性。

比如你去银行取款，你需要从一个账户中取出一定金额的钱。在这个过程中，如果银行系统出现问题或者你输入了错误的金额，你可能需要取消这次取款并重新操作。取款过程就可以看作是一个事务，事务处理就像是确保你的取款操作要么全部成功，要么全部失败，以保证账户金额的准确性和一致性。

### MySQL事务处理

根据不同的数据库类型，事务处理的方式可能会有所不同。在关系型数据库中，MySQL事务处理是一项关键功能。

MySQL事务处理是确保数据操作一致性和完整性的关键功能。通过使用事务，可以将一系列数据库操作作为一个原子操作来执行，要么全部成功提交，要么全部回滚，从而避免数据不一致的情况发生。MySQL事务遵循ACID属性（原子性、一致性、隔离性和持久性），这确保了数据在并发操作中的正确性和可靠性。在应用开发中，合理利用MySQL事务处理功能可以确保数据的安全性，尤其在涉及复杂操作或多表操作时更为重要。

## 2.事务处理在应用开发中的使用

### 了解事务处理在应用开发中的常见应用场景和重要性

在企业级应用中，事务处理的重要性不言而喻，特别是在需要保证数据完整性和一致性的场景下。以下是几个常见的应用场景，展示了事务处理在应用开发中的关键作用：

- 转账操作：

在转账过程中，需要保证从一个账户扣款和向另一个账户存款的操作是原子的，要么全部成功，要么全部失败，避免出现数据丢失或重复扣款的情况。

- 订单处理：

在处理订单的过程中，可能涉及到多个操作，如减少库存、生成发货单等。使用事务可以保证这些操作的一致性，避免出现库存不足或生成发货单失败的问题。

- 数据库备份：

在进行数据库备份时，需要保证备份的数据是一个一致性的状态。使用事务可以确保备份操作的原子性，防止备份过程中的数据变动对备份结果产生影响。

- 批量操作：

当需要执行一系列操作时，使用事务可以保证这些操作的原子性和一致性。如果其中任何一步操作失败，可以回滚整个事务，避免产生不一致的状态。

通过事务处理，开发人员可以确保数据操作的安全性和一致性，提高系统的可靠性。事务处理能够有效地处理数据操作中的问题，确保数据操作的正确性，让应用程序在各种情况下都能够稳定运行。

### 案例：jianghuknex事务处理账单

在江湖JS中，我们使用jianghuknex来处理数据事务。jianghuKnex是在Knex的基础上添加了数据历史特性的封装，用于简化开发者与常见数据库的交互。在事务处理方面，jianghuKnex借助Knex的事务特性，使得处理数据库事务更为便捷。相比原生的 Knex，jianghuKnex 在事务处理上提供了更加简洁的方式，省去了显式的提交和回滚操作。

在使用jianghuKnex进行事务处理时，开发者可以利用其封装的方法来执行一系列数据库操作，并通过COMMIT提交事务，确保所有更改永久生效；或者通过ROLLBACK回滚事务，撤销所有的更改，以维护数据库的一致性。

我们以处理账单为例，理解jianghuknex事务

```
    // 事务处理
    await jianghuKnex.transaction(async trx => {
      //写入账单
      if(dataArray.length > 0){
	  // 检查是否有账单数据
        await trx(tableEnum.payment_record, ctx).jhInsert(dataArray);
		 // 将 dataArray 数组中的数据插入 payment_record 表中
      }
      
      //更新账单
      for(const item of updateArray){
	   // 遍历要更新的账单数组
        await trx(tableEnum.bill, ctx).where({ billId: item.billId }).jhUpdate(item);
		// 根据账单 ID 更新相应的账单数据
      }
```

这段示例使用了 jianghuKnex.transaction 方法进行事务处理，包括写入账单和更新账单两个操作：

1. await jianghuKnex.transaction(async trx => { ... });: 这里通过jianghuKnex.transaction方法创建了一个事务对象trx，在这个事务中执行一系列数据库操作。所有操作要么全部成功提交，要么全部回滚。

2. if(dataArray.length > 0){ await trx(tableEnum.payment_record, ctx).jhInsert(dataArray); }: 这部分代码是在事务中写入账单数据。首先检查dataArray数组是否有数据，如果有数据，则通过trx对象在payment_record表中执行批量插入操作，使用jhInsert方法将dataArray数组中的数据插入数据库中。

3. for(const item of updateArray){ await trx(tableEnum.bill, ctx).where({ billId: item.billId }).jhUpdate(item); }: 这部分代码是在事务中更新账单数据。遍历billUpdateData数组中的每个元素item，然后通过trx对象在bill表中根据billId字段匹配当前元素item的billId值，使用jhUpdate方法更新相应的账单数据。

通过将这些操作放在同一个事务中，可以确保写入账单和更新账单这两个操作要么全部成功执行并提交，要么发生错误时全部回滚，从而保持数据库操作的一致性和完整性。这种事务处理方式在处理复杂的数据库操作时特别有用，可以有效地管理数据的变更过程。

## 3.读文档，学习MySQL事务的提交和回滚

在了解了事务处理的概念及其在开发中的应用场景之后，通过阅读文档，我们可以进一步探索MySQL事务的用法，特别是提交和回滚操作。

### BEGIN语句的作用

BEGIN语句用于显式地开始一个事务。在MySQL中，当执行BEGIN语句时，将标记事务的开始点。所有在BEGIN和COMMIT（或ROLLBACK）之间的操作将被视为一个事务，直到显式地提交或回滚这个事务。

```
BEGIN; 
-- 在这里执行一系列数据库操作
COMMIT;
```
### 事务的提交：COMMIT语句

COMMIT语句用于将事务中的所有操作永久地保存到数据库中。当执行COMMIT语句时，事务中的所有操作将被提交，即使数据库发生故障，也不会丢失已提交的更改。一旦提交了事务，就无法回滚到事务开始之前的状态。

```
BEGIN;
-- 在这里执行一系列数据库操作，例如插入数据
INSERT INTO student (studentId, studentName, gender) VALUES (101, '小草', '女');
COMMIT;
```
在这个示例中，我们开始一个事务（BEGIN），然后向名为student 的表中插入一条记录，其中包括studentId为101、姓名为小草、性别为女。当我们执行COMMIT时，这个插入操作将被永久保存到数据库中。

### 事务的回滚：ROLLBACK语句

ROLLBACK语句用于撤销事务中的所有操作，将数据库恢复到事务开始之前的状态。当执行ROLLBACK语句时，事务中的所有操作都将被撤销，数据库不会保存任何在该事务中的更改。

```
BEGIN;
-- 在这里执行一系列数据库操作，例如插入数据
INSERT INTO student (studentId, studentName, gender) VALUES (101, '小花', '女');
ROLLBACK;
```
在这个示例中，我们开始一个事务（BEGIN），然后向名为student的表中插入一条记录，其中包括studentId为101、姓名为小花、性别为女。但如果ID为1的记录已经存在，插入操作将失败。通过执行ROLLBACK，我们可以撤销这次插入操作，数据库将恢复到事务开始之前的状态，确保数据的完整性。

通过使用BEGIN、COMMIT和ROLLBACK语句，可以有效地管理MySQL中的事务，确保数据操作的一致性和完整性。

参考资料：[MySQL 事务](https://www.runoob.com/mysql/mysql-transaction.html "MySQL 事务")