thinkphp3.2.3框架動(dòng)態(tài)切換多數(shù)據(jù)庫(kù)的方法分析

更新時(shí)間：2020年01月23日 10:26:42 作者：luyaran

這篇文章主要介紹了thinkphp3.2.3框架動(dòng)態(tài)切換多數(shù)據(jù)庫(kù)的方法,結(jié)合實(shí)例形式分析了thinkPHP3.2.3框架多數(shù)據(jù)庫(kù)切換的配置、使用相關(guān)操作技巧與注意事項(xiàng),需要的朋友可以參考下

本文實(shí)例講述了thinkphp3.2.3框架動(dòng)態(tài)切換多數(shù)據(jù)庫(kù)的方法。分享給大家供大家參考，具體如下：

版本說(shuō)明：

thinkphp3.2.3

新增自定義行為類

文件位置：Application/Common/Behaviors/SwitchDbBehavior.class.php

文件內(nèi)容：

namespace Common\Behaviors;
class SwitchDbBehavior
{
 //私有庫(kù)id,如何連接公有庫(kù)則設(shè)置為share字符串
 private $_privateId = '';
 /*
  * 行為擴(kuò)展的執(zhí)行入口必須是run
  * $param 為引用傳值，所以實(shí)參必須是變量
  */
 public function run(&$params)
 {
   //獲取私有庫(kù)id
   $this->_privateId = empty($params) && session('?privateId') ? (int)session('privateId') : trim($params);
   //echo 'curent database is '.$this->_privateId;
   //默認(rèn)連接公有庫(kù)
   if(empty($this->_privateId)) $this->_privateId = 'share';
   $this->_checkDb();
   //連接公有庫(kù)
   if('share' == trim($this->_privateId))
   {
     $share = $this->_connectShare();
   }else
   //連接私有庫(kù)
   {
     $share = $this->_connectPrivate($this->_privateId);
   }
   //循環(huán)修改數(shù)據(jù)庫(kù)配置信息
   foreach($share as $dbKey=>$dbVal)
   {
     C($dbKey,$dbVal);
   }
 }
 /*
 * 判斷數(shù)據(jù)庫(kù)是否存在
 */
 private function _checkDb()
 {
   //C('PRIVATEIDS') 在配置文件Appliation/Common/Conf/dbname.php中定義
   if(!in_array($this->_privateId,C('PRIVATEIDS')))
   {
     exit(__CLASS__.'->'.__FUNCTION__.': dbName error!');
   }
 }
 /*
 * 返回連接私有庫(kù)配置
 */
 private function _connectPrivate($privateId)
 {
   return array(
     'DB_TYPE'  => 'mysql', // 數(shù)據(jù)庫(kù)類型
     'DB_HOST'  => DB_WECHAT_HOST, // 服務(wù)器地址
     'DB_NAME'  => DB_WECHAT_NAME.(int)$privateId, // 數(shù)據(jù)庫(kù)名
     'DB_USER'  => DB_WECHAT_USER, // 用戶名
     'DB_PWD'  => DB_WECHAT_PASS, // 密碼
     'DB_PORT'  => DB_WECHAT_PORT, // 端口
     'DB_PARAMS' => array(), // 數(shù)據(jù)庫(kù)連接參數(shù)
     'DB_PREFIX' => '', // 數(shù)據(jù)庫(kù)表前綴
     'DB_CHARSET'=> 'utf8', // 字符集
     'DB_DEBUG' => DB_WECHAT_DEBUG, // 數(shù)據(jù)庫(kù)調(diào)試模式 開(kāi)啟后可以記錄SQL日志
   );
 }
 /*
 * 返回連接公有庫(kù)配置
 */
 private function _connectShare()
 {
   return array(
     'DB_TYPE'  => 'mysql', // 數(shù)據(jù)庫(kù)類型
     'DB_HOST'  => DB_WECHAT_HOST, // 服務(wù)器地址
     'DB_NAME'  => DB_WECHAT_SHARE_NAME, // 數(shù)據(jù)庫(kù)名
     'DB_USER'  => DB_WECHAT_USER, // 用戶名
     'DB_PWD'  => DB_WECHAT_PASS, // 密碼
     'DB_PORT'  => DB_WECHAT_PORT, // 端口
     'DB_PARAMS' => array(), // 數(shù)據(jù)庫(kù)連接參數(shù)
     'DB_PREFIX' => '', // 數(shù)據(jù)庫(kù)表前綴
     'DB_CHARSET'=> 'utf8', // 字符集
     'DB_DEBUG' => DB_WECHAT_DEBUG, // 數(shù)據(jù)庫(kù)調(diào)試模式 開(kāi)啟后可以記錄SQL日志
   );
 }
}

