mysql实现事务的提交与回滚的实例详解

最近要对数据库的数据进行一个定时迁移，为了防止在执行过程sql语句因为某些原因报错而导致数据转移混乱，因此要对我们的脚本加以事务进行控制。

首先我们建一张tran_test表

CREATE TABLE tran_test(
f1 VARCHAR(10) NOT NULL,
f2 INT(1) DEFAULT NULL,
PRIMARY KEY (f1)
)ENGINE=INNODB CHARSET=utf8

我想对tran_test插入两条数据，但是为了防止插入中报错，因此我要把插入语句控制在一个事务内。

这时候，如果你查一下有些人的文章，许多时候会给出你这么一条答案。

START TRANSACTION;
INSERT INTO tran_test VALUES('A',1);
INSERT INTO tran_test VALUES('B',2);
ROLLBACK;

或

START TRANSACTION;
INSERT INTO tran_test VALUES('A',1);
INSERT INTO tran_test VALUES('B',2);
COMMIT;

看上去很简单的sql语句，并且这两句也确实能实现提交或回滚。

然而这真的能达到我们的目的吗？答案是否定的。

比如第一段，它是将你在事务中的sql语句无论对错全部进行ROLLBACK。这样绝对的回滚使得你的sql没有任何意义了。

因此我们想要真正的控制好事务，我的思路是对要执行的sql进行异常检测。如果sql没有出现异常，COMMIT，如果捕获到了异常，则ROLLBACK。

这时候，我们就需要建一个存储过程来捕获异常。执行成功时进行COMMIT，sql执行失败时则进行ROLLBACK。

两种思路可以达到我想要的效果。

第一种是对我们要执行的sql进行异常捕获，我们再定义一个变量t_error，当捕获到异常的时候，让t_error=1。再对t_error进行条件判断，如果t_error=1则进行ROLLBACK，否则进行COMMIT。

DROP PROCEDURE IF EXISTS t_test;
DELIMITER //
CREATE PROCEDURE t_test()
 BEGIN
  DECLARE t_error INTEGER;
  DECLARE CONTINUE HANDLER FOR SQLEXCEPTION SET t_error = 1;
  START TRANSACTION;
     INSERT INTO tran_test VALUES('A',1);
   INSERT INTO tran_test VALUES('B',2);
     IF t_error = 1 THEN
       ROLLBACK;
     ELSE
       COMMIT;
     END IF;
END//
CALL t_test();

另一只则是第一种的简化，即捕获到异常直接进行ROLLBACK，如果没捕获到异常，直接COMMIT

DROP PROCEDURE IF EXISTS t_test;
DELIMITER //
CREATE PROCEDURE t_test()
BEGIN
DECLARE EXIT HANDLER FOR SQLEXCEPTION ROLLBACK;
START TRANSACTION;
INSERT INTO tran_test VALUES('A',1);
INSERT INTO tran_test VALUES('B',2);
COMMIT;
END//
CALL t_test()

这样，这两个insert语句便真正的被控制在了一个事务内了。

以上实例大家可以在本次测试一下，如果有其他补充和疑问可以直接联系小编，感谢大家对我们的支持。

赞 (0)

