Yii2中事務(wù)如何實(shí)現(xiàn)

這篇文章將為大家詳細(xì)講解有關(guān)Yii2中事務(wù)如何實(shí)現(xiàn)，小編覺得挺實(shí)用的，因此分享給大家做個(gè)參考，希望大家閱讀完這篇文章后可以有所收獲。

準(zhǔn)備

數(shù)據(jù)庫(kù)引擎為innodb

本文使用的yii版本為2.0.5，只要是2.0以上就沒有問題

運(yùn)行環(huán)境為PHP7.0.0,Mysql5.6

Yii中的事務(wù)

處理異常

/**
* 測(cè)試事務(wù)
*/
public function actionTest(){
//創(chuàng)建事務(wù)
$tr = Yii::$app->db->beginTransaction();
try {
for($i=1;$i<=3;$i++){
$test = new Areas();
$test->name = 'name'.$i;
$test->sort=1;
if($test->save()){
echo "save $i | ";
}
}
$test = new Areas();
$test->name = 'ab'.$i;
$test->sorta=1; //寫入不存在的字段
if(!$test->save()){
"save fail"; //如果沒有寫入就輸出
}
//提交
$tr->commit();
} catch (Exception $e) {
//回滾
$tr->rollBack();
echo "rollback";
}
}

運(yùn)行結(jié)果

save 1 | save 2 | save 3 | rollback

注意，因?yàn)樽詈蟮臄?shù)據(jù)沒有插入成功，觸發(fā)了事務(wù)的回滾，所以數(shù)據(jù)表沒有新增數(shù)據(jù)產(chǎn)生。

觸發(fā)事務(wù)回滾的原因是代碼出現(xiàn)了異常(Exception)。

處理數(shù)據(jù)失敗

一般來講，我們的運(yùn)行中的代碼是不會(huì)出現(xiàn)這種明顯的異常，這種異常會(huì)在開發(fā)測(cè)試過程中消滅掉。

而真正造成數(shù)據(jù)需要回滾的是我們的某個(gè)業(yè)務(wù)出現(xiàn)問題，導(dǎo)致沒有寫入部分的數(shù)據(jù)。

/**
* 測(cè)試事務(wù)
*/
public function actionTest(){
//創(chuàng)建事務(wù)
$tr = Yii::$app->db->beginTransaction();
try {
for($i=1;$i<=3;$i++){
$test = new Areas();
$test->name = 'name'.$i;
$test->sort=1;
if($test->save()){
echo "save $i | ";
}
}
$test = new Areas();
$test->name = null; //數(shù)據(jù)庫(kù)設(shè)計(jì)name不能為空,人為造成寫入失敗。
$test->sort=1; //寫入不存在的字段
if(!$test->save()){
echo "save fail"; //如果沒有寫入就輸出
}
//提交
$tr->commit();
} catch (Exception $e) {
//回滾
$tr->rollBack();
echo "rollback";
}
}

運(yùn)行結(jié)果如下，數(shù)據(jù)庫(kù)插入了三條數(shù)據(jù)。

save 1 | save 2 | save 3 | save fail

也就是說，如果因?yàn)闃I(yè)務(wù)邏輯導(dǎo)致某個(gè)數(shù)據(jù)表沒有寫入數(shù)據(jù)，也沒有出現(xiàn)對(duì)應(yīng)的回滾。

改進(jìn)方案如下

/**
* 測(cè)試事務(wù)
*/
public function actionTest(){
//創(chuàng)建事務(wù)
$tr = Yii::$app->db->beginTransaction();
try {
for($i=1;$i<=3;$i++){
$test = new Areas();
$test->name = 'name'.$i;
$test->sort=1;
if($test->save()){
echo "save $i | ";
}
}
$test = new Areas();
$test->name = null; //數(shù)據(jù)庫(kù)設(shè)計(jì)name不能為空,人為造成寫入失敗。
$test->sort=1; //寫入不存在的字段
if(!$test->save()){
throw new \yii\db\Exception(); //手動(dòng)拋出異常,再由下面捕獲。
}
//提交
$tr->commit();
} catch (Exception $e) {
//回滾
$tr->rollBack();
echo "rollback";
}
}

運(yùn)行結(jié)果如下，數(shù)據(jù)庫(kù)沒有插入新數(shù)據(jù)，事務(wù)被回滾。

save 1 | save 2 | save 3 | rollback

分散的數(shù)據(jù)處理

由于實(shí)際項(xiàng)目的復(fù)雜程度，導(dǎo)致我們的數(shù)據(jù)庫(kù)操作分散在不同的Model中。

所以，實(shí)際項(xiàng)目的代碼不會(huì)是上面的樣子。

模擬需求

接收參數(shù)：

名字

性別

