\Throwable if there is any exception during query. In this case the transaction will be rolled back.
* @return mixed result of callback function
*/
public function transaction(callable $callback, $isolationLevel = null)
{
$transaction = $this->beginTransaction($isolationLevel);
$level = $transaction->level;
try {
$result = call_user_func($callback, $this);
if ($transaction->isActive && $transaction->level === $level) {
$transaction->commit();
}
} catch (\Exception $e) {
$this->rollbackTransactionOnLevel($transaction, $level);
throw $e;
} catch (\Throwable $e) {
$this->rollbackTransactionOnLevel($transaction, $level);
throw $e;
}
return $result;
}
这个方法接受一个回调函数和事务的隔离级别,
从这里我们看出,这个方法虽然解决重复代码,却还有几个问题没有解决:
第一,这个方法抛出的异常我们需要在接收外面处理,我们不可能直接抛出,这样对客户端很不友好。
第二:没有记录日志的行为,即使出了问题也不容易排除。
第三:其实还是第一个问题,如果我们需要对每个异常做处理,在transaction方法外再嵌套一层try...catch...,那么和没有封装好像没什么区别?
根据方法可扩展不可修改的原则,我们应该在自己公共方法里对这个方法进行重载,重载代码如下:
public static function TransactionExecute(callable $function,$level=null)
{
try{
\Yii::$app->db->transaction($function,$level);
}catch (\Exception $e){
//记录日志
\Yii::error($e->getMessage());
//这里可以理解成抛出自定义的异常类。
(new self())->returnWayTip(1004, 'trans异常错误');
}
}然后回到如何传参的问题,我们可以使用闭包,贴一段伪代码,如下:
//执行事务
PublicFunction::TransactionExecute(function () use ($token_reward, $reward_info) {
//业务代码
$token_reward->save(0);
MsgHelper::send($reward_info['post_id'], MsgHelper::SOMEONE_FINISH_REWARD, $reward_info);
});相关推荐:
php中的系统设置有哪些?php中常用系统设置的小结(附代码)
php如何生成json?php生成json的方法代码
以上就是Yii2开发: 如何用类似闭包的方式来封装事务的详细内容,更多请关注php中文网其它相关文章!
网站建设是一个广义的术语,涵盖了许多不同的技能和学科中所使用的生产和维护的网站。
关键词:Yii2开发: 如何用类似闭包的方式来封装事务