Laravel事务处理
事务处理
laravel事务处理的两种常用方法
方法一:
方法二:
我用的时候,需要一个while循环,所以就这样:
小知识

事务处理

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

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循环里面,当循环某个环节出错时,抛出异常后继续循环.

laravel处理事务，Eloquent ORM是不支持的，必须使用DB::  

 

数据库事务处理#

你可以使用 transaction 方法，去执行一组数据库事务处理的操作：

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

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


注意： 在 transaction 闭包若抛出任何异常会导致事务自动回滚。


有时候你可能需要自己开始一个事务：

DB::beginTransaction();

你可以通过 rollback 的方法回滚事务：

DB::rollback();

最后，你可以通过 commit 的方法提交事务：

DB::commit();



获取连接#

若要使用多个连接，可以通过 DB::connection 方法取用：

$users = DB::connection(‘foo‘)->select(...);

你也可以取用原始底层的 PDO 实例：

$pdo = DB::connection()->getPdo();

有时候你可能需要重新连接到特定的数据库：

DB::reconnect(‘foo‘);

如果你因为超过了底层 PDO 实例的 max_connections 的限制，需要关闭特定的数据库连接，可以通过 disconnect 方法:

DB::disconnect(‘foo‘);



查找日志记录#

Laravel 可以在内存里访问这次请求中所有的查找语句。然而在有些例子下要注意，比如一次添加 大量的数据，可能会导致应用程序耗损过多内存。 如果要启用日志，可以使用 enableQueryLog 方法：

DB::connection()->enableQueryLog();

要得到执行过的查找纪录数组，你可以使用 getQueryLog 方法：

$queries = DB::getQueryLog();

官方手册说明：https://learnku.com/docs/laravel/5.6/database/1397#database-transactions

前言:

在操作数据库中，实现一个功能时有时候会多次操作数据库，

在多次操作数据库时，就会有可能出现其中一条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());
        }
	}
	
}

传递参数使用匿名函数use来传递参数，参考(http://www.jicker.cn/5846.html);

返回添加数据的主键可以用  $aid->id 方式返回；

public function create(array $data)
{
    DB::transaction(function () use ($data) {
        $mid = parent::create($data);
        $aid = $this->Access->create(array('type' => 1));
        DB::table('access_relational_menu')->insert(array('aid' => $aid->id, 'mid' => $mid->id));
    });
}

Laravel 事务处理文档 https://laravel-china.org/docs/laravel/5.6/database/1397#09ddab