ThinkPHP 不支持开箱即用的分库路由，Db::connect() 仅切换连接，无法自动按 user_id 选库；需通过中间件预埋分片键 + 自定义 Connection 重写 getTableName() 实现动态分库分表。
直接上结论：ThinkPHP 本身不提供开箱即用的分库路由能力，Db::connect() 只能换连接，不能按 user_id 自动选库；真要实现基于用户ID的动态分库，必须用中间件预埋分片键 + 自定义 Connection 类重写 getTableName() 或 parseSql()，否则所有查询都会落到默认库。
为什么 Db::connect() 不能解决分库路由问题
很多人误以为在控制器里写 Db::connect('user_db_0') 就算“分库”了，实际只是手动切连接，和路由无关。关键缺陷有三个：
- 无法与模型联动：调用
UserModel::find(123)时，模型仍走默认连接，不会读你中间件里存的user_id - 无法自动分表：即使连对了库，
user_info还是原表名，不会变成user_info_02这类物理表 - 破坏 ORM 特性：手动拼表名（如
table('user_info_' . $shard)）会导致软删除、时间戳、关联查询全部失效
中间件该做什么、不该做什么
中间件是整个链路的“入口守门人”，它的唯一职责是提取并绑定分片依据，不是执行数据库操作。
Skill Weave Chains — 技能链路由引擎
下载
开箱即用的技能链路由引擎。13 条预定义链覆盖搜索、开发、审查、MLOps、法律、创意等场景，三层路由架构（触发词→SAD反馈→DAG编排），recall@10=96.97%。配置驱动（chains.yaml），零代码扩展。pip install skill-weave-chains 一键安装。
- ✅ 应该做：从
$request->param('uid')或$request->header('X-User-ID')提取值，写入容器：Container::getInstance()->bind('shard_user_id', $uid) - ❌ 绝对不要做：在中间件里调用
Db::connect()或Db::name()—— 此时连接池尚未初始化，会触发默认连接创建，后续自定义逻辑直接被绕过 - ⚠️ 注意顺序：中间件必须注册在
app/middleware.php的before_request阶段，且排在数据库相关中间件之前
自定义 Connection 类如何介入 SQL 构建流程
真正干活的是继承 think\db\Connection 的子类，它要在 SQL 生成前改写目标库和表名。核心是重写 getTableName()：
立即学习“PHP免费学习笔记（深入）”；
class ShardConnection extends \think\db\Connection
{
protected function getTableName($tableName)
{
// 从容器取分片键
$uid = Container::getInstance()->get('shard_user_id');
if (!$uid) {
return parent::getTableName($tableName);
}
// 取模计算库和表索引（示例：4库 × 8表）
$dbIndex = $uid % 4;
$tableIndex = $uid % 8;
// 切换物理库名（注意：不是 setDatabase()，那是运行时无效的）
$this->config['database'] = 'user_db_' . $dbIndex;
// 返回带后缀的物理表名
return $tableName . '_' . str_pad($tableIndex, 2, '0', STR_PAD_LEFT);
}
}
- 别用
setDatabase()：这个方法只影响当前查询上下文，不改变连接配置，query()内部仍用原始config['database'] - 必须改
$this->config['database']：这是连接初始化时读取的唯一来源，改它才能让底层 PDO 实例连对库 - 表名重写要早于 SQL 解析：
getTableName()是模型和查询构造器获取表名的第一道钩子，错过就只能硬拼字符串
容易被忽略的三个落地细节
这套方案跑通不难，但线上出问题往往卡在这些地方：
- 全局唯一 ID 必须提前规划：分库后
AUTO_INCREMENT失效，user_id得由雪花算法或号段服务生成，否则取模结果不可控 - 跨分片查询必须收口到应用层：比如查“某地区所有用户”，不能
JOIN或UNION ALL，得用循环查 4 个库再合并数组 - 事务仅限单库内：
Db::transaction()在分库场景下只对当前连接生效，涉及多库的操作必须降级为最终一致性
