使用thinkphp3.2.3框架怎么实现动态切换多数据库
创始人
2024-12-06 01:01:23
0次

文件内容:

namespace Common\Behaviors;
class SwitchDbBehavior
{
 //私有库id,如何连接公有库则设置为share字符串
 private $_privateId = '';
 /*
  * 行为扩展的执行入口必须是run
  * $param 为引用传值,所以实参必须是变量
  */
 public function run(&$params)
 {
   //获取私有库id
   $this->_privateId = empty($params) && session('?privateId') ? (int)session('privateId') : trim($params);
   //echo 'curent database is '.$this->_privateId;
   //默认连接公有库
   if(empty($this->_privateId)) $this->_privateId = 'share';
   $this->_checkDb();
   //连接公有库
   if('share' == trim($this->_privateId))
   {
     $share = $this->_connectShare();
   }else
   //连接私有库
   {
     $share = $this->_connectPrivate($this->_privateId);
   }
   //循环修改数据库配置信息
   foreach($share as $dbKey=>$dbVal)
   {
     C($dbKey,$dbVal);
   }
 }
 /*
 * 判断数据库是否存在
 */
 private function _checkDb()
 {
   //C('PRIVATEIDS') 在配置文件Appliation/Common/Conf/dbname.php中定义
   if(!in_array($this->_privateId,C('PRIVATEIDS')))
   {
     exit(__CLASS__.'->'.__FUNCTION__.': dbName error!');
   }
 }
 /*
 * 返回连接私有库配置
 */
 private function _connectPrivate($privateId)
 {
   return array(
     'DB_TYPE'  => 'mysql', // 数据库类型
     'DB_HOST'  => DB_WECHAT_HOST, // 服务器地址
     'DB_NAME'  => DB_WECHAT_NAME.(int)$privateId, // 数据库名
     'DB_USER'  => DB_WECHAT_USER, // 用户名
     'DB_PWD'  => DB_WECHAT_PASS, // 密码
     'DB_PORT'  => DB_WECHAT_PORT, // 端口
     'DB_PARAMS' => array(), // 数据库连接参数
     'DB_PREFIX' => '', // 数据库表前缀
     'DB_CHARSET'=> 'utf8', // 字符集
     'DB_DEBUG' => DB_WECHAT_DEBUG, // 数据库调试模式 开启后可以记录SQL日志
   );
 }
 /*
 * 返回连接公有库配置
 */
 private function _connectShare()
 {
   return array(
     'DB_TYPE'  => 'mysql', // 数据库类型
     'DB_HOST'  => DB_WECHAT_HOST, // 服务器地址
     'DB_NAME'  => DB_WECHAT_SHARE_NAME, // 数据库名
     'DB_USER'  => DB_WECHAT_USER, // 用户名
     'DB_PWD'  => DB_WECHAT_PASS, // 密码
     'DB_PORT'  => DB_WECHAT_PORT, // 端口
     'DB_PARAMS' => array(), // 数据库连接参数
     'DB_PREFIX' => '', // 数据库表前缀
     'DB_CHARSET'=> 'utf8', // 字符集
     'DB_DEBUG' => DB_WECHAT_DEBUG, // 数据库调试模式 开启后可以记录SQL日志
   );
 }
}

以上文件中用到的常量在我们的配置文件Application/Common/Conf/constant.php中. 内容如下:

/*数据库配置*/
define('DB_WECHAT_HOST','127.0.0.1');        //主机host
define('DB_WECHAT_USER','common');         //用户名
define('DB_WECHAT_PASS','common');         //密码
define('DB_WECHAT_NAME','wechat_');         //私有库前缀
define('DB_WECHAT_SHARE_NAME','wechat_share');   //共有库名
define('DB_WECHAT_PORT','3306');          //端口
define('DB_WECHAT_DEBUG',TRUE);          //数据库调试模式 开启后可以记录SQL日志

图中代码验证数据库存在不存在的C('PRIVATEIDS')在文件Application/Common/Conf/dbname.php中配置内容如下:

array('share',1,2,3,4)
);

constant.php和dbname.php则是在配置文件Application/Common/Conf/config.php中使用扩展配置选项配置加载;

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

在使用自定义行为类的时候要在Application/Common/Conf/中新增tags.php

内容如下:

/*
* 扩展行为类配置文件
* @author:liangxifeng
* @date:2016-08-13
*/
return array(
   //应用开始标签位添加切换数据库行为
   'action_begin'=>array('Common\\Behaviors\\SwitchDbBehavior'),
);

行为类介绍请点击

扩展行为类详细了解请点击

使用方法

在注册session后或手动加载使用,比如在控制器中:

  public function index()
  {
    //注册session切换数据库
    session('privateId',2);
    //手动切换数据库为私有库
    tag('action_begin',$params='share');
    $wechat = D('Wechat');
    //查询数据库
    $res = $wechat->where('wechat_id=1')->find();
    echo "
";
    var_dump($res);
    exit;
  }

相关内容

热门资讯

空调连续工作多久需要停机休息 空调连续工作的时间取决于多个因素,包括空调的型号、功率、使用环境和维护情况等。一般来说,空调可以连续...
空调哪个符号是除湿的 空调除湿功能通常用一个水滴形状的符号表示。不同品牌和型号的空调遥控器可能会有所差异,但一般来说,除湿...
格力空调多长时间加一次氟利昂 1、一般情况下,空调对氟利昂的使用量是非常小的,所以在空调使用了四年左右的时候再考虑加也没问题。2、...
空调用多长时间需要加氟一次 一般情况下是五年。当出现以下这几种情况时,空调才需要加氟。1、空调的室内机和室外机各有两个接口,当接...
格调生活·C标思享荟:卡萨帝在... 9月12日的郑州龙湖金融岛,夜风轻拂,灯光璀璨。“C标时刻共传奇——卡萨帝思享荟暨20周年品牌盛典郑...
品牌价值破千亿、高端份额持续领... 9月12日,“C标时刻共传奇——卡萨帝思享荟暨20周年品牌盛典郑州站”在郑州龙湖金融岛举办。2026...
空调主板坏了修800还是换新的 空调主板坏了是修还是换新,需要考虑多个因素,以下是一些建议:1. 维修成本:如果维修费用较低,比如 ...
空调开多久需要休息多长时间 问题:空调开多久需要休息多长时间回答:1、在使用空调的过程中,一般空调开7~8个小时左右需要休息2~...
中央空调多长时间清洗一次 1、一般空调开机前清洗一次即可,空调开机中间时段再清洗一次,空调关机时清洗一次,这样比较合理。2、空...
中央空调氟利昂多久加一次 看空调制热和制冷程度,很多人的观点认为氟利昂必须一年放一次,其实这个观点是错误的,理解上面有点偏差,...