草庐IT

MySQL事务(transaction) (有这篇就足够了..)

胡亦. 2023-04-18 原文

MySQL事务处理(TransAction)

大家好,我是胡亦,一名热爱分享技术干货的博主。

思考了很久,决定写一篇关于mysql事务(transaction)的博客,一来嘛,因为最近在复习mysql的相关知识,帮自己回顾总结一下,其次就是想把这篇博客分享给大家,如果你才刚刚开始学习mysql,那么希望这篇博客对你有一点启发;亦或者你早已是一个mysql老油条,这篇博客也会使你对mysql事务有一个更深的印象。

话不多说,正文开始…

首先,什么是事务呢?

事务就是由单独单元的一个或多个sql语句组成,在这个单元中,每个sql语句都是相互依赖的。而整个单独单元是作为一个不可分割的整体存在,类似于物理当中的原子(一种不可分割的最小单位)。

往通俗的讲就是,事务就是一个整体,里面的内容要么都执行成功,要么都不成功。不可能存在部分执行成功而部分执行不成功的情况。

就是说如果单元中某条sql语句一旦执行失败或者产生错误,那么整个单元将会回滚(返回最初状态)。所有受到影响的数据将返回到事务开始之前的状态,但是如果单元中的所有sql语句都执行成功的话,那么该事务也就被顺利执行。

大家都知道,我们的数据都是通过各种不同技术的存储引擎来引导存储的,不同的存储引擎,都有各自的特点。在mysql中,常见的存储引擎有innodb、myisam,memory等。其中innodb支持事务(transaction),而myisam,memory等不支持事务。

可以通过show engines;语句来查看mysql支持的存储引擎

一、事务的四个特性(ACID)【面试常考项】

  • 原子性(Atomicity):指事务是一个不可分割的最小工作单位,事务中的操作只有都发生和都不发生两种情况
  • 一致性(Consistency):事务必须使数据库从一个一致状态变换到另外一个一致状态,举一个栗子,李二给王五转账50元,其事务就是让李二账户上减去50元,王五账户上加上50元;一致性是指其他事务看到的情况是要么李二还没有给王五转账的状态,要么王五已经成功接收到李二的50元转账。而对于李二少了50元,王五还没加上50元这个中间状态是不可见的。
  • 隔离性(Isolation):一个事务的执行不能被其他事务干扰,即一个事务内部的操作及使用的数据对并发的其他事务是隔离的,并发执行的各个事务之间不能互相干扰。
  • 持久性(Durability):一个事务一旦提交成功,它对数据库中数据的改变将是永久性的,接下来的其他操作或故障不应对其有任何影响。

二、事务的分类

事务分为隐式事务和显式事务两种。我们的DML语句(insert、update、delete)就是隐式事务。

  1. 隐式事务:该事务没有明显的开启和结束标记,它们都具有自动提交事务的功能;不妨思考一下,update语句修改数据时,是不是对表中数据进行改变了,它的本质其实就相当于一个事务。

举一个栗子:张三同学买了一个csdn定制保温杯花了99元,是不是就是update语句对字段name为张三的同学的余额balance进行减99元的处理呢?代码如下:

  1. 显示事务:该事务具有明显的开启和结束标记;也是本文重点要讲的东西。使用显式事务的前提是你得先把自动提交事务的功能给禁用。禁用自动提交功能就是设置autocommit变量值为0(0:禁用 1:开启)

先查看一下当前的autocommit变量值,发现当前处于开启自动提交事务的状态

禁用自动提交事务的功能并查看当前状态

三、开启事务的步骤

假设t_account表已经存在

#步骤一:开启事务(可选)
start transaction;
#步骤二:编写事务中的sql语句(insert、update、delete)
#这里实现一下"李二给王五转账"的事务过程
update t_account set balance = 50 where vname = "李二";
update t_account set balance = 130 where vname = "王五";
#步骤三:结束事务
commit; #提交事务
# rollback; #回滚事务:就是事务不执行,回滚到事务执行前的状态

运行结果:

四、事务并发时出现的问题

但是呢,因为某一刻不可能总只有一个事务在运行,可能出现A在操作t_account表中的数据,B也同样在操作t_account表,那么就会出现并发问题,对于同时运行的多个事务,当这些事务访问数据库中相同的数据时,如果没有采用必要的隔离机制,就会发生以下各种并发问题。

  1. 🌴脏读:对于两个事务T1,T2,T1读取了已经被T2更新但还没有被提交的字段之后,若T2回滚,T1读取的内容就是临时且无效
  2. 🌴不可重复读 :对于两个事务T1,T2,T1读取了一个字段,然后T2更新了该字段之后,T1在读取同一个字段,值就不同了
  3. 🌴 幻读:对于两个事务T1,T2,T1在A表中读取了一个字段,然后T2又在A表中插入了一些新的数据时,T1再读取该表时,就会发现神不知鬼不觉的多出几行了…

