mirror-fastadminnet/framework
1
0
Fork 0
mirror of https://gitee.com/fastadminnet/framework.git synced 2026-07-02 21:52:34 +08:00
Code Issues Packages Projects Releases Wiki Activity

改进model类的db方法，支持直接使用：

Browse Source 
$model->db('config') //读取config配置参数作为数据库连接信息

$model->db('config','mysql://root@127.0.0.1/test') //读取指定数据库连接信息连接
This commit is contained in:
thinkphp
2015-05-30 15:30:58 +08:00
parent 827e53c7f6
commit 956be17494
1 changed files with 12 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
library/think/model.php
View File

@@ -701,28 +701,31 @@ class Model {
/**
* 切换当前的数据库连接
* @access public
* @param integer $linkNum 连接序号
* @param mixed $linkId 连接标识
* @param mixed $config 数据库连接信息
* @return Model
*/
public function db($linkNum='',$config=''){
if(''===$linkNum && $this->db) {
public function db($linkId='',$config=''){
if(''===$linkId && $this->db) {
return $this->db;
}
if(!isset($this->_db[$linkNum])) {
if(!isset($this->_db[$linkId])) {
// 创建一个新的实例
if(!empty($config) && is_string($config) && false === strpos($config,'/')) { // 支持读取配置参数
if(is_string($linkId) && ''==$config){
$config = Config::get($linkId);
}elseif(!empty($config) && is_string($config) && false === strpos($config,'/')) { // 支持读取配置参数
$config = Config::get($config);
}
$this->_db[$linkNum] = Db::instance($config);
$this->_db[$linkId] = Db::instance($config);
}elseif(null === $config){
$this->_db[$linkNum]->close(); // 关闭数据库连接
unset($this->_db[$linkNum]);
$this->_db[$linkId]->close(); // 关闭数据库连接
unset($this->_db[$linkId]);
return ;
}
// 切换数据库连接
$this->db = $this->_db[$linkNum];
$this->db = $this->_db[$linkId];
$this->_after_db();
return $this;
}