多应用+插件架构,代码干净,二开方便,首家独创一键云编译技术,文档视频完善,免费商用码云13.8K 广告
[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; } ~~~