ThinkPHP5 数据库事务 - 03

MySQL :

CREATE DATABASE IF NOT EXISTS `db1` DEFAULT CHARACTER SET utf8 ;

USE `db1`;

CREATE TABLE `think_data` (
`user_id` int(8) unsigned NOT NULL AUTO_INCREMENT,
`user_name` varchar(255) NOT NULL COMMENT '名称',
`deposit` decimal(18,4) DEFAULT NULL,
PRIMARY KEY (`user_id`)
) ENGINE=InnoDB AUTO_INCREMENT=9 DEFAULT CHARSET=utf8;

insert into `think_data`(`user_id`,`user_name`,`deposit`) values (1,'Tim','5000.0000'),(2,'Jason','8000.0000'),(3,'Tom','12001.0000'),(4,'Jack','800051.0000'),(5,'Frank','35009.0000'),(6,'Tina','100.0000'),(7,'Suman','3759.0000'),(8,'Linda','5490.0000');

DELIMITER // -- 不要省略双斜线否则无法创建存储过程
CREATE PROCEDURE transfer(IN from_id INT,IN to_id INT,money DECIMAL(18,4))
BEGIN
    DECLARE CheckError INTEGER;
    DECLARE    CONTINUE HANDLER FOR SQLEXCEPTION SET CheckError = 1;
    START TRANSACTION;
        UPDATE think_data SET deposit = deposit - money WHERE think_data.user_id = from_id ;
   UPDATE think_data SET deposit = deposit + money WHERE think_data.user_id = to_id ;
        INSERT INTO think_data VALUES    (3, 'Rainly',3600.50); -- 人为的制造一个主键重复的错误
        IF CheckError = 1 THEN
            ROLLBACK;
        ELSE
            COMMIT;
        END IF;
     SELECT * FROM think_data WHERE think_data.`user_id` IN(from_id,to_id); -- 返回修改后的记录集合不能放在回滚操作的前面
END; // -- 不要省略双斜线否则无法创建存储过程

-- 执行存储过程的方式：

CALL transfer(5,6,3000)

[[email protected] ~]# cat /dev/null > /var/log/mariadb/queries.log && tail -f /var/log/mariadb/queries.log
170805 14:43:44 10 Query CALL transfer(5,6,3000)

编号为5的账户转账给账户为6的用户 3000元失败了发生了回滚，测试成功！

ThinkPHP5 数据库事务 - 03

INSERT INTO think_data VALUES (3, 'Rainly',3600.50); -- 人为的制造一个主键重复的错误,只要将这条抛出异常的插入操作去掉就是个非常标准存储过程事务

ThinkPHP5 原生SQL事务实现

apps/index/controller/User.php :

<?php

namespace app\index\controller;

use think\Controller;
use think\Request;
use think\Db;
use PDO;

class User extends Controller
{
    /**
     * 显示资源列表
     *
     * @return \think\Response
     */
    public function index()
    {
        $from_id = 5;
        $to_id = 6;
        $money = 3000.54;
        // 启动事务
        $db1 = Db::connect('db1');
        $db1->startTrans();
        try{
            $db1->execute(
                'UPDATE think_data SET deposit = deposit - ? WHERE think_data.user_id = ?',
                [[$money,PDO::PARAM_INT],[$from_id,PDO::PARAM_INT]]
            );
            $db1->execute(
                'UPDATE think_data SET deposit = deposit + ? WHERE think_data.user_id = ?',
                [[$money,PDO::PARAM_INT],[$to_id,PDO::PARAM_INT]]
            );
            // $db1->execute('INSERT INTO think_data VALUES    (3, \'Rainly\',3600.50)');
            $db1->commit();
        } catch (\Exception $e){
            $db1->rollback();
        }
        $resultSet = $db1->query(
            'SELECT * FROM think_data WHERE think_data.`user_id` IN(?,?)',
            [[$from_id,PDO::PARAM_INT],[$to_id,PDO::PARAM_INT]]
        );
        var_dump($resultSet);
    }

    /**
     * 显示创建资源表单页.
     *
     * @return \think\Response
     */
    public function create()
    {

    }

    /**
     * 保存新建的资源
     *
     * @param \think\Request $request
     * @return \think\Response
     */
    public function save(Request $request)
    {

    }

    /**
     * 显示指定的资源
     *
     * @param int $user_id
     * @return \think\Response
     */
    public function read($user_id)
    {

    }

    /**
     * 显示编辑资源表单页.
     *
     * @param int $user_id
     * @return \think\Response
     */
    public function edit($user_id)
    {

    }

    /**
     * 保存更新的资源
     *
     * @param \think\Request $request
     * @param int $user_id
     * @return \think\Response
     */
    public function update(Request $request, $user_id)
    {

    }

    /**
     * 删除指定资源
     *
     * @param int $user_id
     * @return \think\Response
     */
    public function delete($user_id)
    {

    }

    public function miss()
    {

    }
}

路由配置 apps/route.php :

<?php
use think\Route;
//主表路由(分组路由配置顺序必须是从表路由优先配置，否则从表路由一直会路由到主表控制器的方法上)
Route::group(['name'=>'users','prefix'=>'index/User/'], function() {
    Route::get('create$','create',['merge_extra_vars'=>true]);
    Route::post('/$','save',['merge_extra_vars'=>true]);
    Route::get(':user_id/edit$','edit',['merge_extra_vars'=>true]);
    Route::get(':user_id$','read',['merge_extra_vars'=>true]);
    Route::put(':user_id$','update',['merge_extra_vars'=>true]);
    Route::delete(':user_id$','delete',['merge_extra_vars'=>true]);
    Route::get('/$','index',['merge_extra_vars'=>true]);
    Route::miss('miss'); // 在根资源路由里面写miss路由
}, [], ['user_id' => '\d+']);

// create GET http://contoso.org/users/create
// save   POST http://contoso.org/users
// edit   GET http://contoso.org/users/10/edit
// read   GET http://contoso.org/users/10
// update PUT http://contoso.org/users/10
// delete DELETE http://contoso.org/users/10
// index GET http://contoso.org/users

ThinkPHP5 数据库事务 - 03