Yii连接多个数据库的方法

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 { ... }