相关推荐

  • mysql实现事务的提交和回滚实例

    mysql创建存储过程的官方语法为: 复制代码 代码如下: START TRANSACTION | BEGIN [WORK]COMMIT [WORK] [AND [NO] CHAIN] [[NO] RELEASE]ROLLBACK [WORK] [AND [NO] CHAIN] [[NO] RELEASE]SET AUTOCOMMIT = {0 | 1} 我这里要说明的mysql事务处理多个SQL语句的回滚情况.比如说在一个存储过程中启动一个事务,这个事务同时往三个表中插入数据,每插完一张表需要

  • python连接mysql并提交mysql事务示例

    复制代码 代码如下: # -*- coding: utf-8 -*-import sysimport MySQLdbreload(sys)sys.setdefaultencoding('utf-8')class DB(object): def __init__(self,host='127.0.0.1',port=3306,user='root',passwd='123',database=''):  self.__host=host  self.__port=port  self.__user

  • Mysql事务隔离级别之读提交详解

    Mysql事务隔离级别之读提交详解

    查看mysql 事务隔离级别 mysql> show variables like '%isolation%'; +---------------+----------------+ | Variable_name | Value | +---------------+----------------+ | tx_isolation | READ-COMMITTED | +---------------+----------------+ 1 row in set (0.00 sec) 可以看到

  • MySQL找出未提交事务信息的方法分享

    MySQL找出未提交事务信息的方法分享

    前阵子,我写了一篇博客"ORACLE中能否找到未提交事务的SQL语句", 那么在MySQL数据库中,我们能否找出未提交事务执行的SQL语句或未提交事务的相关信息呢? 实验验证了一下,如果一个会话(连接)里面有一个未提交事务,然后不做任何操作,那么这个线程处于Sleep状态 mysql> select connection_id() from dual; +-----------------+ | connection_id() | +-----------------+ | 6

  • mysql实现事务的提交与回滚的实例详解

    最近要对数据库的数据进行一个定时迁移,为了防止在执行过程sql语句因为某些原因报错而导致数据转移混乱,因此要对我们的脚本加以事务进行控制. 首先我们建一张tran_test表 CREATE TABLE tran_test( f1 VARCHAR(10) NOT NULL, f2 INT(1) DEFAULT NULL, PRIMARY KEY (f1) )ENGINE=INNODB CHARSET=utf8 我想对tran_test插入两条数据,但是为了防止插入中报错,因此我要把插入语句控制在一

  • git 删除分支和回滚的实例详解

    git 删除分支和回滚的实例详解 [git 删除本地分支] git branch -D br [git 删除远程分支] git push origin :br (origin 后面有空格) git代码库回滚: 指的是将代码库某分支退回到以前的某个commit id [本地代码库回滚]: git reset --hard commit-id :回滚到commit-id,讲commit-id之后提交的commit都去除 git reset --hard HEAD~3:将最近3次的提交回滚 [远程代码

  • golang实现mysql数据库事务的提交与回滚

    MySQL 事务主要用于处理操作量大,复杂度高的数据.在 MySQL 中只有使用了 Innodb 数据库引擎的数据库或表才支持事务. 事务用来管理 insert,update,delete 语句,事务处理可以用来维护数据库的完整性,保证成批的 SQL 语句要么全部执行,要么全部不执行. 一般来说,事务是必须满足4个条件(ACID)::原子性(Atomicity,或称不可分割性).一致性(Consistency).隔离性(Isolation,又称独立性).持久性(Durability). 本文主要

  • MySQL的存储函数与存储过程相关概念与具体实例详解

    目录 MySQL存储过程与存储函数的相关概念 存储过程 存储函数 存储函数与存储过程的对比 存储过程和函数的查看修改删除 MySQL存储过程与存储函数的相关概念 存储函数和存储过程的主要区别: 存储函数一定会有返回值的 存储过程不一定有返回值 存储过程和函数能后将复杂的SQL逻辑封装在一起,应用程序无需关注存储过程和函数内部复杂的SQL逻辑,而只需要简单地调用存储过程和函数即可 存储过程 一组预先编译的SQL语句的封装 执行过程:执行过程预先存储在MySQL服务器上,需要执行的时候,客户端只需要

  • mysql(5.6及以下)解析json的方法实例详解

    mysql(5.6及以下)解析json #json解析函数 DELIMITER $$ DROP FUNCTION IF EXISTS `json_extract_c`$$ CREATE FUNCTION `json_extract_c`( details TEXT, required_field VARCHAR (255) ) RETURNS TEXT CHARSET latin1 BEGIN SET details = SUBSTRING_INDEX(details, "{", -1

  • 详解Java的JDBC API中事务的提交和回滚

    如果JDBC连接是在自动提交模式下,它在默认情况下,那么每个SQL语句都是在其完成时提交到数据库. 这可能是对简单的应用程序,但有三个原因,你可能想关闭自动提交和管理自己的事务: 为了提高性能 为了保持业务流程的完整性 使用分布式事务 若要控制事务,以及何时更改应用到数据库.它把单个SQL语句或一组SQL语句作为一个逻辑单元,而且如果任何语句失败,整个事务失败. 若要启用,而不是JDBC驱动程序默认使用auto-commit模式手动事务支持,使用Connection对象的的setAutoComm

  • 基于Postgresql 事务的提交与回滚解析

    用过oracle或mysql的人都知道在sqlplus或mysql中,做一个dml语句,如果发现做错了,还可以rollback;掉,但在PostgreSQL的psql中,如果执行一个dml,没有先运行begin;的话,一执行完就马上提交了,不能回滚,这样容易导致误操作的发生,有没有什么办法避免这个风险呢? 当然有,在psql中默认是打开自动提交的,我们可以关闭自动提交,方法如下: 设置\set AUTOCOMMIT off test=# create table test1 (x int); C

  • Mysql误操作后利用binlog2sql快速回滚的方法详解

    前言 在日常工作或者学习中,操作数据库时候难免会因为"大意"而误操作,需要快速恢复的话通过备份来恢复是不太可能的,下面这篇文章主要给大家介绍关于Mysql误操作后利用binlog2sql快速回滚的方法,话不多说,来一起看看详细的介绍: 一.总体解释: DML(data manipulation language): 它们是SELECT.UPDATE.INSERT.DELETE,就象它的名字一样,这4条命令是用来对数据库里的数据进行操作的语言 DDL(data definition la

  • SpringBoot事务使用及回滚实现代码详解

    Springboot中事务的使用: 1.启动类加上@EnableTransactionManagement注解,开启事务支持(其实默认是开启的). 2.在使用事务的public(只有public支持事务)方法(或者类-相当于该类的所有public方法都使用)加上@Transactional注解. 在实际使用中一般是在service中使用@Transactional,那么对于controller->service流程中: 如果controller未开启事务,service中开始了事务,servic

随机推荐