关于 tp5 事务操作总结

前提:

使用事务处理的话,需要数据库引擎支持事务处理。比如 MySQL 的 MyISAM 不支持事务处理,需要使用 InnoDB 引擎。

事务操作

使用场景

    Db::startTrans();
    try{
        Db::name('users')->insert(array('name'=>'mike','age'=>28));
         Db::name('products')->where('id','=',1)->update(array('status'=>2));       
        Db::commit();
        return json_return("事务操作成功");      // json_return() 为封装返回json数据的方法
    }catch (\Exception $e){
        Db::rollback();
        return json_return($e->getMessage());      // json_return() 为封装返回json数据的方法
    }

针对事务操作,我们首先需要了解事务的意义:这里不详述了,不清楚的朋友可参考 MySQL事务 进行了解。

常见问题

  • 问题1:如上代码中如果第一条新增语句 返回 true , 第二条更新语句返回 false ,那这个事务还是会 commit 的,而不是我们预期的rellback,这是为什么?

     如果想让两条 sql 真正按照自己的意愿都 "执行成功(都返回 true 时)" 时再提交事务,那需要这样写:
      Db::startTrans();
      try{
          $res1 = Db::name('users')->insert(array('name'=>'mike','age'=>28));
          $res2= Db::name('products')->where('id','=',1)->update(array('status'=>2));       
      }catch (\Exception $e){
          Db::rollback();
      } 
    
      if($re1 && $re2){
          Db::commit();
          return json_return("事务操作成功");      // json_return() 为封装返回json数据的方法
       }else{
          Db::rollback();
          return json_return($e->getMessage());      // json_return() 为封装返回json数据的方法
       }
    
     【延伸】 事务回滚的条件指的是 sql  语法报错,而不是增加、删除、更改 sql 时的影响行数为0
    
  • 问题2: 在事务中,使用了tp5 的函数 $this->success(),即使事务里面的 sql 语句都成功了,但还是走了rollback,为什么?

           Db::startTrans();
           try{
               Db::name('users')->insert(array('name'=>'mike','age'=>28));
               Db::name('products')->where('id','=',1)->update(array('status'=>2));       
               Db::commit();
               $this->success("事务操作成功");   
           }catch (\Exception $e){
               Db::rollback();
               $this->error($e->getMessage());
           }
    
           是因为$this->success() 这个函数的源码其实也是会抛出异常(这里可查看$this->success() 的方法),
           解决办法:
             将
                catch (\Exception $exception)
             改成
                catch (\think\Exception\DbException $exception)   // 仅catch sql 异常
             即可。
    
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容