ThinkPHP连接两个MySQL数据库的实用代码示例-ThinkPHP-PHP中文网

在thinkphp中需在database.php配置多个连接名（如db_main、db_log），模型通过$connection属性指定，跨库不支持join和事务，须应用层拼装查询并采用最终一致性方案。

thinkphp连接两个mysql数据库的实用代码示例

如何在ThinkPHP中同时配置两个MySQL数据库

ThinkPHP支持多数据库连接，但必须通过配置文件显式声明多个连接名，不能只靠database.php里默认的default配置。核心是给每个库起唯一连接标识（如db_main、db_log），并在database.php中以键值对形式定义。

常见错误是直接复制一份default数组并改名，却忘了把default字段也同步改成新连接名——这会导致ThinkPHP仍只读取第一个配置，第二个被忽略。

在config/database.php中添加两个完整连接配置，例如：

'db_main' => [
    'type'         => 'mysql',
    'hostname'     => '192.168.1.100',
    'database'     => 'main_db',
    'username'     => 'user_a',
    'password'     => 'pass_a',
    'hostport'     => '3306',
],
'db_log' => [
    'type'         => 'mysql',
    'hostname'     => '192.168.1.101',
    'database'     => 'log_db',
    'username'     => 'user_b',
    'password'     => 'pass_b',
    'hostport'     => '3306',
],

确保每个配置块顶层键名（如db_main）与你后续调用时传入的连接名严格一致，包括大小写
不要删掉原有的default配置，除非你确定所有模型都不走默认连接；否则未指定连接的查询会 fallback 到它

在模型中指定使用哪个数据库连接

ThinkPHP模型默认走default连接，要切到其他库，必须在模型类中显式设置$connection属性。这个属性值必须和database.php里的连接键名完全匹配。

容易踩的坑是把$connection写成数据库名（如'main_db'）或DSN字符串，实际它只接受配置键名（如'db_main'）。

btpanel phpsite 宝塔面板PHP网站

宝塔面板 PHP 网站管理：站点创建、删除、启停、PHP 版本切换、域名管理、SSL证书管理、伪静态管理、数据库管理

下载

在app/model/User.php中指定主库：

namespace app\model;
use think\Model;

class User extends Model
{
    protected $connection = 'db_main';
}

在app/model/LogRecord.php中指定日志库：

class LogRecord extends Model
{
    protected $connection = 'db_log';
}

若某个方法需临时切换连接（比如从User模型里查一次日志），可用Db::connect('db_log')->table('log_table')->select()，但注意这绕过了模型逻辑，不触发事件和自动转换

跨库关联查询的替代方案

MySQL本身不支持跨实例JOIN（除非用FEDERATED引擎，但生产环境极少启用），ThinkPHP的relation也无法跨$connection生效。所谓“两个数据库的关联”，实际只能靠应用层拼装。

典型场景：查出User列表后，再批量查LogRecord中对应user_id的日志。硬写IN子查询或循环查，性能差且易超时。

优先用两次独立查询 + PHP数组映射：

$users = User::where('status', 1)->select();
$userIds = array_column($users, 'id');
$logs = LogRecord::where('user_id', 'in', $userIds)->select();

// 合并到users结构中（自行实现）
foreach ($users as $u) {
    $u->logs = array_filter($logs, fn($l) => $l['user_id'] == $u['id']);
}

避免在循环里调用LogRecord::where('user_id', $u['id'])->select()，单条查N次比一次IN查慢一个数量级
如果日志量极大且必须实时关联，考虑把日志表迁到主库做分表，或引入Redis缓存预聚合结果

事务无法跨数据库连接

ThinkPHP的Db::transaction()或模型startTrans()只作用于当前连接。试图在一个事务里同时操作db_main和db_log，会导致只有第一个连接生效，第二个提交不受事务控制——这是MySQL底层限制，框架无法绕过。

真正需要强一致性的跨库操作（如扣款+记日志），要么合并到同一实例，要么改用最终一致性方案（如发消息队列异步补日志）。

以下代码看似用了事务，实则无效：

Db::connect('db_main')->transaction(function () {
    User::where('id', 123)->update(['balance' => 99]);
    // 下行不在事务内！
    LogRecord::where('user_id', 123)->insert(['action' => 'deduct']);
});