ThinkPHP数据库配置进阶：利用中间件实现基于用户ID的动态分库路由方案-ThinkPHP-PHP中文网

thinkphp 不支持开箱即用的分库路由，db::connect() 仅切换连接，无法自动按 user_id 选库；需通过中间件预埋分片键 + 自定义 connection 重写 gettablename() 实现动态分库分表。

thinkphp数据库配置进阶：利用中间件实现基于用户id的动态分库路由方案

直接上结论：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()：

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);
    }
}