关于 MySQL 的嵌套事务

cheer 的个人博客 / 667 / 2 / 创建于 4年前 / 更新于 4年前

MySQL事务

事务

事务的概念就不介绍了, 它的目的是解决ACID问题.

MySQL中的事务必须是InnoDB、Berkeley DB引擎，myisam不支持, 新出了一个memory, 貌似也是不支持的, 大家可以查查。
MySQL默认是autocommit=1，也就是说默认是立即提交，如果想开启事务，先设置autocommit=0，然后用START TRANSACTION、 COMMIT、 ROLLBACK来使用具体的事务。

你可能会有一个疑问: 查询会不会开事务?

根据上面两点可以得出, 如果你在INNODB事务引擎下, 并且autocommit=1 (默认值), 答案是会, 否则不会. 其他引擎不支持事务, 这个问题也不存在.

这时候你可能又有另外一个疑问: 我只是执行单个查询语句, 为什么要开事务?
如果你一次执行单条查询语句，则没有必要启用事务支持，数据库默认支持SQL执行期间的读一致性；
如果你一次执行多条查询语句，例如统计查询，报表查询，在这种场景下，多条查询SQL必须保证整体的读一致性，否则，在前条SQL查询之后，后条SQL查询之前，数据被其他用户改变，则该次整体的统计查询将会出现读数据不一致的状态，此时，应该启用事务支持。

简而言之, 因为你需要ACID中的CI: consistency && isolated

嵌套事务

Transactions cannot be nested. This is a consequence of the implicit commit performed for any current transaction when you issue a START TRANSACTION statement or one of its synonyms.

Mysql是不支持嵌套事务的，开启了一个事务的情况下，再开启一个事务，会隐式的提交上一个事务. 所以我们就要在系统架构层面来支持事务的嵌套, 常见的做法就是SAVEPOINT.

savePoint机制

==测试数据表结构==

id	stock
1	109

START TRANSACTION;
SAVEPOINT a;
UPDATE `user` SET stock = 1 WHERE id = 1;
SAVEPOINT b;
UPDATE `user` SET stock = 2 WHERE id = 1;
ROLLBACK TO b;
commit;

执行的代码，会发有数据表中id=1的行stock值被修改为1。

解读一下代码

开启事物
建立保存点a
更新数据stock为1
建立保存点b（此时id=1的数据stock=1）
更新stock为2
回滚至savepoint b
提交事物

粗读这段代码，即可以知道，savepoint是可以在事务进行中建立保存点，类似游戏中的存档一样，但是有个不一样的地方就是savepoint的持有者是事务，当事务commit或者是完全rollback之后，savepoint就会释放。

THINKPHP

PHP框架THINKPHP5的嵌套事务处理策略: 如果开启了supportSavepoint, 则利用SAVEPOINT来等价子事务, 否则啥也不干, MySQL驱动下默认开启

这产生了一个很重要的结论: 子事务的回滚不会导致事务回滚, 只有第一个事务的回滚才是真正的ROLLBACK

==TP5.1关于嵌套事务的实现源码截取==

    /**
     * 启动事务
     * @access public
     * @return void
     * @throws \PDOException
     * @throws \Exception
     */
    public function startTrans()
    {
        $this->initConnect(true);
        if (!$this->linkID) {
            return false;
        }

        ++$this->transTimes;

        try {
            if (1 == $this->transTimes) {
                $this->linkID->beginTransaction();
            } elseif ($this->transTimes > 1 && $this->supportSavepoint()) {
                $this->linkID->exec(
                    $this->parseSavepoint('trans' . $this->transTimes)
                );
            }
        } catch (\Exception $e) {
            if ($this->isBreak($e)) {
                --$this->transTimes;
                return $this->close()->startTrans();
            }
            throw $e;
        }
    }

    /**
     * 事务回滚
     * @access public
     * @return void
     * @throws PDOException
     */
    public function rollback()
    {
        $this->initConnect(true);

        if (1 == $this->transTimes) {
            $this->linkID->rollBack();
        } elseif ($this->transTimes > 1 && $this->supportSavepoint()) {
            $this->linkID->exec(
                $this->parseSavepointRollBack('trans' . $this->transTimes)
            );
        }

        $this->transTimes = max(0, $this->transTimes - 1);
    }

    /**
     * 用于非自动提交状态下面的查询提交
     * @access public
     * @return void
     * @throws PDOException
     */
    public function commit()
    {
        $this->initConnect(true);

        if (1 == $this->transTimes) {
            $this->linkID->commit();
        }

        --$this->transTimes;
    }

    /**
     * 是否支持事务嵌套
     * @return bool
     */
    protected function supportSavepoint()
    {
        return false;
    }

    /**
     * 生成定义保存点的SQL
     * @access protected
     * @param  $name
     * @return string
     */
    protected function parseSavepoint($name)
    {
        return 'SAVEPOINT ' . $name;
    }

==从TP的实现源码上面可以知道，TP框架在出现嵌套事务时，处理方法就是采用savepoint的策略。startTrans 与 rollback方法都不是直接执行mysql的rollback。他执行分两步==