Yii 的資料庫操作物件提供的方法確實很方便。 但是有的時候我們已經習慣了我們以前編寫php的資料庫操作語法，沒有那麼多時間去仔細看每個Yii提供的資料庫操作語法，怎麼辦呢？ 那就是一邊學習，一邊二次封裝自己習慣的資料庫操作類。 以後我們使用資料庫操作物件，就用我們自己定義的元件去操作。

將我的資料庫操作元件註冊進配置檔案web.php 中

array(
    'components'  => array(
        //自定義資料庫操作元件
        'dbOper'    =>  array(
            'class'      => 'app\components\DbOper\realization\DbRealization1'
 

        ),

        //Yii 框架資料庫連線元件
        'db'           =>    array(
                'class'         => 'yii\db\Connection',
                'dsn'           => 'mysql:host=localhost;dbname=yii',
                'username'      => 'root',
                'password'      => '123456',
                'charset'
 
       => 'utf8'
            );

    )
)

然後我們就可以在components 目錄下定義我們的資料庫操作類了。 因為，不知道怎麼去獲得php pdo 的原生操作物件，所以這裡是對Yii資料庫操作類的一個二次封裝。

介面檔案 DbOper.php 自定義的資料庫操作類都得實現該介面

<?php
namespace app\components\DbOper;

/**
 * 自定義資料庫操作元件 依賴系統定義元件db
 */
interface DbOper
{
    /**
     * 查詢多條資料
     * @param
     * String $sql 需要查詢的sql語句
     * array  $keyVal 欄位對映
     * @return
 

     * array 查詢結果
     */
    public function fetchAll($sql='',$keyVal=array());

    /**
     * 查詢一條資料 原生sql
     * @param
     * String $sql 需要查詢的sql語句
     * array  $keyVal 欄位對映
     * @return
     * array 查詢結果
     */
    public function fetch($sql='',$keyVal=array());

    /**
     * 新增資料
     * @param
     * String $tableName 表名
     * array  $values 要插入的資料
     * @return
     * int 受影響的行數
     */
    public function insert($tableName='',$values=array());

    /**
     * 更新資料
     * @param
     * String $tableName 表名
     * array | String  $where 修改條件 為 1 時更改該表所有的行
     * array  $update 要更新的資料 
     * @return
     * int 受影響的行數
     */
    public function update($tableName='',$where='',$update=array());

    /**
     * 刪除資料
     * @param
     * String $tableName 表名
     * array | String $where 刪除條件
     * @return
     * int 受影響的行數
     */
    public function delete($tableName='',$where='');

    /**
     * 事務處理
     * @param
     * array $sqls 要執行的sql集合
     * return
     * boolean 是否執行成功
     */
    public function transcation($sqls = array());

    /**
     * 獲得資料庫連結
     */
    public function getYiiDbConnection();
}

針對DbOper 介面的實現類 DbRealization1.php

<?php
namespace app\components\DbOper\realization;

use Yii;

use app\components\DbOper\DbOper;


/**
 * 自定義資料庫操作元件實現類
 */
class DbRealization1 implements DbOper
{
    private $db = null;

    /**
     * interface @Override
     */
    public function fetchAll($sql='',$keyVal=array())
    {
        if($sql === '')
            return array();

        $result = $this->getQueryObj($sql,$keyVal)->queryAll();

        if($result)
            return $result;
        else
            return array();
    }

    /**
     * interface @Override
     */
    public function fetch($sql='',$keyVal=array())
    {
        if($sql === '')
            return array();

        $result = $this->getQueryObj($sql,$keyVal)->queryOne();

        if($result)
            return $result;
        else
            return array();
    }

    /**
     * interface @Override
     */
    public function insert($tableName='',$values=array())
    {
        if($tableName === '')
            return 0;

        $insert = $this->getYiiDbConnection()->createCommand();

        if(is_array($values[0]))
        {
            $keys = array_keys($values[0]);

            return $insert->batchInsert($tableName,$keys,$values)->execute();
        }

        return  $insert->insert($tableName,$values)->execute();
    }

    /**
     * interface @Override
     */
    public function update($tableName='',$where = '',$update=array())
    {
        if($tableName === '')
            return 0;

        if($where === '')
            return 0;

        return $this->getYiiDbConnection()
                ->createCommand()
                ->update($tableName,$update,$where)
                ->execute();
    }

    /**
     * interface @Override
     */
    public function delete($tableName='',$where='')
    {
        if($tableName === '')
            return 0;

        return $this->getYiiDbConnection()
                ->createCommand()
                ->delete($tableName,$where)
                ->execute();
    }

    /**
     * 獲得查詢操作物件
     * @return 
     * Object 
     */
    private function getQueryObj($sql='',$keyVal=array())
    {
        $query = $this->getYiiDbConnection()->createCommand($sql);

        if(!empty($keyVal))
            $query->bindValues($keyVal);

        return $query;
    }

    /**
     * interface @Override
     */
    public function transcation($sqls = array())
    {
        if(empty($sqls))
            return false;

        $db = $this->getYiiDbConnection();

        $outerTransaction = $db->beginTransaction();

        $runClient = true;

        try
        {
            foreach($sqls as $sql)
            {
                $db->createCommand($sql)->execute();
            }

            $outerTransaction->commit();
        }catch(\Exception $e){
            $runClient = false;

            $outerTransaction->rollback();
        }

        return $runClient;
    }

    /**
     * interface @Override
     */
    public function getYiiDbConnection()
    {
        if($this->db === null)
        {
            $this->db = Yii::$app->db;
        }

        return $this->db;
    }
}

注意：我的自定義資料庫操作類 依賴 Yii::$app->db 這個元件， 也就是框架自帶的資料庫連線元件

然後我們就可以通過 Yii::$app->dbOper 去操作資料庫了。