本文實例分析了ThinkPHP框架分布式數據庫連接方法。分享給大家供大家參考,具體如下:
Thinkphp作為國內的一款流行框架,相信使用的人一定不在少數。本篇我們來分析一下Thinkphp中比較重要的一部分——分布式數據庫的連接。
當然了,我們在這里不是去將如何使用模型去對數據庫進行增刪改查。我們是對其底層的連接代碼做一個分析,可以幫助大家更好的理解thinkphp對數據庫的操作。方便我們以后的使用。
一、單一數據庫的連接
在使用的時候,單一數據庫的連接配置非常簡單。我們只需要在配置文件中配置一下的信息即可。
'DB_TYPE' => 'mysql', 'DB_HOST' => '192.168.5.102', 'DB_NAME' => 'databasename', 'DB_USER' => 'user', 'DB_PWD' => 'password', 'DB_PORT' => '3306', 'DB_PREFIX' => 'onmpw_',
設置完成以后就可以使用了。默認情況下就是單一的數據庫連接。
二、分布式數據庫的連接
單一數據庫的連接很簡單,我們著重分析一下分布式數據庫的連接。
'DB_TYPE' => 'mysql', 'DB_HOST' => '192.168.5.191,192.168.5.88,192.168.5.103', 'DB_NAME' => 'test,test,test', 'DB_USER' => 'masteruser,slaveuser,slaveuser', 'DB_PWD' => 'masterpass,slavepass,slavepass', 'DB_PORT' => '3306', 'DB_PREFIX' => '', 'DB_DEPLOY_TYPE' => 1, // 數據庫部署方式:0 集中式(單一服務器),1 分布式(主從服務器) 'DB_RW_SEPARATE' => true, // 數據庫讀寫是否分離 主從式有效 'DB_MASTER_NUM' => 1, // 讀寫分離后 主服務器數量 'DB_SLAVE_NO' => '', // 指定從服務器序號
按照以上配置就可以連接分布式數據庫了。
下面我們看下面幾個選項
'DB_HOST'
分布式數據庫,有幾臺服務器就要填寫幾個服務器地址,每個地址之間用逗號隔開。如果是主從式分布的話,前面的地址要是主數據庫的地址。
對于下面的用戶名和密碼還有監聽端口之類的,當然是有幾個就寫幾個。如果各個數據庫的用戶名和密碼都一樣的話,可以只寫一個。
對于這些選項的解析的代碼如下
$_config['username'] = explode(',',$this->config['username']); $_config['password'] = explode(',',$this->config['password']); $_config['hostname'] = explode(',',$this->config['hostname']); $_config['hostport'] = explode(',',$this->config['hostport']); $_config['database'] = explode(',',$this->config['database']); $_config['dsn'] = explode(',',$this->config['dsn']); $_config['charset'] = explode(',',$this->config['charset']);
'DB_DEPLOY_TYPE'=>1
1 表示是分布式, 0 表示的是集中式(也就是單一服務器)。
該選項的實現是在類 Think\Db\Dirver中
protected function initConnect($master=true) { if(!empty($this->config['deploy'])) // 采用分布式數據庫 $this->_linkID = $this->multiConnect($master); else // 默認單數據庫 if ( !$this->_linkID ) $this->_linkID = $this->connect(); }
$this->config['deploy']
表示的就是'DB_DEPLOY_TYPE'
這個配置選項,上面的配置在使用之前都已經經過解析了,配置項都在$this->config
數組中。至于是如何解析配置文件的,這里我們不做介紹,感興趣的可以參考Think\Db類。
$this->multiConnect()
函數就是用來進行分布式連接的,如果'DB_DEPLOY_TYPE'
選項設置為1,該函數就會執行。否則直接執行$this->connect()
函數。
'DB_RW_SEPARATE'=>true
true 表示讀寫分離;false表示讀寫不分離。
這里需要注意的是,讀寫分離是以主從式數據庫系統為前提的。該選項設置為true的時候主數據庫寫,從數據庫讀。
if($this->config['rw_separate']){ // 主從式采用讀寫分離 if($master) // 主服務器寫入 $r = $m; else{ if(is_numeric($this->config['slave_no'])) {// 指定服務器讀 $r = $this->config['slave_no']; }else{ // 讀操作連接從服務器 $r = floor(mt_rand($this->config['master_num'],count($_config['hostname'])-1)); // 每次隨機連接的數據庫 } } }else{ // 讀寫操作不區分服務器 $r = floor(mt_rand(0,count($_config['hostname'])-1)); // 每次隨機連接的數據庫 }