13518219792
先创建连接对象
创新互联建站基于10多年网站建设行业经验，一直致力于为中小型企业提供信息化解决方案，创新互联建站做到开放、开源，让企业所有核心数据掌握到企业手里，打破行业乱象，让企业被网络公司掌控的局面不再发生；美工设计部，产品/程序研发部，营销策划部，售后客服部。一切服务为企业量身定制，专注为您！
$connection = new \yii\db\Connection([
'dsn' = $dsn,
'username' = $username,
'password' = $password,
]);
$connection-open();
查询返回多行：
$command = $connection-createCommand('SELECT * FROM post');
$posts = $command-queryAll();
返回单行：
$command = $connection-createCommand('SELECT * FROM post WHERE id=1');
$post = $command-queryOne();
查询多行单值：
$command = $connection-createCommand('SELECT title FROM post');
$titles = $command-queryColumn();
查询标量值/计算值：
$command = $connection-createCommand('SELECT COUNT(*) FROM post');
$postCount = $command-queryScalar();
在saas中，多租户数据库分库管理时常常需要自定义数据库链接，并且需要支持在框架加载后再调用数据库连接。
Yii2 如何定义数据库连接要注意的是：
即除了使用/Yii::app#8722;set()外，还需要再多使用下面一句话：/Yii::app-$database-open();
因为在框架加载后再调用时，yii本身并不会帮打开连接。使用如下代码：
?php/** * User: chenlb */namespace backend/modules/monitorMysql/controllers/show;class AllDatabases extends /yii/base/Action{ private static $_conn = []; public function run() { // Create Test DB Connection $db = $this-getDb('数据库名称'); var_dump($db-getSchema()-getTableSchema('log')-columns['id']-isPrimaryKey); exit; } /** * 得到数据库连接 */ public function getDb($database) { if(!isset(self::$_conn[$database])){ $connInfo = [ 'class' = 'yii/db/Connection', 'dsn' = 'mysql:host=HOST_IP;port=3307;dbname='.$database, 'username' = 'username', 'password' = 'password', 'charset' = 'utf8' ]; /Yii::$app-set($database, $connInfo); /Yii::$app-$database-open(); self::$_conn[$database] = /Yii::$app-$database; } return self::$_conn[$database]; }}
本文实例分析了Yii实现MySQL多数据库和读写分离的方法。分享给大家供大家参考。具体分析如下：Yii Framework是一个基于组件、用于开发大型 Web 应用的高性能 PHP 框架。Yii提供了今日Web 2.0应用开发所需要的几乎一切功能，也是最强大的框架之一，下文我们来介绍Yii实现MySQL多库和读写分离的方法前段时间为SNS产品做了架构设计，在程序框架方面做了不少相关的压力测试，最终选定了YiiFramework，至于为什么没选用公司内部的 PHP框架，其实理由很充分，公司的框架虽然是"前辈"们辛苦的积累，但毕竟不够成熟，没有大型项目的历练，犹如一个涉世未深的年轻小伙。Yii作为一个 颇有名气开源产品，必定有很多人在使用，意味着有一批人在维护，而且在这之前，我也使用Yii开发过大型项目，Yii的设计模式和它的易扩展特性足以堪当重任。SNS同一般的社交产品不同的就是它最终要承受大并发和大数据量的考验，架构设计时就要考虑这些问题， web分布式、负载均衡、分布式文件存储、MySQL分布式或读写分离、NoSQL以及各种缓存，这些都是必不可少的应用方案，本文所讲的就是MySQL 分库和主从读写分离在Yii的配置和使用。Yii默认是不支持读写分离的，我们可以利用Yii的事件驱动模式来实现MySQL的读写分离。Yii提供了一个强大的CActiveRecord数据库操作类，通过重写getDbConnection方法来实现数据库的切换，然后通过事件 beforeSave、beforeDelete、beforeFind 来实现读写服务器的切换，还需要两个配置文件dbconfig和modelconfig分别配置数据库主从服务器和model所对应的数据库名称，附代码DBConfig.php文件如下：复制代码 代码如下:?phpreturn array('passport' = array('write' = array('class' = 'CDbConnection','connectionString' = 'mysql:host=10.1.39.2;dbname=db1′,'emulatePrepare' = true,//'enableParamLogging' = true,'enableProfiling' = true,'username' = 'root','password' = '','charset' = 'utf8′,'schemaCachingDuration'=3600,),'read' = array(array('class' = 'CDbConnection','connectionString' = 'mysql:host=10.1.39.3;dbname=db1,'emulatePrepare' = true,//'enableParamLogging' = true,'enableProfiling' = true,'username' = 'root','password' = '','charset' = 'utf8′,'schemaCachingDuration'=3600,),array('class' = 'CDbConnection','connectionString' = 'mysql:host=10.1.39.4;dbname=db3′,'emulatePrepare' = true,//'enableParamLogging' = true,'enableProfiling' = true,'username' = 'root','password' = '','charset' = 'utf8′,'schemaCachingDuration'=3600,),),),);ModelConfig.php如下：复制代码 代码如下:?phpreturn array(//key为数据库名称，value为Model'passport' = array('User','Post'),'microblog' = array('…'),);?ActiveRecord.php如下：复制代码 代码如下:/*** 基于CActiveRecord类的封装，实现多库和主从读写分离* 所有Model都必须继承些类.**/class ActiveRecord extends CActiveRecord{//model配置public $modelConfig = '';//数据库配置public $dbConfig = '';//定义一个多数据库集合static $dataBase = array();//当前数据库名称public $dbName = '';//定义库类型(读或写)public $dbType = 'read'; //'read' or 'write'/*** 在原有基础上添加了一个dbname参数* @param string $scenario Model的应用场景* @param string $dbname 数据库名称*/public function __construct($scenario='insert', $dbname = ''){if (!empty($dbname))$this-dbName = $dbname;parent::__construct($scenario);}/*** 重写父类的getDbConnection方法* 多库和主从都在这里切换*/public function getDbConnection(){//如果指定的数据库对象存在则直接返回if (self::$dataBase[$this-dbName]!==null)return self::$dataBase[$this-dbName];if ($this-dbName == 'db'){self::$dataBase[$this-dbName] = Yii::app()-getDb();}else{$this-changeConn($this-dbType);}if(self::$dataBase[$this-dbName] instanceof CDbConnection){self::$dataBase[$this-dbName]-setActive(true);return self::$dataBase[$this-dbName];} elsethrow new CDbException(Yii::t('yii','Model requires a "db" CDbConnection application component.'));}/*** 获取配置文件* @param unknown_type $type* @param unknown_type $key*/private function getConfig($type="modelConfig",$key="){$config = Yii::app()-params[$type];if($key)$config = $config[$key];return $config;}/*** 获取数据库名称*/private function getDbName(){if($this-dbName)return $this-dbName;$modelName = get_class($this-model());$this-modelConfig = $this-getConfig('modelConfig');//获取model所对应的数据库名if($this-modelConfig)foreach($this-modelConfig as $key=$val){if(in_array($modelName,$val)){$dbName = $key;break;}}return $dbName;}/*** 切换数据库连接* @param unknown_type $dbtype*/protected function changeConn($dbtype = 'read'){if($this-dbType == $dbtype self::$dataBase[$this-dbName] !== null)return self::$dataBase[$this-dbName];$this-dbName = $this-getDbName();if(Yii::app()-getComponent($this-dbName.'_'.$dbtype) !== null){self::$dataBase[$this-dbName] = Yii::app()-getComponent($this-dbName.'_'.$dbtype);return self::$dataBase[$this-dbName];}$this-dbConfig = $this-getConfig('dbConfig',$this-dbName);//跟据类型取对应的配置(从库是随机值)if($dbtype == 'write'){$config = $this-dbConfig[$dbtype];}else{$slavekey = array_rand($this-dbConfig[$dbtype]);$config = $this-dbConfig[$dbtype][$slavekey];}//将数据库配置加到component中if($dbComponent = Yii::createComponent($config)){Yii::app()-setComponent($this-dbName.'_'.$dbtype,$dbComponent);self::$dataBase[$this-dbName] = Yii::app()-getComponent($this-dbName.'_'.$dbtype);$this-dbType = $dbtype;return self::$dataBase[$this-dbName];} elsethrow new CDbException(Yii::t('yii','Model requires a "changeConn" CDbConnection application component.'));}/*** 保存数据前选择 主 数据库*/protected function beforeSave(){parent::beforeSave();$this-changeConn('write');return true;}/*** 删除数据前选择 主 数据库*/protected function beforeDelete(){parent::beforeDelete();$this-changeConn('write');return true;}/*** 读取数据选择 从 数据库*/protected function beforeFind(){parent::beforeFind();$this-changeConn('read');return true;}/*** 获取master库对象*/public function dbWrite(){return $this-changeConn('write');}/*** 获取slave库对象*/public function dbRead(){return $this-changeConn('read');}}这是我写好的类，放在components文件夹里，然后所有的Model都继承ActiveRecord类就可以实现多库和主从读写分离了，至于如何支持原生的SQL也同时使用读写分离，此类都已经实现。希望本文所述对大家基于Yii框架的PHP程序设计有所帮助。
yii2 的debug工具条可以看到所有东西，比如log和sql（所有执行的sql）都可以找到，
一般都是默认开启的（除非你在执行\init这个脚本的时候，选择了生产环境）
如果没有，可以在配置文件中加入：
config['bootstrap'][] = 'debug';
$config['modules']['debug'] = [
'class' = 'yii\debug\Module',
'allowedIPs' = ['127.0.0.1', '::1'],
];
然后刷新页面，就可以在底部看到debug工具栏了
如果你的应用是restful的，会看不到debug工具栏，不过你可以从其他页面进入debug页面，在那里面可以选择哪个请求所发生的sql。具体自己慢慢看界面吧，文字难说
这个有很多种方法
1. yii有提供一个 getRawSql方法 比如说一个查询
$query = User::find();
$query-select(['username','age'])-where(['id'=1)-one();
echo $query-createCommand()-getRawSql();//输出sql语句
2.可开启yii2的debug模块,这个功能很强大,在里面可以查到当前页面所有的sql信息，具体配置方法自行百度,网上太多这个配置了
3.查找Yii源码 随便找个模型调用原生的方法 比如 User::updateAll 方法,通过编辑器定位到updateAll方法的源码 你会发现下面一段代码
public static function updateAll($attributes, $condition = '', $params = [])
{
$command = static::getDb()-createCommand();
$command-update(static::tableName(), $attributes, $condition, $params);
return $command-execute();
}
继续定位execute方法
public function execute()
{
$sql = $this-getSql();
$rawSql = $this-getRawSql();
Yii::info($rawSql, __METHOD__);
if ($sql == '') {
return 0;
}
$this-prepare(false);
$token = $rawSql;
try {
Yii::beginProfile($token, __METHOD__);
$this-pdoStatement-execute();
$n = $this-pdoStatement-rowCount();
Yii::endProfile($token, __METHOD__);
$this-refreshTableSchema();
return $n;
} catch (\Exception $e) {
Yii::endProfile($token, __METHOD__);
throw $this-db-getSchema()-convertException($e, $rawSql);
}
}
方法里 $rawSql就是最原生要执行的sql拉，在这里打断点输出就ok
个人推荐第二种方法，最方法最高效，具体配置方法自己百度,很简单!
