ThinkPHP 8.0 动态连接多个异构数据库实战跨库

在 ThinkPHP 8.0 中同时操作 MySQL 和 PostgreSQL，必须手动配置连接、显式指定驱动、规避跨库事务陷阱，并处理 JSON 查询语法差异——框架不自动转换 SQL，也不合并跨库结果。

在 ThinkPHP 8.0 中同时操作 MySQL 和 PostgreSQL，必须手动配置连接、显式指定驱动、规避跨库事务陷阱，并处理 JSON 查询语法差异——框架不自动转换 SQL，也不合并跨库结果。

第一步：在 database.php 中预定义两个异构连接

打开 config/database.php，定位到 connections 数组，新增两个键名全小写、无点号、无大写的连接配置：

① 键名为 mysql_main，type 必须设为 mysql，hostname 填 127.0.0.1（Windows 下写 localhost 会静默走命名管道，导致 SQLSTATE[HY000] [2054] 错误）；

② 键名为 pgsql_log，type 必须设为 pgsql，hostname 填 192.168.1.12（PostgreSQL 实例 IP），database 值必须是已存在的 schema 名（如 log_db），不能是 public——PostgreSQL 默认 schema 不等于 MySQL 的 database 概念；

③ 两个连接都必须显式声明 charset：MySQL 用 utf8mb4，PostgreSQL 用 utf8；漏掉 charset 会导致中文插入截断或乱码；

立即学习“PHP免费学习笔记（深入）”；

④ 执行 php think clear:config 清除配置缓存，否则新连接名不会被识别。

第二步：运行时显式调用 Db::connect()

Db::connect() 参数不是数据库名，也不是模型名，而是 config/database.php 中 connections 下定义的连接键名。传错直接抛出 Connection not found 异常，不 fallback、不试错。

方法一：查 MySQL 主库用户表 → Db::connect('mysql_main')->table('users')->where('status', 1)->select()；

方法二：查 PostgreSQL 日志表 → Db::connect('pgsql_log')->table('api_logs')->where('created_at', '>=', '2026-07-01')->select()；

注意：Db::connect(['type'=>'pgsql', ...]) 这种传数组方式虽能跑通，但高并发下不走连接池，MySQL 很快报 Too many connections —— 只用于调试，禁止上线使用。

第三步：避开跨库事务和 JSON 查询坑

Db::transaction() 仅作用于当前连接，包裹对 MySQL 和 PostgreSQL 的混合操作会失败。例如以下代码必然报错：

Db::transaction(function () {
  Db::connect('mysql_main')->table('orders')->insert([...]);
  Db::connect('pgsql_log')->table('events')->insert([...]);
});

ThinkPHP 不支持跨库事务，MySQL 本身也不允许跨实例 commit。必须拆成两个独立事务，各自捕获异常并人工回滚补偿。

JSON 字段查询必须按数据库类型手写语法：
MySQL 8.0+ 支持 json_col->'$.name'，ThinkPHP 会生成它；
PostgreSQL 必须用 json_col->>'name'（文本提取）或 json_col->'name'（JSON 提取），ThinkPHP 默认不生成带 ->> 的语句；
SQLite 根本没有原生 JSON 运算符，ThinkPHP 会退化为 LIKE 匹配，查 {"name":"a"} 可能误中 {"name":"ab"}。

实际建议：复杂 JSON 查询收口到视图或数据库函数，不要依赖 Model::where('json_col->name', 'xxx') 自动推导。

第四步：模型绑定单一连接，禁止跨库 JOIN

在模型类中设置 protected $connection = 'pgsql_log';，只影响该模型主表操作；关联查询仍走各自模型的 $connection，不会自动路由。

例如 User 模型绑 mysql_main，Log 模型绑 pgsql_log，执行 User::with('logs')->select() 时，User 表从 MySQL 查，logs 关联模型仍从 PostgreSQL 查 —— 但 MySQL 本身不支持跨实例 JOIN，TP 也不会帮你合并数据。

真要组合主库用户 + 从库日志，必须手动分两次查：
$users = Db::connect('mysql_main')->table('users')->select();
$logs = Db::connect('pgsql_log')->table('api_logs')->where('user_id', 'in', array_column($users, 'id'))->select();
再用 PHP 合并。