MySQL事务处理

| 阅读:167 发表时间:2019-12-30 19:48:16 Mysql

1 事务处理注意点

  • MySQL中Innodb支持事务,而MyISAM不支持事务
  • 事务 的ACID 特性:Atomicity(原子性)、Consistency(稳定性)、Isolation(隔离性)、Durability(可靠性)

原子性(Atomicity):事务开始后的所有操作,要么全部做完,要么全部不做。事务执行过程中出错,会回滚到事务开始前的状态,所有的操作就像没有发生一样。

一致性(Consistency):事务开始前和结束后,数据库的完整性约束没有被破坏 。比如A向B转账,不可能A扣了钱,B却没收到。

隔离性(Isolation):同一时间,只允许一个事务请求同一数据,不同的事务之间彼此没有任何干扰。比如A正在从一张银行卡中取钱,在A取钱的过程结束前,B不能向这张卡转账。

持久性(Durability):事务完成后,事务对数据库的所有更新将被保存到数据库,不能回滚。

并发问题

1、脏读:事务A读取了事务B更新的数据,然后B回滚操作,那么A读取到的数据是脏数据

2、不可重复读:事务 A 多次读取同一数据,事务 B 在事务A多次读取的过程中,对数据作了更新并提交,导致事务A多次读取同一数据时,结果 不一致。

3、幻读:系统管理员A将数据库中所有学生的成绩从具体分数改为ABCDE等级,但是系统管理员B就在这个时候插入了一条具体分数的记录,当系统管理员A改结束后发现还有一条记录没有改过来,就好像发生了幻觉一样,这就叫幻读。

注:不可重复读的和幻读很容易混淆,不可重复读侧重于修改,幻读侧重于新增或删除。解决不可重复读的问题只需锁住满足条件的行,解决幻读需要锁表

  • MySQL事务隔离级别
事务隔离级别脏读不可重复读幻读
读未提交(read-uncommitted)
不可重复读(read-committed)
可重复读(repeatable-read)
串行化(serializable)

设置隔离级别:

SET SESSION TRANSACTION ISOLATION LEVEL READ UNCOMMITTED;
  • 只有增删改语句才支持事务

2 MySQL事务处理

创建测试表及数据

CREATE TABLE `user` (

`id` int(11) NOT NULL AUTO_INCREMENT,

`name` char(20) NOT NULL,

PRIMARY KEY (`id`)

) ENGINE=InnoDB DEFAULT CHARSET=utf8;

INSERT INTO `user` VALUES ('1', 'brell');

INSERT INTO `user` VALUES ('2', 'jaky');

查询id为1的用户

SELECT * FROM user WHERE id=1;

查询结果

20190313152920667.png

开始一个事务

开始一个事务

start transaction

删除id为1的用户

DELETE FROM `user` WHERE id=1;

再查询一下id为1的用户,此时该用户已经不存在了


SELECT * FROM `user` WHERE id=1;

20190313153451190.png

如果确认操作无误的话可以使用COMMIT提交事务,操作有误的话可以使用ROLLBACK回滚事务,这里我们测试一下回滚事务,然后再查询一下id为1的用户,看看数据是否回滚。

ROLLBACK
SELECT * FROM `user` WHERE id=1;

20190313153957901.png

此时再次查询到id为1的用户,说明事务已经回滚。

3 PHP之PDO处理事务PDO处理事务


$pdo->beginTransaction(); // 开启一个事务
$pdo->commit(); // 提交事务
$pdo->rollback(); // 回滚事务 使用案例
<?php  
try {  
    $pdo->beginTransaction(); // 开启一个事务  
    $row = null;  
    $row = $pdo->exec("INSERT INTO `user` VALUE(1,'brell')"); 
    if (!$row){
      throw new PDOException('添加第一个用户失败');
    }      
    $row = $pdo->exec("UPDATE user SET name='jaky' WHERE id=1");
    if (!$row){
      throw new PDOException('更新用户失败');
    }          
    $pdo->commit();  
} catch (PDOException $e) {  
    $pdo->rollback();        // 执行失败,事务回滚  
    exit($e->getMessage());  // 输出错误信息
}  
?>

4 PHP之MySQLi处理事务

$mysqli = new mysqli("localhost","root","","test"); //连接数据库

$mysqli->autocommit(false); //设置为非自动提交

$sql1  = "INSERT INTO 'user' VALUE(1,'brell')";

$result1 = $mysqli->query($sql1);

$sql2  = "INSERT INTO 'user' VALUE(2,'jaky')";

$result2 = $mysqli->query($sql2);

if ($result1 && $result2) {

    $mysqli->commit();  //操作无误,提交事务

    echo '事务处理完成';

} else {

    $mysqli->rollback(); //回滚事务

    echo '操作失败,回滚事务';

}

$mysqli->autocommit(true); //重新设置为自动提交

$mysqli->close();

热门推荐