所以,为了避免以上出现的各种并发问题,我们就必然要采取一些手段。mysql数据库系统提供了四种事务的隔离级别,用来隔离并发运行各个事务,使得它们相互不受影响,这就是数据库事务的隔离性。

五、事务的隔离级别

mysql中的四种事务隔离级别如下:

1. read uncommitted(读未提交数据):允许事务读取未被其他事务提交的变更。(脏读、不可重复读和幻读的问题都会出现)。
2. read committed(读已提交数据):只允许事务读取已经被其他事务提交的变更。(可以避免脏读,但不可重复读和幻读的问题仍然可能出现)
3.repeatable read(可重复读):确保事务可以多次从一个字段中读取相同的值,在这个事务持续期间,禁止其他事务对这个字段进行更新(update)。(可以避免脏读和不可重复读,但幻读仍然存在)
4. serializable(串行化):确保事务可以从一个表中读取相同的行,在这个事务持续期间,禁止其他事务对该表执行插入、更新和删除操作,所有并发问题都可避免,但性能十分低下(因为你不完成就都不可以弄,效率太低)

了解: oracle支持两种事务隔离级别:read committed、serializable。

oracle默认的事务隔离级别是:read committed。

mysql的默认事务隔离级别是:repeatable read。

一个事务与其他事务隔离的程度称为隔离级别。数据库规定了多种事务隔离级别,不同隔离级别对应不同的干扰程度,隔离级别越高,数据一致性就越好,但并发性就越差。

这里通过一个例子向大家简单介绍一下并发:

一个人🚶 在边开车🚕 边打电话📞,首先,人只有一个大脑(cpu),但是在同一时刻他却在执行2件事情,其实内部就是靠他的大脑在不断的切换执行,之所以人民警察👮 不允许司机开车时打电话,就是怕人脑在那一瞬间切换不过来,从而导致交通事故的发生,并发和这个例子是差不多的意思。但在这里,电脑cpu可比人脑快多了,所以出错的概率也相对来说小很多。

接一下,演示一下在几种不同的事务隔离级别下所发生的不同情况😶 。

在演示之前呢,还需要知道如何查看和设置事务的隔离级别

查看当前的事务隔离级别通过 tx_isolation变量或者transaction_isolation(版本8.0以上使用);

语法:select @@tx_isolation;

注意:在mysql8.0之后,就已经抛弃了tx_isolation变量了,而是用 transaction_isolation变量代替了。

语法:select @@transaction_isolation;

#设置当前mysql连接的隔离级别:
set session transaction isolation level read uncommitted;
#设置数据库系统的全局的隔离级别:
set global transaction isolation level read uncommitted;

注意:当前mysql连接的隔离级别和mysql全局的隔离级别的区别是什么?

如果只设置当前的隔离级别,也就是session,那么另外一个并发的“mysqy程序”的隔离级别不会受到当前连接的影响,而是保持默认的repeatable read。

但是如果是设置全局的事务隔离级别,则整个mysql数据库(包括所有打开的mysql程序连接)的隔离级别都会随之改变,除非服务器重启,不然就不会恢复默认了。

两者仅仅一词之差,其效果却天差地别。

好,了解完如何设置事务的隔离级别之后,下面将正式进入…

呃呃呃… 等一下

这里的讲解主要是为了知道在并发的环境下,不同的事务隔离级别所表现出的不同特点,那么自然还是要先模拟一下并发环境

这里打开两个独立的mysql数据库连接(mysql程序1和mysql程序2),用来模拟并发环境

咳咳咳… 正片开始

同志们打起精神认真看啊!!

  • read uncommitted(读未提交)

首先,我们需要先将两个会话的事务隔离级别都设置为read uncommitted;语句如下:

read uncommitted可以读到其他事务还没提交的变更,这里举例:程序2对t_account表中的数据进行更改,看程序1多次查询的结果是否一致。

可以看到程序2改变了t_account表中的vname字段,将李二改为了张三。但是程序1呢,连续2个select查询语句的结果竟然不一致,估计现在程序1的表情和你手机里的第三个表情包一样。这就是read uncommitted隔离级别的特点。
不管你事务是否提交,只要数据发生改变我就可以察觉到…嘻嘻。是不是感觉它很强大。什么事情都逃不过它的法眼。

