前言

有时候，我们需要配置多个数据库，根据业务查询每个数据库下不同的表。

接下来，我们一步一步实现。

一、创建数据库

我这里测试使用的是本地环境（127.0.0.1）。

创建如下图所示 数据库及表（用户表 / 管理员表），简单写点东西：

• admin（数据库名）：administrator_information（表名）
• user（数据库名）：essential_information（表名）

二、配置数据库

注意：数据库连接参数（如用户名密码）应为你个人的，这里暂时用我的，请自行更改。

在 Thinkphp 6 目录中依次定位【config】 →【database.php】，将刚才创建的数据库信息写入配置：

// 数据库连接配置信息// 我们可以在数据库配置文件中定义多个连接信息// 可理解为每个数组项即为一个数据库'connections' => [/*** 用户*/ 'user' => [ // 数据库类型 'type'=> 'mysql', // 服务器地址 'hostname'=> '127.0.0.1', // 数据库名 'database'=> 'user', // 用户名 'username'=> 'root', // 密码 'password'=> 'root', // 端口 'hostport'=> '3306', // 数据库连接参数 'params'=> [], // 数据库编码默认采用utf8 'charset' => 'utf8', // 数据库表前缀 'prefix'=>'', // 数据库部署方式:0 集中式(单一服务器),1 分布式(主从服务器) 'deploy'=> 0, // 数据库读写是否分离 主从式有效 'rw_separate' => false, // 读写分离后 主服务器数量 'master_num'=> 1, // 指定从服务器序号 'slave_no'=> '', // 是否严格检查字段是否存在 'fields_strict' => true, // 是否需要断线重连 'break_reconnect' => false, // 监听SQL 'trigger_sql' => env('app_debug', true), // 开启字段缓存 'fields_cache'=> false, // 字段缓存路径 'schema_cache_path' => app()->getRuntimePath() . 'schema' . DIRECTORY_SEPARATOR, ], /*** 管理员*/ 'admin' => [ // 数据库类型 'type'=> 'mysql', // 服务器地址 'hostname'=> '127.0.0.1', // 数据库名 'database'=> 'admin', // 用户名 'username'=> 'root', // 密码 'password'=> 'root', // 端口 'hostport'=> '3306', // 数据库连接参数 'params'=> [], // 数据库编码默认采用utf8 'charset' => 'utf8', // 数据库表前缀 'prefix'=>'', // 数据库部署方式:0 集中式(单一服务器),1 分布式(主从服务器) 'deploy'=> 0, // 数据库读写是否分离 主从式有效 'rw_separate' => false, // 读写分离后 主服务器数量 'master_num'=> 1, // 指定从服务器序号 'slave_no'=> '', // 是否严格检查字段是否存在 'fields_strict' => true, // 是否需要断线重连 'break_reconnect' => false, // 监听SQL 'trigger_sql' => env('app_debug', true), // 开启字段缓存 'fields_cache'=> false, // 字段缓存路径 'schema_cache_path' => app()->getRuntimePath() . 'schema' . DIRECTORY_SEPARATOR, ],],

三、创建控制器

准备工作全部完成，接下来开始测试。

创建一个控制器 Database.php（随便） ，用于显示测试结果：

<?php namespace app\controller;// 使用门面类(Db)use think\facade\Db;class Database{/** * 连接数据库:user(essential_information表) * @return Array */public function user(){// 读取user数据库中essential_information表所有记录// @connect: 选择数据库// @table：选择该数据库的表$query = Db::connect('user') -> table('essential_information') -> select();return json($query);}/** * 连接数据库:admin(administrator_information表) * @return Array */public function admin(){// 读取admin数据库中administrator_information表所有记录$query = Db::connect('admin') -> table('administrator_information') -> select();return json($query);}}