前言
有时候,我们需要配置多个数据库,根据业务查询每个数据库下不同的表。
接下来,我们一步一步实现。
一、创建数据库
我这里测试使用的是本地环境(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
{
public function user()
{
// 读取user数据库中essential_information表所有记录
// @connect: 选择数据库
// @table:选择该数据库的表
$query = Db::connect('user') -> table('essential_information') -> select();
return json($query);
}
public function admin()
{
// 读取admin数据库中administrator_information表所有记录
$query = Db::connect('admin') -> table('administrator_information') -> select();
return json($query);
}
}