Yii连接多个数据库的方法

 

 

一、配置多数据库

大多数情况下，我们都会采用同一类型的数据库，只是为了缓解压力分成主从或分布式形式而已。声明你可以在主配置文件（main.php）中里声明其它的数据库连接：

<?php
    'components'=>array(
        'db'=>....// 主链接
        'db1'=>...// 从连接1
        'db2'=>...// 从连接2
    )

操作在代码里，可以通过Yii::app()->db1和Yii::app()->db2获得两个从连接。

'db1'=>array(
            'class'           =>'CDbConnection' ,
            'connectionString'=> 'mysql:host=localhost;dbname=test;charset=…',
            'emulatePrepare'=> true,
            'username'=> 'test',
            'password'=> 'test',
            'charset'=> 'utf8',
        ),

 

 第二个以后的db1数组中一定要写上class参数，让Yii 知道你在定义一个数据库连接对象，不然会报错。
一旦我们这样定义以后，就可以通过Yii::app()->db1来指向第二个数据库了。

二、重载GetDbConnection() 方法
因为每个Model都是（直接或者间接地）继承自基类CActiveRecord的，因此，都包含GetDbConnection()这个方法，GetDbConnection()返回一个数据库连接对象的句柄。我们需要在模型（model）里面通过重载这个方法来返回我们需要的数据库对象。

然后，假设我们新建了一文件 ： protected/components/Sub1ActiveRecord.php ，然后在你的所有要用db1这个数据库的model里extendSub1ActiveRecord 而不是 CActiveRecord 。
这里我们是通过扩展Yii通用类来定义一个新的类，而不是在每个模型里面都重载 getDbConnection 方法，这样做的好处是更大程度上的代码重用，节省时间。

重载代码如下：

 

// protected/components/MyActiveRecord.php
 
class Sub1ActiveRecord extends CActiveRecord{

    public function getDbConnection()
    {
        if(self::$db!==null)
            returnself::$db;
        else
        {
                       //这里就是我们要修改的
            self::$db=Yii::app()->getComponent('db1');
                       //self::$db=Yii::app()->db1;
            if(self::$db instanceofCDbConnection)
                return self::$db;
            else
                throw new CDbException(Yii::t('yii','Active Record requires a "db1" CDbConnectionapplication component.'));
        }
    }
...........
}

三，在模型中使用
经过以上两步以后，我们就可以这样来用：

1 2 3 4 5

// protected/models/Ad.php   class Ad extends Sub1ActiveRecord {     ... }