MySQL事务简介
【注:简介摘录于《菜鸟教程》】
MySQL 事务主要用于处理操作量大,复杂度高的数据。比如说,在人员管理系统中,你删除一个人员,你即需要删除人员的基本资料,也要删除和该人员相关的信息,如信箱,文章等等,这样,这些数据库操作语句就构成一个事务!
- 在 MySQL 中只有使用了 Innodb 数据库引擎的数据库或表才支持事务。
- 事务处理可以用来维护数据库的完整性,保证成批的 SQL 语句要么全部执行,要么全部不执行。
- 事务用来管理 insert,update,delete 语句
一般来说,事务是必须满足4个条件(ACID)::原子性(Atomicity,或称不可分割性)、一致性(Consistency)、隔离性(Isolation,又称独立性)、持久性(Durability)。
- 原子性:一个事务(transaction)中的所有操作,要么全部完成,要么全部不完成,不会结束在中间某个环节。事务在执行过程中发生错误,会被回滚(Rollback)到事务开始前的状态,就像这个事务从来没有执行过一样。
- 一致性:在事务开始之前和事务结束以后,数据库的完整性没有被破坏。这表示写入的资料必须完全符合所有的预设规则,这包含资料的精确度、串联性以及后续数据库可以自发性地完成预定的工作。
- 隔离性:数据库允许多个并发事务同时对其数据进行读写和修改的能力,隔离性可以防止多个事务并发执行时由于交叉执行而导致数据的不一致。事务隔离分为不同级别,包括读未提交(Read uncommitted)、读提交(read committed)、可重复读(repeatable read)和串行化(Serializable)。
- 持久性:事务处理结束后,对数据的修改就是永久的,即便系统故障也不会丢失。
事务控制语句
语句 | 释义 |
---|---|
BEGIN或START TRANSACTION | 开启mysql事务 |
COMMIT或COMMIT WORK | 提交事务 |
ROLLBACK | 回滚事务(撤销未提交修改) |
SAVEPOINT 名称 | 创建事务保存点,可以有多个保存点 |
RELEASE SAVEPOINT 名称 | 删除事务保存点 |
ROLLBACK TO 名称 | 事务回滚到保存点 |
SET TRANSACTION | 设置事务隔离等级 |
事务自动提交
SET AUTOCOMMIT=1 #开启自动提交SET AUTOCOMMIT=0 #禁止自动提交
事务示例
mysql命令事务示例
mysql> CREATE TABLE 动物表(ID int,Name varchar(255));# 创建数据表mysql> INSERT INTO 动物表 VALUES (1, '小猫');#插入新数据mysql> SELECT * FROM 动物表;+----+------+| ID | Name |+----+------+| 1 | 小猫 |+----+------+mysql> BEGIN; # 开始事务mysql> INSERT INTO 动物表 VALUES (2, '小狗');#插入新数据mysql> SELECT * FROM 动物表;+----+------+| ID | Name |+----+------+| 1 | 小猫 || 2 | 小狗 |+----+------+mysql> SAVEPOINT 事务快照1;#保存的事务1mysql> INSERT INTO 动物表 VALUES (3, '小兔');#插入新数据mysql> SELECT * FROM 动物表;+----+------+| ID | Name |+----+------+| 1 | 小猫 || 2 | 小狗 || 3 | 小兔 |+----+------+mysql> ROLLBACK TO 事务快照1;#回滚到所保存的事务1mysql> SELECT * FROM 动物表;+----+------+| ID | Name |+----+------+| 1 | 小猫 || 2 | 小狗 |+----+------+mysql> ROLLBACK;# 回滚事务【回滚到开始事务时】mysql> COMMIT;# 提交事务mysql> SELECT * FROM 动物表;+----+------+| ID | Name |+----+------+| 1 | 小猫 |+----+------+
PHP中使用事务实例
python中使用事务实例
#!/usr/bin/python# -*- coding:utf8 -*-import pymysqldbhost = '192.168.88.80'dbport = 3306dbuser = 'admin'dbpass = 'Abc123'dbdata = 'mydata'conn = pymysql.connect(host=dbhost,port=dbport,user=dbuser,passwd=dbpass,db=dbdata)print()#建立数据库连接cursor = conn.cursor()#数据库连接游标对象,通过游标执行 sql 语句cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)#数据库连接游标对象,通过游标执行 sql 语句【字典形式展示】try: cursor.execute("CREATE TABLE 测试表(ID int,NAME varchar(20));") #数据库执行-建表测试 cursor.execute("INSERT INTO 测试表(ID, NAME) VALUES (1,'测试员1'),(2,'测试员2'),(3,'测试员3');") #数据库执行-数据插入测试 conn.commit() # 数据库连接命令提交 cursor.execute("BEGIN;") #开始事务 cursor.execute("INSERT INTO 测试表(ID, NAME) VALUES (4,'测试员4');") # 数据库执行-数据插入测试 cursor.execute("错误的sql语句测试!!!") #数据库执行-新增数据插入错误sql语句测试 conn.commit() # 数据库连接命令提交except Exception as e: conn.rollback() # 事务回滚测试 cursor.close() # 关闭游标 conn.close() #关闭数据库连接