接下来要看的是read committed(读已提交)

  • read committed(读已提交)

    测试前一定要记住设置事务的隔离级别为read committed;并且禁用自动提交事务【设置autocommit为0】(后面的每个测试都是一样的)

    # 设置事务隔离级别为read committed
    set session transaction isolation level read committed;
    # 禁用自动提交事务功能
    set autocommit = 0; 
    #接下来的 repeatable read 隔离级别和 serializable 隔离级别也是同样的操作
    

以上例子实现了王五为张三转账的事务,可以看到程序2中事务提交前与提交后对程序1中的查询语句产生的影响,前2个查询是事务没提交的结果,最后一个查询是事务提交后的结果。 相信上面的例子已经很充分的诠释了read committed的特点。

  • repeatable read(可重复读)

    该隔离级别为mysql的默认隔离级别;它对某字段进行操作时,其他事务禁止操作该字段。它总能保持你读取的数据是一致的。

    以下代码中,程序1模拟"王五向张三转账30元",程序2则在程序1在处理事务时,对张三的余额进行清空处理

因为当前的事务隔离级别为repeatable read级别,所以在程序1操作t_account表时,程序2是无权对t_account表进行任何操作,如果强行操作的话,就会发生error (错误)

“ERROR 1205 (HY000): Lock wait timeout exceeded; try restarting transaction”;

其中文意思是:“超过锁定等待超时;尝试重新启动事务”

只有当程序1对t_account表操作完成后(结束事务后),程序2才可以对t_account表进行操作。

  • serializable(串行化)

该隔离模式下执行的事务在对某表进行操作期间,禁止其他所有事务对该表进行任何操作

如果强行操作也会报错(和上面那个错误一致),因为serializable用的相对比较少,这里就不做演示了。同学们理解了就好。

  • 事务的保存点(回滚点)

回滚点表示的就是使事务回滚到指定回滚点

语法: savepoint 节点名称 ;

注意:保存点只允许搭配rollback回滚来使用,不能和commit一起使用

已知表t_stu存在,其数据如下:

代码举例如下:

 #禁用自动提交事务
set autocommit = 0;
 #开启事务
start transaction;
 #删除id为2的记录
delete from t_stu where id = 2;
 #设置保存点名为AA
savepoint AA;
 #删除id为3的记录
delete from t_stu where id = 3;
  #回滚到AA保存点处
rollback to AA;

运行结果如下:

可以看到id为2的李四被删除了,而王五却还在,就是因为事务回滚到了AA处,所以id为3的那条记录被回滚掉了。


好了,以上就是本篇博客的全部内容,喜欢的小伙伴们点赞收藏支持一下。

我是lasting,一名热衷于分享技术干货的博主。我们下次见!

