Yii中同时连接多个数据库

0×01: 配置
在主配置文件 (main.php) 中:

1
2
3
4
5
6
7
8
9
10
11
        'db'=>array(
            'connectionString' => 'sqlite:'.dirname(__FILE__).'/../data/testdrive.db',
        ),
    'db2'=>array(
            'class'            => 'CDbConnection' ,
            'connectionString' => 'mysql:host=localhost;dbname=test',
            'emulatePrepare' => true,
            'username' => 'test',
            'password' => 'test',
            'charset' => 'utf8',
        ),

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

0×02 重载 GetDbConnection() 方法
因为每个Model都是(直接或者间接地)继承自基类CActiveRecord的,因此,都包含GetDbConnection()这个方法,GetDbConnection()返回一个数据库连接对象的句柄。我们需要在模型(model)里面通过重载这个方法来返回我们需要的数据库对象。
然后,假设我们新建了一文件 : protected/components/MyActiveRecord.php ,然后在你的所有要用db2这个数据库的model里extend MyActiveRecord 而不是 CActiveRecord 。
这里我们是通过扩展Yii通用类来定义一个新的类,而不是在每个模型里面都重载 getDbConnection 方法,这样做的好处是更大程度上的代码重用,节省时间。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
// protected/components/MyActiveRecord.php
 
class MyActiveRecord extends CActiveRecord {

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

0×03 在模型中使用
经过以上两步以后,我们就可以这样来用:

1
2
3
4
5
// protected/models/Ad.php
 
class Ad extends MyActiveRecord {
    ...
}

参考:
http://www.yiiframework.com/wiki/121/extending-common-classes-to-allow-better-customization/

http://www.yiiframework.com/wiki/78/multiple-databases-and-multiple-domains/

http://www.yiiframework.com/wiki/123/multiple-database-support-in-yii/

更多
3 Responses Post a comment
  1. kuangrenxing

    你好,请问二张不在同一个数据库的表,如何进行relations进行关联?
    在查db2的admin_user表时的SQL是:SELECT * FROM `admin_user` `t` 没有加数据库名,
    在用relations查询
    SELECT `t`.`user_id` AS `t0_c0`, `t`.`firstname` AS `t0_c1`, `profiles`.`birthday` AS `t1_c1`
    FROM `admin_user` `t` LEFT OUTER JOIN `profiles` `profiles` ON (`t`.`user_id`=`profiles`.`user_id`)
    并没有在表名前加数据库名,是有什么办法加数据库名呢?像这样:
    SELECT `t`.`user_id` AS `t0_c0`, `t`.`firstname` AS `t0_c1`, `profiles`.`birthday` AS `t1_c1`
    FROM db1.`admin_user` `t` LEFT OUTER JOIN db2.`profiles` `profiles` ON (`t`.`user_id`=`profiles`.`user_id`)
    谢谢。

  2. Demon

    这个是折腾什么东东呢。

Leave a Reply

Note: You may use basic HTML in your comments. Your email address will not be published.

Subscribe to this comment feed via RSS