簽名

業(yè)務(wù)處理流程：

接收參數(shù)

由發(fā)號(hào)器得到用戶的uid，發(fā)號(hào)器對(duì)應(yīng)數(shù)據(jù)表增加一位數(shù)字

把名字、性別、簽名和上一步的uid寫入用戶信息表

初始化用戶余額表

回滾觸發(fā)時(shí)機(jī)：

初始化余額表沒有傳入uid導(dǎo)出沒有寫入數(shù)據(jù)

實(shí)際代碼

//Controller
/**
* 測(cè)試事務(wù)-注冊(cè)用戶
*/
public function actionReg()
{
//獲取請(qǐng)求
$request = Yii::$app->request;
//設(shè)定返回格式
$response = Yii::$app->response;
$response->format = \yii\web\Response::FORMAT_JSON; //返回json
//測(cè)試代碼,去掉驗(yàn)證身份步驟
$name = $request->get("name");
$gender = $request->get("gender");
$sign = $request->get("sign");
//測(cè)試代碼,省略參數(shù)校驗(yàn)步驟
$tr = Yii::$app->db->beginTransaction();
try {
//得到uid
$uid = App::getSeNo();
UserProfile::add($uid, $name, $gender, 1, $sign);
$user_balance = UserBalance::initUserBalance($uid);
$tr->commit(); //提交數(shù)據(jù)
} catch (Exception $e) {
//回滾
$tr->rollBack();
return $e->getMessage(); //返回自定義異常信息
}
return $user_balance;
}
//UserProfile
/**
* 添加用戶信息
* @param $user_id
* @param $nikename
* @param $gender
* @param $user_type
* @param string $intro
* @return UserProfile
* @throws \Exception
*/
public static function add($user_id, $nikename, $gender,$user_type,$intro="") {
$model = new UserProfile();
$model->gender = $gender;
$model->nikename = $nikename;
$model->user_id = $user_id;
$model->user_type=$user_type;
$model->intro=$intro;
$model->update_time = time();
$insert =$model->insert();
if(!$insert){
throw new Exception("沒有寫入用戶資料");
}
return $model;
}
//UserBalance
/**
* 初始化用戶的可提現(xiàn)余額
* @param $user_id
*/
public static function initUserBalance($user_id){
$info=self::find()->where(['user_id'=>$user_id])->one();
if(!$info ){
$model=new UserBalance();
$model->user_id = $user_id;
$model->price= "0";
$model->update_time=time();
$insert = $model->insert();
if(!$insert){
throw new Exception("沒有初始化用戶余額");
}
$info=$model;
}
return $info->attributes;
}

正常的結(jié)果如下

{"id":124,"user_id":1473179883,"price":"0","update_time":1473179883}

如果把初始化用戶余額部分的user_id沒有傳遞成功，返回的結(jié)果如下

"沒有初始化用戶余額"

我們可以針對(duì)具體情況定位到錯(cuò)誤所在位置，及時(shí)修改。

事務(wù)（Transaction）

從上面的實(shí)際代碼可以看出，創(chuàng)建了事務(wù)，只要在范圍內(nèi)，就算是引入的別的Model也能把異常NG返回，完成回滾操作。

一般情況下，整個(gè)Yii應(yīng)用使用了同一個(gè)數(shù)據(jù)庫(kù)連接，或者說是使用了單例。

而在yii\db\Connection中，又對(duì)事務(wù)對(duì)象進(jìn)行了緩存:

class Connection extends Component
{
// 保存當(dāng)前連接的有效Transaction對(duì)象
private $_transaction;
// 已經(jīng)緩存有事務(wù)對(duì)象，且事務(wù)對(duì)象有效，則返回該事務(wù)對(duì)象
// 否則返回null
public function getTransaction()
{
return $this->_transaction && $this->_transaction->getIsActive() ? $this->_transaction : null;
}
// 看看啟用事務(wù)時(shí)，是如何使用事務(wù)對(duì)象的
public function beginTransaction($isolationLevel = null)
{
$this->open();
// 緩存的事務(wù)對(duì)象有效，則使用緩存中的事務(wù)對(duì)象
// 否則創(chuàng)建一個(gè)新的事務(wù)對(duì)象
if (($transaction = $this->getTransaction()) === null) {
$transaction = $this->_transaction = new Transaction(['db' => $this]);
}
$transaction->begin($isolationLevel);
return $transaction;
}
}

關(guān)于“Yii2中事務(wù)如何實(shí)現(xiàn)”這篇文章就分享到這里了，希望以上內(nèi)容可以對(duì)大家有一定的幫助，使各位可以學(xué)到更多知識(shí)，如果覺得文章不錯(cuò)，請(qǐng)把它分享出去讓更多的人看到。