有关MySQL事务(transaction) (有这篇就足够了..)的更多相关文章

  1. ruby - 我可以使用 aws-sdk-ruby 在 AWS S3 上使用事务性文件删除/上传吗? - 2

    我发现ActiveRecord::Base.transaction在复杂方法中非常有效。我想知道是否可以在如下事务中从AWSS3上传/删除文件:S3Object.transactiondo#writeintofiles#raiseanexceptionend引发异常后,每个操作都应在S3上回滚。S3Object这可能吗?? 最佳答案 虽然S3API具有批量删除功能,但它不支持事务,因为每个删除操作都可以独立于其他操作成功/失败。该API不提供任何批量上传功能(通过PUT或POST),因此每个上传操作都是通过一个独立的API调用完成的

  2. ruby - 分布式事务和队列,ruby,erlang,scala - 2

    我有一个涉及多台机器、消息队列和事务的问题。因此,例如用户点击网页,点击将消息发送到另一台机器,该机器将付款添加到用户的帐户。每秒可能有数千次点击。事务的所有方面都应该是容错的。我以前从未遇到过这样的事情,但一些阅读表明这是一个众所周知的问题。所以我的问题。我假设安全的方法是使用两阶段提交,但协议(protocol)是阻塞的,所以我不会获得所需的性能,我是否正确?我通常写Ruby,但似乎Redis之类的数据库和Rescue、RabbitMQ等消息队列系统对我的帮助不大——即使我实现某种两阶段提交,如果Redis崩溃,数据也会丢失,因为它本质上只是内存。所有这些让我开始关注erlang和

  3. 使用canal同步MySQL数据到ES - 2

    文章目录一、概述简介原理模块二、配置Mysql使用版本环境要求1.操作系统2.mysql要求三、配置canal-server离线下载在线下载上传解压修改配置单机配置集群配置分库分表配置1.修改全局配置2.实例配置垂直分库水平分库3.修改group-instance.xml4.启动监听四、配置canal-adapter1修改启动配置2配置映射文件3启动ES数据同步查询所有订阅同步数据同步开关启动4.验证五、配置canal-admin一、概述简介canal是Alibaba旗下的一款开源项目,Java开发。基于数据库增量日志解析,提供增量数据订阅&消费。Git地址:https://github.co

  4. ruby-on-rails - 无法安装 mysql2 0.3.14 gem - 2

    我看到其他人也遇到过类似的问题,但没有一个解决方案对我有用。0.3.14gem与其他gem文件一起存在。我已经完全按照此处指示完成了所有操作:https://github.com/brianmario/mysql2.我仍然得到以下信息。我不知道为什么安装程序指示它找不到include目录,因为我已经检查过它存在。thread.h文件存在,但不在ruby​​目录中。相反,它在这里:C:\RailsInstaller\DevKit\lib\perl5\5.8\msys\CORE\我正在运行Windows7并尝试在Aptana3中构建我的Rails项目。我的Ruby是1.9.3。$gemin

  5. ruby - 如何使用 ruby​​ mysql2 执行事务 - 2

    我已经开始使用mysql2gem。我试图弄清楚一些基本的事情——其中之一是如何明确地执行事务(对于批处理操作,比如多个INSERT/UPDATE查询)。在旧的ruby-mysql中,这是我的方法:client=Mysql.real_connect(...)inserts=["INSERTINTO...","UPDATE..WHEREid=..",#etc]client.autocommit(false)inserts.eachdo|ins|beginclient.query(ins)rescue#handleerrorsorabortentirelyendendclient.commi

  6. ruby-on-rails - 在 rails 中提交后回滚事务 - 2

    保存成功后可以回滚吗?让我有一个带有属性名称、电子邮件等的用户模型。例如u=User.newu.name="test_name"u.email="test@email.com"u.save现在记录将成功保存在数据库中,之后我想回滚我的事务(不是销毁或删除)。有什么想法吗? 最佳答案 您可以通过交易来做到这一点,请参阅http://markdaggett.com/blog/2011/12/01/transactions-in-rails/例子:User.transactiondoUser.create(:username=>'Nemu

  7. ruby-on-rails - 当我通过 rvm 使用 rails3 时,如何在 ubuntu 上安装 mysql2 gem? - 2

    我正在尝试绕过rails配置这个极其复杂的迷宫。到目前为止,我设法在ubuntu上设置了rvm(出于某种原因,ruby在ubuntu存储库中已经过时了)。我设法建立了一个Rails项目。我希望我的测试项目使用mysql而不是mysqlite。当我尝试“rakedb:migrate”时,出现错误:“!!!缺少mysql2gem。将其添加到您的Gemfile:gem'mysql2'”当我尝试“geminstallmysql”时,出现错误,告诉我需要为安装命令提供参数。但是,参数列表很大,我不知道该选择哪些。如何通过在ubuntu上运行的rvm和mysql获取rails3?谢谢。

  8. ruby - 如何使用 PG Ruby Gem 有条件地回滚事务 - 2

    我目前正在上一门数据库类(class),其中一个实验室问题让我困惑于如何实现上述内容,事实上,如果可能的话。我试过搜索docs但是定义的交易方式比较模糊。这是我第一次尝试在没有Rails的情况下进行任何数据库操作,所以我有点迷茫。我已经成功地创建了一个到我的postgresql数据库的连接并且可以执行语句,我需要做的最后一件事是根据一个简单的条件回滚一个事务。请允许我向您展示代码:require'pg'@conn=PG::Connection.open(:dbname=>'db_15_11_labs')@conn.prepare('insert','INSERTINTOhouse(ho

  9. ruby-on-rails - 在 Rails 的一个 ActiveRecord 事务中更新多条记录 - 2

    如何使用Rails中的事务block一次性更新/保存模型的多个实例?我想更新数百条记录的值;每条记录的值都不同。这不是一个属性的批量更新情况。Model.update_all(attr:value)在这里不合适。MyModel.transactiondothings_to_update.eachdo|thing|thing.score=rand(100)+rand(100)thing.saveendendsave似乎发布了它自己的事务,而不是将更新分批处理到周围的事务中。我希望所有更新都在一次大交易中进行。我怎样才能做到这一点? 最佳答案

  10. ruby-on-rails - Rails Controller 操作是否隐式定义事务绑定(bind)? - 2

    给定以下代码:defcreate@something=Something.new(params[:something])thing=@something.thing#anothermodel#modificationofattributesonboth'something'and'thing'omitted#doIneedtowrapitinsideatransactionblock?@something.savething.saveendcreate方法是隐式包装在ActiveRecord事务中,还是需要将其包装到事务block中?如果我确实需要包装它,这是最好的方法吗?

随机推荐