简介

innodb引擎中支持事务，myisam不支持。

CREATE TABLE `users` (
  `id` int(11) NOT NULL AUTO_INCREMENT PRIMARY KEY,
  `name` varchar(32) DEFAULT NULL,
  `amount` int(11) DEFAULT NULL
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

例如：李杰 给 武沛齐 转账 100，那就会涉及2个步骤。

• 用户A账户 减100
• 用户B账户 加 100

这两个步骤必须同时完成才算完成，并且如果第一个完成、第二步失败，还是回滚到初始状态。
事务，就是来解决这种情况的。 大白话：要成功都成功；要失败都失败。

事务的具有四大特性（ACID）：

• 原子性（Atomicity）

  原子性是指事务包含的所有操作不可分割，要么全部成功，要么全部失败回滚。

• 一致性（Consistency）

  执行的前后数据的完整性保持一致。

• 隔离性（Isolation）

  一个事务执行的过程中,不应该受到其他事务的干扰。

• 持久性（Durability）

  事务一旦结束,数据就持久到数据库

  MySQL客户端

  ```plsql mysql> select * from users; +——+—————+————+ | id | name | amount | +——+—————+————+ | 1 | mufeng | 5 | | 2 | deepwind | 6 | +——+—————+————+ 2 rows in set (0.01 sec)

mysql> begin; — 开启事务 start transaction; Query OK, 0 rows affected (0.00 sec)

mysql> update users set amount=amount-2 where id=1; — 执行操作 Query OK, 1 row affected (0.00 sec) Rows matched: 1 Changed: 1 Warnings: 0

mysql> update users set amount=amount+2 where id=2; — 执行操作 Query OK, 1 row affected (0.00 sec) Rows matched: 1 Changed: 1 Warnings: 0

mysql> commit; — 提交事务 rollback; Query OK, 0 rows affected (0.01 sec)

mysql> select * from users; +——+—————+————+ | id | name | amount | +——+—————+————+ | 1 | mufeng | 3 | | 2 | deepwind | 8 | +——+—————+————+ 2 rows in set (0.00 sec)

```plsql
mysql> begin; -- 开启事务
Query OK, 0 rows affected (0.00 sec)
mysql> update users set amount=amount-2 where id=1;   -- 执行操作
Query OK, 1 row affected (0.00 sec)
Rows matched: 1  Changed: 1  Warnings: 0
mysql>  select * from users;
+----+----------+--------+
| id | name     | amount |
+----+----------+--------+
|  1 | mufeng   |      1 |
|  2 | deepwind |      8 |
+----+----------+--------+
2 rows in set (0.00 sec)
mysql> rollback; -- 事务回滚（回到原来的状态）
Query OK, 0 rows affected (0.01 sec)
mysql>  select * from users;
+----+----------+--------+
| id | name     | amount |
+----+----------+--------+
|  1 | mufeng   |      3 |
|  2 | deepwind |      8 |
+----+----------+--------+
2 rows in set (0.00 sec)

Python代码

import pymysql
conn = pymysql.connect(host='127.0.0.1', port=3306, user='root', passwd='root', charset="utf8", db='db1')
cursor = conn.cursor()
# 开启事务
conn.begin()
try:
    cursor.execute("update users set amount=1 where id=1")
    int('asdf')
    cursor.execute("update tran set amount=2 where id=2")
except Exception as e:
    # 回滚
    print("回滚")
    conn.rollback()
else:
    # 提交
    print("提交")
    conn.commit()
cursor.close()
conn.close()