事务处理

对数据库进行多次操作,要么都成功,要么都回滚,就用到了事务处理.

laravel事务处理的两种常用方法

方法一:

DB::beginTransaction();//开启事务,不需要引入文件;
try {
            $sql_one = DB::table('xxxxxx')->insert($row_one);//转移
            $sql_two = DB::table('yyyyyy')->where('message_id', $aaa)->delete();//删除

            DB::commit();

}catch (\Exception $e){
    DB::rollBack();
    throw $e;
}

方法二:

DB::beginTransaction();//开启事务,不需要引入文件;
  $sql_one = DB::table('xxxxxx')->insert($row_one);//转移
  $sql_two = DB::table('yyyyyy')->where('message_id', $aaa)->delete();//删除

 if ($sql_two && $sql_two) {
                DB::commit();
				return 1;
            } else {
                DB::rollBack();
				return 0;
            }

我用的时候,需要一个while循环,所以就这样:

DB::beginTransaction();//开启事务,不需要引入文件;
try {
    while (true) { // 这里看上去这个循环会一直执行
        $row_one = DB::table('yyyyyy')->where('release_date', '<', $mothTime)->first();
        if ($row_one) {
            $row_one = (array)$row_one;
            $aaa = $row_one['message_id'];
            $row_two = DB::table('xxxxxx')->insert($row_one);//转移
            $row_three = DB::table('yyyyyy')->where('message_id', $aaa)->delete();//删除
             DB::commit();
        }else {
            break;
        }
    }

}catch (\Exception $e){
    DB::rollBack();
}

小知识

while循环放在try里面,当循环某个环节出错时,直接抛出异常停止循环
try放在while循环里面,当循环某个环节出错时,抛出异常后继续循环.

前言:
在操作数据库中，实现一个功能时有时候会多次操作数据库，
在多次操作数据库时，就会有可能出现其中一条sql语句执行成功，而另一条sql语句执行失败。
这样的话就会出现很严重的问题，所以可以用MySQL的事务处理来解决这个问题。

!!:在处理多表操作的时候一般是需要用到事务处理的！

//1、开启事务
DB::beginTransaction();
try{
	//2、执行成功时提交事务
	DB::commit();
}catch(\Exception $exception){
	//3、执行成失败时回滚
	DB::rollBack();
}

注意:
其中要注意一点的是，catch里面的抛出异常，Exception前面要加上一个‘\’，不然的话在框架里面他会找不到这个类，然后就不会抛出异常。框架就会直接报错，起不到事务的作用。

//用户注册demo 
<?php
namespace App\Http\Controllers\Api;

use App\Http\Controllers\Controller;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Hash;

class LoginController extends Controller
{
	public function register(Request $request)
	{
			$rules = [
	            'mobile' => 'required',//laravel-sms
	            'password' => 'required|confirmed|min:8',
	        ];
	        
        $msg = [
            'mobile.required' => '请输入手机号码',
            'password.required' => '请输入密码',
        ];
        
        $validator = Validator::make($request->all(), $rules, $msg);
        if ($validator->fails()) {
            $this->throwValidatorException($validator);
        }
        
        $mobile = $request->input('mobile');
        $password = $request->input('password');
        
        //手机号码查重
        $user = User::where('mobile', $mobile)->first();
        if ($user) {
            return $this->errorWithInfo('手机号码已存在');
        }
        
        DB::beginTransaction();
        try{
        	$user = User::create([
                'mobile' => $mobile,
                'password' => Hash::make($password),
            ]);
            
			//用户仓库,创建用户的时候 赋予用户道具 土地等属性（在仓库表中体现）
            UserTool::create([
                'uid' => $user->id,
                'tool_id' => Daoju::TOOL_SEEDER,
                'pay_time' => Carbon::now()->timestamp,
                'nums' => 1,
            ]);
            DB::table('oauth_access_tokens')->where('user_id', $user->id)->update(['revoked' => 1]);
            DB::commit();
            return $this->proxy($mobile, $password);
            
        } catch (\Exception $exception) {
        
            DB::rollBack();
            return $this->errorWithInfo($exception->getMessage());
        }
	}
	
}

数据库事务

可以使用 DB facade 的 transaction 方法在数据库事务中运行一组操作。如果事务的闭包 Closure
中出现一个异常，事务将会回滚。如果事务闭包 Closure 执行成功，事务将自动提交。一旦你使用了 transaction ，
就不必担心手动回滚或提交的问题

换句话说，如果在处理过程中发生了异常，就会回滚到处理之前。
比如，在删除一篇文章时，删除了一篇文章的话，是不是还要删除与它相关的评论，如果在删除文章过程中发生了异常，那么这些评论就会造成数据堆积，造成大量的垃圾数据，就会拖慢我们的服务器运行，所以，使用事务可以处理这些问题

DB::transaction(function () {
    DB::table('users')->update(['votes' => 1]);

    DB::table('posts')->delete();
});

死锁

transaction 方法接受一个可选的第二个参数 ，该参数用来表示事务发生死锁时重复执行的次数。一旦定义的次数尝试完毕，就会抛出一个异常

DB::transaction(function () {
    DB::table('users')->update(['votes' => 1]);

    DB::table('posts')->delete();
}, 5);

手动使用事务

有时候我们不需要使用闭包的方式，我们需要的是自己去控制数据提交和事务处理，那么，就会使用到手动使用事务

如果你想要手动开始一个事务，并且对回滚和提交能够完全控制，那么你可以使用 DB Facade 的 beginTransaction 方法

手动使用事务的话，是要自己开启事务的

DB::beginTransaction();//开启事务

手动使用事务流程

//手动使用事务
        DB::beginTransaction();//开启事务
        try {
            //这里是数据库操作，一旦这里发送错误，
            //就会抛出异常，就不会到提交那一步
            //提交数据--无异常才可以提交
            DB::commit();
        }catch (\Exception $e){
            //进行回滚操作
            DB::rollBack();
        }

例如，我删除文章的同时再删除评论

	//开启事务
        DB::beginTransaction();
        try {
            //删除博客
            $blog->delete();
            //删除博客相关评论
            $blog->comments()->delete();
            //提交事务
            DB::commit();
            return response()->api('删除成功');
        } catch (\ Exception $e) {
        	//回滚
            DB::rollBack();
            return response()->api('删除失败', 400);
        }