前提:
使用事务处理的话,需要数据库引擎支持事务处理。比如 MySQL 的 MyISAM 不支持事务处理,需要使用 InnoDB 引擎。
事务操作
- 依据 tp5.1手册提供的 事务操作介绍,随便写一个例子:
使用场景
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 异常 即可。