pdo本身不直接支持分库分表,需结合业务逻辑或中间件实现:手动路由(按分片键计算库表名、白名单校验拼接)、封装shardingpdo类解耦路由与执行、对接mycat等代理中间件透明分片,同时注意跨库事务限制、游标分页及聚合查询优化。

PHP PDO 本身不直接支持分库分表,但可以作为底层数据库连接工具,配合业务逻辑或中间件实现分库分表。关键在于把路由逻辑(哪个表、哪个库)和数据操作解耦,让 PDO 专注执行 SQL,路由由上层控制。
手动路由:在业务层决定库与表
这是最直接的方式,适合分片规则简单(如按用户 ID 取模、按时间分月表)的场景。你根据分片键(sharding key)计算目标库名和表名,再用 PDO 连接对应数据库并操作。
- 维护一个数据库配置映射,例如:['db_user_0' => $dsn0, 'db_user_1' => $dsn1]
- 分表时,将原表名 user 替换为 user_001、user_002 等,SQL 中写死或拼接
- 注意预处理语句中的表名不能参数化(PDO 不允许),需白名单校验后字符串拼接,防止 SQL 注入
- 事务跨库无法保证一致性,尽量避免跨库写操作;必须跨库时,用本地消息表 + 补偿机制替代分布式事务
封装 PDO 连接管理器
把“选库”“选表”“连接复用”逻辑封装成类,对外提供类似 PDO 的接口,降低业务代码侵入性。
- 实现 ShardingPDO::prepare() 方法:接收原始 SQL 和分片键,内部解析并重写表名、选择连接实例
- 连接池可基于 PDO 的持久连接(PDO::ATTR_PERSISTENT => true)或自行实现轻量连接缓存
- 支持读写分离时,可在路由前判断是否为 SELECT,并自动路由到从库(需结合 SQL 解析或注释提示)
配合代理中间件(如 MyCat、ShardingSphere-JDBC)
让中间件承担分片逻辑,PHP 层仍用标准 PDO 连接中间件地址,对分库分表无感。
立即学习“PHP免费学习笔记(深入)”;
- PDO 连接的是 MyCat 的 MySQL 协议端口,SQL 写法保持原样(如 INSERT INTO user),由 MyCat 路由到实际物理库表
- 需注意中间件限制:部分不支持子查询、复杂 JOIN 或事务嵌套,提前验证兼容性
- 错误码可能被中间件转换,日志中要记录原始 SQL 和中间件返回信息,方便排查
分页与聚合查询的处理技巧
跨分片查询天然低效,应尽量避免全分片扫描。
- 分页推荐用“游标分页”(基于上次查询最大 ID 或时间戳),而非 LIMIT offset, size,后者需合并所有分片结果再截取
- 统计类需求(如 COUNT、SUM)可先在各分片执行,PHP 层汇总;高频统计建议单独建汇总表或用 Redis 缓存近似值
- 关联查询尽量拆成多次单表查询,在 PHP 层组装,比跨库 JOIN 更可控、更易监控











