zoukankan      html  css  js  c++  java
  • 对mysql事务提交、回滚的错误理解

    一、起因

      begin或者START TRANSACTION开始一个事务

      rollback事务回滚
      commit 事务确认

     人们对事务的解释如下:事务由作为一个单独单元的一个或多个SQL语句组成,如果其中一个语句不能完成,整个单元就会回滚(撤销),所有影响到的数据将返回到事务开始以前的状态。因而,只有事务中的所有语句都成功地执行才能说这个事务被成功地执行。

      这句话本身没有什么问题,问题是我给理解错了,我测试中问题描述为如下:

     mysql事务中有两条insert语句,其中第二条语句是错误的,在运行完事务后,第一条仍然插进去了,代码如下。

     //创建表:
    CREATE TABLE `test_tab` (
    `f1`  int(11) NOT NULL ,
    `f2`  varchar(11)  DEFAULT NULL ,
    PRIMARY KEY (`f1`)
    )
    ENGINE=InnoDB
    
    //执行事务:
    START TRANSACTION;
    INSERT INTO test_tab VALUES    (1, '2');
    INSERT INTO test_tab VALUES    (1, '3');
    COMMIT;

    (错误:这只是我一开始的认为)一开始认为只要把事务写出来,最后用commit提交一下,数据库会自动判断这些语句是否全执行成功,如果成功则把所有的数据插入到数据库,如果有一条失败就自动回滚至原始状态!显然我认为错了。

    我执行上面的语句后的结果是:

    [SQL]START TRANSACTION;

    受影响的行: 0

    时间: 0.000s

    [SQL]

    INSERT INTO test_tab VALUES (1, '2');

    受影响的行: 1

    时间: 0.001s

    [SQL]

    INSERT INTO test_tab VALUES (1, '3');

    [Err] 1062 - Duplicate entry '1' for key 'PRIMARY'

    我们看结果可以知道INSERT INTO test_tab VALUES (1, '3');这一句因为主键冲突运行失败,从而这一条下面的commit也没有执行。

    需要注意的是:这时已经开启了一个事务,并且已经执行了一条正确的插入语句,虽然没有体现在数据库中,但如果以后在该连接中又执行了一条commit beginstart transaction新开一个事务会将该链接中的其他未提交的事务提交,相当于commit)你会发现已经将刚才的INSERT INTO test_tab VALUES (1, '2');写进了数据库。

    所以事务的回滚不是这么理解的,正确的理解应该是,如果事务中所有sql语句执行正确则需要自己手动提交commit;否则有任何一条执行错误,需要自己提交一条rollback,这时会回滚所有操作,而不是commit会给你自动判断和回滚。

    二 解决办法

    1. C++调用方式:(简单示例)

    先定义一个变量标志bool m_flag=true;

    再执行事务和sql语句如:(execute为自己写的函数,如下)

    execute( m_sqlCon, “begin”);

    execute(m_sqlCon,”INSERT INTO test_tab VALUES (1, '2')”);

    execute(m_sqlCon,”INSERT INTO test_tab VALUES (1, '3')”);

    如果执行过程中任意一语句出错则将该标志m_flag置为false

    这时不应该去提交commit,而是用一个函数去判断标志是否为false,如果为false说明执行的sql语句中有失败的,就执行rollback,否则说明全部正确,执行commit。如下面的 commit_transaction()方法。

    代码大致如下,如使用需要修改!

     1 privat void execute(MYSQL m_sqlCon, string sqlStatement)
     2 {
     3 r = mysql_real_query(m_sqlCon, sqlStatement, (unsigned long)strlen(sqlStatement));
     4     if (r)
     5         m_flag = false; // 出错则标记一下
     6 }
     7 public bool commit_transaction()
     8 {
     9         int ret_error = 0;
    10         if (!m_flag)
    11         {
    12             cancel_transaction();
    13             return false;
    14         }
    15         else
    16         {
    17             if (!(ret_error = mysql_commit(m_sqlCon)))
    18             {
    19                 cancel_transaction();
    20                 return true;
    21             }
    22         }
    23         return true;
    24 }

    2.利用存储过程:

     1 CREATE PROCEDURE PRO2()
     2 BEGIN
     3     DECLARE t_error INTEGER;
     4     DECLARE    CONTINUE HANDLER FOR SQLEXCEPTION SET t_error = 1;
     5 
     6     START TRANSACTION;
     7         INSERT INTO test_tab VALUES    (1, '2');
     8         INSERT INTO test_tab VALUES    (1, '3');
     9         
    10         IF t_error = 1 THEN
    11             ROLLBACK;
    12         ELSE
    13             COMMIT;
    14         END IF;
    15 END

    然后调用 CALL  PRO2()

    这个直接可以利用mysql去决定他应该是回滚还是提交。

  • 相关阅读:
    redis运维手册
    grafana展示ES中的nginx日志-地图展示
    nginx针对yum安装nginx重编译
    K8S-yaml里初始化容器
    K8S-资源配置清单补充1
    K8S-资源配置清单详解
    Docker cp 提示“no space left on device”
    磁盘
    ansible 对文件内容的操作
    ansible 初始化系统分区格式化
  • 原文地址:https://www.cnblogs.com/jaejaking/p/5342285.html
Copyright © 2011-2022 走看看