[TOC]
如果應用需要使用數據庫,必須配置數據庫連接信息,數據庫的配置文件有多種定義方式。
#### 一、配置文件定義
常用的配置方式是在應用目錄或者模塊目錄下面的database.php中添加下面的配置參數:
~~~php
return [
// 數據庫類型
'type' => 'mysql',
// 數據庫連接DSN配置
'dsn' => '',
// 服務器地址
'hostname' => '127.0.0.1',
// 數據庫名
'database' => 'thinkphp',
// 數據庫用戶名
'username' => 'root',
// 數據庫密碼
'password' => '',
// 數據庫連接端口
'hostport' => '',
// 數據庫連接參數
'params' => [],
// 數據庫編碼默認采用utf8
'charset' => 'utf8',
// 數據庫表前綴
'prefix' => 'think_',
// 數據庫調試模式
'debug' => false,
// 數據庫部署方式:0 集中式(單一服務器),1 分布式(主從服務器)
'deploy' => 0,
// 數據庫讀寫是否分離 主從式有效
'rw_separate' => false,
// 讀寫分離后 主服務器數量
'master_num' => 1,
// 指定從服務器序號
'slave_no' => '',
// 是否嚴格檢查字段是否存在
'fields_strict' => true,
];
~~~
每個模塊可以設置獨立的數據庫連接參數,并且相同的配置參數可以無需重復設置,例如,我們可以在`admin`模塊的`database.php`配置文件中定義:
~~~
return [
// 服務器地址
'hostname' => '192.168.1.100',
// 數據庫名
'database' => 'admin',
];
~~~
表示admin模塊的數據庫地址改成 `192.168.1.100`,數據庫名改成`admin`,其它的連接參數和應用的`database.php`中的配置一樣。
V5.0.6+版本開始,支持Mysql的斷線重連機制,默認關閉,需要的話,是數據庫配置文件中添加:
~~~
// 開啟斷線重連
'break_reconnect' => true,
~~~
##### params 連接參數
可以針對不同的連接需要添加數據庫的連接參數(具體的連接參數可以參考PHP手冊),內置采用的參數包括如下:
~~~
PDO::ATTR_CASE => PDO::CASE_NATURAL,
PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
PDO::ATTR_ORACLE_NULLS => PDO::NULL_NATURAL,
PDO::ATTR_STRINGIFY_FETCHES => false,
PDO::ATTR_EMULATE_PREPARES => false,
~~~
常用數據庫連接參數(params)可以參考PHP在線手冊中的以PDO::ATTR_開頭的常量。
在database中設置的params參數中的連接配置將會和內置的設置參數合并,如果需要使用長連接,并且返回數據庫的小寫列名,可以采用下面的方式定義:
~~~
'params' => [
\PDO::ATTR_PERSISTENT => true,
\PDO::ATTR_CASE => \PDO::CASE_LOWER,
],
~~~
#### 二、方法配置
我們可以在調用Db類的時候動態定義連接信息,例如:
~~~
Db::connect([
// 數據庫類型
'type' => 'mysql',
// 數據庫連接DSN配置
'dsn' => '',
// 服務器地址
'hostname' => '127.0.0.1',
// 數據庫名
'database' => 'thinkphp',
// 數據庫用戶名
'username' => 'root',
// 數據庫密碼
'password' => '',
// 數據庫連接端口
'hostport' => '',
// 數據庫連接參數
'params' => [],
// 數據庫編碼默認采用utf8
'charset' => 'utf8',
// 數據庫表前綴
'prefix' => 'think_',
]);
~~~
或者使用字符串方式:
~~~
Db::connect('mysql://root:1234@127.0.0.1:3306/thinkphp#utf8');
~~~
字符串連接的定義格式為:
~~~
數據庫類型://用戶名:密碼@數據庫地址:數據庫端口/數據庫名#字符集
~~~
注意:字符串方式可能無法定義某些參數,例如前綴和連接參數。
如果我們已經在應用配置文件(注意這里不是數據庫配置文件)中配置了額外的數據庫連接信息,例如:
~~~
//數據庫配置1
'db_config1' => [
// 數據庫類型
'type' => 'mysql',
// 服務器地址
'hostname' => '127.0.0.1',
// 數據庫名
'database' => 'thinkphp',
// 數據庫用戶名
'username' => 'root',
// 數據庫密碼
'password' => '',
// 數據庫編碼默認采用utf8
'charset' => 'utf8',
// 數據庫表前綴
'prefix' => 'think_',
],
//數據庫配置2
'db_config2' => 'mysql://root:1234@localhost:3306/thinkphp#utf8';
~~~
我們可以改成
~~~
Db::connect('db_config1');
Db::connect('db_config2');
~~~
#### 三、模型類定義
如果在某個模型類里面定義了connection屬性的話,則該模型操作的時候會自動連接給定的數據庫連接,而不是配置文件中設置的默認連接信息,通常用于某些數據表位于當前數據庫連接之外的其它數據庫,例如:
~~~
//在模型里單獨設置數據庫連接信息
namespace app\index\model;
use think\Model;
class User extends Model
{
protected $connection = [
// 數據庫類型
'type' => 'mysql',
// 數據庫連接DSN配置
'dsn' => '',
// 服務器地址
'hostname' => '127.0.0.1',
// 數據庫名
'database' => 'thinkphp',
// 數據庫用戶名
'username' => 'root',
// 數據庫密碼
'password' => '',
// 數據庫連接端口
'hostport' => '',
// 數據庫連接參數
'params' => [],
// 數據庫編碼默認采用utf8
'charset' => 'utf8',
// 數據庫表前綴
'prefix' => 'think_',
];
}
~~~
也可以采用DSN字符串方式定義,例如:
~~~
//在模型里單獨設置數據庫連接信息
namespace app\index\model;
use think\Model;
class User extends Model
{
//或者使用字符串定義
protected $connection = 'mysql://root:1234@127.0.0.1:3306/thinkphp#utf8';
}
~~~
并且支持直接使用數據庫連接的配置名稱,例如:
~~~
//在模型里單獨設置數據庫連接信息
namespace app\index\model;
use think\Model;
class User extends Model
{
// 直接使用配置參數名
protected $connection = 'db_config1';
}
~~~
#### 四、使用連接
多表字段查詢合并用例
~~~
//===========================
// 單一表字段數組批量查詢函數
//===========================
function multiQuery($_query,$_conn=null){
$rtn = array();
foreach($_query as $k=>$v){
$conn = array_key_exists('conn',$v)?$v['conn']:$_conn;
$table = array_key_exists('table',$v)?$v['table']:$_table;
$field = array_key_exists('fields',$v)?$v['fields']:$_fields;
$where = array_key_exists('where',$v)?$v['where']:$_where;
if(null!=$conn){
$sql = "SELECT {$field} FROM {$table} WHERE {$where} LIMIT 1";
$res = \think\Db::connect($conn)->query($sql);
}else{
$res = \think\Db::table($table)->where($where)->field($field)->select();
}
$rtn = $res?array_merge($rtn,$res[0]):$rtn;
}
return $rtn;
}
/**
* 表字段初始化
*/
function _initialize(){
//數據表信息
$this->task = 'd_task';
$this->register = 'l_register';
$this->character = 'd_character';
$this->sky_character = 'd_skyladder_char';
$this->user_character = 'd_user_character';
//數據庫連接
$this->reg = Server::getConfig('注冊數據');
$this->conn = Server::getConfig('游戲數據');
parent::_initialize();
}
/**
* 基本信息查詢
*/
function queryBasicInfo(){
//服務器ID
$sid = array_key_exists("sid",$_REQUEST) ? $_REQUEST['sid']:null;
//角色ID昵稱
$id = array_key_exists("id",$_REQUEST)? $_REQUEST['id']:null;
$nickname = array_key_exists("nickname",$_REQUEST)? $_REQUEST['nickname']:null;
$query = [
[
'conn' => $this->conn,
'table'=>$this->character,
'fields'=>"`id`,`nickname`,`level`,`exp`,`money`,`coin`,`energy`,`lastonlogintime`",
'where'=>"(`id`='{$id}' OR `nickname`='{$nickname}')"
],
[
'conn' => $this->conn,
'table'=>$this->sky_character,
'fields'=>"`level` as sky_level,`star` as sky_star,`score` as sky_score,`kingtimes` as sky_image",
'where'=>"`characterid`='{$id}'"
],
[
'conn' => $this->conn,
'table'=>$this->register,
'fields'=>"`id` as uid,`chanel`,`createtime`",
'where'=>"`character`='{$id}'"
],
[
'conn' => $this->conn,
'table'=>$this->task,
'fields'=>"`goal_point`",
'where'=>"`characterid`='{$id}'"
]
];
$res = multiQuery($query);
//查詢數據
$output = array('success' => $res ? true : false, 'msg' => $res ? "提示:查詢成功":"提示:沒有找到玩家信息", 'data'=>$res);
jsonPCallback($output);
exit;
}
~~~