以上文件中用到的常量在我們的配置文件Application/Common/Conf/constant.php中．內(nèi)容如下：

/*數(shù)據(jù)庫(kù)配置*/
define('DB_WECHAT_HOST','127.0.0.1');        //主機(jī)host
define('DB_WECHAT_USER','common');         //用戶名
define('DB_WECHAT_PASS','common');         //密碼
define('DB_WECHAT_NAME','wechat_');         //私有庫(kù)前綴
define('DB_WECHAT_SHARE_NAME','wechat_share');   //共有庫(kù)名
define('DB_WECHAT_PORT','3306');          //端口
define('DB_WECHAT_DEBUG',TRUE);          //數(shù)據(jù)庫(kù)調(diào)試模式 開(kāi)啟后可以記錄SQL日志

圖中代碼驗(yàn)證數(shù)據(jù)庫(kù)存在不存在的C('PRIVATEIDS')在文件Application/Common/Conf/dbname.php中配置內(nèi)容如下：

<?php
/*
* 本配置文件主要存儲(chǔ)數(shù)據(jù)庫(kù)后綴名，
* 前綴為wechat_,
* 在Application/Common/Behaviors/TestBehavior.class.php中驗(yàn)證
* 注意：在新增數(shù)據(jù)庫(kù)的時(shí)候，注意修改該文件
*
* @author: liangxifeng
* @date: 2016-08-13
*/
return array(
   'PRIVATEIDS'=>array('share',1,2,3,4)
);

constant.php和dbname.php則是在配置文件Application/Common/Conf/config.php中使用擴(kuò)展配置選項(xiàng)配置加載；

'LOAD_EXT_CONFIG' => 'constants,systemConfig,dbname',//加載常量配置

在使用自定義行為類的時(shí)候要在Application/Common/Conf/中新增tags.php

內(nèi)容如下：

/*
* 擴(kuò)展行為類配置文件
* @author:liangxifeng
* @date:2016-08-13
*/
return array(
   //應(yīng)用開(kāi)始標(biāo)簽位添加切換數(shù)據(jù)庫(kù)行為
   'action_begin'=>array('Common\\Behaviors\\SwitchDbBehavior'),
);

行為類介紹請(qǐng)點(diǎn)擊

擴(kuò)展行為類詳細(xì)了解請(qǐng)點(diǎn)擊

使用方法

在注冊(cè)session后或手動(dòng)加載使用，比如在控制器中：

  public function index()
  {
    //注冊(cè)session切換數(shù)據(jù)庫(kù)
    session('privateId',2);
    //手動(dòng)切換數(shù)據(jù)庫(kù)為私有庫(kù)
    tag('action_begin',$params='share');
    $wechat = D('Wechat');
    //查詢數(shù)據(jù)庫(kù)
    $res = $wechat->where('wechat_id=1')->find();
    echo "<pre>";
    var_dump($res);
    exit;
  }

更多關(guān)于thinkPHP相關(guān)內(nèi)容感興趣的讀者可查看本站專題：《ThinkPHP入門教程》、《thinkPHP模板操作技巧總結(jié)》、《ThinkPHP常用方法總結(jié)》、《codeigniter入門教程》、《CI(CodeIgniter)框架進(jìn)階教程》、《Zend FrameWork框架入門教程》及《PHP模板技術(shù)總結(jié)》。

希望本文所述對(duì)大家基于ThinkPHP框架的PHP程序設(shè)計(jì)有所幫助。

您可能感興趣的文章: